source

Documentation

Index

• Constants
• type ElasticsearchMetricsClient
  • func NewElasticsearchMetricsClient(conf map[string]string) (*ElasticsearchMetricsClient, error)
  • func (e *ElasticsearchMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string) (*NodeMetrics, error)
  • func (e *ElasticsearchMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error
• type KMetricsClient
  • func NewCustomMetricsClient(cfg *rest.Config) (*KMetricsClient, error)
  • func (km *KMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error
• type MetricsClient
  • func NewMetricsClient(restConfig *rest.Config, metricsConf map[string]string) (MetricsClient, error)
• type NodeMetrics
• type PrometheusMetricsClient
  • func NewPrometheusMetricsClient(conf map[string]string) (*PrometheusMetricsClient, error)
  • func (p *PrometheusMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string) (*NodeMetrics, error)
  • func (p *PrometheusMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error

Constants

const (
	NODE_METRICS_PERIOD             = "10m"
	Metrics_Type_Prometheus_Adaptor = "prometheus_adaptor"
	Metrics_Tpye_Prometheus         = "prometheus"
	Metrics_Type_Elasticsearch      = "elasticsearch"
)

const (
	// CustomNodeCPUUsageAvg record name of cpu average usage defined in prometheus adapt rules
	CustomNodeCPUUsageAvg = "node_cpu_usage_avg"
	// CustomNodeMemUsageAvg record name of mem average usage defined in prometheus adapt rules
	CustomNodeMemUsageAvg = "node_memory_usage_avg"
)

Types

type ElasticsearchMetricsClient

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

func NewElasticsearchMetricsClient

func NewElasticsearchMetricsClient(conf map[string]string) (*ElasticsearchMetricsClient, error)

func (*ElasticsearchMetricsClient) NodeMetricsAvg

func (e *ElasticsearchMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string) (*NodeMetrics, error)

func (*ElasticsearchMetricsClient) NodesMetricsAvg

func (e *ElasticsearchMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error

type KMetricsClient

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

func NewCustomMetricsClient

func NewCustomMetricsClient(cfg *rest.Config) (*KMetricsClient, error)

func (*KMetricsClient) NodesMetricsAvg

func (km *KMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error

type MetricsClient

type MetricsClient interface {
	NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error
}

func NewMetricsClient

func NewMetricsClient(restConfig *rest.Config, metricsConf map[string]string) (MetricsClient, error)

type NodeMetrics

type NodeMetrics struct {
	MetricsTime time.Time
	CPU         float64
	Memory      float64
}

type PrometheusMetricsClient

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

func NewPrometheusMetricsClient

func NewPrometheusMetricsClient(conf map[string]string) (*PrometheusMetricsClient, error)

func (*PrometheusMetricsClient) NodeMetricsAvg

func (p *PrometheusMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string) (*NodeMetrics, error)

func (*PrometheusMetricsClient) NodesMetricsAvg

func (p *PrometheusMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error