termination

Documentation

Index

• func IsNodeDrainErr(err error) bool
• func NewController(clk clock.Clock, kubeClient client.Client, evictionQueue *EvictionQueue, ...) corecontroller.Controller
• type Controller
  • func (c *Controller) Builder(_ context.Context, m manager.Manager) corecontroller.Builder
  • func (c *Controller) Name() string
  • func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type EvictionQueue
  • func NewEvictionQueue(ctx context.Context, coreV1Client corev1.CoreV1Interface, ...) *EvictionQueue
  • func (e *EvictionQueue) Add(pods []*v1.Pod)
  • func (e *EvictionQueue) Start(ctx context.Context)
• type NodeDrainErr
• type Terminator

Functions

func IsNodeDrainErr

func IsNodeDrainErr(err error) bool

func NewController

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

NewController constructs a terminationController instance

Types

type Controller

type Controller struct {
	Terminator *Terminator
	KubeClient client.Client
	Recorder   events.Recorder
}

Controller for the resource

func (*Controller) Builder

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

func (*Controller) Name

func (c *Controller) Name() string

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

type EvictionQueue

type EvictionQueue struct {
	workqueue.RateLimitingInterface
	set.Set
	// contains filtered or unexported fields
}

func NewEvictionQueue

func NewEvictionQueue(ctx context.Context, coreV1Client corev1.CoreV1Interface, recorder events.Recorder) *EvictionQueue

func (*EvictionQueue) Add

func (e *EvictionQueue) Add(pods []*v1.Pod)

Add adds pods to the EvictionQueue

func (*EvictionQueue) Start

func (e *EvictionQueue) Start(ctx context.Context)

type NodeDrainErr

type NodeDrainErr error

type Terminator

type Terminator struct {
	EvictionQueue *EvictionQueue
	KubeClient    client.Client
	CloudProvider cloudprovider.CloudProvider
	Clock         clock.Clock
}