Struct EventReactor

pub struct EventReactor<'a, T, E, G>
where
    T: StreamConsumer<E, G>,
    E: StreamEntry,
    G: ConsumerGroup,
{ /* private fields */ }

Redis event stream reactor

Implementations

impl<'a, T, E, G> EventReactor<'a, T, E, G>

where T: StreamConsumer<E, G>, E: StreamEntry, G: ConsumerGroup,

pub fn new(data: T::Data, stream_key: Cow<'a, str>) -> Self

pub async fn initialize_consumer_group( &mut self, ) -> Result<ConsumerGroupState, RedisError>

Manually initialize Redis consumer group; this will otherwise initialize automatically as needed and is useful for knowing if a consumer group was previously created

pub async fn clear_idle_backlog( &mut self, min_idle: &Duration, max_idle: &Option<Duration>, ) -> Result<(), RedisError>

Process idle-pending backlog without claiming new entries until none remain and max_idle has elapsed (relative to start_time)

pub async fn start_reactor( &mut self, claim_mode: ClaimMode, ) -> Result<(), RedisError>

Process redis stream entries until shutdown signal received

pub fn shutdown_token(&self) -> Arc<CancellationToken>