malachite

package
v0.3.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 8, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMalachiteMetricsFetcher added in v0.3.0 

func NewMalachiteMetricsFetcher(emitter metrics.MetricEmitter, fetcher pod.PodFetcher, conf *config.Configuration) metric.MetricsFetcher

NewMalachiteMetricsFetcher returns the default implementation of MetricsFetcher.

Types

type MalachiteMetricsFetcher added in v0.3.0 

type MalachiteMetricsFetcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*MalachiteMetricsFetcher) AggregateCoreMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) AggregateCoreMetric(cpuset machine.CPUSet, metricName string, agg utilmetric.Aggregator) utilmetric.MetricData

func (*MalachiteMetricsFetcher) AggregatePodMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) AggregatePodMetric(podList []*v1.Pod, metricName string,
	agg utilmetric.Aggregator, filter utilmetric.ContainerMetricFilter) utilmetric.MetricData

func (*MalachiteMetricsFetcher) AggregatePodNumaMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) AggregatePodNumaMetric(podList []*v1.Pod, numaNode, metricName string,
	agg utilmetric.Aggregator, filter utilmetric.ContainerMetricFilter) utilmetric.MetricData

func (*MalachiteMetricsFetcher) DeRegisterNotifier added in v0.3.0 

func (m *MalachiteMetricsFetcher) DeRegisterNotifier(scope metric.MetricsScope, key string)

func (*MalachiteMetricsFetcher) GetCPUMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) GetCPUMetric(coreID int, metricName string) (utilmetric.MetricData, error)

func (*MalachiteMetricsFetcher) GetCgroupMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) GetCgroupMetric(cgroupPath, metricName string) (utilmetric.MetricData, error)

func (*MalachiteMetricsFetcher) GetCgroupNumaMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) GetCgroupNumaMetric(cgroupPath, numaNode, metricName string) (utilmetric.MetricData, error)

func (*MalachiteMetricsFetcher) GetContainerMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) GetContainerMetric(podUID, containerName, metricName string) (utilmetric.MetricData, error)

func (*MalachiteMetricsFetcher) GetContainerNumaMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) GetContainerNumaMetric(podUID, containerName, numaNode, metricName string) (utilmetric.MetricData, error)

func (*MalachiteMetricsFetcher) GetDeviceMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) GetDeviceMetric(deviceName string, metricName string) (utilmetric.MetricData, error)

func (*MalachiteMetricsFetcher) GetNodeMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) GetNodeMetric(metricName string) (utilmetric.MetricData, error)

func (*MalachiteMetricsFetcher) GetNumaMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) GetNumaMetric(numaID int, metricName string) (utilmetric.MetricData, error)

func (*MalachiteMetricsFetcher) RegisterExternalMetric added in v0.3.0 

func (m *MalachiteMetricsFetcher) RegisterExternalMetric(f func(store *utilmetric.MetricStore))

func (*MalachiteMetricsFetcher) RegisterNotifier added in v0.3.0 

func (m *MalachiteMetricsFetcher) RegisterNotifier(scope metric.MetricsScope, req metric.NotifiedRequest,
	response chan metric.NotifiedResponse) string

func (*MalachiteMetricsFetcher) Run added in v0.3.0 

func (m *MalachiteMetricsFetcher) Run(ctx context.Context)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.