Struct CoalescingEmitter 

pub struct CoalescingEmitter { /* private fields */ }

A throttled event emitter that coalesces rapid-fire events.

Wraps any QueueEventEmitter and suppresses duplicate events for the same job that arrive within the configured coalesce interval.

Implementations

impl CoalescingEmitter

pub fn new(inner: Arc<dyn QueueEventEmitter>, config: EmitterConfig) -> Self

pub fn arc( inner: Arc<dyn QueueEventEmitter>, config: EmitterConfig, ) -> Arc<dyn QueueEventEmitter>

Trait Implementations

impl QueueEventEmitter for CoalescingEmitter

fn emit_job_started(&self, event: JobStartedEvent)

Called when a job starts executing.

fn emit_job_completed(&self, event: JobCompletedEvent)

Called when a job completes successfully.

fn emit_job_failed(&self, event: JobFailedEvent)

Called when a job fails.

fn emit_job_progress(&self, event: JobProgressEvent)

Called when a job reports progress.

fn emit_job_cancelled(&self, event: JobCancelledEvent)

Called when a job is cancelled.