List of all items

Structs

• CdcVersion
• 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
• rebuild::RowTarget
• testing::TestCdcHost

Enums

• consume::actor::Phase
• consume::backlog::BacklogPull

Traits

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

Functions

• consume::backlog::cdc_bytes
• consume::is_relevant_cdc
• consume::watermark::compute_pinning_watermark
• produce::producer::spawn_cdc_producer
• rebuild::changed_objects
• rebuild::rebuild_changes
• rebuild::rebuild_selected_changes
• rebuild::row_target
• testing::make_bytes
• testing::make_key