const kubeSchedulerPort … const kubeControllerManagerPort … const snapshotControllerPort … const kubeProxyPort … var MetricsGrabbingDisabledError … type Collection … type Grabber … // NewMetricsGrabber prepares for grabbing metrics data from several different // components. It should be called when those components are running because // it needs to communicate with them to determine for which components // metrics data can be retrieved. // // Collecting metrics data is an optional debug feature. Not all clusters will // support it. If disabled for a component, the corresponding Grab function // will immediately return an error derived from MetricsGrabbingDisabledError. func NewMetricsGrabber(ctx context.Context, c clientset.Interface, ec clientset.Interface, config *rest.Config, kubelets bool, scheduler bool, controllers bool, apiServer bool, clusterAutoscaler bool, snapshotController bool) (*Grabber, error) { … } func checkPodDebugHandlers(ctx context.Context, c clientset.Interface, requested bool, component, podName string) bool { … } // HasControlPlanePods returns true if metrics grabber was able to find control-plane pods func (g *Grabber) HasControlPlanePods() bool { … } // GrabFromKubelet returns metrics from kubelet func (g *Grabber) GrabFromKubelet(ctx context.Context, nodeName string) (KubeletMetrics, error) { … } // GrabresourceMetricsFromKubelet returns resource metrics from kubelet func (g *Grabber) GrabResourceMetricsFromKubelet(ctx context.Context, nodeName string) (KubeletMetrics, error) { … } func (g *Grabber) grabFromKubeletInternal(ctx context.Context, nodeName string, kubeletPort int, pathSuffix string) (KubeletMetrics, error) { … } func (g *Grabber) getMetricsFromNode(ctx context.Context, nodeName string, kubeletPort int, pathSuffix string) (string, error) { … } // GrabFromKubeProxy returns metrics from kube-proxy func (g *Grabber) GrabFromKubeProxy(ctx context.Context, nodeName string) (KubeProxyMetrics, error) { … } func (g *Grabber) grabFromKubeProxy(ctx context.Context, nodeName string) (string, error) { … } // GrabFromScheduler returns metrics from scheduler func (g *Grabber) GrabFromScheduler(ctx context.Context) (SchedulerMetrics, error) { … } // GrabFromClusterAutoscaler returns metrics from cluster autoscaler func (g *Grabber) GrabFromClusterAutoscaler(ctx context.Context) (ClusterAutoscalerMetrics, error) { … } // GrabFromControllerManager returns metrics from controller manager func (g *Grabber) GrabFromControllerManager(ctx context.Context) (ControllerManagerMetrics, error) { … } // GrabFromSnapshotController returns metrics from controller manager func (g *Grabber) GrabFromSnapshotController(ctx context.Context, podName string, port int) (SnapshotControllerMetrics, error) { … } // GrabFromAPIServer returns metrics from API server func (g *Grabber) GrabFromAPIServer(ctx context.Context) (APIServerMetrics, error) { … } // GrabMetricsSLIsFromAPIServer returns metrics from API server func (g *Grabber) GrabMetricsSLIsFromAPIServer(ctx context.Context) (APIServerMetrics, error) { … } func (g *Grabber) getMetricsFromAPIServer(ctx context.Context) (string, error) { … } func (g *Grabber) getMetricsSLIsFromAPIServer(ctx context.Context) (string, error) { … } // Grab returns metrics from corresponding component func (g *Grabber) Grab(ctx context.Context) (Collection, error) { … } // getMetricsFromPod retrieves metrics data from an insecure port. func (g *Grabber) getMetricsFromPod(ctx context.Context, client clientset.Interface, podName string, namespace string, port int) (string, error) { … } // getSecureMetricsFromPod retrieves metrics from a pod that uses TLS // and checks client credentials. Conceptually this function is // similar to "kubectl port-forward" + "kubectl get --raw // https://localhost:<port>/metrics". It uses the same credentials // as kubelet. func (g *Grabber) getSecureMetricsFromPod(ctx context.Context, podName string, namespace string, port int) (string, error) { … }
Codebase Browser
kubernetes