scheduling

package

v0.6.0 Latest Latest Go to latest Published: Feb 1, 2022 License: Apache-2.0 Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

func IgnoredForTopology(p *v1.Pod) bool

func TopologyListOptions(namespace string, constraint *v1.TopologySpreadConstraint) *client.ListOptions

type Schedule struct {
	*v1alpha5.Constraints
	// Pods is a set of pods that may schedule to the node; used for binpacking.
	Pods []*v1.Pod
}

type Scheduler struct {
	KubeClient client.Client
	Topology   *Topology
}

func NewScheduler(kubeClient client.Client) *Scheduler

func (s *Scheduler) Solve(ctx context.Context, provisioner *v1alpha5.Provisioner, pods []*v1.Pod) (schedules []*Schedule, err error)

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

func (t *Topology) Inject(ctx context.Context, constraints *v1alpha5.Constraints, pods []*v1.Pod) error

Inject injects topology rules into pods using supported NodeSelectors

type TopologyGroup struct {
	Constraint v1.TopologySpreadConstraint
	Pods       []*v1.Pod
	// contains filtered or unexported fields
}

TopologyGroup is a set of pods that share a topology spread constraint

func NewTopologyGroup(pod *v1.Pod, constraint v1.TopologySpreadConstraint) *TopologyGroup

func (t *TopologyGroup) Increment(domain string)

Increment increments the spread of a registered domain

func (t *TopologyGroup) NextDomain(requirement sets.String) string

NextDomain chooses a domain within the constraints that minimizes skew

func (t *TopologyGroup) Register(domains ...string)