qdrant_client.connection module

create_generic_async_client_interceptor(intercept_call: Any) → _GenericAsyncClientInterceptor

create_generic_client_interceptor(intercept_call: Any) → _GenericClientInterceptor

get_async_channel(host: str, port: int, ssl: bool, metadata: Optional[list[tuple[str, str]]] = None, options: Optional[dict[str, Any]] = None, compression: Optional[Compression] = None, auth_token_provider: Optional[Union[Callable[[], str], Callable[[], Awaitable[str]]]] = None, retry_config: Optional[RetryConfig] = None) → Channel

get_channel(host: str, port: int, ssl: bool, metadata: Optional[list[tuple[str, str]]] = None, options: Optional[dict[str, Any]] = None, compression: Optional[Compression] = None, auth_token_provider: Optional[Callable[[], str]] = None, retry_config: Optional[RetryConfig] = None) → Channel

header_adder_async_interceptor(new_metadata: list[tuple[str, str]], auth_token_provider: Optional[Union[Callable[[], str], Callable[[], Awaitable[str]]]] = None) → _GenericAsyncClientInterceptor

header_adder_interceptor(new_metadata: list[tuple[str, str]], auth_token_provider: Optional[Callable[[], str]] = None) → _GenericClientInterceptor

parse_channel_options(options: Optional[dict[str, Any]] = None) → list[tuple[str, Any]]

parse_ssl_credentials(options: Optional[dict[str, Any]] = None) → dict[str, bytes | None]

Parse ssl credentials to create grpc.ssl_channel_credentials for grpc.secure_channel

WARN: Directly modifies input options

Returns:

dict[str, Optional[bytes]] – dict(root_certificates=…, private_key=…, certificate_chain=…)