cluster_info

package
v0.4.13 Latest Latest
Warning

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

Go to latest
Published: Aug 18, 2025 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewK8sNodePodAffinityInfo

func NewK8sNodePodAffinityInfo(
	node *v1.Node, clusterPodAffinityInfo pod_affinity.ClusterPodAffinityInfo,
) pod_affinity.NodePodAffinityInfo

func UpdateQueueHierarchy

func UpdateQueueHierarchy(queues map[common_info.QueueID]*queue_info.QueueInfo)

UpdateQueueHierarchy iterates over a map containing multiple levels of queue hierarchies, and updates queues with child queues where relevant

Types

type ClusterInfo

type ClusterInfo struct {
	// contains filtered or unexported fields
}

func New

func New(
	informerFactory informers.SharedInformerFactory,
	kubeAiSchedulerInformerFactory kubeAiSchedulerinfo.SharedInformerFactory,
	nodePoolParams *conf.SchedulingNodePoolParams,
	restrictNodeScheduling bool,
	clusterPodAffinityInfo pod_affinity.ClusterPodAffinityInfo,
	includeCSIStorageObjects bool,
	fullHierarchyFairness bool,
	podGroupSync status_updater.PodGroupsSync,
) (*ClusterInfo, error)

func (*ClusterInfo) Snapshot

func (c *ClusterInfo) Snapshot() (*api.ClusterInfo, error)

type FairnessLevelType

type FairnessLevelType string
const (
	FullFairness         FairnessLevelType = "fullFairness"
	ProjectLevelFairness FairnessLevelType = "projectLevelFairness"
)

type K8sNodePodAffinityInfo

type K8sNodePodAffinityInfo struct {
	NodeInfo *k8sframework.NodeInfo
	// contains filtered or unexported fields
}

func (*K8sNodePodAffinityInfo) AddPod

func (ni *K8sNodePodAffinityInfo) AddPod(pod *v1.Pod)

func (*K8sNodePodAffinityInfo) HasPodsWithPodAffinity

func (ni *K8sNodePodAffinityInfo) HasPodsWithPodAffinity() bool

func (*K8sNodePodAffinityInfo) HasPodsWithPodAntiAffinity

func (ni *K8sNodePodAffinityInfo) HasPodsWithPodAntiAffinity() bool

func (*K8sNodePodAffinityInfo) Name

func (ni *K8sNodePodAffinityInfo) Name() string

func (*K8sNodePodAffinityInfo) RemovePod

func (ni *K8sNodePodAffinityInfo) RemovePod(pod *v1.Pod) error

Directories

Path Synopsis
Package data_lister is a generated GoMock package.
Package data_lister is a generated GoMock package.

Jump to

Keyboard shortcuts

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