const proxyTimeout … const dockerOperationsLatencyKey … const kubeletSubsystem … const podWorkerDurationKey … const podStartDurationKey … const podStartSLIDurationKey … const cgroupManagerOperationsKey … const podWorkerStartDurationKey … const plegRelistDurationKey … type KubeletMetrics … // Equal returns true if all metrics are the same as the arguments. func (m *KubeletMetrics) Equal(o KubeletMetrics) bool { … } // NewKubeletMetrics returns new metrics which are initialized. func NewKubeletMetrics() KubeletMetrics { … } // GrabKubeletMetricsWithoutProxy retrieve metrics from the kubelet on the given node using a simple GET over http. func GrabKubeletMetricsWithoutProxy(ctx context.Context, nodeName, path string) (KubeletMetrics, error) { … } func parseKubeletMetrics(data string) (KubeletMetrics, error) { … } type KubeletLatencyMetric … type KubeletLatencyMetrics … func (a KubeletLatencyMetrics) Len() int { … } func (a KubeletLatencyMetrics) Swap(i, j int) { … } func (a KubeletLatencyMetrics) Less(i, j int) bool { … } // If a apiserver client is passed in, the function will try to get kubelet metrics from metrics grabber; // or else, the function will try to get kubelet metrics directly from the node. func getKubeletMetricsFromNode(ctx context.Context, c clientset.Interface, nodeName string) (KubeletMetrics, error) { … } // GetKubeletMetrics gets all metrics in kubelet subsystem from specified node and trims // the subsystem prefix. func GetKubeletMetrics(ctx context.Context, c clientset.Interface, nodeName string) (KubeletMetrics, error) { … } // GetDefaultKubeletLatencyMetrics calls GetKubeletLatencyMetrics with a set of default metricNames // identifying common latency metrics. // Note that the KubeletMetrics passed in should not contain subsystem prefix. func GetDefaultKubeletLatencyMetrics(ms KubeletMetrics) KubeletLatencyMetrics { … } // GetKubeletLatencyMetrics filters ms to include only those contained in the metricNames set, // then constructs a KubeletLatencyMetrics list based on the samples associated with those metrics. func GetKubeletLatencyMetrics(ms KubeletMetrics, filterMetricNames sets.String) KubeletLatencyMetrics { … } // HighLatencyKubeletOperations logs and counts the high latency metrics exported by the kubelet server via /metrics. func HighLatencyKubeletOperations(ctx context.Context, c clientset.Interface, threshold time.Duration, nodeName string, logFunc func(fmt string, args ...interface{ … }
Codebase Browser
kubernetes