source

Documentation

Index

• type ElasticsearchMetricsClient
  • func NewElasticsearchMetricsClient(address string, conf map[string]string) (*ElasticsearchMetricsClient, error)
  • func (e *ElasticsearchMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string, period string) (*NodeMetrics, error)
• type MetricsClient
  • func NewMetricsClient(metricsConf map[string]string) (MetricsClient, error)
• type NodeMetrics
• type PrometheusMetricsClient
  • func NewPrometheusMetricsClient(address string, conf map[string]string) (*PrometheusMetricsClient, error)
  • func (p *PrometheusMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string, period string) (*NodeMetrics, error)

Types

type ElasticsearchMetricsClient

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

func NewElasticsearchMetricsClient

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

func (*ElasticsearchMetricsClient) NodeMetricsAvg

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

type MetricsClient

type MetricsClient interface {
	NodeMetricsAvg(ctx context.Context, nodeName string, period string) (*NodeMetrics, error)
}

func NewMetricsClient

func NewMetricsClient(metricsConf map[string]string) (MetricsClient, error)

type NodeMetrics

type NodeMetrics struct {
	CPU    float64
	Memory float64
}

type PrometheusMetricsClient

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

func NewPrometheusMetricsClient

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

func (*PrometheusMetricsClient) NodeMetricsAvg

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