venta 0.9.0

Reliable producer interface for Pulsar
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
use lazy_static::lazy_static;
use prometheus::{register_int_counter_vec, IntCounterVec};

lazy_static! {
    pub static ref NUM_MSGS_QUEUED: IntCounterVec = register_int_counter_vec!(
        "venta_num_messages_queued",
        "Number of messages queued",
        &["topic"]
    )
    .unwrap();
    pub static ref NUM_MSGS_SENT: IntCounterVec = register_int_counter_vec!(
        "venta_num_messages_sent",
        "Number of messages sent",
        &["topic"]
    )
    .unwrap();
}