action

package
v0.28.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package action are various actions used by the package

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Apply

type Apply struct {
	ApplyOptions
	Phases phase.Phases
}

Apply state logic

func NewApply

func NewApply(opts ApplyOptions) *Apply

NewApply an apply action object

func (Apply) Run

func (a Apply) Run(ctx context.Context) error

Run the actions

type ApplyOptions

type ApplyOptions struct {
	// Manager is the phase manager
	Manager *phase.Manager
	// DisableDowngradeCheck skips the downgrade check
	DisableDowngradeCheck bool
	// NoWait skips waiting for the cluster to be ready
	NoWait bool
	// NoDrain skips draining worker nodes
	NoDrain bool
	// ModifyHosts updates the /etc/hosts file with all the nodes in the cluster
	ModifyHosts bool
	// ModifyFirewall updates the firewall, firewalld, ufw, or nftables, on the nodes
	ModifyFirewall bool
	// WorkerConcurrent number of workers that will be installed or upgraded at a time, as a fixed
	// count ("5") or a percentage of the batch ("25%")
	WorkerConcurrent string
	// UpdateKubeConfig whether to update the config
	UpdateKubeConfig bool
	// KubeConfigPath is the kubeconfig file to merge the admin creds into, the standard
	// location when empty
	KubeConfigPath string
	// LabelNodes whether to check and add the node-role.kubernetes.io/<profile> label on nodes
	LabelNodes bool
	// AllowUnmanagedNodes lets an apply continue when the cluster holds a node no host in the
	// config accounts for, rather than stopping on it
	AllowUnmanagedNodes bool
	// Keyring decrypts encrypted registry credentials, in either supported format
	Keyring *clustercfg.Keyring
}

ApplyOptions struct

type EngineConfigSync

type EngineConfigSync struct {
	EngineConfigSyncOptions
	Phases phase.Phases
}

EngineConfigSync state logic

func NewEngineConfigSync

func NewEngineConfigSync(opts EngineConfigSyncOptions) *EngineConfigSync

NewEngineConfigSync an engine-config-sync action object

func (EngineConfigSync) Run

Run the actions

type EngineConfigSyncOptions

type EngineConfigSyncOptions struct {
	// Manager is the phase manager
	Manager *phase.Manager
	// WorkerConcurrent number of workers that will be synced at a time, as a fixed
	// count ("5") or a percentage of the batch ("25%")
	WorkerConcurrent string
	// Keyring decrypts encrypted registry credentials, in either supported format
	Keyring *clustercfg.Keyring
	// LabelNodes whether to check and add the node-role.kubernetes.io/<profile> label on nodes
	LabelNodes bool
	// UpdateKubeConfig whether to update a kubeconfig file with the admin creds for the cluster
	UpdateKubeConfig bool
	// KubeConfigPath is the kubeconfig file to merge the admin creds into, the standard
	// location when empty
	KubeConfigPath string
}

EngineConfigSyncOptions struct

type KubeConfig

type KubeConfig struct {
	KubeConfigOptions
	Phases phase.Phases
}

KubeConfig state logic

func NewKubeConfig

func NewKubeConfig(opts KubeConfigOptions) *KubeConfig

NewKubeConfig pulls the admin cert from a control-plane node and updates the local kube-config

func (KubeConfig) Run

func (a KubeConfig) Run(ctx context.Context) error

Run the actions

type KubeConfigOptions

type KubeConfigOptions struct {
	// Manager is the phase manager
	Manager *phase.Manager
	// KubeConfigPath is the kubeconfig file to merge the admin creds into, the standard
	// location when empty
	KubeConfigPath string
}

KubeConfigOptions struct

type Prepare

type Prepare struct {
	PrepareOptions
	Phases phase.Phases
}

Prepare state logic

func NewPrepare

func NewPrepare(opts PrepareOptions) *Prepare

NewPrepare an prepare action object

func (Prepare) Run

func (a Prepare) Run(ctx context.Context) error

Run the actions

type PrepareOptions

type PrepareOptions struct {
	// Manager is the phase manager
	Manager *phase.Manager
	// DisableDowngradeCheck skips the downgrade check
	DisableDowngradeCheck bool
	// NoWait skips waiting for the cluster to be ready
	NoWait bool
	// NoDrain skips draining worker nodes
	NoDrain bool
	// ModifyHosts updates the /etc/hosts file with all the nodes in the cluster
	ModifyHosts bool
	// ModifyFirewall updates the firewall, firewalld, ufw, or nftables, on the nodes
	ModifyFirewall bool
	// ModifyModules whether to update the host kernel modules
	ModifyModules bool
}

PrepareOptions struct

type Reset

type Reset struct {
	ResetOptions
	Phases phase.Phases
}

Reset state logic

func NewReset

func NewReset(opts ResetOptions) *Reset

NewReset an apply action object

func (Reset) Run

func (r Reset) Run(ctx context.Context) error

Run the actions

type ResetOptions

type ResetOptions struct {
	// Manager is the phase manager
	Manager *phase.Manager
	// NoWait skips waiting for the cluster to be ready
	NoWait bool
	// NoDrain skips draining worker nodes
	NoDrain bool
	// DistroID is the type of Kubernetes engine that will be removed
	DistroID string
	// WorkerConcurrent number of workers that will be installed or upgraded at a time, as a fixed
	// count ("5") or a percentage of the batch ("25%")
	WorkerConcurrent string
}

ResetOptions struct

Jump to

Keyboard shortcuts

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