interruption

package

v0.3.2 Latest Latest Go to latest Published: May 8, 2026 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation ¶

Index ¶

Constants
type Controller
- func NewController(kubeClient client.Client, recorder events.Recorder, ...) *Controller
- func (c *Controller) Reconcile(ctx context.Context) (reconciler.Result, error)
- func (c *Controller) Register(_ context.Context, m manager.Manager) error

Constants ¶

const (
	OperationTypePreempted = "compute.instances.preempted"

	NodeConditionReasonKubeletNotReady = "KubeletNotReady"
	NodeConditionMessageShuttingDown   = "node is shutting down"

	InterruptionReason = "interruption"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Controller ¶

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

Controller is an GCP interruption controller.

func NewController ¶

func NewController(kubeClient client.Client,
	recorder events.Recorder, unavailableOfferingsCache *cache.UnavailableOfferings,
	metadataClient *metadata.Client,
	zoneOperationClient *computev1.ZoneOperationsClient,
	credential auth.Credential,
	instanceProvider instance.Provider,
) *Controller

func (*Controller) Reconcile ¶

func (c *Controller) Reconcile(ctx context.Context) (reconciler.Result, error)

func (*Controller) Register ¶

func (c *Controller) Register(_ context.Context, m manager.Manager) error

Source Files ¶

View all Source files

controller.go

Directories ¶

Path	Synopsis
events

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