Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const SingleCallTimeout + func APICallToPerfData(apicalls *APIResponsiveness) *e2eperftype.PerfData + func LogSuspiciousLatency(latencyData []PodLatencyData, latencyDataLag []PodLatencyData, nodeCount int, ...) + func PodStartupLatencyToPerfData(latency *PodStartupLatency) *e2eperftype.PerfData + func PrettyPrintJSON(metrics interface{}) string + func PrintLatencies(latencies []PodLatencyData, header string) + func ResetMetrics(c clientset.Interface) error + func ResetSchedulerMetrics(c clientset.Interface, provider, cloudMasterName, masterHostname string) error + func VerifyLatencyWithinThreshold(threshold, actual LatencyMetric, metricName string) error + type APICall struct + Count int + Latency LatencyMetric + Resource string + Scope string + Subresource string + Verb string + type APIResponsiveness struct + APICalls []APICall + func HighLatencyRequests(c clientset.Interface, nodeCount int) (int, *APIResponsiveness, error) + func (a *APIResponsiveness) Len() int + func (a *APIResponsiveness) Less(i, j int) bool + func (a *APIResponsiveness) PrintHumanReadable() string + func (a *APIResponsiveness) PrintJSON() string + func (a *APIResponsiveness) SummaryKind() string + func (a *APIResponsiveness) Swap(i, j int) + type APIServerMetrics Metrics + func (m *APIServerMetrics) Equal(o APIServerMetrics) bool + type ClusterAutoscalerMetrics Metrics + func (m *ClusterAutoscalerMetrics) Equal(o ClusterAutoscalerMetrics) bool + type Collection struct + APIServerMetrics APIServerMetrics + ClusterAutoscalerMetrics ClusterAutoscalerMetrics + ControllerManagerMetrics ControllerManagerMetrics + KubeletMetrics map[string]KubeletMetrics + SchedulerMetrics SchedulerMetrics + type ComponentCollection Collection + func (m *ComponentCollection) ComputeClusterAutoscalerMetricsDelta(before Collection) + func (m *ComponentCollection) PrintHumanReadable() string + func (m *ComponentCollection) PrintJSON() string + func (m *ComponentCollection) SummaryKind() string + type ControllerManagerMetrics Metrics + func (m *ControllerManagerMetrics) Equal(o ControllerManagerMetrics) bool + type EtcdMetrics struct + BackendCommitDuration HistogramVec + MaxDatabaseSize float64 + PeerRoundTripTime HistogramVec + SnapshotSaveTotalDuration HistogramVec + WalFsyncDuration HistogramVec + func (l *EtcdMetrics) PrintHumanReadable() string + func (l *EtcdMetrics) PrintJSON() string + func (l *EtcdMetrics) SummaryKind() string + type EtcdMetricsCollector struct + func NewEtcdMetricsCollector() *EtcdMetricsCollector + func (mc *EtcdMetricsCollector) GetMetrics() *EtcdMetrics + func (mc *EtcdMetricsCollector) StartCollecting(interval time.Duration, provider string, masterHostname string) + func (mc *EtcdMetricsCollector) StopAndSummarize(provider string, masterHostname string) error + type Grabber struct + func NewMetricsGrabber(c clientset.Interface, ec clientset.Interface, kubelets bool, scheduler bool, ...) (*Grabber, error) + func (g *Grabber) Grab() (Collection, error) + func (g *Grabber) GrabFromAPIServer() (APIServerMetrics, error) + func (g *Grabber) GrabFromClusterAutoscaler() (ClusterAutoscalerMetrics, error) + func (g *Grabber) GrabFromControllerManager() (ControllerManagerMetrics, error) + func (g *Grabber) GrabFromKubelet(nodeName string) (KubeletMetrics, error) + func (g *Grabber) GrabFromScheduler() (SchedulerMetrics, error) + func (g *Grabber) HasRegisteredMaster() bool + type Histogram struct + Buckets map[string]int + Labels map[string]string + type HistogramVec []Histogram + type KubeletLatencyMetric struct + Latency time.Duration + Method string + Operation string + Quantile float64 + type KubeletLatencyMetrics []KubeletLatencyMetric + func GetDefaultKubeletLatencyMetrics(ms KubeletMetrics) KubeletLatencyMetrics + func GetKubeletLatencyMetrics(ms KubeletMetrics, filterMetricNames sets.String) KubeletLatencyMetrics + func HighLatencyKubeletOperations(c clientset.Interface, threshold time.Duration, nodeName string, ...) (KubeletLatencyMetrics, error) + func (a KubeletLatencyMetrics) Len() int + func (a KubeletLatencyMetrics) Less(i, j int) bool + func (a KubeletLatencyMetrics) Swap(i, j int) + type KubeletMetrics Metrics + func GetKubeletMetrics(c clientset.Interface, nodeName string) (KubeletMetrics, error) + func GrabKubeletMetricsWithoutProxy(nodeName, path string) (KubeletMetrics, error) + func NewKubeletMetrics() KubeletMetrics + func (m *KubeletMetrics) Equal(o KubeletMetrics) bool + type LatencyMetric struct + Perc100 time.Duration + Perc50 time.Duration + Perc90 time.Duration + Perc99 time.Duration + func ExtractLatencyMetrics(latencies []PodLatencyData) LatencyMetric + type LatencySlice []PodLatencyData + func (a LatencySlice) Len() int + func (a LatencySlice) Less(i, j int) bool + func (a LatencySlice) Swap(i, j int) + type Metrics map[string]model.Samples + func NewMetrics() Metrics + func (m *Metrics) Equal(o Metrics) bool + type PodLatencyData struct + Latency time.Duration + Name string + Node string + type PodStartupLatency struct + CreateToScheduleLatency LatencyMetric + E2ELatency LatencyMetric + RunToWatchLatency LatencyMetric + ScheduleToRunLatency LatencyMetric + ScheduleToWatchLatency LatencyMetric + func (l *PodStartupLatency) PrintHumanReadable() string + func (l *PodStartupLatency) PrintJSON() string + func (l *PodStartupLatency) SummaryKind() string + type SchedulerMetrics Metrics + func (m *SchedulerMetrics) Equal(o SchedulerMetrics) bool + type SchedulingMetrics struct + BindingLatency LatencyMetric + PredicateEvaluationLatency LatencyMetric + PreemptionEvaluationLatency LatencyMetric + PriorityEvaluationLatency LatencyMetric + ThroughputAverage float64 + ThroughputPerc50 float64 + ThroughputPerc90 float64 + ThroughputPerc99 float64 + func VerifySchedulerLatency(c clientset.Interface, provider, cloudMasterName, masterHostname string) (*SchedulingMetrics, error) + func (l *SchedulingMetrics) PrintHumanReadable() string + func (l *SchedulingMetrics) PrintJSON() string + func (l *SchedulingMetrics) SummaryKind() string