podpredicates

type FilterPredicate interface {
	Predicate
	Filter(ctx context.Context, hdl PodSetHandle, pod *v1.Pod, node *v1.Node) *framework.Status
}

type Option func(o *predicateOption)

type PodSetHandle interface {
	// ClientSet returns a k8s clientset
	ClientSet() clientset.Interface

	// List returns a list of pods for the podset on the node
	List(context.Context, *v1.Node) ([]*v1.Pod, error)
}

type Predicate interface {
	Name() string
}

type PredicateFactory func(handle PredicateHandle) (Predicate, error)

type PredicateHandle interface {
	CallTimeout() time.Duration
	Log(prefix string) logr.Logger
}

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

type Registry map[string]PredicateFactory

type Resource struct {
	MilliCPU         int64
	Memory           int64
	EphemeralStorage int64
	// We store allowedPodNumber (which is Node.Status.Allocatable.Pods().Value())
	// explicitly as int, to avoid conversions and improve performance.
	AllowedPodNumber int
	// ScalarResources
	ScalarResources map[v1.ResourceName]int64
}

type ScorePredicate interface {
	Predicate
	Score(ctx context.Context, hdl PodSetHandle, pod *v1.Pod, node *v1.Node) (int64, *framework.Status)
}