Lines Matching refs:request

220         $request = [
233         $request = array_replace_recursive($request, $this->connectionParams, $options);
236         if (empty($request['client'])) {
237             unset($request['client']);
241         $future = $handler($request, $this, $transport, $options);
258         return function (array $request, Connection $connection, Transport $transport = null, $options) use ($handler) {
261             $this->lastRequest['request'] = $request;
263             // Send the request using the wrapped handler.
265                 $handler($request), 
266                 function ($response) use ($connection, $transport, $request, $options) {
274                             $exception = $this->getCurlRetryException($request, $response);
276                             $this->logRequestFail($request, $response, $exception);
290                                 $neverRetry = isset($request['client']['never_retry']) ? $request['client']['never_retry'] : false;
291                                 $shouldRetry = $transport->shouldRetry($request);
297                                         $request['http_method'],
298                                         $request['uri'],
300                                         $request['body'],
312                             $this->logRequestFail($request, $response, $exception);
319                             $this->logWarning($request, $response);
327                             $ignore = $request['client']['ignore'] ?? [];
333                             $this->process4xxError($request, $response, $ignore);
335                             $ignore = $request['client']['ignore'] ?? [];
336                             $this->process5xxError($request, $response, $ignore);
342                     $this->logRequestSuccess($request, $response);
344                     return isset($request['client']['verbose']) && $request['client']['verbose'] === true ? $response : $response['body'];
383     public function logWarning(array $request, array $response): void
389      * Log a successful request
391      * @param  array $request
395     public function logRequestSuccess(array $request, array $response): void
397         $port = $request['client']['curl'][CURLOPT_PORT] ?? $response['transfer_stats']['primary_port'] ?? '';
400         $this->log->debug('Request Body', array($request['body']));
404                 'method'    => $request['http_method'],
407                 'headers'   => $request['headers'],
415         $curlCommand = $this->buildCurlCommand($request['http_method'], $uri, $request['body']);
421                 'method'    => $request['http_method'],
431      * Log a failed request
433      * @param array      $request
439     public function logRequestFail(array $request, array $response, \Exception $exception): void
441         $port = $request['client']['curl'][CURLOPT_PORT] ?? $response['transfer_stats']['primary_port'] ?? '';
444         $this->log->debug('Request Body', array($request['body']));
448                 'method'    => $request['http_method'],
451                 'headers'   => $request['headers'],
460         $curlCommand = $this->buildCurlCommand($request['http_method'], $uri, $request['body']);
466                 'method'    => $request['http_method'],
571     protected function getCurlRetryException(array $request, array $response): ElasticsearchException
666     private function process4xxError(array $request, array $response, array $ignore): ?ElasticsearchException
696         $this->logRequestFail($request, $response, $exception);
701     private function process5xxError(array $request, array $response, array $ignore): ?ElasticsearchException
732         $this->logRequestFail($request, $response, $exception);