metric

package

v0.5.0 Latest Latest Go to latest Published: Apr 28, 2024 License: Apache-2.0 Imports: 9 Imported by: 7

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubewharf/katalyst-core

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

Types ¶

type Aggregator ¶ added in v0.2.0

type Aggregator string

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

type ContainerMetricFilter ¶ added in v0.2.0

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 ¶ added in v0.3.0

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 metric data. Including: 1. raw data collected from agent.MetricsFetcher. 2. data calculated based on raw data.

func NewMetricStore ¶ added in v0.3.0

func NewMetricStore() *MetricStore

func (*MetricStore) AggregateCoreMetric ¶ added in v0.2.0

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

AggregateCoreMetric handles metric for all cores

func (*MetricStore) AggregatePodMetric ¶ added in v0.2.0

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

AggregatePodMetric handles metric for all pods

func (*MetricStore) AggregatePodNumaMetric ¶ added in v0.2.0

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 ¶ added in v0.3.0

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

func (*MetricStore) GetCgroupNumaMetric ¶ added in v0.3.0

func (c *MetricStore) GetCgroupNumaMetric(cgroupPath string, numaNode int, 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) GetNetworkMetric ¶ added in v0.4.1

func (c *MetricStore) GetNetworkMetric(networkName 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) GetPodVolumeMetric ¶ added in v0.4.0

func (c *MetricStore) GetPodVolumeMetric(podUID, volumeName, metricName string) (MetricData, error)

func (*MetricStore) SetCPUMetric ¶

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

func (*MetricStore) SetCgroupMetric ¶ added in v0.3.0

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

func (*MetricStore) SetCgroupNumaMetric ¶ added in v0.3.0

func (c *MetricStore) SetCgroupNumaMetric(cgroupPath string, numaNode int, 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) SetNetworkMetric ¶ added in v0.4.1

func (c *MetricStore) SetNetworkMetric(networkName 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)

func (*MetricStore) SetPodVolumeMetric ¶ added in v0.4.0

func (c *MetricStore) SetPodVolumeMetric(podUID, volumeName, metricName string, data MetricData)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL