resourcemonitor

Documentation

Index

• func ComputePodFingerprint(podRes []*podresourcesapi.PodResources) string
• func ContainerDevicesToPerNUMAResourceCounters(devices []*podresourcesapi.ContainerDevices) perNUMAResourceCounter
• func GetAllContainerDevices(podRes []*podresourcesapi.PodResources, namespace string, ...) []*podresourcesapi.ContainerDevices
• func MakeCoreIDToNodeIDMap(topo *ghw.TopologyInfo) map[int]int
• func NewResourceMonitor(podResCli podresourcesapi.PodResourcesListerClient, args Args, ...) (*resourceMonitor, error)
• func NormalizeContainerDevices(devices []*podresourcesapi.ContainerDevices, ...) []*podresourcesapi.ContainerDevices
• func WithK8sClient(c kubernetes.Interface) func(*resourceMonitor)
• func WithNodeName(name string) func(*resourceMonitor)
• func WithTopology(topo *ghw.TopologyInfo) func(*resourceMonitor)
• type Args
• type ResourceExcludeList
  • func (rel ResourceExcludeList) String() string
  • func (rel ResourceExcludeList) ToMapSet() map[string]sets.String
• type ResourceMonitor

Functions

func ComputePodFingerprint

func ComputePodFingerprint(podRes []*podresourcesapi.PodResources) string

func ContainerDevicesToPerNUMAResourceCounters

func ContainerDevicesToPerNUMAResourceCounters(devices []*podresourcesapi.ContainerDevices) perNUMAResourceCounter

func GetAllContainerDevices

func GetAllContainerDevices(podRes []*podresourcesapi.PodResources, namespace string, coreIDToNodeIDMap map[int]int) []*podresourcesapi.ContainerDevices

func MakeCoreIDToNodeIDMap

func MakeCoreIDToNodeIDMap(topo *ghw.TopologyInfo) map[int]int

func NewResourceMonitor

func NewResourceMonitor(podResCli podresourcesapi.PodResourcesListerClient, args Args, options ...func(*resourceMonitor)) (*resourceMonitor, error)

func NormalizeContainerDevices

func NormalizeContainerDevices(devices []*podresourcesapi.ContainerDevices, memoryBlocks []*podresourcesapi.ContainerMemory, cpuIds []int64, coreIDToNodeIDMap map[int]int) []*podresourcesapi.ContainerDevices

func WithK8sClient

func WithK8sClient(c kubernetes.Interface) func(*resourceMonitor)

func WithNodeName

func WithNodeName(name string) func(*resourceMonitor)

func WithTopology

func WithTopology(topo *ghw.TopologyInfo) func(*resourceMonitor)

Types

type Args

type Args struct {
	Namespace            string
	SysfsRoot            string
	ExcludeList          ResourceExcludeList
	RefreshNodeResources bool
	PodSetFingerprint    bool
	ExposeTiming         bool
}

type ResourceExcludeList

type ResourceExcludeList map[string][]string

func (ResourceExcludeList) String

func (rel ResourceExcludeList) String() string

func (ResourceExcludeList) ToMapSet

func (rel ResourceExcludeList) ToMapSet() map[string]sets.String

ToMapSet keeps the original keys, but replaces values with set.String types

type ResourceMonitor

type ResourceMonitor interface {
	Scan(excludeList ResourceExcludeList) (topologyv1alpha1.ZoneList, map[string]string, error)
}