kubernetes: k8s.io/kubernetes/test/e2e/framework/kubelet Index | Files

package kubelet

import "k8s.io/kubernetes/test/e2e/framework/kubelet"


Package Files

config.go kubelet_pods.go stats.go

func FormatRuntimeOperationErrorRate Uses

func FormatRuntimeOperationErrorRate(nodesResult map[string]NodeRuntimeOperationErrorRate) string

FormatRuntimeOperationErrorRate formats the runtime operation error rate to string.

func GetCurrentKubeletConfig Uses

func GetCurrentKubeletConfig(nodeName, namespace string, useProxy bool) (*kubeletconfig.KubeletConfiguration, error)

GetCurrentKubeletConfig fetches the current Kubelet Config for the given node

func GetKubeletHeapStats Uses

func GetKubeletHeapStats(c clientset.Interface, nodeName string) (string, error)

GetKubeletHeapStats returns stats of kubelet heap.

func GetKubeletPods Uses

func GetKubeletPods(c clientset.Interface, node string) (*v1.PodList, error)

GetKubeletPods retrieves the list of pods on the kubelet.

func GetKubeletRunningPods Uses

func GetKubeletRunningPods(c clientset.Interface, node string) (*v1.PodList, error)

GetKubeletRunningPods retrieves the list of running pods on the kubelet. The pods includes necessary information (e.g., UID, name, namespace for pods/containers), but do not contain the full spec.

func GetStatsSummary Uses

func GetStatsSummary(c clientset.Interface, nodeName string) (*kubeletstatsv1alpha1.Summary, error)

GetStatsSummary contacts kubelet for the container information.

func ProxyRequest Uses

func ProxyRequest(c clientset.Interface, node, endpoint string, port int) (restclient.Result, error)

ProxyRequest performs a get on a node proxy endpoint given the nodename and rest client.

func TargetContainers Uses

func TargetContainers() []string

TargetContainers returns a list of containers for which we want to collect resource usage.

type ContainerResourceUsage Uses

type ContainerResourceUsage struct {
    Name                    string
    Timestamp               time.Time
    CPUUsageInCores         float64
    MemoryUsageInBytes      uint64
    MemoryWorkingSetInBytes uint64
    MemoryRSSInBytes        uint64
    // The interval used to calculate CPUUsageInCores.
    CPUInterval time.Duration

ContainerResourceUsage is a structure for gathering container resource usage.

type ContainersCPUSummary Uses

type ContainersCPUSummary map[string]map[float64]float64

ContainersCPUSummary is indexed by the container name with each entry a (percentile, value) map.

type NodeRuntimeOperationErrorRate Uses

type NodeRuntimeOperationErrorRate map[string]*RuntimeOperationErrorRate

NodeRuntimeOperationErrorRate is the runtime operation error rate on one node.

type NodesCPUSummary Uses

type NodesCPUSummary map[string]ContainersCPUSummary

NodesCPUSummary is indexed by the node name with each entry a ContainersCPUSummary map.

type ResourceMonitor Uses

type ResourceMonitor struct {
    // contains filtered or unexported fields

ResourceMonitor manages a resourceCollector per node.

func NewResourceMonitor Uses

func NewResourceMonitor(c clientset.Interface, containerNames []string, pollingInterval time.Duration) *ResourceMonitor

NewResourceMonitor returns a new ResourceMonitor.

func (*ResourceMonitor) FormatCPUSummary Uses

func (r *ResourceMonitor) FormatCPUSummary(summary NodesCPUSummary) string

FormatCPUSummary returns the string of human-readable CPU summary from the specified summary data.

func (*ResourceMonitor) FormatResourceUsage Uses

func (r *ResourceMonitor) FormatResourceUsage(s ResourceUsagePerNode) string

FormatResourceUsage returns the formatted string for LogLatest(). TODO(oomichi): This can be made to local function after making test/e2e/node/kubelet_perf.go use LogLatest directly instead.

func (*ResourceMonitor) GetCPUSummary Uses

func (r *ResourceMonitor) GetCPUSummary() NodesCPUSummary

GetCPUSummary returns summary of CPU.

func (*ResourceMonitor) GetLatest Uses

func (r *ResourceMonitor) GetLatest() (ResourceUsagePerNode, error)

GetLatest returns the latest resource usage.

func (*ResourceMonitor) GetMasterNodeCPUSummary Uses

func (r *ResourceMonitor) GetMasterNodeCPUSummary(summaryPerNode NodesCPUSummary) NodesCPUSummary

GetMasterNodeCPUSummary returns summary of master node CPUs.

func (*ResourceMonitor) GetMasterNodeLatest Uses

func (r *ResourceMonitor) GetMasterNodeLatest(usagePerNode ResourceUsagePerNode) ResourceUsagePerNode

GetMasterNodeLatest returns the latest resource usage of master and node.

func (*ResourceMonitor) LogCPUSummary Uses

func (r *ResourceMonitor) LogCPUSummary()

LogCPUSummary outputs summary of CPU into log.

func (*ResourceMonitor) LogLatest Uses

func (r *ResourceMonitor) LogLatest()

LogLatest outputs the latest resource usage into log.

func (*ResourceMonitor) Reset Uses

func (r *ResourceMonitor) Reset()

Reset resets collectors.

func (*ResourceMonitor) Start Uses

func (r *ResourceMonitor) Start()

Start starts collectors.

func (*ResourceMonitor) Stop Uses

func (r *ResourceMonitor) Stop()

Stop stops collectors.

type ResourceUsagePerContainer Uses

type ResourceUsagePerContainer map[string]*ContainerResourceUsage

ResourceUsagePerContainer is map of ContainerResourceUsage

type ResourceUsagePerNode Uses

type ResourceUsagePerNode map[string]ResourceUsagePerContainer

ResourceUsagePerNode is map of ResourceUsagePerContainer.

type RuntimeOperationErrorRate Uses

type RuntimeOperationErrorRate struct {
    TotalNumber float64
    ErrorRate   float64
    TimeoutRate float64

RuntimeOperationErrorRate is the error rate of a specified runtime operation.

type RuntimeOperationMonitor Uses

type RuntimeOperationMonitor struct {
    // contains filtered or unexported fields

RuntimeOperationMonitor is the tool getting and parsing docker operation metrics.

func NewRuntimeOperationMonitor Uses

func NewRuntimeOperationMonitor(c clientset.Interface) *RuntimeOperationMonitor

NewRuntimeOperationMonitor returns a new RuntimeOperationMonitor.

func (*RuntimeOperationMonitor) GetLatestRuntimeOperationErrorRate Uses

func (m *RuntimeOperationMonitor) GetLatestRuntimeOperationErrorRate() map[string]NodeRuntimeOperationErrorRate

GetLatestRuntimeOperationErrorRate gets latest error rate and timeout rate from last observed RuntimeOperationErrorRate.

func (*RuntimeOperationMonitor) GetRuntimeOperationErrorRate Uses

func (m *RuntimeOperationMonitor) GetRuntimeOperationErrorRate() map[string]NodeRuntimeOperationErrorRate

GetRuntimeOperationErrorRate gets runtime operation records from kubelet metrics and calculate error rates of all runtime operations.

Package kubelet imports 27 packages (graph) and is imported by 116 packages. Updated 2020-12-25. Refresh now. Tools for package owners.