Struct dataflow::source::SourceMetrics [−][src]
pub struct SourceMetrics {
operator_scheduled_counter: DeleteOnDropCounter<'static, AtomicI64, Vec<String>>,
capability: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>,
pub partition_metrics: HashMap<PartitionId, PartitionMetrics>,
logger: Option<Logger>,
source_name: String,
source_id: SourceInstanceId,
base_metrics: SourceBaseMetrics,
}
Expand description
Source-specific Prometheus metrics
Fields
operator_scheduled_counter: DeleteOnDropCounter<'static, AtomicI64, Vec<String>>
Number of times an operator gets scheduled
capability: DeleteOnDropGauge<'static, AtomicU64, Vec<String>>
Value of the capability associated with this source
partition_metrics: HashMap<PartitionId, PartitionMetrics>
Per-partition Prometheus metrics.
logger: Option<Logger>
source_name: String
source_id: SourceInstanceId
base_metrics: SourceBaseMetrics
Implementations
pub fn new(
base: &SourceBaseMetrics,
source_name: &str,
source_id: SourceInstanceId,
worker_id: &str,
logger: Option<Logger>
) -> SourceMetrics
pub fn new(
base: &SourceBaseMetrics,
source_name: &str,
source_id: SourceInstanceId,
worker_id: &str,
logger: Option<Logger>
) -> SourceMetrics
Initialises source metrics for a given (source_id, worker_id)
pub fn record_partition_offsets(
&mut self,
offsets: HashMap<PartitionId, (MzOffset, Timestamp, i64)>
)
pub fn record_partition_offsets(
&mut self,
offsets: HashMap<PartitionId, (MzOffset, Timestamp, i64)>
)
Log updates to which offsets / timestamps read up to.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for SourceMetrics
impl !Send for SourceMetrics
impl !Sync for SourceMetrics
impl Unpin for SourceMetrics
impl !UnwindSafe for SourceMetrics
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