metricscollector

Documentation

Index

• type MetricsCollector
  • func NewMetricsCollector(nodeLister listercorev1.NodeLister, metricsClientset metricsclient.Interface, ...) *MetricsCollector
  • func (mc *MetricsCollector) AllNodesUsage() (map[string]map[v1.ResourceName]*resource.Quantity, error)
  • func (mc *MetricsCollector) Collect(ctx context.Context) error
  • func (mc *MetricsCollector) HasSynced() bool
  • func (mc *MetricsCollector) MetricsClient() metricsclient.Interface
  • func (mc *MetricsCollector) NodeUsage(node *v1.Node) (map[v1.ResourceName]*resource.Quantity, error)
  • func (mc *MetricsCollector) Run(ctx context.Context)

Types

type MetricsCollector

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

func NewMetricsCollector

func NewMetricsCollector(nodeLister listercorev1.NodeLister, metricsClientset metricsclient.Interface, nodeSelector labels.Selector) *MetricsCollector

func (*MetricsCollector) AllNodesUsage

func (mc *MetricsCollector) AllNodesUsage() (map[string]map[v1.ResourceName]*resource.Quantity, error)

func (*MetricsCollector) Collect

func (mc *MetricsCollector) Collect(ctx context.Context) error

func (*MetricsCollector) HasSynced

func (mc *MetricsCollector) HasSynced() bool

func (*MetricsCollector) MetricsClient

func (mc *MetricsCollector) MetricsClient() metricsclient.Interface

func (*MetricsCollector) NodeUsage

func (mc *MetricsCollector) NodeUsage(node *v1.Node) (map[v1.ResourceName]*resource.Quantity, error)

func (*MetricsCollector) Run

func (mc *MetricsCollector) Run(ctx context.Context)