func init() { … } const metricsPath … const cadvisorMetricsPath … const resourceMetricsPath … const proberMetricsPath … const statsPath … const logsPath … const checkpointPath … const pprofBasePath … const debugFlagPath … const podsPath … const runningPodsPath … type Server … type TLSOptions … type containerInterface … type filteringContainer … func (a *filteringContainer) Handle(path string, handler http.Handler) { … } func (a *filteringContainer) RegisteredHandlePaths() []string { … } // ListenAndServeKubeletServer initializes a server to respond to HTTP network requests on the Kubelet. func ListenAndServeKubeletServer( host HostInterface, resourceAnalyzer stats.ResourceAnalyzer, kubeCfg *kubeletconfiginternal.KubeletConfiguration, tlsOptions *TLSOptions, auth AuthInterface, tp oteltrace.TracerProvider) { … } // ListenAndServeKubeletReadOnlyServer initializes a server to respond to HTTP network requests on the Kubelet. func ListenAndServeKubeletReadOnlyServer( host HostInterface, resourceAnalyzer stats.ResourceAnalyzer, address net.IP, port uint, tp oteltrace.TracerProvider) { … } // ListenAndServePodResources initializes a gRPC server to serve the PodResources service func ListenAndServePodResources(endpoint string, providers podresources.PodResourcesProviders) { … } type NodeRequestAttributesGetter … type AuthInterface … type HostInterface … // NewServer initializes and configures a kubelet.Server object to handle HTTP requests. func NewServer( host HostInterface, resourceAnalyzer stats.ResourceAnalyzer, auth AuthInterface, kubeCfg *kubeletconfiginternal.KubeletConfiguration) Server { … } // InstallAuthFilter installs authentication filters with the restful Container. func (s *Server) InstallAuthFilter() { … } // InstallTracingFilter installs OpenTelemetry tracing filter with the restful Container. func (s *Server) InstallTracingFilter(tp oteltrace.TracerProvider, opts ...otelrestful.Option) { … } // addMetricsBucketMatcher adds a regexp matcher and the relevant bucket to use when // it matches. Please be aware this is not thread safe and should not be used dynamically func (s *Server) addMetricsBucketMatcher(bucket string) { … } // getMetricBucket find the appropriate metrics reporting bucket for the given path func (s *Server) getMetricBucket(path string) string { … } // getMetricMethodBucket checks for unknown or invalid HTTP verbs func (s *Server) getMetricMethodBucket(method string) string { … } // InstallDefaultHandlers registers the default set of supported HTTP request // patterns with the restful Container. func (s *Server) InstallDefaultHandlers() { … } // InstallDebuggingHandlers registers the HTTP request patterns that serve logs or run commands/containers func (s *Server) InstallDebuggingHandlers() { … } // InstallDebuggingDisabledHandlers registers the HTTP request patterns that provide better error message func (s *Server) InstallDebuggingDisabledHandlers() { … } // InstallSystemLogHandler registers the HTTP request patterns for logs endpoint. func (s *Server) InstallSystemLogHandler(enableSystemLogHandler bool, enableSystemLogQuery bool) { … } func getHandlerForDisabledEndpoint(errorMessage string) http.HandlerFunc { … } // InstallDebugFlagsHandler registers the HTTP request patterns for /debug/flags/v endpoint. func (s *Server) InstallDebugFlagsHandler(enableDebugFlagsHandler bool) { … } // InstallProfilingHandler registers the HTTP request patterns for /debug/pprof endpoint. func (s *Server) InstallProfilingHandler(enableProfilingLogHandler bool, enableContentionProfiling bool) { … } // getContainerLogs handles containerLogs request against the Kubelet func (s *Server) getContainerLogs(request *restful.Request, response *restful.Response) { … } // encodePods creates an v1.PodList object from pods and returns the encoded // PodList. func encodePods(pods []*v1.Pod) (data []byte, err error) { … } // getPods returns a list of pods bound to the Kubelet and their spec. func (s *Server) getPods(request *restful.Request, response *restful.Response) { … } // getRunningPods returns a list of pods running on Kubelet. The list is // provided by the container runtime, and is different from the list returned // by getPods, which is a set of desired pods to run. func (s *Server) getRunningPods(request *restful.Request, response *restful.Response) { … } // getLogs handles logs requests against the Kubelet. func (s *Server) getLogs(request *restful.Request, response *restful.Response) { … } type execRequestParams … func getExecRequestParams(req *restful.Request) execRequestParams { … } type portForwardRequestParams … func getPortForwardRequestParams(req *restful.Request) portForwardRequestParams { … } type responder … func (r *responder) Error(w http.ResponseWriter, req *http.Request, err error) { … } // proxyStream proxies stream to url. func proxyStream(w http.ResponseWriter, r *http.Request, url *url.URL) { … } // getAttach handles requests to attach to a container. func (s *Server) getAttach(request *restful.Request, response *restful.Response) { … } // getExec handles requests to run a command inside a container. func (s *Server) getExec(request *restful.Request, response *restful.Response) { … } // getRun handles requests to run a command inside a container. func (s *Server) getRun(request *restful.Request, response *restful.Response) { … } // Derived from go-restful writeJSON. func writeJSONResponse(response *restful.Response, data []byte) { … } // getPortForward handles a new restful port forward request. It determines the // pod name and uid and then calls ServePortForward. func (s *Server) getPortForward(request *restful.Request, response *restful.Response) { … } // checkpoint handles the checkpoint API request. It checks if the requested // podNamespace, pod and container actually exist and only then calls out // to the runtime to actually checkpoint the container. func (s *Server) checkpoint(request *restful.Request, response *restful.Response) { … } // getURLRootPath trims a URL path. // For paths in the format of "/metrics/xxx", "metrics/xxx" is returned; // For all other paths, the first part of the path is returned. func getURLRootPath(path string) string { … } var longRunningRequestPathMap … // isLongRunningRequest determines whether the request is long-running or not. func isLongRunningRequest(path string) bool { … } var statusesNoTracePred … // ServeHTTP responds to HTTP requests on the Kubelet. func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request) { … } type prometheusHostAdapter … func (a prometheusHostAdapter) GetRequestedContainersInfo(containerName string, options cadvisorv2.RequestOptions) (map[string]*cadvisorapi.ContainerInfo, error) { … } func (a prometheusHostAdapter) GetVersionInfo() (*cadvisorapi.VersionInfo, error) { … } func (a prometheusHostAdapter) GetMachineInfo() (*cadvisorapi.MachineInfo, error) { … } func containerPrometheusLabelsFunc(s stats.Provider) metrics.ContainerLabelsFunc { … }
Codebase Browser
kubernetes