Struct InProcessBroker 

pub struct InProcessBroker { /* private fields */ }

Synchronous, in-memory implementation of EventBroker.

The broker stores a bounded retention buffer per event type and maintains a bounded delivery queue per subscription. Subscribers poll for events using a broker-issued subscription id and a cursor.

Implementations

impl InProcessBroker

pub fn new(catalog: Arc<EventCatalog>) -> Result<Self, EventError>

Create a new broker backed by the given catalog.

Errors

Returns EventError::InvalidRetentionWindow when the provided configuration is invalid.

pub fn with_clock( catalog: Arc<EventCatalog>, config: BrokerConfig, clock: Arc<dyn BrokerClock>, ) -> Result<Self, EventError>

Create a broker with explicit configuration and clock.

Errors

Returns EventError::InvalidRetentionWindow when the provided configuration is invalid.

Trait Implementations

impl Debug for InProcessBroker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EventBroker for InProcessBroker

fn publish(&self, event: TraverseEvent) -> Result<(), EventError>

Publish event to all registered subscribers.

Errors

• EventError::UnregisteredEventType if the event type is not in the catalog.
• EventError::LifecycleViolation if the catalog entry is Draft or Deprecated.

fn publish_with_cursor( &self, event: TraverseEvent, cursor: &str, ) -> Result<(), EventError>

Publish event, adopting cursor as this broker’s own cursor for it instead of self-assigning the next per-type sequence value. Used by DurableBroker so live-delivery cursors stay numerically consistent with the durable journal’s cursor space (spec 066 FR-007): a cursor obtained during live polling remains valid when a later poll falls back to durable replay.

Errors

Returns EventError::InvalidCursor when cursor is not a base-10 unsigned integer, plus the same errors as Self::publish.

fn subscribe( &self, event_type: &str, from_cursor: &str, ) -> Result<Subscription, EventError>

Create a subscription for event_type starting from from_cursor.

The event type must already be registered in the catalog.

Errors

Returns EventError::UnregisteredEventType if the event type is not catalogued.

fn poll( &self, subscription_id: &str, max_events: usize, ) -> Result<SubscriptionPoll, EventError>

Poll a subscription for up to max_events.

Errors

fn cancel(&self, subscription_id: &str) -> Result<(), EventError>

Cancel a subscription.

Errors

Returns EventError::SubscriptionNotFound if the subscription id is unknown.

fn subscribe_for_subject( &self, event_type: &str, from_cursor: &str, subject_id: Option<&str>, ) -> Result<Subscription, EventError>

Create a subscription optionally limited to one event subject.

fn seed_restart_floor(&self, floor: u64)

Establishes a floor below which any cursor, for any event type this broker has not itself observed, is treated as potentially predating this broker instance’s own history (spec 066 FR-007: restart cursor continuity). DurableBroker::open calls this once at construction, seeded from the durable journal’s latest cursor, so a freshly constructed in-memory broker correctly defers stale-looking cursors to durable replay after a restart instead of accepting them outright. The default implementation is a no-op.