Struct TelemetryConsumer 

pub struct TelemetryConsumer { /* private fields */ }

Implementations

impl TelemetryConsumer

pub async fn new(redis_url: &str) -> Result<Self, Box<dyn Error + Send + Sync>>

pub fn with_stream_key(self, stream_key: &str) -> Self

pub fn with_consumer_group(self, group: &str) -> Self

pub async fn start_consuming<F, Fut>( &self, handler: F, cancellation_token: CancellationToken, ) -> Result<JoinHandle<()>, Box<dyn Error + Send + Sync>>

where F: Fn(UsageRecord) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send,

pub async fn read_single_batch( &self, ) -> Result<Vec<UsageRecord>, Box<dyn Error + Send + Sync>>

Read a single batch of messages from the stream.

Note: This method always reads from the beginning of the stream (ID “0”) and is intended for one-time reads or testing purposes only. For production use with repeated batch reads, use start_consuming which leverages consumer groups for proper message tracking and acknowledgment.