Struct EventEmitter 

pub struct EventEmitter { /* private fields */ }

Non-blocking event emitter that dispatches events via the job queue.

Events never block the HTTP response — they are always enqueued as jobs.

Implementations

impl EventEmitter

pub fn new(job_queue: JobQueue, config: Option<&EventsConfig>) -> Self

Creates a new event emitter.

pub async fn emit( &self, event_name: &str, resource: &str, action: &str, data: Value, ) -> Result<String, ShaperailError>

Emits an event non-blockingly via the job queue.

This enqueues processing jobs for:

1. The event log (always)
2. Each matching subscriber target

Trait Implementations

impl Clone for EventEmitter

fn clone(&self) -> EventEmitter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.