Struct StreamManager 

pub struct StreamManager { /* private fields */ }

Manager for multiple replication streams (consumer groups)

Implementations

impl StreamManager

pub fn new(log: Arc<ReplicationLog>) -> Self

Create a new stream manager

pub fn create_stream( &self, consumer_id: impl Into<String>, ) -> Arc<ReplicationStream>

Create a new stream for a consumer

pub fn create_stream_with_config( &self, consumer_id: impl Into<String>, config: StreamConfig, ) -> Arc<ReplicationStream>

Create a stream with custom configuration

pub fn active_streams(&self) -> Vec<Arc<ReplicationStream>>

Get all active streams

pub fn stream_count(&self) -> usize

Get the number of active streams