metric

Documentation

Index

• Variables
• type Aggregator
• type ContainerMetricFilter
• type MetricData
• type MetricStore
  • func NewMetricStore() *MetricStore
  • func (c *MetricStore) AggregateCoreMetric(cpuset machine.CPUSet, metricName string, agg Aggregator) MetricData
  • func (c *MetricStore) AggregatePodMetric(podList []*v1.Pod, metricName string, agg Aggregator, ...) MetricData
  • func (c *MetricStore) AggregatePodNumaMetric(podList []*v1.Pod, numa, metricName string, agg Aggregator, ...) MetricData
  • func (c *MetricStore) GCPodsMetric(livingPodUIDSet map[string]bool)
  • func (c *MetricStore) GetCPUMetric(coreID int, metricName string) (MetricData, error)
  • func (c *MetricStore) GetCgroupMetric(cgroupPath, metricName string) (MetricData, error)
  • func (c *MetricStore) GetCgroupNumaMetric(cgroupPath, numaNode, metricName string) (MetricData, error)
  • func (c *MetricStore) GetContainerMetric(podUID, containerName, metricName string) (MetricData, error)
  • func (c *MetricStore) GetContainerNumaMetric(podUID, containerName, numaNode, metricName string) (MetricData, error)
  • func (c *MetricStore) GetDeviceMetric(deviceName string, metricName string) (MetricData, error)
  • func (c *MetricStore) GetNodeMetric(metricName string) (MetricData, error)
  • func (c *MetricStore) GetNumaMetric(numaID int, metricName string) (MetricData, error)
  • func (c *MetricStore) SetCPUMetric(cpuID int, metricName string, data MetricData)
  • func (c *MetricStore) SetCgroupMetric(cgroupPath, metricName string, data MetricData)
  • func (c *MetricStore) SetCgroupNumaMetric(cgroupPath, numaNode, metricName string, data MetricData)
  • func (c *MetricStore) SetContainerMetric(podUID, containerName, metricName string, data MetricData)
  • func (c *MetricStore) SetContainerNumaMetric(podUID, containerName, numaNode, metricName string, data MetricData)
  • func (c *MetricStore) SetDeviceMetric(deviceName string, metricName string, data MetricData)
  • func (c *MetricStore) SetNodeMetric(metricName string, data MetricData)
  • func (c *MetricStore) SetNumaMetric(numaID int, metricName string, data MetricData)

Variables

var DefaultContainerMetricFilter = func(_ *v1.Pod, _ *v1.Container) bool { return true }

Types

type Aggregator

type Aggregator string

const (
	AggregatorSum Aggregator = "sum"
	AggregatorAvg Aggregator = "avg"
)

type ContainerMetricFilter

type ContainerMetricFilter func(pod *v1.Pod, container *v1.Container) bool

ContainerMetricFilter is used to filter out unnecessary metrics if this function returns false

type MetricData

type MetricData struct {
	Value float64

	// Time may have different meanings in different scenarios
	// - for single metric: it represents the exact collecting time
	// - for aggregated metric: it represents the newest time among all metric items
	Time *time.Time
}

MetricData represents the standard response data for metric getter functions

type MetricStore

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

MetricStore stores those raw metric data items collected from agent.MetricsFetcher

func NewMetricStore

func NewMetricStore() *MetricStore

func (*MetricStore) AggregateCoreMetric

func (c *MetricStore) AggregateCoreMetric(cpuset machine.CPUSet, metricName string, agg Aggregator) MetricData

AggregateCoreMetric handles metric for all cores

func (*MetricStore) AggregatePodMetric

func (c *MetricStore) AggregatePodMetric(podList []*v1.Pod, metricName string, agg Aggregator, filter ContainerMetricFilter) MetricData

AggregatePodMetric handles metric for all pods

func (*MetricStore) AggregatePodNumaMetric

func (c *MetricStore) AggregatePodNumaMetric(podList []*v1.Pod, numa, metricName string, agg Aggregator, filter ContainerMetricFilter) MetricData

AggregatePodNumaMetric handles numa-level metric for all pods

func (*MetricStore) GCPodsMetric

func (c *MetricStore) GCPodsMetric(livingPodUIDSet map[string]bool)

func (*MetricStore) GetCPUMetric

func (c *MetricStore) GetCPUMetric(coreID int, metricName string) (MetricData, error)

func (*MetricStore) GetCgroupMetric

func (c *MetricStore) GetCgroupMetric(cgroupPath, metricName string) (MetricData, error)

func (*MetricStore) GetCgroupNumaMetric

func (c *MetricStore) GetCgroupNumaMetric(cgroupPath, numaNode, metricName string) (MetricData, error)

func (*MetricStore) GetContainerMetric

func (c *MetricStore) GetContainerMetric(podUID, containerName, metricName string) (MetricData, error)

func (*MetricStore) GetContainerNumaMetric

func (c *MetricStore) GetContainerNumaMetric(podUID, containerName, numaNode, metricName string) (MetricData, error)

func (*MetricStore) GetDeviceMetric

func (c *MetricStore) GetDeviceMetric(deviceName string, metricName string) (MetricData, error)

func (*MetricStore) GetNodeMetric

func (c *MetricStore) GetNodeMetric(metricName string) (MetricData, error)

func (*MetricStore) GetNumaMetric

func (c *MetricStore) GetNumaMetric(numaID int, metricName string) (MetricData, error)

func (*MetricStore) SetCPUMetric

func (c *MetricStore) SetCPUMetric(cpuID int, metricName string, data MetricData)

func (*MetricStore) SetCgroupMetric

func (c *MetricStore) SetCgroupMetric(cgroupPath, metricName string, data MetricData)

func (*MetricStore) SetCgroupNumaMetric

func (c *MetricStore) SetCgroupNumaMetric(cgroupPath, numaNode, metricName string, data MetricData)

func (*MetricStore) SetContainerMetric

func (c *MetricStore) SetContainerMetric(podUID, containerName, metricName string, data MetricData)

func (*MetricStore) SetContainerNumaMetric

func (c *MetricStore) SetContainerNumaMetric(podUID, containerName, numaNode, metricName string, data MetricData)

func (*MetricStore) SetDeviceMetric

func (c *MetricStore) SetDeviceMetric(deviceName string, metricName string, data MetricData)

func (*MetricStore) SetNodeMetric

func (c *MetricStore) SetNodeMetric(metricName string, data MetricData)

func (*MetricStore) SetNumaMetric

func (c *MetricStore) SetNumaMetric(numaID int, metricName string, data MetricData)