consistency

Documentation

Index

• func FailedConsistencyCheckEvent(nodeClaim *v1.NodeClaim, message string) events.Event
• type Check
  • func NewNodeShape() Check
  • func NewTermination(clk clock.Clock, kubeClient client.Client) Check
• 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 Issue
• type NodeShape
  • func (n *NodeShape) Check(_ context.Context, node *corev1.Node, nodeClaim *v1.NodeClaim) ([]Issue, error)
• type Termination
  • func (t *Termination) Check(ctx context.Context, node *corev1.Node, nodeClaim *v1.NodeClaim) ([]Issue, error)

Functions

func FailedConsistencyCheckEvent

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

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, *corev1.Node, *v1.NodeClaim) ([]Issue, error)
}

func NewNodeShape

func NewNodeShape() Check

func NewTermination

func NewTermination(clk clock.Clock, kubeClient client.Client) Check

type Controller

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

func NewController

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

func (*Controller) Reconcile

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

func (*Controller) Register

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

type Issue

type Issue string

type NodeShape

type NodeShape struct{}

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 *corev1.Node, nodeClaim *v1.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 *corev1.Node, nodeClaim *v1.NodeClaim) ([]Issue, error)