Line data    Source code

       1              : //! Broker metrics.
       2              : 
       3              : use metrics::{register_int_counter, register_int_gauge, IntCounter, IntGauge};
       4              : use once_cell::sync::Lazy;
       5              : 
       6            4 : pub static NUM_PUBS: Lazy<IntGauge> = Lazy::new(|| {
       7            4 :     register_int_gauge!("storage_broker_active_publishers", "Number of publications")
       8            4 :         .expect("Failed to register metric")
       9            4 : });
      10              : 
      11            4 : pub static NUM_SUBS_TIMELINE: Lazy<IntGauge> = Lazy::new(|| {
      12            4 :     register_int_gauge!(
      13            4 :         "storage_broker_per_timeline_active_subscribers",
      14            4 :         "Number of subsciptions to particular tenant timeline id"
      15            4 :     )
      16            4 :     .expect("Failed to register metric")
      17            4 : });
      18              : 
      19            4 : pub static NUM_SUBS_ALL: Lazy<IntGauge> = Lazy::new(|| {
      20            4 :     register_int_gauge!(
      21            4 :         "storage_broker_all_keys_active_subscribers",
      22            4 :         "Number of subsciptions to all keys"
      23            4 :     )
      24            4 :     .expect("Failed to register metric")
      25            4 : });
      26              : 
      27            4 : pub static PROCESSED_MESSAGES_TOTAL: Lazy<IntCounter> = Lazy::new(|| {
      28            4 :     register_int_counter!(
      29            4 :         "storage_broker_processed_messages_total",
      30            4 :         "Number of messages received by storage broker, before routing and broadcasting"
      31            4 :     )
      32            4 :     .expect("Failed to register metric")
      33            4 : });
      34              : 
      35            2 : pub static BROADCASTED_MESSAGES_TOTAL: Lazy<IntCounter> = Lazy::new(|| {
      36            2 :     register_int_counter!(
      37            2 :         "storage_broker_broadcasted_messages_total",
      38            2 :         "Number of messages broadcasted (sent over network) to subscribers"
      39            2 :     )
      40            2 :     .expect("Failed to register metric")
      41            2 : });
      42              : 
      43            0 : pub static BROADCAST_DROPPED_MESSAGES_TOTAL: Lazy<IntCounter> = Lazy::new(|| {
      44            0 :     register_int_counter!(
      45            0 :         "storage_broker_broadcast_dropped_messages_total",
      46            0 :         "Number of messages dropped due to channel capacity overflow"
      47            0 :     )
      48            0 :     .expect("Failed to register metric")
      49            0 : });
      50              : 
      51            0 : pub static PUBLISHED_ONEOFF_MESSAGES_TOTAL: Lazy<IntCounter> = Lazy::new(|| {
      52            0 :     register_int_counter!(
      53            0 :         "storage_broker_published_oneoff_messages_total",
      54            0 :         "Number of one-off messages sent via PublishOne method"
      55            0 :     )
      56            0 :     .expect("Failed to register metric")
      57            0 : });