consistency

Documentation

Index

• func FailedConsistencyCheckEvent(nodeClaim *v1beta1.NodeClaim, message string) events.Event
• func NewController(clk clock.Clock, kubeClient client.Client, recorder events.Recorder, ...) operatorcontroller.Controller
• type Check
  • func NewNodeShape(provider cloudprovider.CloudProvider) Check
  • func NewTermination(kubeClient client.Client) Check
• type Controller
  • func (c *Controller) Builder(_ context.Context, m manager.Manager) operatorcontroller.Builder
  • func (c *Controller) Name() string
  • func (c *Controller) Reconcile(ctx context.Context, nodeClaim *v1beta1.NodeClaim) (reconcile.Result, error)
• type Issue
• type NodeShape
  • func (n *NodeShape) Check(_ context.Context, node *v1.Node, nodeClaim *v1beta1.NodeClaim) ([]Issue, error)
• type Termination
  • func (t *Termination) Check(ctx context.Context, node *v1.Node, nodeClaim *v1beta1.NodeClaim) ([]Issue, error)

Functions

func FailedConsistencyCheckEvent

func FailedConsistencyCheckEvent(nodeClaim *v1beta1.NodeClaim, message string) events.Event

func NewController

func NewController(clk clock.Clock, kubeClient client.Client, recorder events.Recorder,
	provider cloudprovider.CloudProvider) operatorcontroller.Controller

Types

type Check

type Check interface {
	// Check performs the consistency check, this should return a list of slice discovered, or an empty
	// slice if no issues were found
	Check(context.Context, *v1.Node, *v1beta1.NodeClaim) ([]Issue, error)
}

func NewNodeShape

func NewNodeShape(provider cloudprovider.CloudProvider) Check

func NewTermination

func NewTermination(kubeClient client.Client) Check

type Controller

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

func (*Controller) Builder

func (c *Controller) Builder(_ context.Context, m manager.Manager) operatorcontroller.Builder

func (*Controller) Name

func (c *Controller) Name() string

func (*Controller) Reconcile

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

type Issue

type Issue string

type NodeShape

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

NodeShape detects nodes that have launched with 10% or less of any resource than was expected.

func (*NodeShape) Check

func (n *NodeShape) Check(_ context.Context, node *v1.Node, nodeClaim *v1beta1.NodeClaim) ([]Issue, error)

type Termination

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

Termination detects nodes that are stuck terminating and reports why.

func (*Termination) Check

func (t *Termination) Check(ctx context.Context, node *v1.Node, nodeClaim *v1beta1.NodeClaim) ([]Issue, error)