Expand description
Connection types.
Modules§
- aws
- AWS configuration for sources and sinks.
- gcp
- GCP configuration for sources and sinks.
- iceberg_
credentials 🔒 - Catalog-vended storage credentials for Iceberg sinks.
- inline
- Contains traits and types to support inlining connection details.
- string_
or_ secret
Structs§
- AwsPrivatelink
- Specifies an AWS PrivateLink service for a
Tunnel. - AwsPrivatelink
Connection - AwsPrivatelink
Rule - AwsPrivatelinks
- AwsSdk
Credential 🔒Loader - 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.
- Connection
Context - Extra context to pass through when instantiating a connection for a source or sink.
- CsrConnection
- A connection to a Confluent Schema Registry.
- CsrConnection
Http Auth - HTTP authentication credentials in a
CsrConnection. - Glue
Schema Registry Connection - A connection to an AWS Glue Schema Registry.
- Iceberg
Catalog Connection - Invalid
AwsPrivatelink Service Name - A
SERVICE NAMEthat cannot name an AWS VPC endpoint service. - Kafka
Broker - Specifies a Kafka broker in a
KafkaConnection. - Kafka
Connection - Kafka
Sasl Config - Kafka
TlsConfig - Kafka
Topic Options - MySql
Connection - A connection to a MySQL server.
- Postgres
Connection - A connection to a PostgreSQL server.
- Rest
Iceberg Catalog - S3Tables
Rest Iceberg Catalog - Sigv4
Authenticator 🔒 - Signs each outgoing REST-catalog request with AWS SigV4.
- SqlServer
Connection Details - 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
- Connection
Validation Error - An error returned by
Connection::validate. - Iceberg
Access Delegation - The value Materialize sends in the Iceberg REST
X-Iceberg-Access-Delegationheader, naming how the catalog should grant access to table storage. - Iceberg
Catalog Auth - Auth mechanism for Iceberg REST catalogs.
- Iceberg
Catalog Impl - Iceberg
Catalog Type - Iceberg
Storage Provider - Which object store holds the data files of a REST catalog’s tables.
- MySql
Connection Validation Error - MySql
SslMode - 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.
- Postgres
Connection Validation Error - SqlServer
Connection Validation Error - Tunnel
- Specifies how to tunnel a connection.
Constants§
- OAUT
H2_ 🔒PARAM_ SCOPE - The OAuth2 form field naming the scopes a token is requested for.
- REST_
CATALOG_ 🔒HEADER_ PROP_ PREFIX - The prefix marking a catalog property that
iceberg-rustturns into a header on every REST request, the same convention the Iceberg Java client uses. - REST_
CATALOG_ 🔒PROP_ ACCESS_ DELEGATION - Requests catalog-vended storage credentials, carried as a header by way of
REST_CATALOG_HEADER_PROP_PREFIX. - REST_
CATALOG_ 🔒PROP_ OAUT H2_ SERVER_ URI
Traits§
- Secrets
Reader 🔒Ext - An extension trait for
SecretsReader
Functions§
- aws_
expiry_ 🔒to_ timestamp - Converts an AWS SDK credential expiry into reqsign’s
Timestamp. - sigv4_
err 🔒