telemetry

Nov 9, 2024

Changes in this version

type PrometheusCollector

+ func (t *PrometheusCollector) GetWorkerStats(workerName string) (WorkerStats, bool)

Jun 14, 2024

Changes in this version

+ func SanitizeMetricName(metricName string) string

+ type PrometheusCollector struct

+ Record chan WorkerStats

+ func InitTelemetryServer(config *pkgconfig.Config, logger *logger.Logger) (*http.Server, *PrometheusCollector, chan error)

+ func NewPrometheusCollector(config *pkgconfig.Config) *PrometheusCollector

+ func (t *PrometheusCollector) Collect(ch chan<- prometheus.Metric)

+ func (t *PrometheusCollector) Describe(ch chan<- *prometheus.Desc)

+ func (t *PrometheusCollector) Stop()

+ func (t *PrometheusCollector) UpdateStats()

+ type WorkerStats struct

+ Name string

+ TotalDiscarded int

+ TotalDroppedPolicy int

+ TotalEgress int

+ TotalForwardedPolicy int

+ TotalIngress int