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
- CdcBatch
- A batch of CDC entries with continuation info.
- 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 Batch - A batch of multi-version values with continuation info.
- Multi
Version Values - Query
- Single
Version Values - Statement
Column - Statement
Line - Table
RowInsertion - Tracks a table row insertion for post-commit event emission
- Transaction
Id - A unique identifier for a transaction using UUIDv7 for time-ordered uniqueness
- Transactional
DefChanges
Enums§
- CdcChange
- Fragment
- Fragment - owns all its data
- Identity
- Operation
- Log entry for operation ordering
- Operation
Type - Params
- RowChange
- Tracks row changes across different entity types for post-commit event emission
Traits§
- CdcQuery
Transaction - CdcTransaction
- Command
Transaction - Engine
- Async database engine trait.
- Execute
- Execute
Command - Execute
Query - Multi
Version Command Transaction - Multi
Version Query Transaction - Multi
Version Transaction - Query
Transaction - Single
Version Command Transaction - Single-version command transaction trait. Uses tokio::sync locks which are Send-safe with owned guards.
- Single
Version Query Transaction - Single-version query transaction trait. Uses tokio::sync locks which are Send-safe with owned guards.
- Single
Version Transaction - Transactional
Changes - Transactional
Dictionary Changes - Transactional
Flow 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