resourcemonitor

package
v0.19.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2024 License: Apache-2.0 Imports: 26 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ComputePodFingerprint added in v0.6.1

func ComputePodFingerprint(podRes []*podresourcesapi.PodResources, st *podfingerprint.Status, allowFilter func(*podresourcesapi.PodResources) bool) string

func ContainerDevicesToPerNUMAResourceCounters added in v0.1.1

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

func GetAllContainerDevices added in v0.1.1

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

func MakeCoreIDToNodeIDMap added in v0.1.1

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

func NewResourceMonitor added in v0.1.1

func NewResourceMonitor(hnd Handle, args Args, options ...func(*resourceMonitor)) (*resourceMonitor, error)

func NormalizeContainerDevices added in v0.1.1

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

func PFPMethodIsSupported added in v0.12.0

func PFPMethodIsSupported(value string) (string, error)

func PFPMethodSupported added in v0.12.0

func PFPMethodSupported() string

func WithK8sClient added in v0.7.0

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

func WithNodeName added in v0.7.0

func WithNodeName(name string) func(*resourceMonitor)

func WithTopology added in v0.7.0

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

Types

type Args

type Args struct {
	Namespace                   string          `json:"namespace,omitempty"`
	SysfsRoot                   string          `json:"sysfsRoot,omitempty"`
	ResourceExclude             ResourceExclude `json:"resourceExclude,omitempty"`
	RefreshNodeResources        bool            `json:"refreshNodeResources,omitempty"`
	PodSetFingerprint           bool            `json:"podSetFingerprint,omitempty"`
	PodSetFingerprintMethod     string          `json:"podSetFingerprintMethod,omitempty"`
	ExposeTiming                bool            `json:"exposeTiming,omitempty"`
	PodSetFingerprintStatusFile string          `json:"podSetFingerprintStatusFile,omitempty"`
	PodExclude                  podexclude.List `json:"podExclude,omitempty"`
	ExcludeTerminalPods         bool            `json:"excludeTerminalPods,omitempty"`
}

func (Args) Clone added in v0.17.0

func (args Args) Clone() Args

type Handle added in v0.11.100

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

type ResourceExclude added in v0.11.0

type ResourceExclude map[string][]string

func (ResourceExclude) Clone added in v0.17.0

func (re ResourceExclude) Clone() map[string][]string

func (ResourceExclude) String added in v0.11.0

func (rel ResourceExclude) String() string

func (ResourceExclude) ToMapSet added in v0.11.0

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

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

type ResourceMonitor added in v0.1.1

type ResourceMonitor interface {
	Scan(excludeList ResourceExclude) (ScanResponse, error)
}

type ScanResponse added in v0.10.0

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

func (ScanResponse) SortedZones added in v0.10.0

func (sr ScanResponse) SortedZones() v1alpha2.ZoneList

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL