metrics_plugin

Sep 3, 2024

Changes in this version

+ func GetPluginInitializers() map[string]InitFunc

+ func RegisterPluginInitializer(name string, initFunc InitFunc)

+ type DummyMetricsPlugin struct

+ NodeMetricsScopes []string

+ PodMetricsScopes []string

+ func (d DummyMetricsPlugin) GetSupportedNodeMetricsScope() []string

+ func (d DummyMetricsPlugin) GetSupportedPodMetricsScope() []string

+ func (d DummyMetricsPlugin) Name() string

+ func (d DummyMetricsPlugin) Run()

+ type InitFunc func(ctx context.Context, conf *controller.NPDConfig, extraConf interface{}, ...) (MetricsPlugin, error)

+ type MetricsGetter interface

+ DeleteNodeProfileStatus func(name string)

+ GetNodeProfileStatus func(name string) *v1alpha1.NodeProfileDescriptorStatus

+ GetNodeProfileStatusQueue func() workqueue.RateLimitingInterface

+ type MetricsManager struct

+ func NewMetricsManager() *MetricsManager

+ func (im *MetricsManager) DeleteNodeProfileStatus(name string)

+ func (im *MetricsManager) GetNodeProfileStatus(name string) *v1alpha1.NodeProfileDescriptorStatus

+ func (im *MetricsManager) GetNodeProfileStatusQueue() workqueue.RateLimitingInterface

+ func (im *MetricsManager) UpdateNodeMetrics(name string, scopedNodeMetrics []v1alpha1.ScopedNodeMetrics)

+ func (im *MetricsManager) UpdatePodMetrics(nodeName string, scopedPodMetrics []v1alpha1.ScopedPodMetrics)

+ type MetricsPlugin interface

+ GetSupportedNodeMetricsScope func() []string

+ GetSupportedPodMetricsScope func() []string

+ Name func() string

+ Run func()

+ type MetricsUpdater interface

+ UpdateNodeMetrics func(name string, scopedNodeMetrics []v1alpha1.ScopedNodeMetrics)

+ UpdatePodMetrics func(nodeName string, scopedPodMetrics []v1alpha1.ScopedPodMetrics)