/
azathd
/
mutiagent
Обзор
Документация
Войти
/
azathd
/
mutiagent
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
src/common/telemetry.py
32 строки
755 B
Your Name
init
15 май 2026, 17:47
15 май 2026, 17:47
359c81e
Код
Авторство
О чём код?
"""Prometheus metrics and lightweight timing helpers.""" from __future__ import annotations from collections.abc import Iterator from contextlib import contextmanager from prometheus_client import Counter, Histogram, REGISTRY _EVENTS = Counter( "xray_events_processed_total", "Events processed across agents", labelnames=("agent", "topic"), registry=REGISTRY, ) _SPAN_HIST = Histogram( "xray_span_seconds", "Span duration bucket for coarse tracing", labelnames=("name",), registry=REGISTRY, ) def incr_events(agent: str, topic: str) -> None: _EVENTS.labels(agent=agent, topic=topic).inc() @contextmanager def span_timer(name: str) -> Iterator[None]: with _SPAN_HIST.labels(name=name).time(): yield