Struct dataflow::sink::kafka::SinkMetrics [−][src]
pub struct SinkMetrics {
messages_sent_counter: DeleteOnDropCounter<'static, AtomicI64, Vec<String>>,
message_send_errors_counter: DeleteOnDropCounter<'static, AtomicI64, Vec<String>>,
message_delivery_errors_counter: DeleteOnDropCounter<'static, AtomicI64, Vec<String>>,
rows_queued: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
}
Expand description
Per-Kafka sink metrics.
Fields
messages_sent_counter: DeleteOnDropCounter<'static, AtomicI64, Vec<String>>
message_send_errors_counter: DeleteOnDropCounter<'static, AtomicI64, Vec<String>>
message_delivery_errors_counter: DeleteOnDropCounter<'static, AtomicI64, Vec<String>>
rows_queued: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>
Implementations
fn new(
base: &KafkaBaseMetrics,
topic_name: &str,
sink_id: &str,
worker_id: &str
) -> SinkMetrics
Auto Trait Implementations
impl !RefUnwindSafe for SinkMetrics
impl Send for SinkMetrics
impl Sync for SinkMetrics
impl Unpin for SinkMetrics
impl !UnwindSafe for SinkMetrics
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