inflightchecks

Dec 9, 2022

Changes in this version

+ func NewController(clk clock.Clock, kubeClient client.Client, recorder events.Recorder, ...) corecontroller.Controller

+ type Check interface

+ Check func(ctx context.Context, node *v1.Node, provisioner *v1alpha5.Provisioner, ...) ([]Issue, error)

+ func NewFailedInit(clk clock.Clock, provider cloudprovider.CloudProvider) Check

+ func NewNodeShape(provider cloudprovider.CloudProvider) Check

+ func NewTermination(kubeClient client.Client) Check

+ type Controller struct

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

+ func (c *Controller) Name() string

+ func (c *Controller) Reconcile(ctx context.Context, node *v1.Node) (reconcile.Result, error)

+ type FailedInit struct

+ func (f FailedInit) Check(ctx context.Context, n *v1.Node, provisioner *v1alpha5.Provisioner, ...) ([]Issue, error)

+ type Issue struct

+ type NodeShape struct

+ func (n *NodeShape) Check(ctx context.Context, node *v1.Node, provisioner *v1alpha5.Provisioner, ...) ([]Issue, error)

+ type Termination struct

+ func (t *Termination) Check(ctx context.Context, node *v1.Node, provisioner *v1alpha5.Provisioner, ...) ([]Issue, error)