Module connector_common

Common parameters and utilities for both source and sink.

Re-exports

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

Modules

• common 🔒
• connection 🔒
• iceberg 🔒
• maybe_tls_connector 🔒
• mqtt_common 🔒
• postgres

Structs

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

Enums

• MqttQualityOfService

Constants

• PRIVATE_LINK_BROKER_REWRITE_MAP_KEY
• PRIVATE_LINK_TARGETS_KEY
• SCHEMA_REGISTRY_CONNECTION_TYPE

Traits

• Connection

Functions

• validate_connection