Struct NoopEmitter 

pub struct NoopEmitter;

A no-op event emitter that discards all events.

Used as the default when no monitoring feature is enabled.

Trait Implementations

impl EventEmitter for NoopEmitter

fn on_worker_started(&self, _runner_id: &RunnerId)

A runner process has started.

fn on_worker_shutdown(&self, _runner_id: &RunnerId)

A runner process is shutting down.

fn on_task_submitted(&self, _task_id: &TaskId, _inv_id: &InvocationId)

A task invocation was submitted to the system.

fn on_task_started(&self, _task_id: &TaskId, _inv_id: &InvocationId)

A runner began executing a task invocation.

fn on_task_succeeded( &self, _task_id: &TaskId, _inv_id: &InvocationId, _duration: Duration, )

A task invocation completed successfully.

fn on_task_failed( &self, _task_id: &TaskId, _inv_id: &InvocationId, _error: &str, _duration: Duration, )

A task invocation failed (final failure, retries exhausted).

fn on_task_retried( &self, _task_id: &TaskId, _inv_id: &InvocationId, _attempt: u32, )

A task invocation is being retried.

fn on_queue_depth(&self, _queue: &str, _depth: usize)

Current queue depth snapshot.

fn on_cc_rejected(&self, _task_id: &TaskId)

Concurrency control rejected an invocation registration.

fn on_cc_slot_acquired(&self, _task_id: &TaskId)

A concurrency slot was successfully acquired.

fn on_cc_slot_released(&self, _task_id: &TaskId)

A concurrency slot was released (invocation reached terminal state).