resourcemonitor

Documentation

Index

• func ComputePodFingerprint(podRes []*podresourcesapi.PodResources, st *podfingerprint.Status) 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
• type ScanResponse
  • func (sr ScanResponse) SortedZones() v1alpha2.ZoneList

Functions

func ComputePodFingerprint

func ComputePodFingerprint(podRes []*podresourcesapi.PodResources, st *podfingerprint.Status) 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
	PodSetFingerprintStatusFile string
}

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) (ScanResponse, error)
}

type ScanResponse

type ScanResponse struct {
	Zones       v1alpha2.ZoneList
	Attributes  v1alpha2.AttributeList
	Annotations map[string]string
}

func (ScanResponse) SortedZones

func (sr ScanResponse) SortedZones() v1alpha2.ZoneList