List of all items

Structs

• CdcVersion
• compact::actor::CompactActor
• compact::block::CompactBlockSummary
• compact::cache::BlockCache
• consume::actor::PollActor
• consume::actor::PollActorConfig
• consume::actor::PollState
• consume::checkpoint::CdcCheckpoint
• consume::poll::PollConsumer
• consume::poll::PollConsumerConfig
• produce::producer::CdcProducerActor
• produce::producer::CdcProducerEventListener
• produce::producer::CdcProducerState
• produce::watermark::CdcProducerWatermark
• storage::DropBeforeResult
• storage::DroppedCdcEntry
• storage::memory::MemoryCdcStorage
• storage::sqlite::storage::SqliteCdcStorage
• testing::TestCdcHost

Enums

• compact::actor::CompactMessage
• consume::actor::Phase
• error::CdcError
• storage::CdcStore

Traits

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

Functions

• compact::block::decode
• compact::block::encode
• consume::watermark::compute_watermark
• error::diagnostic::codec_error
• error::diagnostic::not_found
• error::diagnostic::storage_error
• produce::producer::spawn_cdc_producer
• testing::make_key
• testing::make_row

Type Aliases

• error::CdcResult
• storage::CdcStorageResult