Module transactional_processing 

Transactional Processing with Exactly-Once Semantics

This module provides enterprise-grade transactional processing capabilities with exactly-once delivery guarantees for stream processing.

Features

• Exactly-once semantics: Guaranteed event delivery without duplicates
• Two-phase commit: Distributed transaction coordination
• Multiple isolation levels: Read uncommitted, read committed, repeatable read, serializable
• Idempotency: Automatic deduplication of events
• Transaction log: Persistent transaction state
• Recovery: Automatic recovery from failures
• Checkpoint management: Periodic state snapshots

Architecture

The transactional processing system uses a combination of:

• Write-ahead logging (WAL) for durability
• Two-phase commit for atomicity
• Bloom filters for deduplication
• State checkpointing for recovery

Structs

TransactionCheckpoint

Checkpoint for recovery

TransactionLogEntry

Transaction log entry for write-ahead logging

TransactionMetadata

Transaction metadata

TransactionalConfig

Configuration for transactional processing

TransactionalProcessor

Transactional processing manager

TransactionalStats

Statistics for transactional processing

Enums

IsolationLevel

Transaction isolation levels

LogEntryType

Type of transaction log entry

TransactionState

Transaction state in the two-phase commit protocol