type ResourceConstraint … type SingleContainerSummary … type ContainerResourceUsage … type ResourceUsagePerContainer … type ResourceUsageSummary … // PrintHumanReadable prints resource usage summary in human readable. func (s *ResourceUsageSummary) PrintHumanReadable() string { … } // PrintJSON prints resource usage summary in JSON. func (s *ResourceUsageSummary) PrintJSON() string { … } // SummaryKind returns string of ResourceUsageSummary func (s *ResourceUsageSummary) SummaryKind() string { … } type uint64arr … func (a uint64arr) Len() int { … } func (a uint64arr) Swap(i, j int) { … } func (a uint64arr) Less(i, j int) bool { … } type usageDataPerContainer … func computePercentiles(timeSeries []ResourceUsagePerContainer, percentilesToCompute []int) map[int]ResourceUsagePerContainer { … } func leftMergeData(left, right map[int]ResourceUsagePerContainer) map[int]ResourceUsagePerContainer { … } type resourceGatherWorker … func (w *resourceGatherWorker) singleProbe(ctx context.Context) { … } // getOneTimeResourceUsageOnNode queries the node's /stats/summary endpoint // and returns the resource usage of all containerNames for the past // cpuInterval. // The acceptable range of the interval is 2s~120s. Be warned that as the // interval (and #containers) increases, the size of kubelet's response // could be significant. E.g., the 60s interval stats for ~20 containers is // ~1.5MB. Don't hammer the node with frequent, heavy requests. // // cadvisor records cumulative cpu usage in nanoseconds, so we need to have two // stats points to compute the cpu usage over the interval. Assuming cadvisor // polls every second, we'd need to get N stats points for N-second interval. // Note that this is an approximation and may not be accurate, hence we also // write the actual interval used for calculation (based on the timestamps of // the stats points in ContainerResourceUsage.CPUInterval. // // containerNames is a function returning a collection of container names in which // user is interested in. func getOneTimeResourceUsageOnNode( c clientset.Interface, nodeName string, cpuInterval time.Duration, containerNames func() []string, ) (ResourceUsagePerContainer, error) { … } // getStatsSummary contacts kubelet for the container information. func getStatsSummary(c clientset.Interface, nodeName string) (*kubeletstatsv1alpha1.Summary, error) { … } func removeUint64Ptr(ptr *uint64) uint64 { … } func (w *resourceGatherWorker) gather(ctx context.Context, initialSleep time.Duration) { … } type ContainerResourceGatherer … type ResourceGathererOptions … type NodesSet … const AllNodes … const MasterNodes … const MasterAndDNSNodes … // nodeHasControlPlanePods returns true if specified node has control plane pods // (kube-scheduler and/or kube-controller-manager). func nodeHasControlPlanePods(ctx context.Context, c clientset.Interface, nodeName string) (bool, error) { … } // NewResourceUsageGatherer returns a new ContainerResourceGatherer. func NewResourceUsageGatherer(ctx context.Context, c clientset.Interface, options ResourceGathererOptions, pods *v1.PodList) (*ContainerResourceGatherer, error) { … } // StartGatheringData starts a stat gathering worker blocks for each node to track, // and blocks until StopAndSummarize is called. func (g *ContainerResourceGatherer) StartGatheringData(ctx context.Context) { … } // StopAndSummarize stops stat gathering workers, processes the collected stats, // generates resource summary for the passed-in percentiles, and returns the summary. // It returns an error if the resource usage at any percentile is beyond the // specified resource constraints. func (g *ContainerResourceGatherer) StopAndSummarize(percentiles []int, constraints map[string]ResourceConstraint) (*ResourceUsageSummary, error) { … } type kubemarkResourceUsage … func getMasterUsageByPrefix(ctx context.Context, prefix string) (string, error) { … } // getKubemarkMasterComponentsResourceUsage returns the resource usage of kubemark which contains multiple combinations of cpu and memory usage for each pod name. func getKubemarkMasterComponentsResourceUsage(ctx context.Context) map[string]*kubemarkResourceUsage { … }
Codebase Browser
kubernetes