@@ -154,7 +154,7 @@ |
||
| 154 | 154 | /** |
| 155 | 155 | * Update entries in the db based on a query. |
| 156 | 156 | * |
| 157 | - * @param array|Query|string $query Query object or array |
|
| 157 | + * @param string $query Query object or array |
|
| 158 | 158 | * @param AbstractScript $script Script |
| 159 | 159 | * @param array $options Optional params |
| 160 | 160 | * |
@@ -212,7 +212,7 @@ discard block |
||
| 212 | 212 | * NOTICE php will encode modified(or named keys) array into object format in json format request |
| 213 | 213 | * so the fields array must a sequence(list) type of array. |
| 214 | 214 | * |
| 215 | - * @param array $fields Fields to be returned |
|
| 215 | + * @param string[] $fields Fields to be returned |
|
| 216 | 216 | * |
| 217 | 217 | * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/search-request-body.html#request-body-search-stored-fields |
| 218 | 218 | */ |
@@ -349,7 +349,7 @@ discard block |
||
| 349 | 349 | /** |
| 350 | 350 | * Sets the _source field to be returned with every hit. |
| 351 | 351 | * |
| 352 | - * @param array|bool $params Fields to be returned or false to disable source |
|
| 352 | + * @param boolean $params Fields to be returned or false to disable source |
|
| 353 | 353 | * |
| 354 | 354 | * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/search-request-body.html#request-body-search-source-filtering |
| 355 | 355 | */ |
@@ -361,7 +361,7 @@ discard block |
||
| 361 | 361 | /** |
| 362 | 362 | * Sets a post_filter to the current query. |
| 363 | 363 | * |
| 364 | - * @param AbstractQuery|array $filter |
|
| 364 | + * @param AbstractQuery $filter |
|
| 365 | 365 | * |
| 366 | 366 | * @see https://www.elastic.co/guide/en/elasticsearch/reference/current/search-request-body.html#request-body-search-post-filter |
| 367 | 367 | */ |
@@ -399,6 +399,9 @@ |
||
| 399 | 399 | return $index; |
| 400 | 400 | } |
| 401 | 401 | |
| 402 | + /** |
|
| 403 | + * @param TopHits $innerAggr |
|
| 404 | + */ |
|
| 402 | 405 | protected function getOuterAggregationResult($innerAggr) |
| 403 | 406 | { |
| 404 | 407 | $outerAggr = new Terms('top_tags'); |
@@ -47,6 +47,7 @@ discard block |
||
| 47 | 47 | |
| 48 | 48 | /** |
| 49 | 49 | * @param array $params Additional configuration params. Host and Port are already set |
| 50 | + * @param \Closure $callback |
|
| 50 | 51 | */ |
| 51 | 52 | protected function _getClient(array $params = [], ?callable $callback = null, ?LoggerInterface $logger = null): Client |
| 52 | 53 | { |
@@ -90,6 +91,9 @@ discard block |
||
| 90 | 91 | return 'http://'.$proxyHost.':8001'; |
| 91 | 92 | } |
| 92 | 93 | |
| 94 | + /** |
|
| 95 | + * @param string $name |
|
| 96 | + */ |
|
| 93 | 97 | protected function _createIndex(?string $name = null, bool $delete = true, int $shards = 1): Index |
| 94 | 98 | { |
| 95 | 99 | $name = $name ?: static::buildUniqueId(); |
@@ -143,6 +147,9 @@ discard block |
||
| 143 | 147 | return \substr($data['version']['number'], 0, 1); |
| 144 | 148 | } |
| 145 | 149 | |
| 150 | + /** |
|
| 151 | + * @param string $version |
|
| 152 | + */ |
|
| 146 | 153 | protected function _checkVersion($version): void |
| 147 | 154 | { |
| 148 | 155 | $data = $this->_getClient()->request('/')->getData(); |
@@ -5,7 +5,6 @@ |
||
| 5 | 5 | use Elastica\Document; |
| 6 | 6 | use Elastica\Index; |
| 7 | 7 | use Elastica\Query\Ids; |
| 8 | -use Elastica\Query\Type; |
|
| 9 | 8 | use Elastica\Test\Base as BaseTest; |
| 10 | 9 | |
| 11 | 10 | /** |
@@ -139,6 +139,9 @@ |
||
| 139 | 139 | $client->request('_status', 'GET'); |
| 140 | 140 | } |
| 141 | 141 | |
| 142 | + /** |
|
| 143 | + * @param string $url |
|
| 144 | + */ |
|
| 142 | 145 | protected function checkProxy($url): void |
| 143 | 146 | { |
| 144 | 147 | $url = \parse_url($url); |
@@ -97,7 +97,7 @@ |
||
| 97 | 97 | |
| 98 | 98 | $indicesWithAlias = $status->getIndicesWithAlias($aliasName); |
| 99 | 99 | $this->assertEquals([$indexName], \array_map( |
| 100 | - function ($index) { |
|
| 100 | + function($index) { |
|
| 101 | 101 | return $index->getName(); |
| 102 | 102 | }, |
| 103 | 103 | $indicesWithAlias |
@@ -172,7 +172,7 @@ discard block |
||
| 172 | 172 | $this->assertEquals('AnonCoin', $index->getDocument(1)->get('name')); |
| 173 | 173 | $this->assertEquals('iXcoin', $index->getDocument(2)->get('name')); |
| 174 | 174 | |
| 175 | - $ixCoin->setIndex(null); // Make sure the index gets set properly if missing |
|
| 175 | + $ixCoin->setIndex(null); // Make sure the index gets set properly if missing |
|
| 176 | 176 | $index->deleteDocuments([$anonCoin, $ixCoin]); |
| 177 | 177 | |
| 178 | 178 | $this->expectException(NotFoundException::class); |
@@ -385,7 +385,7 @@ discard block |
||
| 385 | 385 | $count = 0; |
| 386 | 386 | |
| 387 | 387 | // Callback function which verifies that disabled connection objects are returned |
| 388 | - $callback = function (Connection $connection, \Exception $exception, Client $client) use (&$count): void { |
|
| 388 | + $callback = function(Connection $connection, \Exception $exception, Client $client) use (&$count): void { |
|
| 389 | 389 | $this->assertInstanceOf(Connection::class, $connection); |
| 390 | 390 | $this->assertInstanceOf(ConnectionException::class, $exception); |
| 391 | 391 | $this->assertInstanceOf(Client::class, $client); |
@@ -76,7 +76,7 @@ discard block |
||
| 76 | 76 | ]; |
| 77 | 77 | |
| 78 | 78 | $count = 0; |
| 79 | - $callback = function ($connection, $exception, $client) use (&$count): void { |
|
| 79 | + $callback = function($connection, $exception, $client) use (&$count): void { |
|
| 80 | 80 | ++$count; |
| 81 | 81 | }; |
| 82 | 82 | |
@@ -105,7 +105,7 @@ discard block |
||
| 105 | 105 | ]; |
| 106 | 106 | |
| 107 | 107 | $count = 0; |
| 108 | - $client = $this->_getClient(['roundRobin' => true], function () use (&$count): void { |
|
| 108 | + $client = $this->_getClient(['roundRobin' => true], function() use (&$count): void { |
|
| 109 | 109 | ++$count; |
| 110 | 110 | }); |
| 111 | 111 | |