controller

Documentation

Index

• Constants
• func IsDisruptionWindowActive(ctx context.Context, podNamespace, podName string, ...) bool
• type DeprovisionController
  • func (c *DeprovisionController) HandleBlockingPods(ctx context.Context, pods []corev1.Pod, nodeName string)
  • func (c *DeprovisionController) Reconcile(ctx context.Context, e *corev1.Event) (reconcile.Result, error)
  • func (c *DeprovisionController) Register(_ context.Context, mgr manager.Manager) error

Constants

const (
	DisruptionWindowSchedKey      = "k8s.adsrvr.net/disruption-window-schedule"
	DisruptionWindowDurationKey   = "k8s.adsrvr.net/disruption-window-duration"
	DisruptionBlockedEventReason  = "DisruptionBlocked"
	DisruptionBlockedEventMessage = "Cannot disrupt Node: state node is marked for deletion"
	DisruptionBlockedEventKind    = "Node"
)

Functions

func IsDisruptionWindowActive

func IsDisruptionWindowActive(ctx context.Context, podNamespace, podName string, disruptionWindowSched, disruptionWindowDuration string) bool

IsDisruptionWindowActive checks if the current time is within the disruption window.

Types

type DeprovisionController

type DeprovisionController struct {
	Client client.Client
}

func (*DeprovisionController) HandleBlockingPods

func (c *DeprovisionController) HandleBlockingPods(ctx context.Context, pods []corev1.Pod, nodeName string)

func (*DeprovisionController) Reconcile

func (c *DeprovisionController) Reconcile(ctx context.Context, e *corev1.Event) (reconcile.Result, error)

func (*DeprovisionController) Register

func (c *DeprovisionController) Register(_ context.Context, mgr manager.Manager) error