predicates

package

v0.6.21 Latest Latest Go to latest Published: May 7, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/NVIDIA/KAI-scheduler

Links

Documentation ¶

Index ¶

Constants
func NewSessionPredicates(ssn *framework.Session) k8s_internal.SessionPredicates
func NewSessionScorePredicates(ssn *framework.Session) *k8s_internal.SessionScoreFns
func NewVolumeBindingFilter(ssn *framework.Session, plugin k8sframework.Plugin, ...) k8s_internal.FitPredicateFilter
type ConfigMapPredicate
- func NewConfigMapPredicate(configmaps map[common_info.ConfigMapID]*configmap_info.ConfigMapInfo) *ConfigMapPredicate
- func (cmp *ConfigMapPredicate) PreFilter(ctx context.Context, _ ksf.CycleState, pod *v1.Pod, _ []ksf.NodeInfo) (*k8sframework.PreFilterResult, *ksf.Status)
type MaxNodeResourcesPredicate
- func NewMaxNodeResourcesPredicate(nodesMap map[string]*node_info.NodeInfo, nodePoolName string) *MaxNodeResourcesPredicate
- func (mnr *MaxNodeResourcesPredicate) PreFilter(_ context.Context, _ ksf.CycleState, pod *v1.Pod, _ []ksf.NodeInfo) (*k8sframework.PreFilterResult, *ksf.Status)

Constants ¶

View Source

const (
	PodFitsHostPorts       = "PodFitsHostPorts"
	PodToleratesNodeTaints = "PodToleratesNodeTaints"
	NodeAffinity           = "NodeAffinity"
	PodAffinity            = "PodAffinity"
	VolumeBinding          = "VolumeBinding"
	DynamicResources       = "DynamicResources"
	NodeScheduler          = "NodeScheduler"
	MaxNodePoolResources   = "MaxNodePoolResources"
	ConfigMap              = "ConfigMap"
)

Variables ¶

This section is empty.

Functions ¶

func NewSessionPredicates ¶

func NewSessionPredicates(ssn *framework.Session) k8s_internal.SessionPredicates

func NewSessionScorePredicates ¶

func NewSessionScorePredicates(ssn *framework.Session) *k8s_internal.SessionScoreFns

func NewVolumeBindingFilter ¶

func NewVolumeBindingFilter(ssn *framework.Session, plugin k8sframework.Plugin, ignoreInsufficientResources bool) k8s_internal.FitPredicateFilter

NewVolumeBindingFilter returns a function that wraps k8s internal volume binding filter, while ignoring insufficient resources error if configured to.

Types ¶

type ConfigMapPredicate ¶

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

func NewConfigMapPredicate ¶

func NewConfigMapPredicate(configmaps map[common_info.ConfigMapID]*configmap_info.ConfigMapInfo) *ConfigMapPredicate

func (*ConfigMapPredicate) PreFilter ¶

func (cmp *ConfigMapPredicate) PreFilter(ctx context.Context, _ ksf.CycleState, pod *v1.Pod, _ []ksf.NodeInfo) (
	*k8sframework.PreFilterResult, *ksf.Status)

type MaxNodeResourcesPredicate ¶

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

func NewMaxNodeResourcesPredicate ¶

func NewMaxNodeResourcesPredicate(nodesMap map[string]*node_info.NodeInfo, nodePoolName string) *MaxNodeResourcesPredicate

func (*MaxNodeResourcesPredicate) PreFilter ¶

func (mnr *MaxNodeResourcesPredicate) PreFilter(_ context.Context, _ ksf.CycleState, pod *v1.Pod, _ []ksf.NodeInfo) (
	*k8sframework.PreFilterResult, *ksf.Status)

Source Files ¶

View all Source files

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