Struct RedisEventBus 

pub struct RedisEventBus { /* private fields */ }

Redis-backed transient event publisher and reconnecting subscriber.

Implementations

impl RedisEventBus

pub fn from_url( url: &str, topic: impl Into<String>, ) -> Result<Self, RedisEventBusError>

Creates a bus from a Redis URL and logical topic.

pub fn from_client(client: Client, topic: impl Into<String>) -> Self

Creates a bus from an existing Redis client.

pub fn with_reconnect_policy(self, policy: RedisEventReconnectPolicy) -> Self

Overrides the reconnect policy.

pub fn topic(&self) -> &str

Returns the configured logical topic.

pub async fn publish( &self, payload: impl Into<String>, ) -> Result<(), RedisEventBusError>

Publishes one opaque payload. Payload interpretation belongs to the product layer.

pub async fn subscribe( &self, ) -> Result<RedisEventSubscription, RedisEventBusError>

Opens one Redis subscription attempt.

pub async fn run_subscription<F, Fut>( &self, shutdown: CancellationToken, observer: Option<&dyn EventConnectionObserver>, on_payload: F, )

where F: FnMut(String) -> Fut, Fut: Future<Output = ()>,

Runs a reconnecting subscription until shutdown is cancelled.

Malformed Redis payloads are logged and skipped. The callback is responsible for decoding the product payload and deciding whether an event belongs to the current runtime.

Trait Implementations

impl Clone for RedisEventBus

fn clone(&self) -> RedisEventBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl EventSubscriptionSource for RedisEventBus

type Item = String

Item emitted by the transport.

type Subscription = RedisEventSubscription

One active transport subscription.

type Error = RedisEventBusError

Transport error returned by subscribe or receive.

fn subscribe<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Self::Subscription, Self::Error>> + Send + 'async_trait>>

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

Opens one subscription attempt.

fn receive<'life0, 'life1, 'async_trait>( &'life0 self, subscription: &'life1 mut Self::Subscription, ) -> Pin<Box<dyn Future<Output = Result<Self::Item, Self::Error>> + Send + 'async_trait>>

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

Receives one item from an active subscription.