metrics

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

type APIMetric struct {
	Name       string        `json:"metric"`
	Host       *string       `json:"host,omitempty"`
	Tags       []string      `json:"tags,omitempty"`
	MetricType MetricType    `json:"type"`
	Interval   *float64      `json:"interval,omitempty"`
	Points     []interface{} `json:"points"`
}

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

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

type Client interface {
	SendMetrics(metrics []APIMetric) error
}

type Config struct {
	APIKey               string
	Site                 string
	ShouldRetryOnFailure bool
	BatchInterval        time.Duration
}

type Distribution struct {
	Name   string
	Tags   []string
	Host   *string
	Values []MetricValue
}

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

type Metric interface {
	AddPoint(timestamp time.Time, value float64)
	ToAPIMetric(interval time.Duration) []APIMetric
	ToBatchKey() BatchKey
	Join(metric Metric)
}

type MetricType string

type MetricValue struct {
	Value     float64
	Timestamp time.Time
}

type Processor interface {
	// AddMetric sends a metric to the agent
	AddMetric(metric Metric)
	// StartProcessing begins processing metrics asynchronously
	StartProcessing()
	// FinishProcessing shuts down the agent, and tries to flush any remaining metrics
	FinishProcessing()
}

type TimeService interface {
	NewTicker(duration time.Duration) *time.Ticker
	Now() time.Time
}