telemetry

Documentation

Index

• func SanitizeMetricName(metricName string) string
• type PrometheusCollector
  • 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) GetWorkerStats(workerName string) (WorkerStats, bool)
  • func (t *PrometheusCollector) Stop()
  • func (t *PrometheusCollector) UpdateStats()
• type WorkerStats

Functions

func SanitizeMetricName

func SanitizeMetricName(metricName string) string

Types

type PrometheusCollector

type PrometheusCollector struct {
	sync.Mutex

	Record chan WorkerStats
	// contains filtered or unexported fields
}

func InitTelemetryServer

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

func NewPrometheusCollector

func NewPrometheusCollector(config *pkgconfig.Config) *PrometheusCollector

func (*PrometheusCollector) Collect

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

func (*PrometheusCollector) Describe

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

func (*PrometheusCollector) GetWorkerStats

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

func (*PrometheusCollector) Stop

func (t *PrometheusCollector) Stop()

func (*PrometheusCollector) UpdateStats

func (t *PrometheusCollector) UpdateStats()

type WorkerStats

type WorkerStats struct {
	Name                 string
	TotalIngress         int
	TotalEgress          int
	TotalForwardedPolicy int
	TotalDroppedPolicy   int
	TotalDiscarded       int
}