tasks

package
v0.8.3 Latest Latest
Warning

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

Go to latest
Published: Apr 12, 2024 License: AGPL-3.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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)

Jump to

Keyboard shortcuts

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