Module connector_common

Source
Expand description

Common parameters and utilities for both source and sink.

Re-exportsΒ§

pub use postgres::PostgresExternalTable;
pub use postgres::SslMode;
pub use postgres::create_pg_client;

ModulesΒ§

common πŸ”’
connection πŸ”’
iceberg πŸ”’
maybe_tls_connector πŸ”’
mqtt_common πŸ”’
postgres

StructsΒ§

AwsAuthProps
A flatten config map for aws auth.
AwsPrivateLinkItem
ConfluentSchemaRegistryConnection
ElasticsearchConnection
IcebergCommon
IcebergConnection
IcebergSinkCompactionUpdate
KafkaCommon
KafkaConnection
KafkaConnectionProps
KafkaPrivateLinkCommon
KinesisCommon
MongodbCommon
MqttCommon
NatsCommon
PulsarCommon
PulsarOauthCommon
RdKafkaPropertiesCommon

EnumsΒ§

MqttQualityOfService

ConstantsΒ§

DISABLE_DEFAULT_CREDENTIAL
The environment variable to disable using default credential from environment. It’s recommended to set this variable to true in cloud hosting environment.
PRIVATE_LINK_BROKER_REWRITE_MAP_KEY
PRIVATE_LINK_TARGETS_KEY
SCHEMA_REGISTRY_CONNECTION_TYPE

TraitsΒ§

Connection

FunctionsΒ§

read_kafka_log_level
validate_connection