Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsNodeDrainError ¶
Types ¶
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 NodeDrainError ¶
type NodeDrainError struct {
// contains filtered or unexported fields
}
func NewNodeDrainError ¶
func NewNodeDrainError(err error) *NodeDrainError
type Terminator ¶
type Terminator struct {
// contains filtered or unexported fields
}
func NewTerminator ¶
func NewTerminator(clk clock.Clock, kubeClient client.Client, cloudProvider cloudprovider.CloudProvider, eq *EvictionQueue) *Terminator
func (*Terminator) Drain ¶
Drain evicts pods from the node and returns true when all pods are evicted https://kubernetes.io/docs/concepts/architecture/nodes/#graceful-node-shutdown
func (*Terminator) TerminateNode ¶
TerminateNode calls cloud provider delete then removes the finalizer to delete the node
Source Files
Click to show internal directories.
Click to hide internal directories.