metrics

Documentation

Index

• Constants
• func PrintSample(sample *model.Sample) string
• type ApiServerMetrics
  • func NewApiServerMetrics() ApiServerMetrics
  • func (m *ApiServerMetrics) Equal(o ApiServerMetrics) bool
• type ClusterAutoscalerMetrics
  • func NewClusterAutoscalerMetrics() ClusterAutoscalerMetrics
  • func (m *ClusterAutoscalerMetrics) Equal(o ClusterAutoscalerMetrics) bool
• type ControllerManagerMetrics
  • func NewControllerManagerMetrics() ControllerManagerMetrics
  • func (m *ControllerManagerMetrics) Equal(o ControllerManagerMetrics) bool
• type KubeletMetrics
  • func GrabKubeletMetricsWithoutProxy(nodeName string) (KubeletMetrics, error)
  • func NewKubeletMetrics() KubeletMetrics
  • func (m *KubeletMetrics) Equal(o KubeletMetrics) bool
• type Metrics
  • func NewMetrics() Metrics
  • func (m *Metrics) Equal(o Metrics) bool
• type MetricsCollection
• type MetricsGrabber
  • func NewMetricsGrabber(c clientset.Interface, ec clientset.Interface, kubelets bool, scheduler bool, ...) (*MetricsGrabber, error)
  • func (g *MetricsGrabber) Grab() (MetricsCollection, error)
  • func (g *MetricsGrabber) GrabFromApiServer() (ApiServerMetrics, error)
  • func (g *MetricsGrabber) GrabFromClusterAutoscaler() (ClusterAutoscalerMetrics, error)
  • func (g *MetricsGrabber) GrabFromControllerManager() (ControllerManagerMetrics, error)
  • func (g *MetricsGrabber) GrabFromKubelet(nodeName string) (KubeletMetrics, error)
  • func (g *MetricsGrabber) GrabFromScheduler() (SchedulerMetrics, error)
  • func (g *MetricsGrabber) HasRegisteredMaster() bool
• type SchedulerMetrics
  • func NewSchedulerMetrics() SchedulerMetrics
  • func (m *SchedulerMetrics) Equal(o SchedulerMetrics) bool

Constants

const (
	ProxyTimeout = 2 * time.Minute
)

Functions

func PrintSample

func PrintSample(sample *model.Sample) string

Types

type ApiServerMetrics

type ApiServerMetrics Metrics

func NewApiServerMetrics

func NewApiServerMetrics() ApiServerMetrics

func (*ApiServerMetrics) Equal

func (m *ApiServerMetrics) Equal(o ApiServerMetrics) bool

type ClusterAutoscalerMetrics

type ClusterAutoscalerMetrics Metrics

func NewClusterAutoscalerMetrics

func NewClusterAutoscalerMetrics() ClusterAutoscalerMetrics

func (*ClusterAutoscalerMetrics) Equal

func (m *ClusterAutoscalerMetrics) Equal(o ClusterAutoscalerMetrics) bool

type ControllerManagerMetrics

type ControllerManagerMetrics Metrics

func NewControllerManagerMetrics

func NewControllerManagerMetrics() ControllerManagerMetrics

func (*ControllerManagerMetrics) Equal

func (m *ControllerManagerMetrics) Equal(o ControllerManagerMetrics) bool

type KubeletMetrics

type KubeletMetrics Metrics

func GrabKubeletMetricsWithoutProxy

func GrabKubeletMetricsWithoutProxy(nodeName string) (KubeletMetrics, error)

GrabKubeletMetricsWithoutProxy retrieve metrics from the kubelet on the given node using a simple GET over http. Currently only used in integration tests.

func NewKubeletMetrics

func NewKubeletMetrics() KubeletMetrics

func (*KubeletMetrics) Equal

func (m *KubeletMetrics) Equal(o KubeletMetrics) bool

type Metrics

type Metrics map[string]model.Samples

func NewMetrics

func NewMetrics() Metrics

func (*Metrics) Equal

func (m *Metrics) Equal(o Metrics) bool

type MetricsCollection

type MetricsCollection struct {
	ApiServerMetrics         ApiServerMetrics
	ControllerManagerMetrics ControllerManagerMetrics
	KubeletMetrics           map[string]KubeletMetrics
	SchedulerMetrics         SchedulerMetrics
	ClusterAutoscalerMetrics ClusterAutoscalerMetrics
}

type MetricsGrabber

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

func NewMetricsGrabber

func NewMetricsGrabber(c clientset.Interface, ec clientset.Interface, kubelets bool, scheduler bool, controllers bool, apiServer bool, clusterAutoscaler bool) (*MetricsGrabber, error)

func (*MetricsGrabber) Grab

func (g *MetricsGrabber) Grab() (MetricsCollection, error)

func (*MetricsGrabber) GrabFromApiServer

func (g *MetricsGrabber) GrabFromApiServer() (ApiServerMetrics, error)

func (*MetricsGrabber) GrabFromClusterAutoscaler

func (g *MetricsGrabber) GrabFromClusterAutoscaler() (ClusterAutoscalerMetrics, error)

func (*MetricsGrabber) GrabFromControllerManager

func (g *MetricsGrabber) GrabFromControllerManager() (ControllerManagerMetrics, error)

func (*MetricsGrabber) GrabFromKubelet

func (g *MetricsGrabber) GrabFromKubelet(nodeName string) (KubeletMetrics, error)

func (*MetricsGrabber) GrabFromScheduler

func (g *MetricsGrabber) GrabFromScheduler() (SchedulerMetrics, error)

func (*MetricsGrabber) HasRegisteredMaster

func (g *MetricsGrabber) HasRegisteredMaster() bool

HasRegisteredMaster returns if metrics grabber was able to find a master node

type SchedulerMetrics

type SchedulerMetrics Metrics

func NewSchedulerMetrics

func NewSchedulerMetrics() SchedulerMetrics

func (*SchedulerMetrics) Equal

func (m *SchedulerMetrics) Equal(o SchedulerMetrics) bool