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::backlog::FlowBacklog
- consume::checkpoint::CdcCheckpoint
- consume::checkpoint::CheckpointRow
- consume::poll::PollConsumer
- consume::poll::PollConsumerConfig
- consume::wake::CdcWakeRegistry
- consume::watermark::CdcConsumerWatermark
- consume::watermark::FlowCaughtUpWatermark
- produce::producer::CdcProducerActor
- produce::producer::CdcProducerEventListener
- produce::producer::CdcProducerState
- produce::watermark::CdcProducerWatermark
- storage::CdcHotReader
- storage::DropBeforeResult
- storage::memory::MemoryCdcStorage
- storage::sqlite::storage::SqliteCdcStorage
- testing::TestCdcHost
Enums
- compact::actor::CompactMessage
- consume::actor::Phase
- consume::backlog::BacklogPull
- error::CdcError
- storage::CdcStore
- storage::sqlite::storage::ReadClass
Traits
- consume::consumer::CdcConsume
- consume::consumer::CdcConsumer
- consume::host::CdcHost
- storage::CdcStorage
Functions
- compact::block::decode
- compact::block::encode
- consume::backlog::cdc_bytes
- consume::is_relevant_cdc
- consume::watermark::compute_pinning_watermark
- error::diagnostic::codec_error
- error::diagnostic::consumer_overtaken
- error::diagnostic::not_found
- error::diagnostic::storage_error
- produce::producer::spawn_cdc_producer
- testing::make_bytes
- testing::make_key