Module sink

Re-exports

• pub use tracing;

Modules

• big_query
• boxed
• catalog
• clickhouse
• coordinate
• decouple_checkpoint_log_sink
• deltalake
• doris
• doris_starrocks_connector
• dynamodb
• elasticsearch_opensearch
• encoder
• file_sink
• formatter
• google_pubsub
• iceberg
• kafka
• kinesis
• log_store
• mock_coordination_client
• mongodb
• mqtt
• nats
• pulsar
• redis
• remote
• sqlserver
• starrocks
• test_sink
• trivial
• utils
• writer

Macros

• def_sink_impl 🔒

Structs

• DummySinkCommitCoordinator
• SinkMetrics
• SinkParam
• SinkWriterMetrics
• SinkWriterParam

Enums

• SinkError
• SinkImpl
• SinkMetaClient

Constants

• BOUNDED_CHANNEL_SIZE 🔒
• CONNECTOR_TYPE_KEY
• SINK_TYPE_APPEND_ONLY
• SINK_TYPE_DEBEZIUM
• SINK_TYPE_OPTION
• SINK_TYPE_UPSERT
• SINK_USER_FORCE_APPEND_ONLY_OPTION
• SINK_WITHOUT_BACKFILL

Statics

• GLOBAL_SINK_METRICS

Traits

• LogSinker
• Sink
• SinkCommitCoordinator
• SinkLogReader

Functions

• build_sink
• is_sink_support_commit_checkpoint_interval 🔒

Type Aliases

• Result