@@ -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); |