k3s

Documentation

Index

• func SyncKubeBinaries(runtime connector.Runtime, binariesMap map[string]*files.KubeBinary) error
• type AddMasterTaint
  • func (a *AddMasterTaint) Execute(runtime connector.Runtime) error
• type AddWorkerLabel
  • func (a *AddWorkerLabel) Execute(runtime connector.Runtime) error
• type ChmodScript
  • func (c *ChmodScript) Execute(runtime connector.Runtime) error
• type ClusterIsExist
  • func (c *ClusterIsExist) PreCheck(_ connector.Runtime) (bool, error)
• type CopyK3sKubeConfig
  • func (c *CopyK3sKubeConfig) Execute(runtime connector.Runtime) error
• type DeleteClusterModule
  • func (d *DeleteClusterModule) Init()
• type EnableK3sService
  • func (e *EnableK3sService) Execute(runtime connector.Runtime) error
• type ExecUninstallScript
  • func (e *ExecUninstallScript) Execute(runtime connector.Runtime) error
• type GenerateK3sRegistryConfig
  • func (g *GenerateK3sRegistryConfig) Execute(runtime connector.Runtime) error
• type GenerateK3sService
  • func (g *GenerateK3sService) Execute(runtime connector.Runtime) error
• type GenerateK3sServiceEnv
  • func (g *GenerateK3sServiceEnv) Execute(runtime connector.Runtime) error
• type GetClusterStatus
  • func (g *GetClusterStatus) Execute(runtime connector.Runtime) error
• type InitClusterModule
  • func (i *InitClusterModule) Init()
• type InstallKubeBinariesModule
  • func (i *InstallKubeBinariesModule) Init()
• type JoinNodesModule
  • func (j *JoinNodesModule) Init()
• type K3sStatus
  • func NewK3sStatus() *K3sStatus
  • func (k *K3sStatus) LoadKubeConfig(runtime connector.Runtime, kubeConf *common.KubeConf) error
  • func (k *K3sStatus) SearchInfo(runtime connector.Runtime) error
  • func (k *K3sStatus) SearchKubeConfig(runtime connector.Runtime) error
  • func (k *K3sStatus) SearchNodeToken(runtime connector.Runtime) error
  • func (k *K3sStatus) SearchNodesInfo(_ connector.Runtime) error
  • func (k *K3sStatus) SearchVersion(runtime connector.Runtime) error
• type NodeInCluster
  • func (n *NodeInCluster) PreCheck(runtime connector.Runtime) (bool, error)
• type SaveKubeConfig
  • func (s *SaveKubeConfig) Execute(_ connector.Runtime) error
• type SaveKubeConfigModule
  • func (s *SaveKubeConfigModule) Init()
• type StatusModule
  • func (s *StatusModule) Init()
• type SyncKubeBinary
  • func (s *SyncKubeBinary) Execute(runtime connector.Runtime) error
• type SyncKubeConfigToWorker
  • func (s *SyncKubeConfigToWorker) Execute(runtime connector.Runtime) error
• type UsePrivateRegstry
  • func (c *UsePrivateRegstry) PreCheck(_ connector.Runtime) (bool, error)

Functions

func SyncKubeBinaries

func SyncKubeBinaries(runtime connector.Runtime, binariesMap map[string]*files.KubeBinary) error

SyncKubeBinaries is used to sync kubernetes' binaries to each node.

Types

type AddMasterTaint

type AddMasterTaint struct {
	common.KubeAction
}

func (*AddMasterTaint) Execute

func (a *AddMasterTaint) Execute(runtime connector.Runtime) error

type AddWorkerLabel

type AddWorkerLabel struct {
	common.KubeAction
}

func (*AddWorkerLabel) Execute

func (a *AddWorkerLabel) Execute(runtime connector.Runtime) error

type ChmodScript

type ChmodScript struct {
	common.KubeAction
}

func (*ChmodScript) Execute

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

type ClusterIsExist

type ClusterIsExist struct {
	common.KubePrepare
	Not bool
}

func (*ClusterIsExist) PreCheck

func (c *ClusterIsExist) PreCheck(_ connector.Runtime) (bool, error)

type CopyK3sKubeConfig

type CopyK3sKubeConfig struct {
	common.KubeAction
}

func (*CopyK3sKubeConfig) Execute

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

type DeleteClusterModule

type DeleteClusterModule struct {
	common.KubeModule
}

func (*DeleteClusterModule) Init

func (d *DeleteClusterModule) Init()

type EnableK3sService

type EnableK3sService struct {
	common.KubeAction
}

func (*EnableK3sService) Execute

func (e *EnableK3sService) Execute(runtime connector.Runtime) error

type ExecUninstallScript

type ExecUninstallScript struct {
	common.KubeAction
}

func (*ExecUninstallScript) Execute

func (e *ExecUninstallScript) Execute(runtime connector.Runtime) error

type GenerateK3sRegistryConfig

type GenerateK3sRegistryConfig struct {
	common.KubeAction
}

func (*GenerateK3sRegistryConfig) Execute

func (g *GenerateK3sRegistryConfig) Execute(runtime connector.Runtime) error

type GenerateK3sService

type GenerateK3sService struct {
	common.KubeAction
}

func (*GenerateK3sService) Execute

func (g *GenerateK3sService) Execute(runtime connector.Runtime) error

type GenerateK3sServiceEnv

type GenerateK3sServiceEnv struct {
	common.KubeAction
}

func (*GenerateK3sServiceEnv) Execute

func (g *GenerateK3sServiceEnv) Execute(runtime connector.Runtime) error

type GetClusterStatus

type GetClusterStatus struct {
	common.KubeAction
}

func (*GetClusterStatus) Execute

func (g *GetClusterStatus) Execute(runtime connector.Runtime) error

type InitClusterModule

type InitClusterModule struct {
	common.KubeModule
}

func (*InitClusterModule) Init

func (i *InitClusterModule) Init()

type InstallKubeBinariesModule

type InstallKubeBinariesModule struct {
	common.KubeModule
}

func (*InstallKubeBinariesModule) Init

func (i *InstallKubeBinariesModule) Init()

type JoinNodesModule

type JoinNodesModule struct {
	common.KubeModule
}

func (*JoinNodesModule) Init

func (j *JoinNodesModule) Init()

type K3sStatus

type K3sStatus struct {
	Version     string
	ClusterInfo string
	NodeToken   string
	KubeConfig  string
	NodesInfo   map[string]string
}

func NewK3sStatus

func NewK3sStatus() *K3sStatus

func (*K3sStatus) LoadKubeConfig

func (k *K3sStatus) LoadKubeConfig(runtime connector.Runtime, kubeConf *common.KubeConf) error

func (*K3sStatus) SearchInfo

func (k *K3sStatus) SearchInfo(runtime connector.Runtime) error

func (*K3sStatus) SearchKubeConfig

func (k *K3sStatus) SearchKubeConfig(runtime connector.Runtime) error

func (*K3sStatus) SearchNodeToken

func (k *K3sStatus) SearchNodeToken(runtime connector.Runtime) error

func (*K3sStatus) SearchNodesInfo

func (k *K3sStatus) SearchNodesInfo(_ connector.Runtime) error

func (*K3sStatus) SearchVersion

func (k *K3sStatus) SearchVersion(runtime connector.Runtime) error

type NodeInCluster

type NodeInCluster struct {
	common.KubePrepare
	Not bool
}

func (*NodeInCluster) PreCheck

func (n *NodeInCluster) PreCheck(runtime connector.Runtime) (bool, error)

type SaveKubeConfig

type SaveKubeConfig struct {
	common.KubeAction
}

func (*SaveKubeConfig) Execute

func (s *SaveKubeConfig) Execute(_ connector.Runtime) error

type SaveKubeConfigModule

type SaveKubeConfigModule struct {
	common.KubeModule
}

func (*SaveKubeConfigModule) Init

func (s *SaveKubeConfigModule) Init()

type StatusModule

type StatusModule struct {
	common.KubeModule
}

func (*StatusModule) Init

func (s *StatusModule) Init()

type SyncKubeBinary

type SyncKubeBinary struct {
	common.KubeAction
}

func (*SyncKubeBinary) Execute

func (s *SyncKubeBinary) Execute(runtime connector.Runtime) error

type SyncKubeConfigToWorker

type SyncKubeConfigToWorker struct {
	common.KubeAction
}

func (*SyncKubeConfigToWorker) Execute

func (s *SyncKubeConfigToWorker) Execute(runtime connector.Runtime) error

type UsePrivateRegstry

type UsePrivateRegstry struct {
	common.KubePrepare
	Not bool
}

func (*UsePrivateRegstry) PreCheck

func (c *UsePrivateRegstry) PreCheck(_ connector.Runtime) (bool, error)