defaultassigner

Documentation

Index

• Constants
• func DynamicDivideReplicas(sub *appsapi.Subscription, deviations []appsapi.FeedOrder, ...) (framework.TargetClusters, error)
• func NewDynamicAssigner(_ runtime.Object, handle framework.Handle) (framework.Plugin, error)
• func NewStaticAssigner(_ runtime.Object, handle framework.Handle) (framework.Plugin, error)
• func StaticDivideReplicas(selected *framework.TargetClusters, sub *appsapi.Subscription, ...) error
• type DynamicAssigner
  • func (pl *DynamicAssigner) Assign(ctx context.Context, state *framework.CycleState, sub *appsapi.Subscription, ...) (framework.TargetClusters, *framework.Status)
  • func (pl *DynamicAssigner) Name() string
  • func (pl *DynamicAssigner) PreAssign(ctx context.Context, state *framework.CycleState, sub *appsapi.Subscription, ...) *framework.Status
• type StaticAssigner
  • func (pl *StaticAssigner) Assign(ctx context.Context, state *framework.CycleState, sub *appsapi.Subscription, ...) (framework.TargetClusters, *framework.Status)
  • func (pl *StaticAssigner) Name() string

Constants

const (
	// NameDynamicAssigner is the name of the plugin used in the plugin registry and configurations.
	NameDynamicAssigner = names.DynamicAssigner
)

const NameStaticAssigner = names.StaticAssigner

NameStaticAssigner is the name of the plugin used in the plugin registry and configurations.

Functions

func DynamicDivideReplicas

func DynamicDivideReplicas(sub *appsapi.Subscription, deviations []appsapi.FeedOrder, availableReplicas framework.TargetClusters) (framework.TargetClusters, error)

DynamicDivideReplicas will fill the target replicas of all feeds based on predictor result and deviation. First time scheduling is considered as a special kind of scaling. When the desired replicas in deviation are negative, it means we should try to scale down, otherwise we try to scale up deviation replicas.

func NewDynamicAssigner

func NewDynamicAssigner(_ runtime.Object, handle framework.Handle) (framework.Plugin, error)

NewDynamicAssigner creates a DefaultAssigner.

func NewStaticAssigner

func NewStaticAssigner(_ runtime.Object, handle framework.Handle) (framework.Plugin, error)

NewStaticAssigner creates a Default Assigner.

func StaticDivideReplicas

func StaticDivideReplicas(selected *framework.TargetClusters, sub *appsapi.Subscription, clusters []*clusterapi.ManagedCluster, finv *appsapi.FeedInventory) error

StaticDivideReplicas will fill the target replicas of all feeds based on a weight list and feed finv.

Types

type DynamicAssigner

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

DynamicAssigner assigns replicas to clusters.

func (*DynamicAssigner) Assign

func (pl *DynamicAssigner) Assign(ctx context.Context, state *framework.CycleState, sub *appsapi.Subscription, finv *appsapi.FeedInventory, availableReplicas framework.TargetClusters) (framework.TargetClusters, *framework.Status)

Assign assigns subscriptions to clusters using the clusternet client.

func (*DynamicAssigner) Name

func (pl *DynamicAssigner) Name() string

Name returns the name of the plugin.

func (*DynamicAssigner) PreAssign

func (pl *DynamicAssigner) PreAssign(ctx context.Context, state *framework.CycleState, sub *appsapi.Subscription, finv *appsapi.FeedInventory, availableReplicas framework.TargetClusters) *framework.Status

type StaticAssigner

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

StaticAssigner assigns replicas to clusters.

func (*StaticAssigner) Assign

func (pl *StaticAssigner) Assign(ctx context.Context, state *framework.CycleState, sub *appsapi.Subscription, finv *appsapi.FeedInventory, availableReplicas framework.TargetClusters) (framework.TargetClusters, *framework.Status)

Assign assigns subscriptions to clusters using the clusternet client.

func (*StaticAssigner) Name

func (pl *StaticAssigner) Name() string

Name returns the name of the plugin.