INNER CODE UNIT · Python

Metrics

scality/Zenko · monitoring/dr/dr.dashboard.py:20

class Metrics:
    DR_SOURCE = 'drSinkInstance=""'
    DR_SINK = 'drSinkInstance="${dr_sink_instance}"'

    UP = metrics.Metric(
        "up",
        "drSinkInstance", job="${job}", namespace="${namespace}",
    )

    KAFKA_CONSUMERGROUP_LAG = metrics.Metric(
        "kafka_consumergroup_group_max_lag",
        "group", cluster_name="${kafka_instance}", namespace="${namespace}",
    )

    KAFKA_CONNECT_SOURCE_TASK_RECORDS_LAG = metrics.Metric(
        "kafka_consumer_fetch_manager_records_lag",
        "drSinkInstance", "job", namespace="${namespace}",
    )

View source record →