Module mz_storage::client::connections

source · [−]

Expand description

Connection types.

Modules

AWS configuration for sources and sinks.

proto_kafka_connection_security

Nested message and enum types in ProtoKafkaConnectionSecurity.

proto_string_or_secret

Nested message and enum types in ProtoStringOrSecret.

Structs

ConnectionContext

Extra context to pass through when instantiating a connection for a source or sink.

A connection to a Confluent Schema Registry.

CsrConnectionHttpAuth

HTTP authentication credentials in a CsrConnection.

KafkaConnection

PostgresConnection

A connection to a PostgreSQL server.

ProtoCsrConnection

ProtoCsrConnectionHttpAuth

ProtoKafkaConnection

ProtoKafkaConnectionSaslConfig

ProtoKafkaConnectionSecurity

ProtoKafkaConnectionTlsConfig

ProtoPostgresConnection

ProtoStringOrSecret

ProtoTlsIdentity

A connection to a SSH tunnel.

A TLS key pair used for client identity.

Enums

Constants

_IMPL_ARBITRARY_FOR_Connection 🔒

_IMPL_ARBITRARY_FOR_CsrConnectionHttpAuth 🔒

_IMPL_ARBITRARY_FOR_KafkaConnection 🔒

_IMPL_ARBITRARY_FOR_KafkaSecurity 🔒

_IMPL_ARBITRARY_FOR_KafkaTlsConfig 🔒

_IMPL_ARBITRARY_FOR_SaslConfig 🔒

_IMPL_ARBITRARY_FOR_SshConnection 🔒

_IMPL_ARBITRARY_FOR_StringOrSecret 🔒

_IMPL_ARBITRARY_FOR_TlsIdentity 🔒

Traits

Meant to create an equivalence function between enum-named options and their free-form String counterparts.

PopulateClientConfig

Provides cleaner access to the populate_client_config implementation for structs.

Functions

populate_client_config

Propagates appropriate configuration options from kafka_connection and options into config, ignoring any options identified in drop_option_keys.