@@ -13,8 +13,6 @@ |
||
| 13 | 13 | use Basis\Framework; |
| 14 | 14 | use Basis\Http; |
| 15 | 15 | use Basis\Lock; |
| 16 | -use Basis\Service; |
|
| 17 | -use GuzzleHttp\Client as GuzzleHttpClient; |
|
| 18 | 16 | use League\Container\ServiceProvider\AbstractServiceProvider; |
| 19 | 17 | use Predis\Client as PredisClient; |
| 20 | 18 | |
@@ -66,6 +66,9 @@ discard block |
||
| 66 | 66 | return $this->get(Mapper::class); |
| 67 | 67 | } |
| 68 | 68 | |
| 69 | + /** |
|
| 70 | + * @param string $space |
|
| 71 | + */ |
|
| 69 | 72 | protected function getRepository($space) |
| 70 | 73 | { |
| 71 | 74 | if (strpos($space, '.') !== false) { |
@@ -74,6 +77,9 @@ discard block |
||
| 74 | 77 | return $this->get(Mapper::class)->getRepository($space); |
| 75 | 78 | } |
| 76 | 79 | |
| 80 | + /** |
|
| 81 | + * @param string $tube |
|
| 82 | + */ |
|
| 77 | 83 | public function getQueue($tube) |
| 78 | 84 | { |
| 79 | 85 | $alias = "queue.$tube"; |
@@ -100,6 +106,9 @@ discard block |
||
| 100 | 106 | return $this->getRepository($space)->remove($params); |
| 101 | 107 | } |
| 102 | 108 | |
| 109 | + /** |
|
| 110 | + * @param string $fields |
|
| 111 | + */ |
|
| 103 | 112 | protected function select($fields, string $table, array $params) |
| 104 | 113 | { |
| 105 | 114 | return $this->get(Clickhouse::class)->select($fields, $table, $params); |
@@ -110,6 +119,9 @@ discard block |
||
| 110 | 119 | return $this->get(Clickhouse::class)->insert($table, $data, $headers); |
| 111 | 120 | } |
| 112 | 121 | |
| 122 | + /** |
|
| 123 | + * @param string $contents |
|
| 124 | + */ |
|
| 113 | 125 | protected function upload(string $filename, $contents) : string |
| 114 | 126 | { |
| 115 | 127 | return $this->get(Storage::class)->upload($filename, $contents); |