Lines Matching refs:endpoint

124         $endpoint = \class_exists(GetMapping::class) ? new GetMapping() : new MappingGet();
126         $response = $this->requestEndpoint($endpoint);
195         $endpoint = new UpdateByQuery();
202         $endpoint->setBody($body);
203         $endpoint->setParams($options);
205         return $this->requestEndpoint($endpoint);
217         $endpoint = new IndexEndpoint();
220             $endpoint->setId($doc->getId());
238         $endpoint->setBody($doc->getData());
239         $endpoint->setParams($options);
241         $response = $this->requestEndpoint($endpoint);
295         $endpoint = new DocumentGet();
296         $endpoint->setId($id);
297         $endpoint->setParams($options);
299         $response = $this->requestEndpoint($endpoint);
335         $endpoint = new \Elasticsearch\Endpoints\Delete();
336         $endpoint->setId(\trim($id));
337         $endpoint->setParams($options);
339         return $this->requestEndpoint($endpoint);
360         $endpoint = new DeleteByQuery();
361         $endpoint->setBody(['query' => \is_array($query) ? $query : $query->toArray()]);
362         $endpoint->setParams($options);
364         return $this->requestEndpoint($endpoint);
378         $endpoint = new OpenPointInTime();
379         $endpoint->setParams(['keep_alive' => $keepAlive]);
381         return $this->requestEndpoint($endpoint);
397      * Uses the "_bulk" endpoint to delete documents from the server.
433         $endpoint = new ForceMerge();
434         $endpoint->setParams($args);
436         return $this->requestEndpoint($endpoint);
458      * @param array      $args    Additional arguments to pass to the Create endpoint
484         $endpoint = new Create();
485         $invalidOptions = \array_diff(\array_keys($options), $allowedOptions = \array_merge($endpoint->getParamWhitelist(), [
507         $endpoint->setParams($options);
508         $endpoint->setBody($args);
510         return $this->requestEndpoint($endpoint);
628         $endpoint = \class_exists(UpdateAliases::class) ? new UpdateAliases() : new Update();
629         $endpoint->setBody($data);
631         return $this->getClient()->requestEndpoint($endpoint);
646         $endpoint = \class_exists(DeleteAlias::class) ? new DeleteAlias() : new Alias\Delete();
647         $endpoint->setName($name);
649         return $this->requestEndpoint($endpoint);
664         $endpoint = \class_exists(GetAlias::class) ? new GetAlias() : new Alias\Get();
665         $endpoint->setName('*');
667         $responseData = $this->requestEndpoint($endpoint)->getData();
701         $endpoint = \class_exists(ClearCache::class) ? new ClearCache() : new Clear();
704         return $this->requestEndpoint($endpoint);
718         $endpoint = new Flush();
719         $endpoint->setParams($options);
721         return $this->requestEndpoint($endpoint);
738         $endpoint = \class_exists(PutSettings::class) ? new PutSettings() : new Put();
739         $endpoint->setBody($data);
741         return $this->requestEndpoint($endpoint);
769     public function requestEndpoint(AbstractEndpoint $endpoint): Response
771         $cloned = clone $endpoint;
791         $endpoint = new Analyze();
792         $endpoint->setBody($body);
793         $endpoint->setParams($args);
795         $data = $this->requestEndpoint($endpoint)->getData();