List of all items

Structs

• CdcVersion
• consume::actor::PollActor
• consume::actor::PollActorConfig
• consume::checkpoint::CdcCheckpoint
• consume::poll::PollConsumer
• consume::poll::PollConsumerConfig
• produce::producer::CdcProducerActor
• produce::producer::CdcProducerEventListener
• produce::producer::CdcProducerState
• storage::DropBeforeResult
• storage::DroppedCdcEntry
• storage::memory::MemoryCdcStorage

Enums

• consume::actor::PollState
• error::CdcError
• storage::CdcStore

Traits

• consume::consumer::CdcConsume
• consume::consumer::CdcConsumer
• consume::host::CdcHost
• storage::CdcStorage

Functions

• consume::watermark::compute_watermark
• error::diagnostic::codec_error
• error::diagnostic::not_found
• error::diagnostic::storage_error
• produce::producer::spawn_cdc_producer

Type Aliases

• error::CdcResult
• storage::CdcStorageResult