Struct dataflow::sink::metrics::KafkaBaseMetrics [−][src]
pub struct KafkaBaseMetrics {
pub(crate) messages_sent_counter: IntCounterVec,
pub(crate) message_send_errors_counter: IntCounterVec,
pub(crate) message_delivery_errors_counter: IntCounterVec,
pub(crate) rows_queued: UIntGaugeVec,
}
Expand description
Metrics reported by each kafka sink.
Fields
messages_sent_counter: IntCounterVec
message_send_errors_counter: IntCounterVec
message_delivery_errors_counter: IntCounterVec
rows_queued: UIntGaugeVec
Implementations
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for KafkaBaseMetrics
impl Send for KafkaBaseMetrics
impl Sync for KafkaBaseMetrics
impl Unpin for KafkaBaseMetrics
impl !UnwindSafe for KafkaBaseMetrics
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more