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(hnd Handle, args Args, options ...func(*resourceMonitor)) (*resourceMonitor, error)
• func NormalizeContainerDevices(devices []*podresourcesapi.ContainerDevices, ...) []*podresourcesapi.ContainerDevices
• func PFPMethodIsSupported(value string) (string, error)
• func PFPMethodSupported() string
• func WithK8sClient(c kubernetes.Interface) func(*resourceMonitor)
• func WithNodeName(name string) func(*resourceMonitor)
• func WithTopology(topo *ghw.TopologyInfo) func(*resourceMonitor)
• type Args
• type Handle
• type ResourceExclude
  • func (rel ResourceExclude) String() string
  • func (rel ResourceExclude) 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, allowFilter func(*podresourcesapi.PodResources) bool) 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(hnd Handle, 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 PFPMethodIsSupported

func PFPMethodIsSupported(value string) (string, error)

func PFPMethodSupported

func PFPMethodSupported() string

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
	ResourceExclude             ResourceExclude
	RefreshNodeResources        bool
	PodSetFingerprint           bool
	PodSetFingerprintMethod     string
	ExposeTiming                bool
	PodSetFingerprintStatusFile string
	PodExclude                  podexclude.List
	ExcludeTerminalPods         bool
}

type Handle

type Handle struct {
	PodResCli podresourcesapi.PodResourcesListerClient
	K8SCli    kubernetes.Interface
}

type ResourceExclude

type ResourceExclude map[string][]string

func (ResourceExclude) String

func (rel ResourceExclude) String() string

func (ResourceExclude) ToMapSet

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

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

type ResourceMonitor

type ResourceMonitor interface {
	Scan(excludeList ResourceExclude) (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