metrics

type Gatherer interface {
	DatabaseMetadata() (globalStatus map[string]string, globalVariables map[string]string, err error)
	FollowerMetadata() (slaveStatus map[string]string, heartbeatStatus map[string]string, err error)
	IsDatabaseFollower() (bool, error)
	IsDatabaseAvailable() bool
	DiskStats() (map[string]string, error)
	BrokerStats() (map[string]string, error)
	CPUStats() (map[string]string, error)
}

type Logger interface {
	Debug(string, map[string]interface{})
	Error(string, error)
}

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

type Metric struct {
	Key      string  `json:"key"`
	Value    float64 `json:"value"`
	Unit     string  `json:"unit"`
	RawValue string
	Error    error
}

type MetricDefinition struct {
	Key  string `yaml:"key"`
	Unit string `yaml:"unit"`
}

type MetricMappingConfig struct {
	MysqlMetricMappings          map[string]MetricDefinition
	GaleraMetricMappings         map[string]MetricDefinition
	LeaderFollowerMetricMappings map[string]MetricDefinition
	DiskMetricMappings           map[string]MetricDefinition
	BrokerMetricMappings         map[string]MetricDefinition
	CPUMetricMappings            map[string]MetricDefinition
}

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

type MetricsComputer interface {
	ComputeAvailabilityMetric(bool) *Metric
	ComputeIsFollowerMetric(bool) *Metric
	ComputeGlobalMetrics(map[string]string) []*Metric
	ComputeLeaderFollowerMetrics(map[string]string) []*Metric
	ComputeDiskMetrics(map[string]string) []*Metric
	ComputeBrokerMetrics(map[string]string) []*Metric
	ComputeGaleraMetrics(map[string]string) []*Metric
	ComputeCPUMetrics(map[string]string) []*Metric
}

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

type Sender interface {
	SendValue(name string, value float64, unit string) error
}

type Writer interface {
	Write(metric []*Metric) error
}