resourcemonitor

Documentation

Index

• 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 NewResourceMonitorWithTopology(nodeName string, topo *ghw.TopologyInfo, ...) (*resourceMonitor, error)
• func NormalizeContainerDevices(devices []*podresourcesapi.ContainerDevices, ...) []*podresourcesapi.ContainerDevices
• type Args
• type ResourceExcludeList
  • func (r *ResourceExcludeList) String() string
  • func (r *ResourceExcludeList) ToMapSet() map[string]sets.String
• type ResourceMonitor

Functions

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) (*resourceMonitor, error)

func NewResourceMonitorWithTopology

func NewResourceMonitorWithTopology(nodeName string, topo *ghw.TopologyInfo, podResCli podresourcesapi.PodResourcesListerClient, args Args) (*resourceMonitor, error)

func NormalizeContainerDevices

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

Types

type Args

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

type ResourceExcludeList

type ResourceExcludeList struct {
	ExcludeList map[string][]string
}

func (*ResourceExcludeList) String

func (r *ResourceExcludeList) String() string

func (*ResourceExcludeList) ToMapSet

func (r *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, error)
}