tasks

Documentation

Index

• type Task
  • func (t *Task) Run(s *state.State) error
• type Tasks
  • func WithBinariesOnly(t Tasks) Tasks
  • func WithClusterStatus(t Tasks) Tasks
  • func WithFullInstall(t Tasks) Tasks
  • func WithHostnameOS(t Tasks) Tasks
  • func WithReset(t Tasks) Tasks
  • func WithUpgrade(t Tasks) Tasks
  • func (t Tasks) Run(s *state.State) error

Types

type Task

type Task struct {
	Fn      func(*state.State) error
	ErrMsg  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 WithClusterStatus

func WithClusterStatus(t Tasks) 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 WithReset

func WithReset(t Tasks) Tasks

func WithUpgrade

func WithUpgrade(t Tasks) Tasks

func (Tasks) Run

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