preferencebinpack

Documentation

Index

• func NewPreferenceBinPack(frameworkHandle framework.Handle) (framework.Plugin, error)
• func Plan(rsp *ReplicaSchedulingPreference, totalReplicas int64, ...) (map[string]int64, map[string]int64, error)
• type ClusterPreferences
• type PreferenceBinPack
  • func (pl *PreferenceBinPack) Name() string
  • func (pl *PreferenceBinPack) ReplicaScheduling(ctx context.Context, su *framework.SchedulingUnit, ...) (framework.ClusterReplicasList, *framework.Result)
• type ReplicaSchedulingPreference

Functions

func NewPreferenceBinPack

func NewPreferenceBinPack(frameworkHandle framework.Handle) (framework.Plugin, error)

func Plan

func Plan(
	rsp *ReplicaSchedulingPreference,
	totalReplicas int64,
	availableClusters []string,
	currentReplicaCount map[string]int64,
	estimatedCapacity map[string]int64,
	limitedCapacity map[string]int64,
	avoidDisruption bool,
	keepUnschedulableReplicas bool,
	scheduledReplicas map[string]int64,
) (map[string]int64, map[string]int64, error)

Types

type ClusterPreferences

type ClusterPreferences struct {
	// Minimum number of replicas that should be assigned to this cluster workload object. 0 by default.
	MinReplicas int64

	// Maximum number of replicas that should be assigned to this cluster workload object.
	// Unbounded if no value provided (default).
	MaxReplicas *int64
}

ClusterPreferences regarding number of replicas assigned to a cluster workload object (dep, rs, ..) within a federated workload object.

type PreferenceBinPack

type PreferenceBinPack struct{}

func (*PreferenceBinPack) Name

func (pl *PreferenceBinPack) Name() string

func (*PreferenceBinPack) ReplicaScheduling

func (pl *PreferenceBinPack) ReplicaScheduling(
	ctx context.Context,
	su *framework.SchedulingUnit,
	clusters []*fedcorev1a1.FederatedCluster,
) (framework.ClusterReplicasList, *framework.Result)

type ReplicaSchedulingPreference

type ReplicaSchedulingPreference struct {
	Clusters map[string]ClusterPreferences
}