Struct ChangeStream 

pub struct ChangeStream { /* private fields */ }

Change stream

Implementations

impl ChangeStream

pub fn new(name: String, config: ChangeStreamConfig) -> Self

Create a new change stream

pub fn name(&self) -> &str

Get stream name

pub fn add_event( &self, collection: String, change_type: ChangeType, document_id: String, data: Option<Value>, ) -> Result<u64>

Add a change event

pub fn subscribe(&self) -> Receiver<ChangeEvent>

Subscribe to change events

pub fn get_events(&self, since_change_id: Option<u64>) -> Vec<ChangeEvent>

Get buffered events

pub fn buffer_size(&self) -> usize

Get buffer size

pub fn clear(&self)

Clear buffer

pub fn stats(&self) -> ChangeStreamStatsSnapshot

Get statistics