termination

Documentation

Index

• Variables
• type Controller
  • func NewController(clk clock.Clock, kubeClient client.Client, ...) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, n *corev1.Node) (reconcile.Result, error)
  • func (c *Controller) Register(_ context.Context, m manager.Manager) error

Variables

var (
	TerminationDurationSeconds = prometheus.NewSummaryVec(
		prometheus.SummaryOpts{
			Namespace:  metrics.Namespace,
			Subsystem:  metrics.NodeSubsystem,
			Name:       "termination_duration_seconds",
			Help:       "The time taken between a node's deletion request and the removal of its finalizer",
			Objectives: metrics.SummaryObjectives(),
		},
		[]string{metrics.NodePoolLabel},
	)
)

Types

type Controller

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

Controller for the resource

func NewController

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

NewController constructs a controller instance

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, n *corev1.Node) (reconcile.Result, error)

func (*Controller) Register

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