Struct TransactionTopicEmitter 

pub struct TransactionTopicEmitter { /* private fields */ }

Emitter for transaction boundary events.

Tracks in-flight transactions and emits BEGIN/END events to dedicated topic.

Implementations

impl TransactionTopicEmitter

pub fn new(config: TransactionTopicConfig) -> Self

Create a new transaction topic emitter.

pub fn topic_name(&self) -> String

Get the transaction topic name.

pub fn stats(&self) -> TransactionTopicStatsSnapshot

Get current statistics.

pub async fn begin_transaction( &self, txn_id: &str, lsn: &str, ts_ms: i64, ) -> Option<TransactionEvent>

Register transaction begin.

Returns BEGIN event if emission is enabled.

pub async fn track_event( &self, txn_id: &str, data_collection: &str, ts_ms: i64, ) -> Option<TransactionContext>

Track an event within a transaction.

Returns (total_order, data_collection_order) for event enrichment. Returns None if transaction not found.

pub async fn end_transaction( &self, txn_id: &str, ts_ms: i64, ) -> Option<TransactionEvent>

End a transaction and emit END event.

Returns END event if emission is enabled.

pub async fn in_flight_count(&self) -> usize

Get number of in-flight transactions.

pub async fn clear_in_flight(&self)

Clear all in-flight transactions (e.g., on reconnect).

pub async fn enrich_event(&self, event: &mut CdcEvent) -> bool

Enrich a CDC event with transaction context.

Modifies the event’s transaction metadata in place.

Trait Implementations

impl Clone for TransactionTopicEmitter

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TransactionTopicEmitter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.