drain

Documentation

Index

• type CordonHelper
  • func NewCordonHelper(node *corev1.Node, desired bool) *CordonHelper
  • func NewCordonHelperFromRuntimeObject(nodeObject runtime.Object, scheme *runtime.Scheme, gvk schema.GroupVersionKind, ...) (*CordonHelper, error)
  • func (c *CordonHelper) IsUpdateRequired() bool
  • func (c *CordonHelper) PatchOrReplace(clientset kubernetes.Interface) (error, error)
• type Evictor
• type NodeGroupDrainer
  • func NewNodeGroupDrainer(clientSet kubernetes.Interface, ng eks.KubeNodeGroup, ...) NodeGroupDrainer
  • func (n *NodeGroupDrainer) Drain(ctx context.Context, sem *semaphore.Weighted) error

Types

type CordonHelper

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

CordonHelper wraps functionality to cordon/uncordon nodes

func NewCordonHelper

func NewCordonHelper(node *corev1.Node, desired bool) *CordonHelper

NewCordonHelper returns a new CordonHelper

func NewCordonHelperFromRuntimeObject

func NewCordonHelperFromRuntimeObject(nodeObject runtime.Object, scheme *runtime.Scheme, gvk schema.GroupVersionKind, desired bool) (*CordonHelper, error)

NewCordonHelperFromRuntimeObject returns a new CordonHelper, or an error if given object is not a node or cannot be encoded as JSON

func (*CordonHelper) IsUpdateRequired

func (c *CordonHelper) IsUpdateRequired() bool

IsUpdateRequired returns true if c.node.Spec.Unschedulable matches desired state, or false when it is

func (*CordonHelper) PatchOrReplace

func (c *CordonHelper) PatchOrReplace(clientset kubernetes.Interface) (error, error)

PatchOrReplace uses given clientset to update the node status, either by patching or updating the given node object; it may return error if the object cannot be encoded as JSON, or if either patch or update calls fail; it will also return a second error whenever creating a patch has failed

type Evictor

type Evictor interface {
	CanUseEvictions() error
	EvictOrDeletePod(pod corev1.Pod) error
	GetPodsForEviction(nodeName string) (*evictor.PodDeleteList, []error)
}

type NodeGroupDrainer

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

func NewNodeGroupDrainer

func NewNodeGroupDrainer(clientSet kubernetes.Interface, ng eks.KubeNodeGroup, maxGracePeriod, nodeDrainWaitPeriod time.Duration, podEvictionWaitPeriod time.Duration, undo, disableEviction bool, parallel int) NodeGroupDrainer

func (*NodeGroupDrainer) Drain

func (n *NodeGroupDrainer) Drain(ctx context.Context, sem *semaphore.Weighted) error

Drain drains a nodegroup