metrics

Documentation

Index

• Constants
• type ContainerCpuRepository
  • func NewContainerCpuRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ContainerCpuRepository
  • func (r *ContainerCpuRepository) CreateMetrics(metrics []*DaoMetricTypes.ContainerMetricSample) error
  • func (r *ContainerCpuRepository) ListMetrics(request DaoMetricTypes.ListPodMetricsRequest) ([]*DaoMetricTypes.ContainerMetric, error)
• type ContainerMemoryRepository
  • func NewContainerMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ContainerMemoryRepository
  • func (r *ContainerMemoryRepository) CreateMetrics(metrics []*DaoMetricTypes.ContainerMetricSample) error
  • func (r *ContainerMemoryRepository) ListMetrics(request DaoMetricTypes.ListPodMetricsRequest) ([]*DaoMetricTypes.ContainerMetric, error)
• type NodeCpuRepository
  • func NewNodeCpuRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeCpuRepository
  • func (r *NodeCpuRepository) CreateMetrics(metrics []*DaoMetricTypes.NodeMetricSample) error
  • func (r *NodeCpuRepository) ListMetrics(request DaoMetricTypes.ListNodeMetricsRequest) ([]*DaoMetricTypes.NodeMetric, error)
• type NodeMemoryRepository
  • func NewNodeMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeMemoryRepository
  • func (r *NodeMemoryRepository) CreateMetrics(metrics []*DaoMetricTypes.NodeMetricSample) error
  • func (r *NodeMemoryRepository) ListMetrics(request DaoMetricTypes.ListNodeMetricsRequest) ([]*DaoMetricTypes.NodeMetric, error)

Constants

const (
	ContainerCpu    InternalInflux.Measurement = "container_cpu"
	ContainerMemory InternalInflux.Measurement = "container_memory"
	NodeCpu         InternalInflux.Measurement = "node_cpu"
	NodeMemory      InternalInflux.Measurement = "node_memory"
)

Types

type ContainerCpuRepository

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

func NewContainerCpuRepositoryWithConfig

func NewContainerCpuRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ContainerCpuRepository

func (*ContainerCpuRepository) CreateMetrics

func (r *ContainerCpuRepository) CreateMetrics(metrics []*DaoMetricTypes.ContainerMetricSample) error

func (*ContainerCpuRepository) ListMetrics

func (r *ContainerCpuRepository) ListMetrics(request DaoMetricTypes.ListPodMetricsRequest) ([]*DaoMetricTypes.ContainerMetric, error)

type ContainerMemoryRepository

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

func NewContainerMemoryRepositoryWithConfig

func NewContainerMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ContainerMemoryRepository

func (*ContainerMemoryRepository) CreateMetrics

func (r *ContainerMemoryRepository) CreateMetrics(metrics []*DaoMetricTypes.ContainerMetricSample) error

func (*ContainerMemoryRepository) ListMetrics

func (r *ContainerMemoryRepository) ListMetrics(request DaoMetricTypes.ListPodMetricsRequest) ([]*DaoMetricTypes.ContainerMetric, error)

type NodeCpuRepository

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

func NewNodeCpuRepositoryWithConfig

func NewNodeCpuRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeCpuRepository

func (*NodeCpuRepository) CreateMetrics

func (r *NodeCpuRepository) CreateMetrics(metrics []*DaoMetricTypes.NodeMetricSample) error

func (*NodeCpuRepository) ListMetrics

func (r *NodeCpuRepository) ListMetrics(request DaoMetricTypes.ListNodeMetricsRequest) ([]*DaoMetricTypes.NodeMetric, error)

type NodeMemoryRepository

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

func NewNodeMemoryRepositoryWithConfig

func NewNodeMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeMemoryRepository

func (*NodeMemoryRepository) CreateMetrics

func (r *NodeMemoryRepository) CreateMetrics(metrics []*DaoMetricTypes.NodeMetricSample) error

func (*NodeMemoryRepository) ListMetrics

func (r *NodeMemoryRepository) ListMetrics(request DaoMetricTypes.ListNodeMetricsRequest) ([]*DaoMetricTypes.NodeMetric, error)