terminator

Documentation

Index

• Constants
• Variables
• func IsNodeDrainError(err error) bool
• type NodeDrainError
  • func NewNodeDrainError(err error) *NodeDrainError
• type Queue
  • func NewQueue(kubeClient client.Client, recorder events.Recorder) *Queue
  • func NewTestingQueue(kubeClient client.Client, recorder events.Recorder) *Queue
  • func (q *Queue) Add(node *corev1.Node, pods ...*corev1.Pod)
  • func (q *Queue) Evict(ctx context.Context, key QueueKey) bool
  • func (q *Queue) Has(node *corev1.Node, pod *corev1.Pod) bool
  • func (q *Queue) Reconcile(ctx context.Context) (reconcile.Result, error)
  • func (q *Queue) Register(_ context.Context, m manager.Manager) error
• type QueueKey
  • func NewQueueKey(pod *corev1.Pod, providerID string) QueueKey
• type Terminator
  • func NewTerminator(clk clock.Clock, kubeClient client.Client, eq *Queue, recorder events.Recorder) *Terminator
  • func (t *Terminator) DeleteExpiringPods(ctx context.Context, pods []*corev1.Pod, ...) error
  • func (t *Terminator) Drain(ctx context.Context, node *corev1.Node, ...) error
  • func (t *Terminator) Taint(ctx context.Context, node *corev1.Node, taint corev1.Taint) error

Constants

const (
	// CodeLabel for eviction request
	CodeLabel = "code"
)

Variables

var NodesEvictionRequestsTotal = opmetrics.NewPrometheusCounter(
	crmetrics.Registry,
	prometheus.CounterOpts{
		Namespace: metrics.Namespace,
		Subsystem: metrics.NodeSubsystem,
		Name:      "eviction_requests_total",
		Help:      "The total number of eviction requests made by Karpenter",
	},
	[]string{CodeLabel},
)

Functions

func IsNodeDrainError

func IsNodeDrainError(err error) bool

Types

type NodeDrainError

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

func NewNodeDrainError

func NewNodeDrainError(err error) *NodeDrainError

type Queue

type Queue struct {
	workqueue.TypedRateLimitingInterface[QueueKey]
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(kubeClient client.Client, recorder events.Recorder) *Queue

func NewTestingQueue

func NewTestingQueue(kubeClient client.Client, recorder events.Recorder) *Queue

func (*Queue) Add

func (q *Queue) Add(node *corev1.Node, pods ...*corev1.Pod)

Add adds pods to the Queue

func (*Queue) Evict

func (q *Queue) Evict(ctx context.Context, key QueueKey) bool

Evict returns true if successful eviction call, and false if there was an eviction-related error

func (*Queue) Has

func (q *Queue) Has(node *corev1.Node, pod *corev1.Pod) bool

func (*Queue) Reconcile

func (q *Queue) Reconcile(ctx context.Context) (reconcile.Result, error)

func (*Queue) Register

func (q *Queue) Register(_ context.Context, m manager.Manager) error

type QueueKey

type QueueKey struct {
	types.NamespacedName
	UID types.UID
	// contains filtered or unexported fields
}

func NewQueueKey

func NewQueueKey(pod *corev1.Pod, providerID string) QueueKey

type Terminator

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

func NewTerminator

func NewTerminator(clk clock.Clock, kubeClient client.Client, eq *Queue, recorder events.Recorder) *Terminator

func (*Terminator) DeleteExpiringPods

func (t *Terminator) DeleteExpiringPods(ctx context.Context, pods []*corev1.Pod, nodeGracePeriodTerminationTime *time.Time) error

func (*Terminator) Drain

func (t *Terminator) Drain(ctx context.Context, node *corev1.Node, nodeGracePeriodExpirationTime *time.Time) error

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) Taint

func (t *Terminator) Taint(ctx context.Context, node *corev1.Node, taint corev1.Taint) error

Taint idempotently adds a given taint to a node with a NodeClaim