Struct EventSystem 

pub struct EventSystem { /* private fields */ }

Available on crate feature events only.

Central event system that coordinates all event delivery mechanisms

Implementations

impl EventSystem

pub fn new() -> Self

Create a new event system with default configuration

pub fn with_config(config: EventConfig) -> Self

Create a new event system with custom configuration

impl EventSystem

pub const fn emitter(&self) -> &EventEmitter

Get the event emitter for publishing events

pub fn subscribe(&self) -> EventSubscription

Subscribe to all events

pub fn subscribe_filtered<F>(&self, filter: F) -> FilteredSubscription<F>

where F: Fn(&CommerceEvent) -> bool + Send + 'static,

Subscribe to events matching a filter

pub fn register_webhook(&self, webhook: Webhook) -> Uuid

Register a webhook endpoint.

This is a legacy API that preserves the previous Uuid-returning contract. Prefer register_webhook_strict or try_register_webhook when you need explicit failure handling.

pub fn register_webhook_strict( &self, webhook: Webhook, ) -> Result<Uuid, WebhookRegistrationError>

Register a webhook endpoint with explicit failure semantics.

pub fn try_register_webhook(&self, webhook: Webhook) -> Option<Uuid>

Register a webhook endpoint. Returns None when registration is rejected (e.g. unsafe URL), or when webhooks are disabled.

pub fn unregister_webhook(&self, id: Uuid) -> bool

Unregister a webhook

pub fn list_webhooks(&self) -> Vec<Webhook>

List all registered webhooks

pub fn webhook_deliveries(&self, webhook_id: Uuid) -> Vec<WebhookDelivery>

Get delivery history for a webhook (newest-first).

pub const fn bus(&self) -> &Arc<EventBus>

Get the event bus for advanced usage

pub const fn config(&self) -> &EventConfig

Get configuration

pub fn event_store(&self) -> Option<&(dyn EventStore + Send + Sync)>

Access the configured event store, if enabled.

pub fn emit(&self, event: CommerceEvent)

Emit an event.

Broadcast delivery is non-blocking. Webhook delivery is dispatched to a background task. Event persistence (if enabled) is best-effort and may block depending on the configured store.

pub fn subscriber_count(&self) -> usize

Get the number of active subscribers

pub fn bus_publish_failures(&self) -> u64

Get total publish failures on the event bus

Trait Implementations

impl Debug for EventSystem

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

Formats the value using the given formatter.

impl Default for EventSystem

fn default() -> Self

Returns the “default value” for a type.