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.

Errors

Returns an error when the topic is blank or the Redis client rejects url.

pub fn from_credentials( base_url: &str, username: Option<&str>, password: Option<&str>, topic: impl Into<String>, ) -> Result<Self, RedisEventBusError>

Creates a bus from a base Redis URL and raw credentials.

The base URL must not contain userinfo. username = None with a password creates the password-only URL form used by Redis deployments without ACL usernames.

Errors

Returns an error when the topic is blank, the base URL or credential combination is invalid, or the Redis client rejects the resulting URL.

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.

Errors

Returns an error when a Redis connection cannot be opened or the publish command fails.

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

Opens one Redis subscription attempt.

Errors

Returns an error when the Pub/Sub connection cannot be opened or the topic subscription command fails.

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.