Struct ReplicationStream 

pub struct ReplicationStream { /* private fields */ }

Manages a replication stream

Implementations

impl ReplicationStream

pub fn new(log: Arc<ReplicationLog>, consumer_id: impl Into<String>) -> Self

Create a new replication stream

pub fn with_config( log: Arc<ReplicationLog>, consumer_id: impl Into<String>, config: StreamConfig, ) -> Self

Create with custom configuration

pub async fn stream_from( &self, start_sequence: u64, ) -> Result<Receiver<Vec<ChangeEvent>>>

Start streaming from a given position

pub async fn resume(&self) -> Result<Receiver<Vec<ChangeEvent>>>

Resume streaming from the last checkpoint

pub fn get_checkpoint(&self) -> Option<Checkpoint>

Get the current checkpoint

pub fn set_checkpoint(&self, checkpoint: Checkpoint)

Set a checkpoint manually

pub fn clear_checkpoint(&self)

Clear the checkpoint