Struct MetricsMiddleware 

pub struct MetricsMiddleware { /* private fields */ }

Simple metrics middleware that tracks task counts.

Implementations

impl MetricsMiddleware

pub fn new() -> Self

pub fn tasks_started(&self) -> u64

pub fn tasks_succeeded(&self) -> u64

pub fn tasks_failed(&self) -> u64

Trait Implementations

impl Clone for MetricsMiddleware

fn clone(&self) -> MetricsMiddleware

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MetricsMiddleware

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MetricsMiddleware

fn default() -> Self

Returns the “default value” for a type.

impl Middleware for MetricsMiddleware

fn before<'life0, 'life1, 'async_trait>( &'life0 self, _message: &'life1 TaskMessage, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

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

Called before task execution. Return Err to abort.

fn after<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _message: &'life1 TaskMessage, _result: &'life2 Value, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called after successful task execution.

fn on_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _message: &'life1 TaskMessage, _error: &'life2 KojinError, ) -> Pin<Box<dyn Future<Output = Result<(), KojinError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when task execution fails.