Re-exports§
pub use catalog::*;pub use identifier::*;pub use resolved::*;pub use crate::key::*;
Modules§
Structs§
- Cdc
- Structure for storing CDC data with shared metadata
- CdcConsumer
Id - CdcSequenced
Change - Structure for individual changes within a transaction
- Change
- Represents a single change
- Command
- Consumer
State - Represents the state of a CDC consumer
- Multi
Version Values - Query
- Single
Version Values - Statement
Column - Statement
Line - Transaction
Id - A unique identifier for a transaction using UUIDv7 for time-ordered uniqueness
- Transactional
DefChanges
Enums§
- Borrowed
Fragment - Borrowed fragment - zero-copy for parsing
- CdcChange
- Fragment
- Core enum for fragment types
- Identity
- Operation
- Log entry for operation ordering
- Operation
Type - Owned
Fragment - Owned fragment - owns all its data
- Params
Traits§
- CdcQuery
Transaction - CdcTransaction
- Command
Transaction - Engine
- Execute
- Execute
Command - Execute
Query - Into
Fragment - Trait for types that can be converted into a Fragment
- Lazy
Fragment - Trait for lazy fragment generation that returns Fragment instead of OwnedFragment
- Multi
Version Command Transaction - Multi
Version Query Transaction - Multi
Version Transaction - Query
Transaction - Single
Version Command Transaction - Single
Version Query Transaction - Single
Version Transaction - Transactional
Changes - Transactional
Namespace Changes - Transactional
Ring Buffer Changes - Transactional
Table Changes - Transactional
View Changes - With
Event Bus
Functions§
- get_
all_ consumer_ states - Retrieves the state of all CDC consumers