Struct StreamConsumer 

pub struct StreamConsumer { /* private fields */ }

Enhanced stream consumer for receiving RDF changes with backend support

Implementations

impl StreamConsumer

pub async fn new(config: StreamConfig) -> Result<Self>

Create a new enhanced stream consumer with backend support

pub async fn new_with_group( config: StreamConfig, consumer_group: Option<String>, ) -> Result<Self>

Create a new stream consumer with a specific consumer group

pub async fn consume(&mut self) -> Result<Option<StreamEvent>>

Consume stream events with circuit breaker protection

pub async fn consume_batch( &mut self, max_events: usize, timeout: Duration, ) -> Result<Vec<StreamEvent>>

Consume multiple events as a batch

pub async fn start_consuming<F>(&mut self, callback: F) -> Result<()>

where F: FnMut(StreamEvent) -> Result<()> + Send,

Start consuming events with a callback function

pub async fn start_consuming_async<F, Fut>(&mut self, callback: F) -> Result<()>

where F: FnMut(StreamEvent) -> Fut + Send, Fut: Future<Output = Result<()>> + Send,

Start consuming events with an async callback function

pub async fn get_stats(&self) -> ConsumerStats

Get consumer statistics

pub async fn health_check(&self) -> bool

Get consumer health status

pub fn consumer_group(&self) -> Option<&String>

Get the consumer group name if any

pub async fn reset_position(&mut self) -> Result<()>

Reset consumer position (for testing with memory backend)

pub async fn set_test_events(&mut self, _events: Vec<StreamEvent>) -> Result<()>

Set test events for memory backend (for testing) - deprecated with backend implementation