Skip to main content

Module connections

Module connections 

Source
Expand description

Connection types.

Modules§

aws
AWS configuration for sources and sinks.
inline
Contains traits and types to support inlining connection details.
string_or_secret

Structs§

AwsPrivatelink
Specifies an AWS PrivateLink service for a Tunnel.
AwsPrivatelinkConnection
AwsSdkCredentialLoader 🔒
A credential loader that wraps an aws-sdk-rust credentials provider for use with iceberg/OpenDAL. This allows us to provide refreshable credentials from the AWS SDK credential chain (including the full assume role chain) to OpenDAL’s S3 implementation.
ConnectionContext
Extra context to pass through when instantiating a connection for a source or sink.
CsrConnection
A connection to a Confluent Schema Registry.
CsrConnectionHttpAuth
HTTP authentication credentials in a CsrConnection.
IcebergCatalogConnection
KafkaBroker
Specifies a Kafka broker in a KafkaConnection.
KafkaConnection
KafkaSaslConfig
KafkaTlsConfig
KafkaTopicOptions
MySqlConnection
A connection to a MySQL server.
PostgresConnection
A connection to a PostgreSQL server.
RestIcebergCatalog
S3TablesRestIcebergCatalog
SqlServerConnectionDetails
Details how to connect to an instance of Microsoft SQL Server.
SshConnection
A connection to an SSH tunnel.
SshTunnel
Specifies an SSH tunnel connection.
TlsIdentity
A TLS key pair used for client identity.

Enums§

Connection
ConnectionValidationError
An error returned by Connection::validate.
IcebergCatalogImpl
IcebergCatalogType
MySqlConnectionValidationError
MySqlSslMode
Specifies which MySQL SSL Mode to use: https://dev.mysql.com/doc/refman/8.0/en/connection-options.html#option_general_ssl-mode This is not available as an enum in the mysql-async crate, so we define our own.
PostgresConnectionValidationError
SqlServerConnectionValidationError
Tunnel
Specifies how to tunnel a connection.

Constants§

REST_CATALOG_PROP_CREDENTIAL 🔒
REST_CATALOG_PROP_SCOPE 🔒

Traits§

SecretsReaderExt 🔒
An extension trait for SecretsReader