Struct InMemoryEventSubscriptionService 

pub struct InMemoryEventSubscriptionService { /* private fields */ }

In-memory event subscription service backed by DashMap.

Webhook delivery is logged but not actually performed (no HTTP client). Enable the webhook-delivery feature for real HTTP delivery.

Implementations

impl InMemoryEventSubscriptionService

pub fn new() -> Self

Create a new empty event subscription service.

Trait Implementations

impl Default for InMemoryEventSubscriptionService

fn default() -> Self

Returns the “default value” for a type.

impl EventSubscriptionService for InMemoryEventSubscriptionService

fn create<'life0, 'async_trait>( &'life0 self, subscription: EventSubscription, ) -> Pin<Box<dyn Future<Output = Result<Uuid, AwpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a new subscription, returning its ID.

fn get<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<EventSubscription>, AwpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a subscription by ID.

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventSubscription>, AwpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all subscriptions.

fn delete<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), AwpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a subscription by ID.

fn deliver<'life0, 'async_trait>( &'life0 self, event: AwpEvent, ) -> Pin<Box<dyn Future<Output = Result<(), AwpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Deliver an event to all matching subscribers.