serviceaffinity

Documentation

Index

• Constants
• func New(plArgs *runtime.Unknown, handle framework.FrameworkHandle) (framework.Plugin, error)
• type Args
• type ServiceAffinity
  • func (pl *ServiceAffinity) AddPod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, ...) *framework.Status
  • func (pl *ServiceAffinity) Filter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (pl *ServiceAffinity) Name() string
  • func (pl *ServiceAffinity) NormalizeScore(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (pl *ServiceAffinity) PreFilter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod) *framework.Status
  • func (pl *ServiceAffinity) PreFilterExtensions() framework.PreFilterExtensions
  • func (pl *ServiceAffinity) RemovePod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, ...) *framework.Status
  • func (pl *ServiceAffinity) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status)
  • func (pl *ServiceAffinity) ScoreExtensions() framework.ScoreExtensions

Constants

const (
	// Name is the name of the plugin used in the plugin registry and configurations.
	Name = "ServiceAffinity"

	// ErrReason is used for CheckServiceAffinity predicate error.
	ErrReason = "node(s) didn't match service affinity"
)

Functions

func New

func New(plArgs *runtime.Unknown, handle framework.FrameworkHandle) (framework.Plugin, error)

New initializes a new plugin and returns it.

Types

type Args

type Args struct {
	// Labels are homogeneous for pods that are scheduled to a node.
	// (i.e. it returns true IFF this pod can be added to this node such that all other pods in
	// the same service are running on nodes with the exact same values for Labels).
	AffinityLabels []string `json:"affinityLabels,omitempty"`
	// AntiAffinityLabelsPreference are the labels to consider for service anti affinity scoring.
	AntiAffinityLabelsPreference []string `json:"antiAffinityLabelsPreference,omitempty"`
}

Args holds the args that are used to configure the plugin.

type ServiceAffinity

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

ServiceAffinity is a plugin that checks service affinity.

func (*ServiceAffinity) AddPod

func (pl *ServiceAffinity) AddPod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, podToAdd *v1.Pod, nodeInfo *nodeinfo.NodeInfo) *framework.Status

AddPod from pre-computed data in cycleState.

func (*ServiceAffinity) Filter

func (pl *ServiceAffinity) Filter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod, nodeInfo *nodeinfo.NodeInfo) *framework.Status

Filter matches nodes in such a way to force that ServiceAffinity.labels are homogeneous for pods that are scheduled to a node. (i.e. it returns true IFF this pod can be added to this node such that all other pods in the same service are running on nodes with the exact same ServiceAffinity.label values).

For example: If the first pod of a service was scheduled to a node with label "region=foo", all the other subsequent pods belong to the same service will be schedule on nodes with the same "region=foo" label.

Details:

If (the svc affinity labels are not a subset of pod's label selectors )

The pod has all information necessary to check affinity, the pod's label selector is sufficient to calculate
the match.

Otherwise:

Create an "implicit selector" which guarantees pods will land on nodes with similar values
for the affinity labels.

To do this, we "reverse engineer" a selector by introspecting existing pods running under the same service+namespace.
These backfilled labels in the selector "L" are defined like so:
	- L is a label that the ServiceAffinity object needs as a matching constraint.
	- L is not defined in the pod itself already.
	- and SOME pod, from a service, in the same namespace, ALREADY scheduled onto a node, has a matching value.

func (*ServiceAffinity) Name

func (pl *ServiceAffinity) Name() string

Name returns name of the plugin. It is used in logs, etc.

func (*ServiceAffinity) NormalizeScore

func (pl *ServiceAffinity) NormalizeScore(ctx context.Context, _ *framework.CycleState, pod *v1.Pod, scores framework.NodeScoreList) *framework.Status

NormalizeScore invoked after scoring all nodes.

func (*ServiceAffinity) PreFilter

func (pl *ServiceAffinity) PreFilter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod) *framework.Status

PreFilter invoked at the prefilter extension point.

func (*ServiceAffinity) PreFilterExtensions

func (pl *ServiceAffinity) PreFilterExtensions() framework.PreFilterExtensions

PreFilterExtensions returns prefilter extensions, pod add and remove.

func (*ServiceAffinity) RemovePod

func (pl *ServiceAffinity) RemovePod(ctx context.Context, cycleState *framework.CycleState, podToSchedule *v1.Pod, podToRemove *v1.Pod, nodeInfo *nodeinfo.NodeInfo) *framework.Status

RemovePod from pre-computed data in cycleState.

func (*ServiceAffinity) Score

func (pl *ServiceAffinity) Score(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status)

Score invoked at the Score extension point.

func (*ServiceAffinity) ScoreExtensions

func (pl *ServiceAffinity) ScoreExtensions() framework.ScoreExtensions

ScoreExtensions of the Score plugin.