Struct dataflow::metrics::Metrics [−][src]
pub struct Metrics {
events_read: UIntCounterVec,
debezium_upsert_count: UIntGaugeVec,
}
Expand description
Metrics specific to a single worker.
Fields
events_read: UIntCounterVec
debezium_upsert_count: UIntGaugeVec
Implementations
pub(crate) fn debezium_upsert_count_for(
&self,
src_id: GlobalId,
dataflow_id: usize
) -> UIntGauge
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Metrics
impl !UnwindSafe for Metrics
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