Crate aster_forge_events 

Product-neutral transient event transport primitives.

This crate owns broker connection lifecycle, reconnect backoff, shutdown cancellation, and raw payload delivery. Products own payload schemas, authorization, origin filtering, and the local event semantics built on top of the transport.

Structs

EventConnectionObservation

Connection lifecycle observation emitted by a subscription supervisor.

EventReconnectPolicy

Reconnect policy for a transient event subscription.

RedisEventBus

Redis-backed transient event publisher and reconnecting subscriber.

RedisEventSubscription

One active Redis Pub/Sub subscription.

TransientEventBus

Process-local event broadcast paired with an optional shared transport.

Enums

EventConnectionState

Connection lifecycle state emitted by a reconnecting event subscriber.

EventSubscriptionUpdate

One update emitted by a reconnecting subscription supervisor.

RedisEventBusError

Redis event transport errors returned while creating a publisher.

Traits

EventConnectionObserver

Receives subscriber lifecycle observations.

EventSubscriptionSource

A transport-specific source that can open and receive from one subscription.

Functions

supervise_event_subscription

Supervises one transient subscription until shutdown or receiver closure.

Type Aliases

RedisEventReconnectPolicy

Backwards-compatible name for the shared event reconnect policy.