Struct RedisNotifier 

pub struct RedisNotifier { /* private fields */ }

Redis pub/sub backplane wrapping an InMemoryNotifier for local fan-out.

build fails fast if Redis is unreachable at startup. Once running, publish-to-Redis is fire-and-forget (local fan-out happens first). A background SUB task handles reconnects with exponential backoff and is supervised against panics.

Implementations

impl RedisNotifier

pub async fn build( url: &str, channel: Option<String>, capacity: usize, ) -> Result<Arc<Self>>

Open PUB and SUB connections to Redis, verify connectivity, spawn the background SUB loop, and return a reference-counted handle.

Fails immediately if the URL is invalid or either connection cannot be established (strict startup).

Trait Implementations

impl ActivityNotifier for RedisNotifier

fn publish<'life0, 'async_trait>( &'life0 self, event: NotifyEvent, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Fire-and-forget publish. Failures are logged but not propagated.

fn subscribe<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, tenant_id: &'life1 str, conversation_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<EventStream, NotifierError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Subscribe to events for a specific (tenant, conversation_id). Drop the returned stream to unsubscribe.