Module stream 

Change data capture and streaming for replication

Provides mechanisms for streaming changes from the replication log with support for checkpointing, resumption, and backpressure handling.

Structs

ChangeEvent

A change event in the replication stream

Checkpoint

Checkpoint for resuming a replication stream

ReplicationStream

Manages a replication stream

StreamConfig

Configuration for a replication stream

StreamManager

Manager for multiple replication streams (consumer groups)

Enums

ChangeOperation

Type of change operation