termination

Documentation

Index

• func IsStuckTerminating(pod *v1.Pod) bool
• type Controller
  • func NewController(ctx context.Context, kubeClient client.Client, ...) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (c *Controller) Register(_ context.Context, m manager.Manager) 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 Terminator

Functions

func IsStuckTerminating

func IsStuckTerminating(pod *v1.Pod) bool

Types

type Controller

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

Controller for the resource

func NewController

func NewController(ctx context.Context, kubeClient client.Client, coreV1Client corev1.CoreV1Interface, cloudProvider cloudprovider.CloudProvider) *Controller

NewController constructs a controller instance

func (*Controller) Reconcile

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

Reconcile executes a termination control loop for the resource

func (*Controller) Register

func (c *Controller) Register(_ context.Context, m manager.Manager) 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) *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 Terminator

type Terminator struct {
	EvictionQueue *EvictionQueue
	KubeClient    client.Client
	CoreV1Client  corev1.CoreV1Interface
	CloudProvider cloudprovider.CloudProvider
}