orchestration

Documentation

Index

• Variables
• func IsUnrecoverableError(err error) bool
• type Command
  • func NewCommand(replacements []string, candidates []*state.StateNode, id types.UID, ...) *Command
  • func (c *Command) Decision() string
  • func (c *Command) Reason() string
• type Queue
  • func NewQueue(kubeClient client.Client, recorder events.Recorder, cluster *state.Cluster, ...) *Queue
  • func (q *Queue) Add(cmd *Command) error
  • func (q *Queue) HasAny(ids ...string) bool
  • func (q *Queue) IsEmpty() bool
  • func (q *Queue) Reconcile(ctx context.Context) (reconcile.Result, error)
  • func (q *Queue) Register(_ context.Context, m manager.Manager) error
  • func (q *Queue) Remove(cmd *Command)
• type Replacement
• type UnrecoverableError
  • func NewUnrecoverableError(err error) *UnrecoverableError

Variables

var (
	DisruptionQueueFailuresTotal = opmetrics.NewPrometheusCounter(
		crmetrics.Registry,
		prometheus.CounterOpts{
			Namespace: metrics.Namespace,
			Subsystem: voluntaryDisruptionSubsystem,
			Name:      "queue_failures_total",
			Help:      "The number of times that an enqueued disruption decision failed. Labeled by disruption method.",
		},
		[]string{decisionLabel, metrics.ReasonLabel, consolidationTypeLabel},
	)
)

Functions

func IsUnrecoverableError

func IsUnrecoverableError(err error) bool

Types

type Command

type Command struct {
	Replacements []Replacement
	// contains filtered or unexported fields
}

func NewCommand

func NewCommand(replacements []string, candidates []*state.StateNode, id types.UID, reason v1.DisruptionReason, consolidationType string) *Command

NewCommand creates a command key and adds in initial data for the orchestration queue.

func (*Command) Decision

func (c *Command) Decision() string

func (*Command) Reason

func (c *Command) Reason() string

type Queue

type Queue struct {
	workqueue.RateLimitingInterface
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(kubeClient client.Client, recorder events.Recorder, cluster *state.Cluster, clock clock.Clock,
	provisioner *provisioning.Provisioner,
) *Queue

NewQueue creates a queue that will asynchronously orchestrate disruption commands

func (*Queue) Add

func (q *Queue) Add(cmd *Command) error

Add adds commands to the Queue Each command added to the queue should already be validated and ready for execution.

func (*Queue) HasAny

func (q *Queue) HasAny(ids ...string) bool

HasAny checks to see if the candidate is part of an currently executing command.

func (*Queue) IsEmpty

func (q *Queue) IsEmpty() bool

func (*Queue) Reconcile

func (q *Queue) Reconcile(ctx context.Context) (reconcile.Result, error)

func (*Queue) Register

func (q *Queue) Register(_ context.Context, m manager.Manager) error

func (*Queue) Remove

func (q *Queue) Remove(cmd *Command)

Remove fully clears the queue of all references of a hash/command

type Replacement

type Replacement struct {

	// Use a bool track if a node has already been initialized so we can fire metrics for intialization once.
	// This intentionally does not capture nodes that go initialized then go NotReady after as other pods can
	// schedule to this node as well.
	Initialized bool
	// contains filtered or unexported fields
}

Replacement wraps a NodeClaim name with an initialized field to save on readiness checks and identify when a NodeClaim is first initialized for metrics and events.

type UnrecoverableError

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

func NewUnrecoverableError

func NewUnrecoverableError(err error) *UnrecoverableError