metricsservice

Feb 7, 2020

Changes in this version

+ const MetricsConfigMapName

Oct 4, 2019

Changes in this version

+ const HttpStatPrefix

+ const ListenerStatPrefix

+ const PrometheusStatPrefix

+ const ReadConfigStatPrefix

+ const ServerUptime

+ const TcpStatPrefix

+ func NewConfigMapBackedDefaultHandler(ctx context.Context) (*metricsHandler, error)

+ func NewConfigMapStorage(podNamespace string, configMapClient k8s.ConfigMapInterface) *configMapStorageClient

+ func NewDefaultConfigMapStorage(podNamespace string) (*configMapStorageClient, error)

+ func NewDefaultMetricsHandler(storage StorageClient, merger *UsageMerger) *metricsHandler

+ type CurrentTimeProvider func() time.Time

+ type EnvoyMetrics struct

+ HttpRequests uint64

+ TcpConnections uint64

+ Uptime time.Duration

+ type EnvoyUsage struct

+ Active bool

+ EnvoyMetrics *EnvoyMetrics

+ FirstRecordedAt time.Time

+ LastRecordedAt time.Time

+ type GlobalUsage struct

+ EnvoyIdToUsage map[string]*EnvoyUsage

+ type MetricsHandler interface

+ HandleMetrics func(context.Context, *envoymet.StreamMetricsMessage) error

+ type Options struct

+ Ctx context.Context

+ type Server struct

+ func NewServer(opts Options, handler MetricsHandler) *Server

+ func (s *Server) StreamMetrics(envoyMetrics envoymet.MetricsService_StreamMetricsServer) error

+ type StorageClient interface

+ GetUsage func(ctx context.Context) (*GlobalUsage, error)

+ RecordUsage func(ctx context.Context, usage *GlobalUsage) error

+ type UsageMerger struct

+ func NewUsageMerger(currentTimeProvider CurrentTimeProvider) *UsageMerger

+ func (u *UsageMerger) MergeUsage(envoyInstanceId string, oldUsage *GlobalUsage, newMetrics *EnvoyMetrics) *GlobalUsage