Struct CompositeEmitter 

pub struct CompositeEmitter { /* private fields */ }

Fans out events to multiple sinks, each with an associated EventLevel filter. A sink only receives events at or below its configured level.

Implementations

impl CompositeEmitter

pub fn new() -> Self

Create a new composite emitter with no sinks.

pub fn add_sink(&mut self, level: EventLevel, sink: impl EventEmitter + 'static)

Add a sink that receives events up to (and including) the given level.

Trait Implementations

impl Default for CompositeEmitter

fn default() -> Self

Returns the “default value” for a type.

impl EventEmitter for CompositeEmitter

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).