| Methods |
public
|
__construct(
callable $handler,
array{host: string, port?: int, scheme?: string, user?: string, pass?: string, path?: string} $hostDetails,
array{client?: array{headers?: array<string, list<string>>, curl?: array<int, mixed>}} $connectionParams,
SerializerInterface $serializer,
LoggerInterface $log,
LoggerInterface $trace,
)
|
#
|
public
|
performRequest(
string $method,
string $uri,
null|array<string, mixed> $params = [],
mixed $body = null,
array $options = [],
Transport|null $transport = null,
): mixed
|
#
|
public
|
getTransportSchema(): string
Get the transport schema for this connection
Get the transport schema for this connection
Implements
|
#
|
public
|
getLastRequestInfo(): array
Return an associative array of information about the last request
Return an associative array of information about the last request
Implements
|
#
|
public
|
getHeaders(): array<string, list<string>>
|
#
|
public
|
logWarning(array $request, array $response): void
|
#
|
public
|
logRequestSuccess(array $request, array $response): void
Log a successful request
|
#
|
public
|
logRequestFail(array $request, array $response, Throwable $exception): void
Log a failed request
|
#
|
public
|
ping(): bool
|
#
|
public
|
sniff(): array|FutureArray
|
#
|
public
|
isAlive(): bool
Check to see if this instance is marked as 'alive'
Check to see if this instance is marked as 'alive'
Implements
|
#
|
public
|
markAlive(): void
Mark this instance as 'alive'
Mark this instance as 'alive'
Implements
|
#
|
public
|
markDead(): void
Mark this instance as 'dead'
Mark this instance as 'dead'
Implements
|
#
|
public
|
getLastPing(): int
|
#
|
public
|
getPingFailures(): int
|
#
|
public
|
getHost(): string
Get the hostname for this connection
Get the hostname for this connection
Implements
|
#
|
public
|
getUserPass(): ?string
Get the username:password string for this connection, null if not set
Get the username:password string for this connection, null if not set
Implements
|
#
|
public
|
getPath(): ?string
Get the URL path suffix, null if not set
Get the URL path suffix, null if not set
Implements
|
#
|
public
|
getPort(): int
Get the port for this connection
Get the port for this connection
Implements
|
#
|
protected
|
getCurlRetryException(array $request, array $response): OpenSearchException
|
#
|