Module common 

Structs

AwsAuthProps

A flatten config map for aws auth.

AwsPrivateLinkItem

KafkaCommon

KafkaConnectionProps

KafkaPrivateLinkCommon

KinesisAsyncSleepImpl

KinesisCommon

MongodbCommon

NatsCommon

NatsConnectionProps

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).

PulsarCommon

PulsarOauthCommon

RdKafkaPropertiesCommon

Constants

AWS_MSK_IAM_AUTH 🔒

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

Statics

SHARED_NATS_CLIENT

Shared NATS client cache. Client connections are cached as Weak pointers 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 should upgrade the weak pointer to an Arc reference. After all strong (Arc) references are dropped, the client connection will be cleaned up. Cache eviction naturally takes care of the dangling weak pointers.

Functions

create_credential_temp_file 🔒

default_kafka_sync_call_timeout 🔒

default_socket_keepalive_enable 🔒

kinesis_default_connect_timeout_ms 🔒

kinesis_default_init_backoff_ms 🔒

kinesis_default_max_backoff_ms 🔒

kinesis_default_max_retry_limit 🔒

kinesis_default_operation_attempt_timeout_ms 🔒

kinesis_default_operation_timeout_ms 🔒

kinesis_default_read_timeout_ms 🔒

load_certs 🔒

load_private_key 🔒