tasks

package
v1.7.3 Latest Latest
Warning

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

Go to latest
Published: Mar 1, 2024 License: Apache-2.0 Imports: 74 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var KubeProxyObjectKey = dynclient.ObjectKey{
	Namespace: "kube-system",
	Name:      "kube-proxy",
}

Functions

This section is empty.

Types

type Task

type Task struct {
	Fn          func(*state.State) error
	Predicate   func(*state.State) bool
	Description string
	Operation   string
	Retries     int
}

Task is a runnable task

func (*Task) Run

func (t *Task) Run(s *state.State) error

Run runs a task

type Tasks

type Tasks []Task

func WithBinariesOnly

func WithBinariesOnly(t Tasks) Tasks

WithBinariesOnly will prepend passed tasks with tasks WithHostnameOS() and append install prerequisite binaries (docker, kubeadm, kubelet, etc...) on all hosts

func WithCCMCSIMigration added in v1.3.0

func WithCCMCSIMigration(t Tasks) Tasks

func WithClusterStatus

func WithClusterStatus(t Tasks) Tasks

func WithContainerDMigration added in v1.3.0

func WithContainerDMigration(t Tasks) Tasks

func WithCustomEncryptionConfigUpdated added in v1.3.0

func WithCustomEncryptionConfigUpdated(t Tasks) Tasks

func WithDisableEncryptionProviders added in v1.3.0

func WithDisableEncryptionProviders(t Tasks, customConfig bool) Tasks

func WithFullInstall

func WithFullInstall(t Tasks) Tasks

WithFullInstall with install binaries (using WithBinariesOnly) and orchestrate complete cluster init

func WithHostnameOS

func WithHostnameOS(t Tasks) Tasks

WithHostnameOS will prepend passed tasks with 2 basic tasks:

  • detect OS on all cluster hosts
  • detect hostnames on all cluster hosts

func WithHostnameOSAndProbes added in v1.3.0

func WithHostnameOSAndProbes(t Tasks) Tasks

func WithProbes

func WithProbes(t Tasks) Tasks

WithProbes will run different probes over the defined cluster

func WithProbesAndSafeguard added in v1.3.0

func WithProbesAndSafeguard(t Tasks) Tasks

func WithReset

func WithReset(t Tasks) Tasks

func WithResources added in v1.3.0

func WithResources(t Tasks) Tasks

func WithRewriteSecrets added in v1.3.0

func WithRewriteSecrets(t Tasks) Tasks

func WithRotateKey added in v1.3.0

func WithRotateKey(t Tasks) Tasks

func WithUpgrade

func WithUpgrade(t Tasks) Tasks

func (Tasks) Descriptions

func (t Tasks) Descriptions(s *state.State) []string

func (Tasks) Run

func (t Tasks) Run(s *state.State) error

Jump to

Keyboard shortcuts

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