Documentation
¶
Index ¶
- func IsUnrecoverableError(err error) bool
- type Command
- type Queue
- func (q *Queue) Add(cmd *Command) error
- func (q *Queue) Builder(_ context.Context, m manager.Manager) controller.Builder
- func (q *Queue) HasAny(ids ...string) bool
- func (q *Queue) IsEmpty() bool
- func (q *Queue) Name() string
- func (q *Queue) Reconcile(ctx context.Context, _ reconcile.Request) (reconcile.Result, error)
- func (q *Queue) Remove(cmd *Command)
- func (q *Queue) Reset()
- type Replacement
- type UnrecoverableError
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsUnrecoverableError ¶
Types ¶
type Command ¶
type Command struct {
Replacements []Replacement
// contains filtered or unexported fields
}
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 NewTestingQueue ¶
func NewTestingQueue(kubeClient client.Client, recorder events.Recorder, cluster *state.Cluster, clock clock.Clock, provisioner *provisioning.Provisioner, ) *Queue
NewTestingQueue uses a test RateLimitingInterface that will immediately re-queue items.
func (*Queue) Add ¶
Add adds commands to the Queue Each command added to the queue should already be validated and ready for execution.
func (*Queue) HasAny ¶
HasAny checks to see if the candidate is part of an currently executing 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
Source Files
Click to show internal directories.
Click to hide internal directories.