stats

Documentation

Index

• type ByCreationTime
  • func (a ByCreationTime) Len() int
  • func (a ByCreationTime) Less(i, j int) bool
  • func (a ByCreationTime) Swap(i, j int)
• type LogMetricsService
  • func NewLogMetricsService() LogMetricsService
• type StatsProvider
  • func NewCRIStatsProvider(cadvisor cadvisor.Interface, resourceAnalyzer stats.ResourceAnalyzer, ...) *StatsProvider
  • func NewCadvisorStatsProvider(cadvisor cadvisor.Interface, resourceAnalyzer stats.ResourceAnalyzer, ...) *StatsProvider
  • func (p *StatsProvider) GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error)
  • func (p *StatsProvider) GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error)
  • func (p *StatsProvider) GetContainerInfo(podFullName string, podUID types.UID, containerName string, ...) (*cadvisorapiv1.ContainerInfo, error)
  • func (p *StatsProvider) GetRawContainerInfo(containerName string, req *cadvisorapiv1.ContainerInfoRequest, ...) (map[string]*cadvisorapiv1.ContainerInfo, error)
  • func (p *StatsProvider) HasDedicatedImageFs() (bool, error)
  • func (p *StatsProvider) RlimitStats() (*statsapi.RlimitStats, error)
  • func (p *StatsProvider) RootFsStats() (*statsapi.FsStats, error)

Types

type ByCreationTime

type ByCreationTime []containerInfoWithCgroup

ByCreationTime implements sort.Interface for []containerInfoWithCgroup based on the cinfo.Spec.CreationTime field.

func (ByCreationTime) Len

func (a ByCreationTime) Len() int

func (ByCreationTime) Less

func (a ByCreationTime) Less(i, j int) bool

func (ByCreationTime) Swap

func (a ByCreationTime) Swap(i, j int)

type LogMetricsService

type LogMetricsService interface {
	// contains filtered or unexported methods
}

func NewLogMetricsService

func NewLogMetricsService() LogMetricsService

type StatsProvider

type StatsProvider struct {
	// contains filtered or unexported fields
}

StatsProvider provides the stats of the node and the pod-managed containers.

func NewCRIStatsProvider

func NewCRIStatsProvider(
	cadvisor cadvisor.Interface,
	resourceAnalyzer stats.ResourceAnalyzer,
	podManager kubepod.Manager,
	runtimeCache kubecontainer.RuntimeCache,
	runtimeService internalapi.RuntimeService,
	imageService internalapi.ImageManagerService,
	logMetricsService LogMetricsService,
) *StatsProvider

NewCRIStatsProvider returns a StatsProvider that provides the node stats from cAdvisor and the container stats from CRI.

func NewCadvisorStatsProvider

func NewCadvisorStatsProvider(
	cadvisor cadvisor.Interface,
	resourceAnalyzer stats.ResourceAnalyzer,
	podManager kubepod.Manager,
	runtimeCache kubecontainer.RuntimeCache,
	imageService kubecontainer.ImageService,
) *StatsProvider

NewCadvisorStatsProvider returns a containerStatsProvider that provides both the node and the container stats from cAdvisor.

func (*StatsProvider) GetCgroupCPUAndMemoryStats

func (p *StatsProvider) GetCgroupCPUAndMemoryStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, error)

GetCgroupCPUAndMemoryStats returns the CPU and memory stats of the cgroup with the cgroupName. Note that this function doesn't generate filesystem stats.

func (*StatsProvider) GetCgroupStats

func (p *StatsProvider) GetCgroupStats(cgroupName string, updateStats bool) (*statsapi.ContainerStats, *statsapi.NetworkStats, error)

GetCgroupStats returns the stats of the cgroup with the cgroupName. Note that this function doesn't generate filesystem stats.

func (*StatsProvider) GetContainerInfo

func (p *StatsProvider) GetContainerInfo(podFullName string, podUID types.UID, containerName string, req *cadvisorapiv1.ContainerInfoRequest) (*cadvisorapiv1.ContainerInfo, error)

GetContainerInfo returns stats (from cAdvisor) for a container.

func (*StatsProvider) GetRawContainerInfo

func (p *StatsProvider) GetRawContainerInfo(containerName string, req *cadvisorapiv1.ContainerInfoRequest, subcontainers bool) (map[string]*cadvisorapiv1.ContainerInfo, error)

GetRawContainerInfo returns the stats (from cadvisor) for a non-Kubernetes container.

func (*StatsProvider) HasDedicatedImageFs

func (p *StatsProvider) HasDedicatedImageFs() (bool, error)

HasDedicatedImageFs returns true if a dedicated image filesystem exists for storing images.

func (*StatsProvider) RlimitStats

func (p *StatsProvider) RlimitStats() (*statsapi.RlimitStats, error)

func (*StatsProvider) RootFsStats

func (p *StatsProvider) RootFsStats() (*statsapi.FsStats, error)

RootFsStats returns the stats of the node root filesystem.