metrics

Jan 14, 2025

Changes in this version

+ var MessagesConfirmed *vmetrics.Counter

type MetricsServer

+ func (m *MetricsServer) StartTime(t time.Time)

Dec 5, 2024

Changes in this version

type MetricsServer

+ func Start(ctx context.Context, cfg config.Config) *MetricsServer

Nov 25, 2024

Changes in this version

+ var CommandLineArgs *vmetrics.Gauge

+ func RegisterCommandLineMetric(cfg config.Config, globalLabels map[string]string)

Nov 21, 2024

Changes in this version

type MetricsServer

+ func (m *MetricsServer) PrintSummary()

+ func (m MetricsServer) PrintAll()

Sep 2, 2024

Changes in this version

+ var MessagesConsumedHighPriority *vmetrics.Counter

+ var MessagesConsumedNormalPriority *vmetrics.Counter

+ var MessagesConsumedOutOfOrderHighPriority *vmetrics.Counter

+ var MessagesConsumedOutOfOrderNormalPriority *vmetrics.Counter

+ func MessagesConsumedMetric(priority int) *vmetrics.Counter

+ func MessagesConsumedOutOfOrderMetric(priority int) *vmetrics.Counter

type MetricsServer

+ func (m *MetricsServer) PrintFinalMetrics()

+ func (m *MetricsServer) PrintMessageRates(ctx context.Context)

Aug 13, 2024

Changes in this version

+ var MessagesConsumedOutOfOrder *prometheus.CounterVec

Feb 14, 2024

Changes in this version

+ func Reset()

Feb 12, 2024

Changes in this version

+ func RegisterMetrics(globalLabels prometheus.Labels)

+ func UnregisterMetrics()

Sep 28, 2023

Changes in this version

+ var EndToEndLatency = promauto.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... })

+ var MessagesConsumed = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var MessagesPublished = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var PublishingLatency = promauto.NewSummaryVec(prometheus.SummaryOpts{ ... }, []string{ ... })

+ type MetricsServer struct

+ func GetMetricsServer() *MetricsServer

+ func (m MetricsServer) PrintMetrics()

+ func (m MetricsServer) Start()

+ func (m MetricsServer) Stop()