disruption

Documentation

Index

• Constants
• type Consolidation
  • func (c *Consolidation) Reconcile(ctx context.Context, nodePool *v1.NodePool, nodeClaim *v1.NodeClaim) (reconcile.Result, error)
• type Controller
  • func NewController(clk clock.Clock, kubeClient client.Client, ...) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, nodeClaim *v1.NodeClaim) (reconcile.Result, error)
  • func (c *Controller) Register(_ context.Context, m manager.Manager) error
• type Drift
  • func (d *Drift) Reconcile(ctx context.Context, nodePool *v1.NodePool, nodeClaim *v1.NodeClaim) (reconcile.Result, error)

Constants

const (
	NodePoolDrifted      cloudprovider.DriftReason = "NodePoolDrifted"
	RequirementsDrifted  cloudprovider.DriftReason = "RequirementsDrifted"
	InstanceTypeNotFound cloudprovider.DriftReason = "InstanceTypeNotFound"
)

Types

type Consolidation

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

Consolidation is a nodeclaim sub-controller that adds or removes status conditions on empty nodeclaims based on consolidateAfter

func (*Consolidation) Reconcile

func (c *Consolidation) Reconcile(ctx context.Context, nodePool *v1.NodePool, nodeClaim *v1.NodeClaim) (reconcile.Result, error)

type Controller

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

Controller is a disruption controller that adds StatusConditions to nodeclaims when they meet certain disruption conditions e.g. When the NodeClaim has become empty, then it is marked as "Empty" in the StatusConditions

func NewController

func NewController(clk clock.Clock, kubeClient client.Client, cloudProvider cloudprovider.CloudProvider) *Controller

NewController constructs a nodeclaim disruption controller. Note that every sub-controller has a dependency on its nodepool. Disruption mechanisms that don't depend on the nodepool (like expiration), should live elsewhere.

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, nodeClaim *v1.NodeClaim) (reconcile.Result, error)

Reconcile executes a control loop for the resource

func (*Controller) Register

func (c *Controller) Register(_ context.Context, m manager.Manager) error

type Drift

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

Drift is a nodeclaim sub-controller that adds or removes status conditions on drifted nodeclaims

func (*Drift) Reconcile

func (d *Drift) Reconcile(ctx context.Context, nodePool *v1.NodePool, nodeClaim *v1.NodeClaim) (reconcile.Result, error)