termination

package

v0.10.1 Latest Latest Go to latest Published: May 23, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/aws/karpenter

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL