tasks

Documentation

Index

• Constants
• func GetDefaultConfig() string
• type AddonsInstaller
  • func (a *AddonsInstaller) Init()
• type CheckNodeArchitectureModule
  • func (i *CheckNodeArchitectureModule) Init()
• type ConfigureNodeOSModule
  • func (c *ConfigureNodeOSModule) Init()
• type DownloadKubernetesBinary
  • func (d *DownloadKubernetesBinary) Execute(runtime connector.Runtime) error
• type InstallCRIModule
  • func (i *InstallCRIModule) Init()
• type InstallDependenciesModule
  • func (i *InstallDependenciesModule) Init()
• type InstallDependenciesTask
  • func (i *InstallDependenciesTask) Execute(runtime connector.Runtime) (err error)
• type KBAddonsInstall
  • func (i *KBAddonsInstall) Execute(runtime connector.Runtime) error
• type NodeScriptGenerator
  • func (c *NodeScriptGenerator) Execute(runtime connector.Runtime) error
• type PipelineWrapper
  • func NewPipelineRunner(name string, modules []module.Module, runtime connector.Runtime) *PipelineWrapper
  • func (w *PipelineWrapper) Do(output io.Writer) error
• type PrepareK8sBinariesModule
  • func (p *PrepareK8sBinariesModule) Init()
• type SaveKubeConfig
  • func (c *SaveKubeConfig) Execute(runtime connector.Runtime) error
• type SaveKubeConfigModule
  • func (p *SaveKubeConfigModule) Init()
• type UpdateNodeTask
  • func (i *UpdateNodeTask) Execute(runtime connector.Runtime) (err error)

Constants

const (
	CurlDownloadURLFormat = "curl -L -o %s %s"
	WgetDownloadURLFormat = "wget -O %s %s"
)

Functions

func GetDefaultConfig

func GetDefaultConfig() string

Types

type AddonsInstaller

type AddonsInstaller struct {
	common.KubeModule

	Addons     []types.PluginMeta
	Kubeconfig string
}

func (*AddonsInstaller) Init

func (a *AddonsInstaller) Init()

type CheckNodeArchitectureModule

type CheckNodeArchitectureModule struct {
	common.KubeModule
}

func (*CheckNodeArchitectureModule) Init

func (i *CheckNodeArchitectureModule) Init()

Init install dependencies module

type ConfigureNodeOSModule

type ConfigureNodeOSModule struct {
	common.KubeModule
	Nodes []types.ClusterNode
}

func (*ConfigureNodeOSModule) Init

func (c *ConfigureNodeOSModule) Init()

type DownloadKubernetesBinary

type DownloadKubernetesBinary struct {
	common.KubeAction
	BinaryVersion types.InfraVersionInfo
}

func (*DownloadKubernetesBinary) Execute

func (d *DownloadKubernetesBinary) Execute(runtime connector.Runtime) error

type InstallCRIModule

type InstallCRIModule struct {
	common.KubeModule
	SandBoxImage string
}

func (*InstallCRIModule) Init

func (i *InstallCRIModule) Init()

type InstallDependenciesModule

type InstallDependenciesModule struct {
	common.KubeModule
}

func (*InstallDependenciesModule) Init

func (i *InstallDependenciesModule) Init()

Init install dependencies module

type InstallDependenciesTask

type InstallDependenciesTask struct {
	common.KubeAction
	// contains filtered or unexported fields
}

func (*InstallDependenciesTask) Execute

func (i *InstallDependenciesTask) Execute(runtime connector.Runtime) (err error)

type KBAddonsInstall

type KBAddonsInstall struct {
	common.KubeAction

	Addons     []types.PluginMeta
	Kubeconfig string
}

func (*KBAddonsInstall) Execute

func (i *KBAddonsInstall) Execute(runtime connector.Runtime) error

type NodeScriptGenerator

type NodeScriptGenerator struct {
	common.KubeAction

	Nodes []types.ClusterNode
	Hosts []string
}

func (*NodeScriptGenerator) Execute

func (c *NodeScriptGenerator) Execute(runtime connector.Runtime) error

type PipelineWrapper

type PipelineWrapper struct {
	pipeline.Pipeline
}

func NewPipelineRunner

func NewPipelineRunner(name string, modules []module.Module, runtime connector.Runtime) *PipelineWrapper

func (*PipelineWrapper) Do

func (w *PipelineWrapper) Do(output io.Writer) error

type PrepareK8sBinariesModule

type PrepareK8sBinariesModule struct {
	common.KubeModule

	// kubernetes version
	BinaryVersion types.InfraVersionInfo
}

func (*PrepareK8sBinariesModule) Init

func (p *PrepareK8sBinariesModule) Init()

type SaveKubeConfig

type SaveKubeConfig struct {
	common.KubeAction
	// contains filtered or unexported fields
}

func (*SaveKubeConfig) Execute

func (c *SaveKubeConfig) Execute(runtime connector.Runtime) error

type SaveKubeConfigModule

type SaveKubeConfigModule struct {
	common.KubeModule

	OutputKubeconfig string
}

func (*SaveKubeConfigModule) Init

func (p *SaveKubeConfigModule) Init()

type UpdateNodeTask

type UpdateNodeTask struct {
	common.KubeAction
}

func (*UpdateNodeTask) Execute

func (i *UpdateNodeTask) Execute(runtime connector.Runtime) (err error)