metrics

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

type Gauge interface {
	Metric
	Value() int64
	Update(int64)
}

type GaugeFloat64 interface {
	Metric
	Value() float64
	Update(float64)
}

type Handler interface {
	// AcceptMetrics is called when new metrics become available
	AcceptMetrics(message *metrics_pb.MetricsMessage)
}

type Histogram interface {
	Metric
	Count() int64
	Max() int64
	Mean() float64
	Min() int64
	Percentile(float64) float64
	Percentiles([]float64) []float64
	StdDev() float64
	Sum() int64
	Variance() float64

	Clear()
	Update(int64)
	CreateSnapshot() Histogram
}

type IntervalCounter interface {
	Metric
	Update(intervalId string, time time.Time, value uint64)
}

type Meter interface {
	Metric
	Count() int64
	Rate1() float64
	Rate5() float64
	Rate15() float64
	RateMean() float64
	Mark(int64)
}

type Metric interface {
	Dispose()
}

type MetricSink interface {
	Filter(name string) bool
	StartReport(registry Registry)
	EndReport(registry Registry)
	AcceptIntMetric(name string, value int64)
	AcceptFloatMetric(name string, value float64)
	AcceptPercentileMetric(name string, value PercentileSource)
}

type PercentileSource interface {
	Percentile(float64) float64
}

type Registry interface {
	// SourceId returns the source id of this Registry
	SourceId() string

	// Gauge returns a Gauge for the given name. If one does not yet exist, one will be created
	Gauge(name string) Gauge

	// FuncGauge returns a Gauge for the given name. If one does not yet exist, one will be created using
	// the given function
	FuncGauge(name string, f func() int64) Gauge

	// GaugeFloat64 returns a GaugeFloat64 for the given name. If one does not yet exist, one will be created
	GaugeFloat64(name string) GaugeFloat64

	// FuncGaugeFloat64 returns a GaugeFloat64 for the given name. If one does not yet exist, one will be created
	// using the given function
	FuncGaugeFloat64(name string, f func() float64) GaugeFloat64

	// Meter returns a Meter for the given name. If one does not yet exist, one will be created
	Meter(name string) Meter

	// Histogram returns a Histogram for the given name. If one does not yet exist, one will be created
	Histogram(name string) Histogram

	// Timer returns a Timer for the given name. If one does not yet exist, one will be created
	Timer(name string) Timer

	// EachMetric calls the given visitor function for each Metric in this registry
	EachMetric(visitor func(name string, metric Metric))

	// GetGauge returns the Gauge for the given name or nil if a Gauge with that name doesn't exist
	GetGauge(name string) Gauge

	// GetGaugeFloat64 returns the GaugeFloat64 for the given name or nil if one doesn't exist
	GetGaugeFloat64(name string) GaugeFloat64

	// GetMeter returns the Meter for the given name or nil if a Meter with that name doesn't exist
	GetMeter(name string) Meter

	// GetHistogram returns the Histogram for the given name or nil if a Histogram with that name doesn't exist
	GetHistogram(name string) Histogram

	// GetTimer returns the Timer for the given name or nil if a Timer with that name doesn't exist
	GetTimer(name string) Timer

	// IsValidMetric returns true if a metric with the given name exists in the registry, false otherwise
	IsValidMetric(name string) bool

	// Poll returns a MetricsMessage with a snapshot of the metrics in the Registry
	Poll() *metrics_pb.MetricsMessage

	AcceptVisitor(visitor Visitor)

	// DisposeAll removes and cleans up all metrics currently in the Registry
	DisposeAll()
}

type Timer interface {
	Metric
	Count() int64
	Max() int64
	Mean() float64
	Min() int64
	Percentile(float64) float64
	Percentiles([]float64) []float64
	Rate1() float64
	Rate5() float64
	Rate15() float64
	RateMean() float64
	StdDev() float64
	Sum() int64
	Variance() float64

	Time(func())
	Update(time.Duration)
	UpdateSince(time.Time)
	CreateSnapshot() Timer
}

type UsageCounter interface {
	Metric
	Update(source UsageSource, usageType string, time time.Time, value uint64)
}

type UsageRegistry interface {
	Registry
	PollWithoutUsageMetrics() *metrics_pb.MetricsMessage
	IntervalCounter(name string, intervalSize time.Duration) IntervalCounter
	UsageCounter(name string, intervalSize time.Duration) UsageCounter
	FlushToHandler(handler Handler)
	StartReporting(eventSink Handler, reportInterval time.Duration, msgQueueSize int)
}

type UsageRegistryConfig struct {
	SourceId             string
	Tags                 map[string]string
	EventQueueSize       int
	CloseNotify          <-chan struct{}
	IntervalAgeThreshold time.Duration
}

type UsageSource interface {
	GetIntervalId() string
	GetTags() map[string]string
}

type Visitor interface {
	VisitGauge(name string, gauge Gauge)
	VisitGaugeFloat64(name string, gauge GaugeFloat64)
	VisitMeter(name string, meter Meter)
	VisitHistogram(name string, histogram Histogram)
	VisitTimer(name string, timer Timer)
}