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.

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

Create a broker with an explicit governed-event enforcement policy.

Migration mode records violations without interrupting existing traffic; enforcement mode rejects invalid envelopes.

Errors

Returns EventError::InvalidRetentionWindow when the configuration cannot maintain replay and queue guarantees.

pub fn validation_evidence(&self) -> Vec<EventValidationEvidence>

Returns sanitized validation and quarantine evidence. Payload data is never retained through this interface.

pub fn quarantine_records(&self) -> Vec<EventQuarantineRecord>

Returns sanitized enforcement rejections prepared for governed quarantine.

pub fn observed_lineage(&self) -> Vec<EventLineageRecord>

Returns sanitized runtime delivery observations for catalog reconciliation.

pub fn telemetry(&self) -> Vec<EventTelemetryRecord>

Returns deterministic, sanitized boundary telemetry for host export.

pub fn metrics(&self) -> EventRuntimeMetrics

Returns a deterministic counter snapshot for event runtime evidence.

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

Subscribe with the consuming capability identity needed for observed lineage.

The identity is runtime evidence only; it does not declare a catalog relationship.

Errors

Returns EventError::LifecycleViolation when consumer_id is empty, plus the same errors as EventBroker::subscribe_for_subject.

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.