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§
Structs§
- AwsAuth
Props - A flatten config map for aws auth.
- AwsPrivate
Link Item - Confluent
Schema Registry Connection - Elasticsearch
Connection - Iceberg
Common - Iceberg
Connection - Iceberg
Sink Compaction Update - Iceberg
Table Identifier - Kafka
Common - Kafka
Connection - Kafka
Connection Props - Kafka
Private Link Common - Kinesis
Common - Mongodb
Common - Mqtt
Common - Nats
Common - Nats
Connection Props - Connection properties for NATS, used as a cache key for shared clients. This includes all properties that affect the connection itself (not stream/subject specific).
- Pulsar
Common - Pulsar
Oauth Common - RdKafka
Properties Common
Enums§
Constants§
- DISABLE_
DEFAULT_ CREDENTIAL - The environment variable to disable using default credential from environment.
It’s recommended to set this variable to
truein cloud hosting environment. - PRIVATE_
LINK_ BROKER_ REWRITE_ MAP_ KEY - PRIVATE_
LINK_ TARGETS_ KEY - SCHEMA_
REGISTRY_ CONNECTION_ TYPE
Statics§
- SHARED_
NATS_ CLIENT - Shared NATS client cache.
Client connections are cached as
Weakpointers in the cache. NATS Connector can access this cache to reuse existing client connections, and avoid exhausting host machine ports. When reading from the cache, the connector shouldupgradethe weak pointer to anArcreference. After all strong (Arc) references are dropped, the client connection will be cleaned up. Cache eviction naturally takes care of the dangling weak pointers.