Struct RustRabbitMetrics 

pub struct RustRabbitMetrics { /* private fields */ }

Metrics collector for RustRabbit operations

Implementations

impl RustRabbitMetrics

pub fn new() -> Result<Self, Error>

Create a new metrics instance with default registry

pub fn with_registry(registry: Arc<Registry>) -> Result<Self, Error>

Create a new metrics instance with custom registry

pub fn registry(&self) -> Arc<Registry>

Get the Prometheus registry for exposing metrics

pub fn record_message_published( &self, queue: &str, exchange: &str, routing_key: &str, )

Record a published message

pub fn record_message_consumed( &self, queue: &str, consumer_tag: &str, success: bool, )

Record a consumed message

pub fn record_message_failed( &self, queue: &str, error_type: &str, retry_attempt: u32, )

Record a failed message processing

pub fn record_message_retry(&self, queue: &str, retry_reason: &str)

Record a message retry

pub fn record_processing_duration( &self, queue: &str, consumer_tag: &str, duration: Duration, )

Record message processing duration

pub fn record_publish_duration( &self, queue: &str, exchange: &str, duration: Duration, )

Record message publish duration

pub fn update_connection_pool(&self, total: i64, healthy: i64, unhealthy: i64)

Update connection pool metrics

pub fn record_connection_attempt(&self)

Record a connection attempt

pub fn record_connection_failure(&self)

Record a connection failure

pub fn update_queue_depth(&self, queue: &str, depth: i64)

Update queue depth

pub fn update_consumer_count(&self, queue: &str, count: i64)

Update consumer count

pub fn record_health_check_duration(&self, duration: Duration)

Record health check duration

Trait Implementations

impl Clone for RustRabbitMetrics

fn clone(&self) -> RustRabbitMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RustRabbitMetrics

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

Formats the value using the given formatter.

impl Default for RustRabbitMetrics

fn default() -> Self

Returns the “default value” for a type.