Struct dataflow::source::SourceMetrics

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,
}

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

impl 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)>
)

Log updates to which offsets / timestamps read up to.

Trait Implementations

impl Drop for SourceMetrics

fn drop(&mut self)

Executes the destructor for this type.