Documentation ¶
Index ¶
- Variables
- func HandlePanic(configuration *config.Config, logger logging.Logger)
- func RunWorker(gatherers []MetricsGatherer, gatherers_configuration []MetricsGatherer, ...)
- type AWSRDSEnhancedMetricsGatherer
- type AWSRDSInstanceGatherer
- type AWSRDSMetricsGatherer
- type AgentMetricsGatherer
- type DbCollectQueries
- type DbConfGatherer
- type DbInfoGatherer
- type DbMetricsBaseGatherer
- type DbMetricsGatherer
- type Metric
- type MetricContext
- type MetricGroupValue
- type MetricIntervalType
- type MetricType
- type MetricValue
- type Metrics
- type MetricsGatherer
- type MetricsRepeater
- type Mode
- type OSMetricsGatherer
- type Task
Constants ¶
This section is empty.
Variables ¶
View Source
var Ready bool
Functions ¶
func RunWorker ¶
func RunWorker(gatherers []MetricsGatherer, gatherers_configuration []MetricsGatherer, repeaters map[string]MetricsRepeater, logger logging.Logger, configuration *config.Config, configFile string, Mode Mode)
Types ¶
type AWSRDSEnhancedMetricsGatherer ¶
type AWSRDSEnhancedMetricsGatherer struct {
// contains filtered or unexported fields
}
func NewAWSRDSEnhancedMetricsGatherer ¶
func NewAWSRDSEnhancedMetricsGatherer(logger logging.Logger, dbinstance types.DBInstance, cwlogsclient *cloudwatchlogs.Client, configuration *config.Config) *AWSRDSEnhancedMetricsGatherer
func (*AWSRDSEnhancedMetricsGatherer) GetMetrics ¶
func (awsrdsenhancedmetrics *AWSRDSEnhancedMetricsGatherer) GetMetrics(metrics *Metrics) error
type AWSRDSInstanceGatherer ¶
type AWSRDSInstanceGatherer struct {
// contains filtered or unexported fields
}
func (*AWSRDSInstanceGatherer) GetMetrics ¶
func (awsrdsinstance *AWSRDSInstanceGatherer) GetMetrics(metrics *Metrics) error
type AWSRDSMetricsGatherer ¶
type AWSRDSMetricsGatherer struct {
// contains filtered or unexported fields
}
func NewAWSRDSMetricsGatherer ¶
func NewAWSRDSMetricsGatherer(logger logging.Logger, cwclient *cloudwatch.Client, configuration *config.Config) *AWSRDSMetricsGatherer
func (*AWSRDSMetricsGatherer) GetMetrics ¶
func (awsrdsmetrics *AWSRDSMetricsGatherer) GetMetrics(metrics *Metrics) error
type AgentMetricsGatherer ¶
type AgentMetricsGatherer struct {
// contains filtered or unexported fields
}
func NewAgentMetricsGatherer ¶
func NewAgentMetricsGatherer(logger logging.Logger, configuration *config.Config) *AgentMetricsGatherer
func (*AgentMetricsGatherer) GetMetrics ¶
func (Agent *AgentMetricsGatherer) GetMetrics(metrics *Metrics) error
type DbCollectQueries ¶
type DbCollectQueries struct {
// contains filtered or unexported fields
}
func NewDbCollectQueries ¶
func (*DbCollectQueries) GetMetrics ¶
func (DbCollectQueries *DbCollectQueries) GetMetrics(metrics *Metrics) error
type DbConfGatherer ¶
type DbConfGatherer struct {
// contains filtered or unexported fields
}
func NewDbConfGatherer ¶
func (*DbConfGatherer) GetMetrics ¶
func (DbConf *DbConfGatherer) GetMetrics(metrics *Metrics) error
type DbInfoGatherer ¶
type DbInfoGatherer struct {
// contains filtered or unexported fields
}
func NewDbInfoGatherer ¶
func (*DbInfoGatherer) GetMetrics ¶
func (DbInfo *DbInfoGatherer) GetMetrics(metrics *Metrics) error
type DbMetricsBaseGatherer ¶
type DbMetricsBaseGatherer struct {
// contains filtered or unexported fields
}
func (*DbMetricsBaseGatherer) GetMetrics ¶
func (DbMetricsBase *DbMetricsBaseGatherer) GetMetrics(metrics *Metrics) error
type DbMetricsGatherer ¶
type DbMetricsGatherer struct {
// contains filtered or unexported fields
}
func NewDbMetricsGatherer ¶
func (*DbMetricsGatherer) GetMetrics ¶
func (DbMetrics *DbMetricsGatherer) GetMetrics(metrics *Metrics) error
type Metric ¶
type Metric map[string]MetricGroupValue
type MetricContext ¶
type MetricGroupValue ¶
type MetricGroupValue map[string]interface{}
func MapJoin ¶
func MapJoin(map1, map2 MetricGroupValue) MetricGroupValue
func StructToMap ¶
func StructToMap(valueStruct string) MetricGroupValue
type MetricIntervalType ¶
type MetricIntervalType byte
type MetricType ¶
type MetricType byte
type MetricValue ¶
type MetricValue struct {
// contains filtered or unexported fields
}
type Metrics ¶
type Metrics struct { System struct { Info MetricGroupValue Conf MetricGroupValue Metrics MetricGroupValue } DB struct { Metrics struct { Status MetricGroupValue TotalTables string TotalMyisamIndexes string Engine map[string]MetricGroupValue Latency string Databases []string } Conf struct { Variables MetricGroupValue } Info MetricGroupValue Queries []MetricGroupValue } ReleemAgent struct { Info MetricGroupValue Tasks MetricGroupValue } }
type MetricsGatherer ¶
type MetricsRepeater ¶
type MetricsRepeater interface {
ProcessMetrics(context MetricContext, metrics Metrics) (interface{}, error)
}
type OSMetricsGatherer ¶
type OSMetricsGatherer struct {
// contains filtered or unexported fields
}
func NewOSMetricsGatherer ¶
func NewOSMetricsGatherer(logger logging.Logger, configuration *config.Config) *OSMetricsGatherer
func (*OSMetricsGatherer) GetMetrics ¶
func (OS *OSMetricsGatherer) GetMetrics(metrics *Metrics) error
Click to show internal directories.
Click to hide internal directories.