disruption

Documentation

Index

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

Constants

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

Types

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 surpassed its owning provisioner's expirationTTL, then it is marked as "Expired" in the StatusConditions

func NewController

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

NewController constructs a nodeclaim disruption controller

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, nodeClaim *v1beta1.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 *v1beta1.NodePool, nodeClaim *v1beta1.NodeClaim) (reconcile.Result, error)

type Emptiness

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

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

func (*Emptiness) Reconcile

func (e *Emptiness) Reconcile(ctx context.Context, nodePool *v1beta1.NodePool, nodeClaim *v1beta1.NodeClaim) (reconcile.Result, error)

type Expiration

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

Expiration is a nodeclaim sub-controller that adds or removes status conditions on expired nodeclaims based on TTLSecondsUntilExpired

func (*Expiration) Reconcile

func (e *Expiration) Reconcile(ctx context.Context, nodePool *v1beta1.NodePool, nodeClaim *v1beta1.NodeClaim) (reconcile.Result, error)