@@ -20,10 +20,10 @@ |
||
20 | 20 | |
21 | 21 | class AsyncOnSuccess implements OnSuccessInterface |
22 | 22 | { |
23 | - public function success(ResponseInterface $response, int $count): Elasticsearch |
|
24 | - { |
|
25 | - $result = new Elasticsearch; |
|
26 | - $result->setResponse($response, true); |
|
27 | - return $result; |
|
28 | - } |
|
23 | + public function success(ResponseInterface $response, int $count): Elasticsearch |
|
24 | + { |
|
25 | + $result = new Elasticsearch; |
|
26 | + $result->setResponse($response, true); |
|
27 | + return $result; |
|
28 | + } |
|
29 | 29 | } |
30 | 30 | \ No newline at end of file |
@@ -10,7 +10,7 @@ |
||
10 | 10 | * Elasticsearch B.V licenses this file to you under the MIT License. |
11 | 11 | * See the LICENSE file in the project root for more information. |
12 | 12 | */ |
13 | -declare(strict_types = 1); |
|
13 | +declare(strict_types=1); |
|
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Transport; |
16 | 16 |
@@ -18,8 +18,7 @@ |
||
18 | 18 | use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Async\OnSuccessInterface; |
19 | 19 | use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface; |
20 | 20 | |
21 | -class AsyncOnSuccess implements OnSuccessInterface |
|
22 | -{ |
|
21 | +class AsyncOnSuccess implements OnSuccessInterface { |
|
23 | 22 | public function success(ResponseInterface $response, int $count): Elasticsearch |
24 | 23 | { |
25 | 24 | $result = new Elasticsearch; |
@@ -20,10 +20,10 @@ |
||
20 | 20 | |
21 | 21 | class AsyncOnSuccessNoException implements OnSuccessInterface |
22 | 22 | { |
23 | - public function success(ResponseInterface $response, int $count): Elasticsearch |
|
24 | - { |
|
25 | - $result = new Elasticsearch; |
|
26 | - $result->setResponse($response, false); |
|
27 | - return $result; |
|
28 | - } |
|
23 | + public function success(ResponseInterface $response, int $count): Elasticsearch |
|
24 | + { |
|
25 | + $result = new Elasticsearch; |
|
26 | + $result->setResponse($response, false); |
|
27 | + return $result; |
|
28 | + } |
|
29 | 29 | } |
30 | 30 | \ No newline at end of file |
@@ -10,7 +10,7 @@ |
||
10 | 10 | * Elasticsearch B.V licenses this file to you under the MIT License. |
11 | 11 | * See the LICENSE file in the project root for more information. |
12 | 12 | */ |
13 | -declare(strict_types = 1); |
|
13 | +declare(strict_types=1); |
|
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Transport; |
16 | 16 |
@@ -18,8 +18,7 @@ |
||
18 | 18 | use OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Transport\Async\OnSuccessInterface; |
19 | 19 | use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface; |
20 | 20 | |
21 | -class AsyncOnSuccessNoException implements OnSuccessInterface |
|
22 | -{ |
|
21 | +class AsyncOnSuccessNoException implements OnSuccessInterface { |
|
23 | 22 | public function success(ResponseInterface $response, int $count): Elasticsearch |
24 | 23 | { |
25 | 24 | $result = new Elasticsearch; |
@@ -16,23 +16,23 @@ |
||
16 | 16 | |
17 | 17 | final class RequestOptions |
18 | 18 | { |
19 | - /** |
|
20 | - * Enable or sidable the SSL verification |
|
21 | - */ |
|
22 | - public const SSL_VERIFY = 'ssl_verify'; |
|
19 | + /** |
|
20 | + * Enable or sidable the SSL verification |
|
21 | + */ |
|
22 | + public const SSL_VERIFY = 'ssl_verify'; |
|
23 | 23 | |
24 | - /** |
|
25 | - * SSL certificate |
|
26 | - */ |
|
27 | - public const SSL_CERT = 'ssl_cert'; |
|
24 | + /** |
|
25 | + * SSL certificate |
|
26 | + */ |
|
27 | + public const SSL_CERT = 'ssl_cert'; |
|
28 | 28 | |
29 | - /** |
|
30 | - * SSL key |
|
31 | - */ |
|
32 | - public const SSL_KEY = 'ssl_key'; |
|
29 | + /** |
|
30 | + * SSL key |
|
31 | + */ |
|
32 | + public const SSL_KEY = 'ssl_key'; |
|
33 | 33 | |
34 | - /** |
|
35 | - * SSL Certificate Authority (CA) bundle |
|
36 | - */ |
|
37 | - public const SSL_CA = 'ssl_ca'; |
|
34 | + /** |
|
35 | + * SSL Certificate Authority (CA) bundle |
|
36 | + */ |
|
37 | + public const SSL_CA = 'ssl_ca'; |
|
38 | 38 | } |
39 | 39 | \ No newline at end of file |
@@ -10,7 +10,7 @@ |
||
10 | 10 | * Elasticsearch B.V licenses this file to you under the MIT License. |
11 | 11 | * See the LICENSE file in the project root for more information. |
12 | 12 | */ |
13 | -declare(strict_types = 1); |
|
13 | +declare(strict_types=1); |
|
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Transport; |
16 | 16 |
@@ -14,8 +14,7 @@ |
||
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Transport; |
16 | 16 | |
17 | -final class RequestOptions |
|
18 | -{ |
|
17 | +final class RequestOptions { |
|
19 | 18 | /** |
20 | 19 | * Enable or sidable the SSL verification |
21 | 20 | */ |
@@ -20,25 +20,25 @@ |
||
20 | 20 | |
21 | 21 | class Guzzle implements AdapterInterface |
22 | 22 | { |
23 | - public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface |
|
24 | - { |
|
25 | - $guzzleConfig = []; |
|
26 | - foreach ($config as $key => $value) { |
|
27 | - switch ($key) { |
|
28 | - case RequestOptions::SSL_CERT: |
|
29 | - $guzzleConfig[GuzzleOptions::CERT] = $value; |
|
30 | - break; |
|
31 | - case RequestOptions::SSL_KEY: |
|
32 | - $guzzleConfig[GuzzleOptions::SSL_KEY] = $value; |
|
33 | - break; |
|
34 | - case RequestOptions::SSL_VERIFY: |
|
35 | - $guzzleConfig[GuzzleOptions::VERIFY] = $value; |
|
36 | - break; |
|
37 | - case RequestOptions::SSL_CA: |
|
38 | - $guzzleConfig[GuzzleOptions::VERIFY] = $value; |
|
39 | - } |
|
40 | - } |
|
41 | - $class = get_class($client); |
|
42 | - return new $class(array_merge($clientOptions, $guzzleConfig)); |
|
43 | - } |
|
23 | + public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface |
|
24 | + { |
|
25 | + $guzzleConfig = []; |
|
26 | + foreach ($config as $key => $value) { |
|
27 | + switch ($key) { |
|
28 | + case RequestOptions::SSL_CERT: |
|
29 | + $guzzleConfig[GuzzleOptions::CERT] = $value; |
|
30 | + break; |
|
31 | + case RequestOptions::SSL_KEY: |
|
32 | + $guzzleConfig[GuzzleOptions::SSL_KEY] = $value; |
|
33 | + break; |
|
34 | + case RequestOptions::SSL_VERIFY: |
|
35 | + $guzzleConfig[GuzzleOptions::VERIFY] = $value; |
|
36 | + break; |
|
37 | + case RequestOptions::SSL_CA: |
|
38 | + $guzzleConfig[GuzzleOptions::VERIFY] = $value; |
|
39 | + } |
|
40 | + } |
|
41 | + $class = get_class($client); |
|
42 | + return new $class(array_merge($clientOptions, $guzzleConfig)); |
|
43 | + } |
|
44 | 44 | } |
45 | 45 | \ No newline at end of file |
@@ -10,7 +10,7 @@ |
||
10 | 10 | * Elasticsearch B.V licenses this file to you under the MIT License. |
11 | 11 | * See the LICENSE file in the project root for more information. |
12 | 12 | */ |
13 | -declare(strict_types = 1); |
|
13 | +declare(strict_types=1); |
|
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Transport\Adapter; |
16 | 16 |
@@ -18,8 +18,7 @@ |
||
18 | 18 | use OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\RequestOptions As GuzzleOptions; |
19 | 19 | use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Client\ClientInterface; |
20 | 20 | |
21 | -class Guzzle implements AdapterInterface |
|
22 | -{ |
|
21 | +class Guzzle implements AdapterInterface { |
|
23 | 22 | public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface |
24 | 23 | { |
25 | 24 | $guzzleConfig = []; |
@@ -18,5 +18,5 @@ |
||
18 | 18 | |
19 | 19 | interface AdapterInterface |
20 | 20 | { |
21 | - public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface; |
|
21 | + public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface; |
|
22 | 22 | } |
23 | 23 | \ No newline at end of file |
@@ -10,7 +10,7 @@ |
||
10 | 10 | * Elasticsearch B.V licenses this file to you under the MIT License. |
11 | 11 | * See the LICENSE file in the project root for more information. |
12 | 12 | */ |
13 | -declare(strict_types = 1); |
|
13 | +declare(strict_types=1); |
|
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Transport\Adapter; |
16 | 16 |
@@ -16,7 +16,6 @@ |
||
16 | 16 | |
17 | 17 | use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Client\ClientInterface; |
18 | 18 | |
19 | -interface AdapterInterface |
|
20 | -{ |
|
19 | +interface AdapterInterface { |
|
21 | 20 | public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface; |
22 | 21 | } |
23 | 22 | \ No newline at end of file |
@@ -19,9 +19,9 @@ |
||
19 | 19 | */ |
20 | 20 | final class AdapterOptions |
21 | 21 | { |
22 | - const HTTP_ADAPTERS = [ |
|
23 | - "OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\\Client" => "Elastic\\Elasticsearch\\Transport\\Adapter\\Guzzle", |
|
24 | - "Symfony\\Component\\HttpClient\\HttplugClient" => "Elastic\\Elasticsearch\\Transport\\Adapter\\Symfony", |
|
25 | - "Symfony\\Component\\HttpClient\\Psr18Client" => "Elastic\\Elasticsearch\\Transport\\Adapter\\Symfony" |
|
26 | - ]; |
|
22 | + const HTTP_ADAPTERS = [ |
|
23 | + "OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\\Client" => "Elastic\\Elasticsearch\\Transport\\Adapter\\Guzzle", |
|
24 | + "Symfony\\Component\\HttpClient\\HttplugClient" => "Elastic\\Elasticsearch\\Transport\\Adapter\\Symfony", |
|
25 | + "Symfony\\Component\\HttpClient\\Psr18Client" => "Elastic\\Elasticsearch\\Transport\\Adapter\\Symfony" |
|
26 | + ]; |
|
27 | 27 | } |
28 | 28 | \ No newline at end of file |
@@ -10,7 +10,7 @@ |
||
10 | 10 | * Elasticsearch B.V licenses this file to you under the MIT License. |
11 | 11 | * See the LICENSE file in the project root for more information. |
12 | 12 | */ |
13 | -declare(strict_types = 1); |
|
13 | +declare(strict_types=1); |
|
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Transport\Adapter; |
16 | 16 |
@@ -17,8 +17,7 @@ |
||
17 | 17 | /** |
18 | 18 | * The HTTP client adapters supported |
19 | 19 | */ |
20 | -final class AdapterOptions |
|
21 | -{ |
|
20 | +final class AdapterOptions { |
|
22 | 21 | const HTTP_ADAPTERS = [ |
23 | 22 | "OCA\FullTextSearch_Elasticsearch\Vendor\GuzzleHttp\\Client" => "Elastic\\Elasticsearch\\Transport\\Adapter\\Guzzle", |
24 | 23 | "Symfony\\Component\\HttpClient\\HttplugClient" => "Elastic\\Elasticsearch\\Transport\\Adapter\\Symfony", |
@@ -20,27 +20,27 @@ |
||
20 | 20 | |
21 | 21 | class Symfony implements AdapterInterface |
22 | 22 | { |
23 | - public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface |
|
24 | - { |
|
25 | - $symfonyConfig = []; |
|
26 | - foreach ($config as $key => $value) { |
|
27 | - switch ($key) { |
|
28 | - case RequestOptions::SSL_CERT: |
|
29 | - $symfonyConfig['local_cert'] = $value; |
|
30 | - break; |
|
31 | - case RequestOptions::SSL_KEY: |
|
32 | - $symfonyConfig['local_pk'] = $value; |
|
33 | - break; |
|
34 | - case RequestOptions::SSL_VERIFY: |
|
35 | - $symfonyConfig['verify_host'] = $value; |
|
36 | - $symfonyConfig['verify_peer'] = $value; |
|
37 | - break; |
|
38 | - case RequestOptions::SSL_CA: |
|
39 | - $symfonyConfig['cafile'] = $value; |
|
40 | - } |
|
41 | - } |
|
42 | - $class = get_class($client); |
|
43 | - $httpClient = HttpClient::create(array_merge($clientOptions, $symfonyConfig)); |
|
44 | - return new $class($httpClient); |
|
45 | - } |
|
23 | + public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface |
|
24 | + { |
|
25 | + $symfonyConfig = []; |
|
26 | + foreach ($config as $key => $value) { |
|
27 | + switch ($key) { |
|
28 | + case RequestOptions::SSL_CERT: |
|
29 | + $symfonyConfig['local_cert'] = $value; |
|
30 | + break; |
|
31 | + case RequestOptions::SSL_KEY: |
|
32 | + $symfonyConfig['local_pk'] = $value; |
|
33 | + break; |
|
34 | + case RequestOptions::SSL_VERIFY: |
|
35 | + $symfonyConfig['verify_host'] = $value; |
|
36 | + $symfonyConfig['verify_peer'] = $value; |
|
37 | + break; |
|
38 | + case RequestOptions::SSL_CA: |
|
39 | + $symfonyConfig['cafile'] = $value; |
|
40 | + } |
|
41 | + } |
|
42 | + $class = get_class($client); |
|
43 | + $httpClient = HttpClient::create(array_merge($clientOptions, $symfonyConfig)); |
|
44 | + return new $class($httpClient); |
|
45 | + } |
|
46 | 46 | } |
47 | 47 | \ No newline at end of file |
@@ -10,7 +10,7 @@ |
||
10 | 10 | * Elasticsearch B.V licenses this file to you under the MIT License. |
11 | 11 | * See the LICENSE file in the project root for more information. |
12 | 12 | */ |
13 | -declare(strict_types = 1); |
|
13 | +declare(strict_types=1); |
|
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Transport\Adapter; |
16 | 16 |
@@ -18,8 +18,7 @@ |
||
18 | 18 | use OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Client\ClientInterface; |
19 | 19 | use Symfony\Component\HttpClient\HttpClient; |
20 | 20 | |
21 | -class Symfony implements AdapterInterface |
|
22 | -{ |
|
21 | +class Symfony implements AdapterInterface { |
|
23 | 22 | public function setConfig(ClientInterface $client, array $config, array $clientOptions): ClientInterface |
24 | 23 | { |
25 | 24 | $symfonyConfig = []; |
@@ -24,73 +24,73 @@ |
||
24 | 24 | */ |
25 | 25 | trait MessageResponseTrait |
26 | 26 | { |
27 | - public function getProtocolVersion(): string |
|
28 | - { |
|
29 | - return $this->response->getProtocolVersion(); |
|
30 | - } |
|
31 | - |
|
32 | - public function withProtocolVersion($version): MessageInterface |
|
33 | - { |
|
34 | - return $this->response->withProtocolVersion($version); |
|
35 | - } |
|
36 | - |
|
37 | - public function getHeaders(): array |
|
38 | - { |
|
39 | - return $this->response->getHeaders(); |
|
40 | - } |
|
41 | - |
|
42 | - public function hasHeader(string $name): bool |
|
43 | - { |
|
44 | - return $this->response->hasHeader($name); |
|
45 | - } |
|
46 | - |
|
47 | - public function getHeader(string $name): array |
|
48 | - { |
|
49 | - return $this->response->getHeader($name); |
|
50 | - } |
|
51 | - |
|
52 | - public function getHeaderLine(string $name): string |
|
53 | - { |
|
54 | - return $this->response->getHeaderLine($name); |
|
55 | - } |
|
56 | - |
|
57 | - public function withHeader(string $name, $value): MessageInterface |
|
58 | - { |
|
59 | - return $this->response->withHeader($name, $value); |
|
60 | - } |
|
61 | - |
|
62 | - public function withAddedHeader(string $name, $value): MessageInterface |
|
63 | - { |
|
64 | - return $this->response->withAddedHeader($name, $value); |
|
65 | - } |
|
66 | - |
|
67 | - public function withoutHeader(string $name): MessageInterface |
|
68 | - { |
|
69 | - return $this->response->withoutHeader($name); |
|
70 | - } |
|
71 | - |
|
72 | - public function getBody(): StreamInterface |
|
73 | - { |
|
74 | - return $this->response->getBody(); |
|
75 | - } |
|
76 | - |
|
77 | - public function withBody(StreamInterface $body): MessageInterface |
|
78 | - { |
|
79 | - return $this->response->withBody($body); |
|
80 | - } |
|
81 | - |
|
82 | - public function getStatusCode(): int |
|
83 | - { |
|
84 | - return $this->response->getStatusCode(); |
|
85 | - } |
|
86 | - |
|
87 | - public function withStatus(int $code, string $reasonPhrase = ''): ResponseInterface |
|
88 | - { |
|
89 | - return $this->response->withStatus($code, $reasonPhrase); |
|
90 | - } |
|
91 | - |
|
92 | - public function getReasonPhrase(): string |
|
93 | - { |
|
94 | - return $this->response->getReasonPhrase(); |
|
95 | - } |
|
27 | + public function getProtocolVersion(): string |
|
28 | + { |
|
29 | + return $this->response->getProtocolVersion(); |
|
30 | + } |
|
31 | + |
|
32 | + public function withProtocolVersion($version): MessageInterface |
|
33 | + { |
|
34 | + return $this->response->withProtocolVersion($version); |
|
35 | + } |
|
36 | + |
|
37 | + public function getHeaders(): array |
|
38 | + { |
|
39 | + return $this->response->getHeaders(); |
|
40 | + } |
|
41 | + |
|
42 | + public function hasHeader(string $name): bool |
|
43 | + { |
|
44 | + return $this->response->hasHeader($name); |
|
45 | + } |
|
46 | + |
|
47 | + public function getHeader(string $name): array |
|
48 | + { |
|
49 | + return $this->response->getHeader($name); |
|
50 | + } |
|
51 | + |
|
52 | + public function getHeaderLine(string $name): string |
|
53 | + { |
|
54 | + return $this->response->getHeaderLine($name); |
|
55 | + } |
|
56 | + |
|
57 | + public function withHeader(string $name, $value): MessageInterface |
|
58 | + { |
|
59 | + return $this->response->withHeader($name, $value); |
|
60 | + } |
|
61 | + |
|
62 | + public function withAddedHeader(string $name, $value): MessageInterface |
|
63 | + { |
|
64 | + return $this->response->withAddedHeader($name, $value); |
|
65 | + } |
|
66 | + |
|
67 | + public function withoutHeader(string $name): MessageInterface |
|
68 | + { |
|
69 | + return $this->response->withoutHeader($name); |
|
70 | + } |
|
71 | + |
|
72 | + public function getBody(): StreamInterface |
|
73 | + { |
|
74 | + return $this->response->getBody(); |
|
75 | + } |
|
76 | + |
|
77 | + public function withBody(StreamInterface $body): MessageInterface |
|
78 | + { |
|
79 | + return $this->response->withBody($body); |
|
80 | + } |
|
81 | + |
|
82 | + public function getStatusCode(): int |
|
83 | + { |
|
84 | + return $this->response->getStatusCode(); |
|
85 | + } |
|
86 | + |
|
87 | + public function withStatus(int $code, string $reasonPhrase = ''): ResponseInterface |
|
88 | + { |
|
89 | + return $this->response->withStatus($code, $reasonPhrase); |
|
90 | + } |
|
91 | + |
|
92 | + public function getReasonPhrase(): string |
|
93 | + { |
|
94 | + return $this->response->getReasonPhrase(); |
|
95 | + } |
|
96 | 96 | } |
97 | 97 | \ No newline at end of file |
@@ -10,7 +10,7 @@ |
||
10 | 10 | * Elasticsearch B.V licenses this file to you under the MIT License. |
11 | 11 | * See the LICENSE file in the project root for more information. |
12 | 12 | */ |
13 | -declare(strict_types = 1); |
|
13 | +declare(strict_types=1); |
|
14 | 14 | |
15 | 15 | namespace OCA\FullTextSearch_Elasticsearch\Vendor\Elastic\Elasticsearch\Traits; |
16 | 16 |
@@ -22,8 +22,7 @@ |
||
22 | 22 | * Proxy class for OCA\FullTextSearch_Elasticsearch\Vendor\Psr\Http\Message\ResponseInterface using |
23 | 23 | * $this->response as source object |
24 | 24 | */ |
25 | -trait MessageResponseTrait |
|
26 | -{ |
|
25 | +trait MessageResponseTrait { |
|
27 | 26 | public function getProtocolVersion(): string |
28 | 27 | { |
29 | 28 | return $this->response->getProtocolVersion(); |
@@ -65,13 +65,13 @@ discard block |
||
65 | 65 | { |
66 | 66 | $this->checkRequiredParameters(['body'], $params); |
67 | 67 | if (isset($params['index'])) { |
68 | - $url = '/' . $this->encode($params['index']) . '/_bulk'; |
|
68 | + $url = '/'.$this->encode($params['index']).'/_bulk'; |
|
69 | 69 | $method = 'POST'; |
70 | 70 | } else { |
71 | 71 | $url = '/_bulk'; |
72 | 72 | $method = 'POST'; |
73 | 73 | } |
74 | - $url = $this->addQueryString($url, $params, ['wait_for_active_shards','refresh','routing','timeout','type','_source','_source_excludes','_source_includes','pipeline','require_alias','require_data_stream','list_executed_pipelines','pretty','human','error_trace','source','filter_path']); |
|
74 | + $url = $this->addQueryString($url, $params, ['wait_for_active_shards', 'refresh', 'routing', 'timeout', 'type', '_source', '_source_excludes', '_source_includes', 'pipeline', 'require_alias', 'require_data_stream', 'list_executed_pipelines', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
75 | 75 | $headers = [ |
76 | 76 | 'Accept' => 'application/json', |
77 | 77 | 'Content-Type' => 'application/x-ndjson', |
@@ -104,13 +104,13 @@ discard block |
||
104 | 104 | public function clearScroll(array $params = []) |
105 | 105 | { |
106 | 106 | if (isset($params['scroll_id'])) { |
107 | - $url = '/_search/scroll/' . $this->encode($params['scroll_id']); |
|
107 | + $url = '/_search/scroll/'.$this->encode($params['scroll_id']); |
|
108 | 108 | $method = 'DELETE'; |
109 | 109 | } else { |
110 | 110 | $url = '/_search/scroll'; |
111 | 111 | $method = 'DELETE'; |
112 | 112 | } |
113 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
113 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
114 | 114 | $headers = [ |
115 | 115 | 'Accept' => 'application/json', |
116 | 116 | 'Content-Type' => 'application/json', |
@@ -144,7 +144,7 @@ discard block |
||
144 | 144 | $url = '/_pit'; |
145 | 145 | $method = 'DELETE'; |
146 | 146 | |
147 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
147 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
148 | 148 | $headers = [ |
149 | 149 | 'Accept' => 'application/json', |
150 | 150 | 'Content-Type' => 'application/json', |
@@ -191,13 +191,13 @@ discard block |
||
191 | 191 | public function count(array $params = []) |
192 | 192 | { |
193 | 193 | if (isset($params['index'])) { |
194 | - $url = '/' . $this->encode($params['index']) . '/_count'; |
|
194 | + $url = '/'.$this->encode($params['index']).'/_count'; |
|
195 | 195 | $method = empty($params['body']) ? 'GET' : 'POST'; |
196 | 196 | } else { |
197 | 197 | $url = '/_count'; |
198 | 198 | $method = empty($params['body']) ? 'GET' : 'POST'; |
199 | 199 | } |
200 | - $url = $this->addQueryString($url, $params, ['ignore_unavailable','ignore_throttled','allow_no_indices','expand_wildcards','min_score','preference','routing','q','analyzer','analyze_wildcard','default_operator','df','lenient','terminate_after','pretty','human','error_trace','source','filter_path']); |
|
200 | + $url = $this->addQueryString($url, $params, ['ignore_unavailable', 'ignore_throttled', 'allow_no_indices', 'expand_wildcards', 'min_score', 'preference', 'routing', 'q', 'analyzer', 'analyze_wildcard', 'default_operator', 'df', 'lenient', 'terminate_after', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
201 | 201 | $headers = [ |
202 | 202 | 'Accept' => 'application/json', |
203 | 203 | 'Content-Type' => 'application/json', |
@@ -240,11 +240,11 @@ discard block |
||
240 | 240 | */ |
241 | 241 | public function create(array $params = []) |
242 | 242 | { |
243 | - $this->checkRequiredParameters(['id','index','body'], $params); |
|
244 | - $url = '/' . $this->encode($params['index']) . '/_create/' . $this->encode($params['id']); |
|
243 | + $this->checkRequiredParameters(['id', 'index', 'body'], $params); |
|
244 | + $url = '/'.$this->encode($params['index']).'/_create/'.$this->encode($params['id']); |
|
245 | 245 | $method = 'PUT'; |
246 | 246 | |
247 | - $url = $this->addQueryString($url, $params, ['wait_for_active_shards','refresh','routing','timeout','version','version_type','pipeline','pretty','human','error_trace','source','filter_path']); |
|
247 | + $url = $this->addQueryString($url, $params, ['wait_for_active_shards', 'refresh', 'routing', 'timeout', 'version', 'version_type', 'pipeline', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
248 | 248 | $headers = [ |
249 | 249 | 'Accept' => 'application/json', |
250 | 250 | 'Content-Type' => 'application/json', |
@@ -285,11 +285,11 @@ discard block |
||
285 | 285 | */ |
286 | 286 | public function delete(array $params = []) |
287 | 287 | { |
288 | - $this->checkRequiredParameters(['id','index'], $params); |
|
289 | - $url = '/' . $this->encode($params['index']) . '/_doc/' . $this->encode($params['id']); |
|
288 | + $this->checkRequiredParameters(['id', 'index'], $params); |
|
289 | + $url = '/'.$this->encode($params['index']).'/_doc/'.$this->encode($params['id']); |
|
290 | 290 | $method = 'DELETE'; |
291 | 291 | |
292 | - $url = $this->addQueryString($url, $params, ['wait_for_active_shards','refresh','routing','timeout','if_seq_no','if_primary_term','version','version_type','pretty','human','error_trace','source','filter_path']); |
|
292 | + $url = $this->addQueryString($url, $params, ['wait_for_active_shards', 'refresh', 'routing', 'timeout', 'if_seq_no', 'if_primary_term', 'version', 'version_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
293 | 293 | $headers = [ |
294 | 294 | 'Accept' => 'application/json', |
295 | 295 | ]; |
@@ -350,11 +350,11 @@ discard block |
||
350 | 350 | */ |
351 | 351 | public function deleteByQuery(array $params = []) |
352 | 352 | { |
353 | - $this->checkRequiredParameters(['index','body'], $params); |
|
354 | - $url = '/' . $this->encode($params['index']) . '/_delete_by_query'; |
|
353 | + $this->checkRequiredParameters(['index', 'body'], $params); |
|
354 | + $url = '/'.$this->encode($params['index']).'/_delete_by_query'; |
|
355 | 355 | $method = 'POST'; |
356 | 356 | |
357 | - $url = $this->addQueryString($url, $params, ['analyzer','analyze_wildcard','default_operator','df','from','ignore_unavailable','allow_no_indices','conflicts','expand_wildcards','lenient','preference','q','routing','scroll','search_type','search_timeout','max_docs','sort','terminate_after','stats','version','request_cache','refresh','timeout','wait_for_active_shards','scroll_size','wait_for_completion','requests_per_second','slices','pretty','human','error_trace','source','filter_path']); |
|
357 | + $url = $this->addQueryString($url, $params, ['analyzer', 'analyze_wildcard', 'default_operator', 'df', 'from', 'ignore_unavailable', 'allow_no_indices', 'conflicts', 'expand_wildcards', 'lenient', 'preference', 'q', 'routing', 'scroll', 'search_type', 'search_timeout', 'max_docs', 'sort', 'terminate_after', 'stats', 'version', 'request_cache', 'refresh', 'timeout', 'wait_for_active_shards', 'scroll_size', 'wait_for_completion', 'requests_per_second', 'slices', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
358 | 358 | $headers = [ |
359 | 359 | 'Accept' => 'application/json', |
360 | 360 | 'Content-Type' => 'application/json', |
@@ -387,11 +387,11 @@ discard block |
||
387 | 387 | */ |
388 | 388 | public function deleteByQueryRethrottle(array $params = []) |
389 | 389 | { |
390 | - $this->checkRequiredParameters(['task_id','requests_per_second'], $params); |
|
391 | - $url = '/_delete_by_query/' . $this->encode($params['task_id']) . '/_rethrottle'; |
|
390 | + $this->checkRequiredParameters(['task_id', 'requests_per_second'], $params); |
|
391 | + $url = '/_delete_by_query/'.$this->encode($params['task_id']).'/_rethrottle'; |
|
392 | 392 | $method = 'POST'; |
393 | 393 | |
394 | - $url = $this->addQueryString($url, $params, ['requests_per_second','pretty','human','error_trace','source','filter_path']); |
|
394 | + $url = $this->addQueryString($url, $params, ['requests_per_second', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
395 | 395 | $headers = [ |
396 | 396 | 'Accept' => 'application/json', |
397 | 397 | ]; |
@@ -425,10 +425,10 @@ discard block |
||
425 | 425 | public function deleteScript(array $params = []) |
426 | 426 | { |
427 | 427 | $this->checkRequiredParameters(['id'], $params); |
428 | - $url = '/_scripts/' . $this->encode($params['id']); |
|
428 | + $url = '/_scripts/'.$this->encode($params['id']); |
|
429 | 429 | $method = 'DELETE'; |
430 | 430 | |
431 | - $url = $this->addQueryString($url, $params, ['timeout','master_timeout','pretty','human','error_trace','source','filter_path']); |
|
431 | + $url = $this->addQueryString($url, $params, ['timeout', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
432 | 432 | $headers = [ |
433 | 433 | 'Accept' => 'application/json', |
434 | 434 | ]; |
@@ -470,11 +470,11 @@ discard block |
||
470 | 470 | */ |
471 | 471 | public function exists(array $params = []) |
472 | 472 | { |
473 | - $this->checkRequiredParameters(['id','index'], $params); |
|
474 | - $url = '/' . $this->encode($params['index']) . '/_doc/' . $this->encode($params['id']); |
|
473 | + $this->checkRequiredParameters(['id', 'index'], $params); |
|
474 | + $url = '/'.$this->encode($params['index']).'/_doc/'.$this->encode($params['id']); |
|
475 | 475 | $method = 'HEAD'; |
476 | 476 | |
477 | - $url = $this->addQueryString($url, $params, ['stored_fields','preference','realtime','refresh','routing','_source','_source_excludes','_source_includes','version','version_type','pretty','human','error_trace','source','filter_path']); |
|
477 | + $url = $this->addQueryString($url, $params, ['stored_fields', 'preference', 'realtime', 'refresh', 'routing', '_source', '_source_excludes', '_source_includes', 'version', 'version_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
478 | 478 | $headers = [ |
479 | 479 | 'Accept' => 'application/json', |
480 | 480 | ]; |
@@ -515,11 +515,11 @@ discard block |
||
515 | 515 | */ |
516 | 516 | public function existsSource(array $params = []) |
517 | 517 | { |
518 | - $this->checkRequiredParameters(['id','index'], $params); |
|
519 | - $url = '/' . $this->encode($params['index']) . '/_source/' . $this->encode($params['id']); |
|
518 | + $this->checkRequiredParameters(['id', 'index'], $params); |
|
519 | + $url = '/'.$this->encode($params['index']).'/_source/'.$this->encode($params['id']); |
|
520 | 520 | $method = 'HEAD'; |
521 | 521 | |
522 | - $url = $this->addQueryString($url, $params, ['preference','realtime','refresh','routing','_source','_source_excludes','_source_includes','version','version_type','pretty','human','error_trace','source','filter_path']); |
|
522 | + $url = $this->addQueryString($url, $params, ['preference', 'realtime', 'refresh', 'routing', '_source', '_source_excludes', '_source_includes', 'version', 'version_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
523 | 523 | $headers = [ |
524 | 524 | 'Accept' => 'application/json', |
525 | 525 | ]; |
@@ -564,11 +564,11 @@ discard block |
||
564 | 564 | */ |
565 | 565 | public function explain(array $params = []) |
566 | 566 | { |
567 | - $this->checkRequiredParameters(['id','index'], $params); |
|
568 | - $url = '/' . $this->encode($params['index']) . '/_explain/' . $this->encode($params['id']); |
|
567 | + $this->checkRequiredParameters(['id', 'index'], $params); |
|
568 | + $url = '/'.$this->encode($params['index']).'/_explain/'.$this->encode($params['id']); |
|
569 | 569 | $method = empty($params['body']) ? 'GET' : 'POST'; |
570 | 570 | |
571 | - $url = $this->addQueryString($url, $params, ['analyze_wildcard','analyzer','default_operator','df','stored_fields','lenient','preference','q','routing','_source','_source_excludes','_source_includes','pretty','human','error_trace','source','filter_path']); |
|
571 | + $url = $this->addQueryString($url, $params, ['analyze_wildcard', 'analyzer', 'default_operator', 'df', 'stored_fields', 'lenient', 'preference', 'q', 'routing', '_source', '_source_excludes', '_source_includes', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
572 | 572 | $headers = [ |
573 | 573 | 'Accept' => 'application/json', |
574 | 574 | 'Content-Type' => 'application/json', |
@@ -609,13 +609,13 @@ discard block |
||
609 | 609 | public function fieldCaps(array $params = []) |
610 | 610 | { |
611 | 611 | if (isset($params['index'])) { |
612 | - $url = '/' . $this->encode($params['index']) . '/_field_caps'; |
|
612 | + $url = '/'.$this->encode($params['index']).'/_field_caps'; |
|
613 | 613 | $method = empty($params['body']) ? 'GET' : 'POST'; |
614 | 614 | } else { |
615 | 615 | $url = '/_field_caps'; |
616 | 616 | $method = empty($params['body']) ? 'GET' : 'POST'; |
617 | 617 | } |
618 | - $url = $this->addQueryString($url, $params, ['fields','ignore_unavailable','allow_no_indices','expand_wildcards','include_unmapped','filters','types','include_empty_fields','pretty','human','error_trace','source','filter_path']); |
|
618 | + $url = $this->addQueryString($url, $params, ['fields', 'ignore_unavailable', 'allow_no_indices', 'expand_wildcards', 'include_unmapped', 'filters', 'types', 'include_empty_fields', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
619 | 619 | $headers = [ |
620 | 620 | 'Accept' => 'application/json', |
621 | 621 | 'Content-Type' => 'application/json', |
@@ -659,11 +659,11 @@ discard block |
||
659 | 659 | */ |
660 | 660 | public function get(array $params = []) |
661 | 661 | { |
662 | - $this->checkRequiredParameters(['id','index'], $params); |
|
663 | - $url = '/' . $this->encode($params['index']) . '/_doc/' . $this->encode($params['id']); |
|
662 | + $this->checkRequiredParameters(['id', 'index'], $params); |
|
663 | + $url = '/'.$this->encode($params['index']).'/_doc/'.$this->encode($params['id']); |
|
664 | 664 | $method = 'GET'; |
665 | 665 | |
666 | - $url = $this->addQueryString($url, $params, ['force_synthetic_source','stored_fields','preference','realtime','refresh','routing','_source','_source_excludes','_source_includes','version','version_type','pretty','human','error_trace','source','filter_path']); |
|
666 | + $url = $this->addQueryString($url, $params, ['force_synthetic_source', 'stored_fields', 'preference', 'realtime', 'refresh', 'routing', '_source', '_source_excludes', '_source_includes', 'version', 'version_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
667 | 667 | $headers = [ |
668 | 668 | 'Accept' => 'application/json', |
669 | 669 | ]; |
@@ -696,10 +696,10 @@ discard block |
||
696 | 696 | public function getScript(array $params = []) |
697 | 697 | { |
698 | 698 | $this->checkRequiredParameters(['id'], $params); |
699 | - $url = '/_scripts/' . $this->encode($params['id']); |
|
699 | + $url = '/_scripts/'.$this->encode($params['id']); |
|
700 | 700 | $method = 'GET'; |
701 | 701 | |
702 | - $url = $this->addQueryString($url, $params, ['master_timeout','pretty','human','error_trace','source','filter_path']); |
|
702 | + $url = $this->addQueryString($url, $params, ['master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
703 | 703 | $headers = [ |
704 | 704 | 'Accept' => 'application/json', |
705 | 705 | ]; |
@@ -731,7 +731,7 @@ discard block |
||
731 | 731 | $url = '/_script_context'; |
732 | 732 | $method = 'GET'; |
733 | 733 | |
734 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
734 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
735 | 735 | $headers = [ |
736 | 736 | 'Accept' => 'application/json', |
737 | 737 | ]; |
@@ -763,7 +763,7 @@ discard block |
||
763 | 763 | $url = '/_script_language'; |
764 | 764 | $method = 'GET'; |
765 | 765 | |
766 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
766 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
767 | 767 | $headers = [ |
768 | 768 | 'Accept' => 'application/json', |
769 | 769 | ]; |
@@ -804,11 +804,11 @@ discard block |
||
804 | 804 | */ |
805 | 805 | public function getSource(array $params = []) |
806 | 806 | { |
807 | - $this->checkRequiredParameters(['id','index'], $params); |
|
808 | - $url = '/' . $this->encode($params['index']) . '/_source/' . $this->encode($params['id']); |
|
807 | + $this->checkRequiredParameters(['id', 'index'], $params); |
|
808 | + $url = '/'.$this->encode($params['index']).'/_source/'.$this->encode($params['id']); |
|
809 | 809 | $method = 'GET'; |
810 | 810 | |
811 | - $url = $this->addQueryString($url, $params, ['preference','realtime','refresh','routing','_source','_source_excludes','_source_includes','version','version_type','pretty','human','error_trace','source','filter_path']); |
|
811 | + $url = $this->addQueryString($url, $params, ['preference', 'realtime', 'refresh', 'routing', '_source', '_source_excludes', '_source_includes', 'version', 'version_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
812 | 812 | $headers = [ |
813 | 813 | 'Accept' => 'application/json', |
814 | 814 | ]; |
@@ -842,13 +842,13 @@ discard block |
||
842 | 842 | public function healthReport(array $params = []) |
843 | 843 | { |
844 | 844 | if (isset($params['feature'])) { |
845 | - $url = '/_health_report/' . $this->encode($params['feature']); |
|
845 | + $url = '/_health_report/'.$this->encode($params['feature']); |
|
846 | 846 | $method = 'GET'; |
847 | 847 | } else { |
848 | 848 | $url = '/_health_report'; |
849 | 849 | $method = 'GET'; |
850 | 850 | } |
851 | - $url = $this->addQueryString($url, $params, ['timeout','verbose','size','pretty','human','error_trace','source','filter_path']); |
|
851 | + $url = $this->addQueryString($url, $params, ['timeout', 'verbose', 'size', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
852 | 852 | $headers = [ |
853 | 853 | 'Accept' => 'application/json', |
854 | 854 | ]; |
@@ -893,15 +893,15 @@ discard block |
||
893 | 893 | */ |
894 | 894 | public function index(array $params = []) |
895 | 895 | { |
896 | - $this->checkRequiredParameters(['index','body'], $params); |
|
896 | + $this->checkRequiredParameters(['index', 'body'], $params); |
|
897 | 897 | if (isset($params['id'])) { |
898 | - $url = '/' . $this->encode($params['index']) . '/_doc/' . $this->encode($params['id']); |
|
898 | + $url = '/'.$this->encode($params['index']).'/_doc/'.$this->encode($params['id']); |
|
899 | 899 | $method = 'PUT'; |
900 | 900 | } else { |
901 | - $url = '/' . $this->encode($params['index']) . '/_doc'; |
|
901 | + $url = '/'.$this->encode($params['index']).'/_doc'; |
|
902 | 902 | $method = 'POST'; |
903 | 903 | } |
904 | - $url = $this->addQueryString($url, $params, ['wait_for_active_shards','op_type','refresh','routing','timeout','version','version_type','if_seq_no','if_primary_term','pipeline','require_alias','require_data_stream','pretty','human','error_trace','source','filter_path']); |
|
904 | + $url = $this->addQueryString($url, $params, ['wait_for_active_shards', 'op_type', 'refresh', 'routing', 'timeout', 'version', 'version_type', 'if_seq_no', 'if_primary_term', 'pipeline', 'require_alias', 'require_data_stream', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
905 | 905 | $headers = [ |
906 | 906 | 'Accept' => 'application/json', |
907 | 907 | 'Content-Type' => 'application/json', |
@@ -934,7 +934,7 @@ discard block |
||
934 | 934 | $url = '/'; |
935 | 935 | $method = 'GET'; |
936 | 936 | |
937 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
937 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
938 | 938 | $headers = [ |
939 | 939 | 'Accept' => 'application/json', |
940 | 940 | ]; |
@@ -969,10 +969,10 @@ discard block |
||
969 | 969 | public function knnSearch(array $params = []) |
970 | 970 | { |
971 | 971 | $this->checkRequiredParameters(['index'], $params); |
972 | - $url = '/' . $this->encode($params['index']) . '/_knn_search'; |
|
972 | + $url = '/'.$this->encode($params['index']).'/_knn_search'; |
|
973 | 973 | $method = empty($params['body']) ? 'GET' : 'POST'; |
974 | 974 | |
975 | - $url = $this->addQueryString($url, $params, ['routing','pretty','human','error_trace','source','filter_path']); |
|
975 | + $url = $this->addQueryString($url, $params, ['routing', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
976 | 976 | $headers = [ |
977 | 977 | 'Accept' => 'application/json', |
978 | 978 | 'Content-Type' => 'application/json', |
@@ -1015,13 +1015,13 @@ discard block |
||
1015 | 1015 | { |
1016 | 1016 | $this->checkRequiredParameters(['body'], $params); |
1017 | 1017 | if (isset($params['index'])) { |
1018 | - $url = '/' . $this->encode($params['index']) . '/_mget'; |
|
1018 | + $url = '/'.$this->encode($params['index']).'/_mget'; |
|
1019 | 1019 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1020 | 1020 | } else { |
1021 | 1021 | $url = '/_mget'; |
1022 | 1022 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1023 | 1023 | } |
1024 | - $url = $this->addQueryString($url, $params, ['force_synthetic_source','stored_fields','preference','realtime','refresh','routing','_source','_source_excludes','_source_includes','pretty','human','error_trace','source','filter_path']); |
|
1024 | + $url = $this->addQueryString($url, $params, ['force_synthetic_source', 'stored_fields', 'preference', 'realtime', 'refresh', 'routing', '_source', '_source_excludes', '_source_includes', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1025 | 1025 | $headers = [ |
1026 | 1026 | 'Accept' => 'application/json', |
1027 | 1027 | 'Content-Type' => 'application/json', |
@@ -1062,13 +1062,13 @@ discard block |
||
1062 | 1062 | { |
1063 | 1063 | $this->checkRequiredParameters(['body'], $params); |
1064 | 1064 | if (isset($params['index'])) { |
1065 | - $url = '/' . $this->encode($params['index']) . '/_msearch'; |
|
1065 | + $url = '/'.$this->encode($params['index']).'/_msearch'; |
|
1066 | 1066 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1067 | 1067 | } else { |
1068 | 1068 | $url = '/_msearch'; |
1069 | 1069 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1070 | 1070 | } |
1071 | - $url = $this->addQueryString($url, $params, ['search_type','max_concurrent_searches','typed_keys','pre_filter_shard_size','max_concurrent_shard_requests','rest_total_hits_as_int','ccs_minimize_roundtrips','pretty','human','error_trace','source','filter_path']); |
|
1071 | + $url = $this->addQueryString($url, $params, ['search_type', 'max_concurrent_searches', 'typed_keys', 'pre_filter_shard_size', 'max_concurrent_shard_requests', 'rest_total_hits_as_int', 'ccs_minimize_roundtrips', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1072 | 1072 | $headers = [ |
1073 | 1073 | 'Accept' => 'application/json', |
1074 | 1074 | 'Content-Type' => 'application/x-ndjson', |
@@ -1107,13 +1107,13 @@ discard block |
||
1107 | 1107 | { |
1108 | 1108 | $this->checkRequiredParameters(['body'], $params); |
1109 | 1109 | if (isset($params['index'])) { |
1110 | - $url = '/' . $this->encode($params['index']) . '/_msearch/template'; |
|
1110 | + $url = '/'.$this->encode($params['index']).'/_msearch/template'; |
|
1111 | 1111 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1112 | 1112 | } else { |
1113 | 1113 | $url = '/_msearch/template'; |
1114 | 1114 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1115 | 1115 | } |
1116 | - $url = $this->addQueryString($url, $params, ['search_type','typed_keys','max_concurrent_searches','rest_total_hits_as_int','ccs_minimize_roundtrips','pretty','human','error_trace','source','filter_path']); |
|
1116 | + $url = $this->addQueryString($url, $params, ['search_type', 'typed_keys', 'max_concurrent_searches', 'rest_total_hits_as_int', 'ccs_minimize_roundtrips', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1117 | 1117 | $headers = [ |
1118 | 1118 | 'Accept' => 'application/json', |
1119 | 1119 | 'Content-Type' => 'application/x-ndjson', |
@@ -1158,13 +1158,13 @@ discard block |
||
1158 | 1158 | public function mtermvectors(array $params = []) |
1159 | 1159 | { |
1160 | 1160 | if (isset($params['index'])) { |
1161 | - $url = '/' . $this->encode($params['index']) . '/_mtermvectors'; |
|
1161 | + $url = '/'.$this->encode($params['index']).'/_mtermvectors'; |
|
1162 | 1162 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1163 | 1163 | } else { |
1164 | 1164 | $url = '/_mtermvectors'; |
1165 | 1165 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1166 | 1166 | } |
1167 | - $url = $this->addQueryString($url, $params, ['ids','term_statistics','field_statistics','fields','offsets','positions','payloads','preference','routing','realtime','version','version_type','pretty','human','error_trace','source','filter_path']); |
|
1167 | + $url = $this->addQueryString($url, $params, ['ids', 'term_statistics', 'field_statistics', 'fields', 'offsets', 'positions', 'payloads', 'preference', 'routing', 'realtime', 'version', 'version_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1168 | 1168 | $headers = [ |
1169 | 1169 | 'Accept' => 'application/json', |
1170 | 1170 | 'Content-Type' => 'application/json', |
@@ -1202,11 +1202,11 @@ discard block |
||
1202 | 1202 | */ |
1203 | 1203 | public function openPointInTime(array $params = []) |
1204 | 1204 | { |
1205 | - $this->checkRequiredParameters(['index','keep_alive'], $params); |
|
1206 | - $url = '/' . $this->encode($params['index']) . '/_pit'; |
|
1205 | + $this->checkRequiredParameters(['index', 'keep_alive'], $params); |
|
1206 | + $url = '/'.$this->encode($params['index']).'/_pit'; |
|
1207 | 1207 | $method = 'POST'; |
1208 | 1208 | |
1209 | - $url = $this->addQueryString($url, $params, ['preference','routing','ignore_unavailable','expand_wildcards','keep_alive','pretty','human','error_trace','source','filter_path']); |
|
1209 | + $url = $this->addQueryString($url, $params, ['preference', 'routing', 'ignore_unavailable', 'expand_wildcards', 'keep_alive', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1210 | 1210 | $headers = [ |
1211 | 1211 | 'Accept' => 'application/json', |
1212 | 1212 | 'Content-Type' => 'application/json', |
@@ -1239,7 +1239,7 @@ discard block |
||
1239 | 1239 | $url = '/'; |
1240 | 1240 | $method = 'HEAD'; |
1241 | 1241 | |
1242 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
1242 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1243 | 1243 | $headers = [ |
1244 | 1244 | 'Accept' => 'application/json', |
1245 | 1245 | ]; |
@@ -1274,15 +1274,15 @@ discard block |
||
1274 | 1274 | */ |
1275 | 1275 | public function putScript(array $params = []) |
1276 | 1276 | { |
1277 | - $this->checkRequiredParameters(['id','body'], $params); |
|
1277 | + $this->checkRequiredParameters(['id', 'body'], $params); |
|
1278 | 1278 | if (isset($params['context'])) { |
1279 | - $url = '/_scripts/' . $this->encode($params['id']) . '/' . $this->encode($params['context']); |
|
1279 | + $url = '/_scripts/'.$this->encode($params['id']).'/'.$this->encode($params['context']); |
|
1280 | 1280 | $method = 'PUT'; |
1281 | 1281 | } else { |
1282 | - $url = '/_scripts/' . $this->encode($params['id']); |
|
1282 | + $url = '/_scripts/'.$this->encode($params['id']); |
|
1283 | 1283 | $method = 'PUT'; |
1284 | 1284 | } |
1285 | - $url = $this->addQueryString($url, $params, ['timeout','master_timeout','pretty','human','error_trace','source','filter_path']); |
|
1285 | + $url = $this->addQueryString($url, $params, ['timeout', 'master_timeout', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1286 | 1286 | $headers = [ |
1287 | 1287 | 'Accept' => 'application/json', |
1288 | 1288 | 'Content-Type' => 'application/json', |
@@ -1320,13 +1320,13 @@ discard block |
||
1320 | 1320 | { |
1321 | 1321 | $this->checkRequiredParameters(['body'], $params); |
1322 | 1322 | if (isset($params['index'])) { |
1323 | - $url = '/' . $this->encode($params['index']) . '/_rank_eval'; |
|
1323 | + $url = '/'.$this->encode($params['index']).'/_rank_eval'; |
|
1324 | 1324 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1325 | 1325 | } else { |
1326 | 1326 | $url = '/_rank_eval'; |
1327 | 1327 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1328 | 1328 | } |
1329 | - $url = $this->addQueryString($url, $params, ['ignore_unavailable','allow_no_indices','expand_wildcards','search_type','pretty','human','error_trace','source','filter_path']); |
|
1329 | + $url = $this->addQueryString($url, $params, ['ignore_unavailable', 'allow_no_indices', 'expand_wildcards', 'search_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1330 | 1330 | $headers = [ |
1331 | 1331 | 'Accept' => 'application/json', |
1332 | 1332 | 'Content-Type' => 'application/json', |
@@ -1371,7 +1371,7 @@ discard block |
||
1371 | 1371 | $url = '/_reindex'; |
1372 | 1372 | $method = 'POST'; |
1373 | 1373 | |
1374 | - $url = $this->addQueryString($url, $params, ['refresh','timeout','wait_for_active_shards','wait_for_completion','requests_per_second','scroll','slices','max_docs','pretty','human','error_trace','source','filter_path']); |
|
1374 | + $url = $this->addQueryString($url, $params, ['refresh', 'timeout', 'wait_for_active_shards', 'wait_for_completion', 'requests_per_second', 'scroll', 'slices', 'max_docs', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1375 | 1375 | $headers = [ |
1376 | 1376 | 'Accept' => 'application/json', |
1377 | 1377 | 'Content-Type' => 'application/json', |
@@ -1404,11 +1404,11 @@ discard block |
||
1404 | 1404 | */ |
1405 | 1405 | public function reindexRethrottle(array $params = []) |
1406 | 1406 | { |
1407 | - $this->checkRequiredParameters(['task_id','requests_per_second'], $params); |
|
1408 | - $url = '/_reindex/' . $this->encode($params['task_id']) . '/_rethrottle'; |
|
1407 | + $this->checkRequiredParameters(['task_id', 'requests_per_second'], $params); |
|
1408 | + $url = '/_reindex/'.$this->encode($params['task_id']).'/_rethrottle'; |
|
1409 | 1409 | $method = 'POST'; |
1410 | 1410 | |
1411 | - $url = $this->addQueryString($url, $params, ['requests_per_second','pretty','human','error_trace','source','filter_path']); |
|
1411 | + $url = $this->addQueryString($url, $params, ['requests_per_second', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1412 | 1412 | $headers = [ |
1413 | 1413 | 'Accept' => 'application/json', |
1414 | 1414 | ]; |
@@ -1440,13 +1440,13 @@ discard block |
||
1440 | 1440 | public function renderSearchTemplate(array $params = []) |
1441 | 1441 | { |
1442 | 1442 | if (isset($params['id'])) { |
1443 | - $url = '/_render/template/' . $this->encode($params['id']); |
|
1443 | + $url = '/_render/template/'.$this->encode($params['id']); |
|
1444 | 1444 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1445 | 1445 | } else { |
1446 | 1446 | $url = '/_render/template'; |
1447 | 1447 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1448 | 1448 | } |
1449 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
1449 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1450 | 1450 | $headers = [ |
1451 | 1451 | 'Accept' => 'application/json', |
1452 | 1452 | 'Content-Type' => 'application/json', |
@@ -1481,7 +1481,7 @@ discard block |
||
1481 | 1481 | $url = '/_scripts/painless/_execute'; |
1482 | 1482 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1483 | 1483 | |
1484 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
1484 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1485 | 1485 | $headers = [ |
1486 | 1486 | 'Accept' => 'application/json', |
1487 | 1487 | 'Content-Type' => 'application/json', |
@@ -1516,13 +1516,13 @@ discard block |
||
1516 | 1516 | public function scroll(array $params = []) |
1517 | 1517 | { |
1518 | 1518 | if (isset($params['scroll_id'])) { |
1519 | - $url = '/_search/scroll/' . $this->encode($params['scroll_id']); |
|
1519 | + $url = '/_search/scroll/'.$this->encode($params['scroll_id']); |
|
1520 | 1520 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1521 | 1521 | } else { |
1522 | 1522 | $url = '/_search/scroll'; |
1523 | 1523 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1524 | 1524 | } |
1525 | - $url = $this->addQueryString($url, $params, ['scroll','rest_total_hits_as_int','pretty','human','error_trace','source','filter_path']); |
|
1525 | + $url = $this->addQueryString($url, $params, ['scroll', 'rest_total_hits_as_int', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1526 | 1526 | $headers = [ |
1527 | 1527 | 'Accept' => 'application/json', |
1528 | 1528 | 'Content-Type' => 'application/json', |
@@ -1600,13 +1600,13 @@ discard block |
||
1600 | 1600 | public function search(array $params = []) |
1601 | 1601 | { |
1602 | 1602 | if (isset($params['index'])) { |
1603 | - $url = '/' . $this->encode($params['index']) . '/_search'; |
|
1603 | + $url = '/'.$this->encode($params['index']).'/_search'; |
|
1604 | 1604 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1605 | 1605 | } else { |
1606 | 1606 | $url = '/_search'; |
1607 | 1607 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1608 | 1608 | } |
1609 | - $url = $this->addQueryString($url, $params, ['analyzer','analyze_wildcard','ccs_minimize_roundtrips','default_operator','df','explain','stored_fields','docvalue_fields','from','force_synthetic_source','ignore_unavailable','ignore_throttled','allow_no_indices','expand_wildcards','lenient','preference','q','routing','scroll','search_type','size','sort','_source','_source_excludes','_source_includes','terminate_after','stats','suggest_field','suggest_mode','suggest_size','suggest_text','timeout','track_scores','track_total_hits','allow_partial_search_results','typed_keys','version','seq_no_primary_term','request_cache','batched_reduce_size','max_concurrent_shard_requests','pre_filter_shard_size','rest_total_hits_as_int','min_compatible_shard_node','include_named_queries_score','pretty','human','error_trace','source','filter_path']); |
|
1609 | + $url = $this->addQueryString($url, $params, ['analyzer', 'analyze_wildcard', 'ccs_minimize_roundtrips', 'default_operator', 'df', 'explain', 'stored_fields', 'docvalue_fields', 'from', 'force_synthetic_source', 'ignore_unavailable', 'ignore_throttled', 'allow_no_indices', 'expand_wildcards', 'lenient', 'preference', 'q', 'routing', 'scroll', 'search_type', 'size', 'sort', '_source', '_source_excludes', '_source_includes', 'terminate_after', 'stats', 'suggest_field', 'suggest_mode', 'suggest_size', 'suggest_text', 'timeout', 'track_scores', 'track_total_hits', 'allow_partial_search_results', 'typed_keys', 'version', 'seq_no_primary_term', 'request_cache', 'batched_reduce_size', 'max_concurrent_shard_requests', 'pre_filter_shard_size', 'rest_total_hits_as_int', 'min_compatible_shard_node', 'include_named_queries_score', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1610 | 1610 | $headers = [ |
1611 | 1611 | 'Accept' => 'application/json', |
1612 | 1612 | 'Content-Type' => 'application/json', |
@@ -1651,11 +1651,11 @@ discard block |
||
1651 | 1651 | */ |
1652 | 1652 | public function searchMvt(array $params = []) |
1653 | 1653 | { |
1654 | - $this->checkRequiredParameters(['index','field','zoom','x','y'], $params); |
|
1655 | - $url = '/' . $this->encode($params['index']) . '/_mvt/' . $this->encode($params['field']) . '/' . $this->encode($params['zoom']) . '/' . $this->encode($params['x']) . '/' . $this->encode($params['y']); |
|
1654 | + $this->checkRequiredParameters(['index', 'field', 'zoom', 'x', 'y'], $params); |
|
1655 | + $url = '/'.$this->encode($params['index']).'/_mvt/'.$this->encode($params['field']).'/'.$this->encode($params['zoom']).'/'.$this->encode($params['x']).'/'.$this->encode($params['y']); |
|
1656 | 1656 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1657 | 1657 | |
1658 | - $url = $this->addQueryString($url, $params, ['exact_bounds','extent','grid_precision','grid_type','size','track_total_hits','with_labels','pretty','human','error_trace','source','filter_path']); |
|
1658 | + $url = $this->addQueryString($url, $params, ['exact_bounds', 'extent', 'grid_precision', 'grid_type', 'size', 'track_total_hits', 'with_labels', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1659 | 1659 | $headers = [ |
1660 | 1660 | 'Accept' => 'application/vnd.mapbox-vector-tile', |
1661 | 1661 | 'Content-Type' => 'application/json', |
@@ -1693,13 +1693,13 @@ discard block |
||
1693 | 1693 | public function searchShards(array $params = []) |
1694 | 1694 | { |
1695 | 1695 | if (isset($params['index'])) { |
1696 | - $url = '/' . $this->encode($params['index']) . '/_search_shards'; |
|
1696 | + $url = '/'.$this->encode($params['index']).'/_search_shards'; |
|
1697 | 1697 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1698 | 1698 | } else { |
1699 | 1699 | $url = '/_search_shards'; |
1700 | 1700 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1701 | 1701 | } |
1702 | - $url = $this->addQueryString($url, $params, ['preference','routing','local','ignore_unavailable','allow_no_indices','expand_wildcards','pretty','human','error_trace','source','filter_path']); |
|
1702 | + $url = $this->addQueryString($url, $params, ['preference', 'routing', 'local', 'ignore_unavailable', 'allow_no_indices', 'expand_wildcards', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1703 | 1703 | $headers = [ |
1704 | 1704 | 'Accept' => 'application/json', |
1705 | 1705 | ]; |
@@ -1745,13 +1745,13 @@ discard block |
||
1745 | 1745 | { |
1746 | 1746 | $this->checkRequiredParameters(['body'], $params); |
1747 | 1747 | if (isset($params['index'])) { |
1748 | - $url = '/' . $this->encode($params['index']) . '/_search/template'; |
|
1748 | + $url = '/'.$this->encode($params['index']).'/_search/template'; |
|
1749 | 1749 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1750 | 1750 | } else { |
1751 | 1751 | $url = '/_search/template'; |
1752 | 1752 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1753 | 1753 | } |
1754 | - $url = $this->addQueryString($url, $params, ['ignore_unavailable','ignore_throttled','allow_no_indices','expand_wildcards','preference','routing','scroll','search_type','explain','profile','typed_keys','rest_total_hits_as_int','ccs_minimize_roundtrips','pretty','human','error_trace','source','filter_path']); |
|
1754 | + $url = $this->addQueryString($url, $params, ['ignore_unavailable', 'ignore_throttled', 'allow_no_indices', 'expand_wildcards', 'preference', 'routing', 'scroll', 'search_type', 'explain', 'profile', 'typed_keys', 'rest_total_hits_as_int', 'ccs_minimize_roundtrips', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1755 | 1755 | $headers = [ |
1756 | 1756 | 'Accept' => 'application/json', |
1757 | 1757 | 'Content-Type' => 'application/json', |
@@ -1785,10 +1785,10 @@ discard block |
||
1785 | 1785 | public function termsEnum(array $params = []) |
1786 | 1786 | { |
1787 | 1787 | $this->checkRequiredParameters(['index'], $params); |
1788 | - $url = '/' . $this->encode($params['index']) . '/_terms_enum'; |
|
1788 | + $url = '/'.$this->encode($params['index']).'/_terms_enum'; |
|
1789 | 1789 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1790 | 1790 | |
1791 | - $url = $this->addQueryString($url, $params, ['pretty','human','error_trace','source','filter_path']); |
|
1791 | + $url = $this->addQueryString($url, $params, ['pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1792 | 1792 | $headers = [ |
1793 | 1793 | 'Accept' => 'application/json', |
1794 | 1794 | 'Content-Type' => 'application/json', |
@@ -1835,13 +1835,13 @@ discard block |
||
1835 | 1835 | { |
1836 | 1836 | $this->checkRequiredParameters(['index'], $params); |
1837 | 1837 | if (isset($params['id'])) { |
1838 | - $url = '/' . $this->encode($params['index']) . '/_termvectors/' . $this->encode($params['id']); |
|
1838 | + $url = '/'.$this->encode($params['index']).'/_termvectors/'.$this->encode($params['id']); |
|
1839 | 1839 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1840 | 1840 | } else { |
1841 | - $url = '/' . $this->encode($params['index']) . '/_termvectors'; |
|
1841 | + $url = '/'.$this->encode($params['index']).'/_termvectors'; |
|
1842 | 1842 | $method = empty($params['body']) ? 'GET' : 'POST'; |
1843 | 1843 | } |
1844 | - $url = $this->addQueryString($url, $params, ['term_statistics','field_statistics','fields','offsets','positions','payloads','preference','routing','realtime','version','version_type','pretty','human','error_trace','source','filter_path']); |
|
1844 | + $url = $this->addQueryString($url, $params, ['term_statistics', 'field_statistics', 'fields', 'offsets', 'positions', 'payloads', 'preference', 'routing', 'realtime', 'version', 'version_type', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1845 | 1845 | $headers = [ |
1846 | 1846 | 'Accept' => 'application/json', |
1847 | 1847 | 'Content-Type' => 'application/json', |
@@ -1887,11 +1887,11 @@ discard block |
||
1887 | 1887 | */ |
1888 | 1888 | public function update(array $params = []) |
1889 | 1889 | { |
1890 | - $this->checkRequiredParameters(['id','index','body'], $params); |
|
1891 | - $url = '/' . $this->encode($params['index']) . '/_update/' . $this->encode($params['id']); |
|
1890 | + $this->checkRequiredParameters(['id', 'index', 'body'], $params); |
|
1891 | + $url = '/'.$this->encode($params['index']).'/_update/'.$this->encode($params['id']); |
|
1892 | 1892 | $method = 'POST'; |
1893 | 1893 | |
1894 | - $url = $this->addQueryString($url, $params, ['wait_for_active_shards','_source','_source_excludes','_source_includes','lang','refresh','retry_on_conflict','routing','timeout','if_seq_no','if_primary_term','require_alias','pretty','human','error_trace','source','filter_path']); |
|
1894 | + $url = $this->addQueryString($url, $params, ['wait_for_active_shards', '_source', '_source_excludes', '_source_includes', 'lang', 'refresh', 'retry_on_conflict', 'routing', 'timeout', 'if_seq_no', 'if_primary_term', 'require_alias', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1895 | 1895 | $headers = [ |
1896 | 1896 | 'Accept' => 'application/json', |
1897 | 1897 | 'Content-Type' => 'application/json', |
@@ -1957,10 +1957,10 @@ discard block |
||
1957 | 1957 | public function updateByQuery(array $params = []) |
1958 | 1958 | { |
1959 | 1959 | $this->checkRequiredParameters(['index'], $params); |
1960 | - $url = '/' . $this->encode($params['index']) . '/_update_by_query'; |
|
1960 | + $url = '/'.$this->encode($params['index']).'/_update_by_query'; |
|
1961 | 1961 | $method = 'POST'; |
1962 | 1962 | |
1963 | - $url = $this->addQueryString($url, $params, ['analyzer','analyze_wildcard','default_operator','df','from','ignore_unavailable','allow_no_indices','conflicts','expand_wildcards','lenient','pipeline','preference','q','routing','scroll','search_type','search_timeout','max_docs','sort','terminate_after','stats','version','version_type','request_cache','refresh','timeout','wait_for_active_shards','scroll_size','wait_for_completion','requests_per_second','slices','pretty','human','error_trace','source','filter_path']); |
|
1963 | + $url = $this->addQueryString($url, $params, ['analyzer', 'analyze_wildcard', 'default_operator', 'df', 'from', 'ignore_unavailable', 'allow_no_indices', 'conflicts', 'expand_wildcards', 'lenient', 'pipeline', 'preference', 'q', 'routing', 'scroll', 'search_type', 'search_timeout', 'max_docs', 'sort', 'terminate_after', 'stats', 'version', 'version_type', 'request_cache', 'refresh', 'timeout', 'wait_for_active_shards', 'scroll_size', 'wait_for_completion', 'requests_per_second', 'slices', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
1964 | 1964 | $headers = [ |
1965 | 1965 | 'Accept' => 'application/json', |
1966 | 1966 | 'Content-Type' => 'application/json', |
@@ -1993,11 +1993,11 @@ discard block |
||
1993 | 1993 | */ |
1994 | 1994 | public function updateByQueryRethrottle(array $params = []) |
1995 | 1995 | { |
1996 | - $this->checkRequiredParameters(['task_id','requests_per_second'], $params); |
|
1997 | - $url = '/_update_by_query/' . $this->encode($params['task_id']) . '/_rethrottle'; |
|
1996 | + $this->checkRequiredParameters(['task_id', 'requests_per_second'], $params); |
|
1997 | + $url = '/_update_by_query/'.$this->encode($params['task_id']).'/_rethrottle'; |
|
1998 | 1998 | $method = 'POST'; |
1999 | 1999 | |
2000 | - $url = $this->addQueryString($url, $params, ['requests_per_second','pretty','human','error_trace','source','filter_path']); |
|
2000 | + $url = $this->addQueryString($url, $params, ['requests_per_second', 'pretty', 'human', 'error_trace', 'source', 'filter_path']); |
|
2001 | 2001 | $headers = [ |
2002 | 2002 | 'Accept' => 'application/json', |
2003 | 2003 | ]; |
@@ -26,8 +26,7 @@ |
||
26 | 26 | /** |
27 | 27 | * @generated This file is generated, please do not edit |
28 | 28 | */ |
29 | -trait ClientEndpointsTrait |
|
30 | -{ |
|
29 | +trait ClientEndpointsTrait { |
|
31 | 30 | /** |
32 | 31 | * Allows to perform multiple index/update/delete operations in a single request. |
33 | 32 | * |