metricsservice

type CurrentTimeProvider func() time.Time

type EnvoyMetrics struct {
	HttpRequests   uint64
	TcpConnections uint64
	Uptime         time.Duration
}

type EnvoyUsage struct {
	EnvoyMetrics    *EnvoyMetrics
	LastRecordedAt  time.Time
	FirstRecordedAt time.Time
	Active          bool // whether or not we believe this envoy to be active
}

type GlobalUsage struct {
	EnvoyIdToUsage map[string]*EnvoyUsage
}

type MetricsHandler interface {
	HandleMetrics(context.Context, *envoymet.StreamMetricsMessage) error
}

type Options struct {
	Ctx context.Context
}

type Server struct {
	// contains filtered or unexported fields
}

type StorageClient interface {
	RecordUsage(usage *GlobalUsage) error
	GetUsage() (*GlobalUsage, error)
}

type UsageMerger struct {
	// contains filtered or unexported fields
}