metrics

Documentation

Index

• Variables
• func HandlePanic(configuration *config.Config, logger logging.Logger)
• func RunWorker(gatherers []MetricsGatherer, gatherers_configuration []MetricsGatherer, ...)
• type AWSRDSEnhancedMetricsGatherer
  • func NewAWSRDSEnhancedMetricsGatherer(logger logging.Logger, dbinstance types.DBInstance, ...) *AWSRDSEnhancedMetricsGatherer
  • func (awsrdsenhancedmetrics *AWSRDSEnhancedMetricsGatherer) GetMetrics(metrics *Metrics) error
• type AWSRDSInstanceGatherer
  • func NewAWSRDSInstanceGatherer(logger logging.Logger, rdsclient *rds.Client, ec2client *ec2.Client, ...) *AWSRDSInstanceGatherer
  • func (awsrdsinstance *AWSRDSInstanceGatherer) GetMetrics(metrics *Metrics) error
• type AWSRDSMetricsGatherer
  • func NewAWSRDSMetricsGatherer(logger logging.Logger, cwclient *cloudwatch.Client, ...) *AWSRDSMetricsGatherer
  • func (awsrdsmetrics *AWSRDSMetricsGatherer) GetMetrics(metrics *Metrics) error
• type AgentMetricsGatherer
  • func NewAgentMetricsGatherer(logger logging.Logger, configuration *config.Config) *AgentMetricsGatherer
  • func (Agent *AgentMetricsGatherer) GetMetrics(metrics *Metrics) error
• type DbCollectQueries
  • func NewDbCollectQueries(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbCollectQueries
  • func (DbCollectQueries *DbCollectQueries) GetMetrics(metrics *Metrics) error
• type DbConfGatherer
  • func NewDbConfGatherer(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbConfGatherer
  • func (DbConf *DbConfGatherer) GetMetrics(metrics *Metrics) error
• type DbInfoGatherer
  • func NewDbInfoGatherer(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbInfoGatherer
  • func (DbInfo *DbInfoGatherer) GetMetrics(metrics *Metrics) error
• type DbMetricsBaseGatherer
  • func NewDbMetricsBaseGatherer(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbMetricsBaseGatherer
  • func (DbMetricsBase *DbMetricsBaseGatherer) GetMetrics(metrics *Metrics) error
• type DbMetricsGatherer
  • func NewDbMetricsGatherer(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbMetricsGatherer
  • func (DbMetrics *DbMetricsGatherer) GetMetrics(metrics *Metrics) error
• type Metric
• type MetricContext
• type MetricGroupValue
  • func MapJoin(map1, map2 MetricGroupValue) MetricGroupValue
  • func StructToMap(valueStruct string) MetricGroupValue
• type MetricIntervalType
• type MetricType
• type MetricValue
• type Metrics
• type MetricsGatherer
• type MetricsRepeater
• type Mode
• type OSMetricsGatherer
  • func NewOSMetricsGatherer(logger logging.Logger, configuration *config.Config) *OSMetricsGatherer
  • func (OS *OSMetricsGatherer) GetMetrics(metrics *Metrics) error
• type Task

Variables

var Ready bool

Functions

func HandlePanic

func HandlePanic(configuration *config.Config, logger logging.Logger)

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 NewAWSRDSInstanceGatherer

func NewAWSRDSInstanceGatherer(logger logging.Logger, rdsclient *rds.Client, ec2client *ec2.Client, configuration *config.Config) *AWSRDSInstanceGatherer

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 NewDbCollectQueries(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbCollectQueries

func (*DbCollectQueries) GetMetrics

func (DbCollectQueries *DbCollectQueries) GetMetrics(metrics *Metrics) error

type DbConfGatherer

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

func NewDbConfGatherer

func NewDbConfGatherer(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbConfGatherer

func (*DbConfGatherer) GetMetrics

func (DbConf *DbConfGatherer) GetMetrics(metrics *Metrics) error

type DbInfoGatherer

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

func NewDbInfoGatherer

func NewDbInfoGatherer(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbInfoGatherer

func (*DbInfoGatherer) GetMetrics

func (DbInfo *DbInfoGatherer) GetMetrics(metrics *Metrics) error

type DbMetricsBaseGatherer

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

func NewDbMetricsBaseGatherer

func NewDbMetricsBaseGatherer(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbMetricsBaseGatherer

func (*DbMetricsBaseGatherer) GetMetrics

func (DbMetricsBase *DbMetricsBaseGatherer) GetMetrics(metrics *Metrics) error

type DbMetricsGatherer

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

func NewDbMetricsGatherer

func NewDbMetricsGatherer(logger logging.Logger, db *sql.DB, configuration *config.Config) *DbMetricsGatherer

func (*DbMetricsGatherer) GetMetrics

func (DbMetrics *DbMetricsGatherer) GetMetrics(metrics *Metrics) error

type Metric

type Metric map[string]MetricGroupValue

type MetricContext

type MetricContext interface {
	GetApiKey() string
	GetEnv() string
	GetMemoryLimit() int
	GetReleemConfDir() string
}

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 MetricsGatherer interface {
	GetMetrics(metrics *Metrics) error
}

type MetricsRepeater

type MetricsRepeater interface {
	ProcessMetrics(context MetricContext, metrics Metrics) (interface{}, error)
}

type Mode

type Mode struct {
	Name     string
	ModeType string
}

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

type Task

type Task struct {
	TaskID     *int    `json:"task_id"`
	TaskTypeID *int    `json:"task_type_id"`
	IsExist    *string `json:"is_exist"`
}