container

Documentation

Index

• Constants
• func InstallContainerd(m *InstallContainerModule) []task.Interface
• func InstallDocker(m *InstallContainerModule) []task.Interface
• func MigrateACri(p *CriMigrateModule) []task.Interface
• func MigrateMCri(p *CriMigrateModule) []task.Interface
• func MigrateSelfNodeCriTasks(runtime connector.Runtime, kubeAction common.KubeAction) error
• func MigrateWCri(p *CriMigrateModule) []task.Interface
• func UninstallContainerd(m *UninstallContainerModule) []task.Interface
• func UninstallDocker(m *UninstallContainerModule) []task.Interface
• type ContainerdExist
  • func (c *ContainerdExist) PreCheck(runtime connector.Runtime) (bool, error)
• type CordonNode
  • func (d *CordonNode) Execute(runtime connector.Runtime) error
• type CriMigrateModule
  • func (p *CriMigrateModule) Init()
  • func (i *CriMigrateModule) IsSkip() bool
• type CrictlExist
  • func (c *CrictlExist) PreCheck(runtime connector.Runtime) (bool, error)
• type DisableContainerd
  • func (d *DisableContainerd) Execute(runtime connector.Runtime) error
• type DisableDocker
  • func (d *DisableDocker) Execute(runtime connector.Runtime) error
• type DockerExist
  • func (d *DockerExist) PreCheck(runtime connector.Runtime) (bool, error)
• type DockerLoginRegistry
  • func (p *DockerLoginRegistry) Execute(runtime connector.Runtime) error
• type DrainNode
  • func (d *DrainNode) Execute(runtime connector.Runtime) error
• type EditKubeletCri
  • func (i *EditKubeletCri) Execute(runtime connector.Runtime) error
• type EnableContainerd
  • func (e *EnableContainerd) Execute(runtime connector.Runtime) error
• type EnableDocker
  • func (e *EnableDocker) Execute(runtime connector.Runtime) error
• type InstallContainerModule
  • func (i *InstallContainerModule) Init()
  • func (i *InstallContainerModule) IsSkip() bool
• type MigrateSelfNodeCri
  • func (d *MigrateSelfNodeCri) Execute(runtime connector.Runtime) error
• type PrivateRegistryAuth
  • func (p *PrivateRegistryAuth) PreCheck(runtime connector.Runtime) (bool, error)
• type RestartCri
  • func (i *RestartCri) Execute(runtime connector.Runtime) error
• type RestartKubeletNode
  • func (d *RestartKubeletNode) Execute(runtime connector.Runtime) error
• type SyncContainerd
  • func (s *SyncContainerd) Execute(runtime connector.Runtime) error
• type SyncCrictlBinaries
  • func (s *SyncCrictlBinaries) Execute(runtime connector.Runtime) error
• type SyncDockerBinaries
  • func (s *SyncDockerBinaries) Execute(runtime connector.Runtime) error
• type UnCordonNode
  • func (d *UnCordonNode) Execute(runtime connector.Runtime) error
• type UninstallContainerModule
  • func (i *UninstallContainerModule) Init()
  • func (i *UninstallContainerModule) IsSkip() bool

Constants

const (
	DefaultContainerdCRISocket = "/run/containerd/containerd.sock"
)

Functions

func InstallContainerd

func InstallContainerd(m *InstallContainerModule) []task.Interface

func InstallDocker

func InstallDocker(m *InstallContainerModule) []task.Interface

func MigrateACri

func MigrateACri(p *CriMigrateModule) []task.Interface

func MigrateMCri

func MigrateMCri(p *CriMigrateModule) []task.Interface

func MigrateSelfNodeCriTasks

func MigrateSelfNodeCriTasks(runtime connector.Runtime, kubeAction common.KubeAction) error

func MigrateWCri

func MigrateWCri(p *CriMigrateModule) []task.Interface

func UninstallContainerd

func UninstallContainerd(m *UninstallContainerModule) []task.Interface

func UninstallDocker

func UninstallDocker(m *UninstallContainerModule) []task.Interface

Types

type ContainerdExist

type ContainerdExist struct {
	common.KubePrepare
	Not bool
}

func (*ContainerdExist) PreCheck

func (c *ContainerdExist) PreCheck(runtime connector.Runtime) (bool, error)

type CordonNode

type CordonNode struct {
	common.KubeAction
}

func (*CordonNode) Execute

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

type CriMigrateModule

type CriMigrateModule struct {
	common.KubeModule

	Skip bool
}

func (*CriMigrateModule) Init

func (p *CriMigrateModule) Init()

func (*CriMigrateModule) IsSkip

func (i *CriMigrateModule) IsSkip() bool

type CrictlExist

type CrictlExist struct {
	common.KubePrepare
	Not bool
}

func (*CrictlExist) PreCheck

func (c *CrictlExist) PreCheck(runtime connector.Runtime) (bool, error)

type DisableContainerd

type DisableContainerd struct {
	common.KubeAction
}

func (*DisableContainerd) Execute

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

type DisableDocker

type DisableDocker struct {
	common.KubeAction
}

func (*DisableDocker) Execute

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

type DockerExist

type DockerExist struct {
	common.KubePrepare
	Not bool
}

func (*DockerExist) PreCheck

func (d *DockerExist) PreCheck(runtime connector.Runtime) (bool, error)

type DockerLoginRegistry

type DockerLoginRegistry struct {
	common.KubeAction
}

func (*DockerLoginRegistry) Execute

func (p *DockerLoginRegistry) Execute(runtime connector.Runtime) error

type DrainNode

type DrainNode struct {
	common.KubeAction
}

func (*DrainNode) Execute

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

type EditKubeletCri

type EditKubeletCri struct {
	common.KubeAction
}

func (*EditKubeletCri) Execute

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

type EnableContainerd

type EnableContainerd struct {
	common.KubeAction
}

func (*EnableContainerd) Execute

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

type EnableDocker

type EnableDocker struct {
	common.KubeAction
}

func (*EnableDocker) Execute

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

type InstallContainerModule

type InstallContainerModule struct {
	common.KubeModule
	Skip bool
}

func (*InstallContainerModule) Init

func (i *InstallContainerModule) Init()

func (*InstallContainerModule) IsSkip

func (i *InstallContainerModule) IsSkip() bool

type MigrateSelfNodeCri

type MigrateSelfNodeCri struct {
	common.KubeAction
}

func (*MigrateSelfNodeCri) Execute

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

type PrivateRegistryAuth

type PrivateRegistryAuth struct {
	common.KubePrepare
}

func (*PrivateRegistryAuth) PreCheck

func (p *PrivateRegistryAuth) PreCheck(runtime connector.Runtime) (bool, error)

type RestartCri

type RestartCri struct {
	common.KubeAction
}

func (*RestartCri) Execute

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

type RestartKubeletNode

type RestartKubeletNode struct {
	common.KubeAction
}

func (*RestartKubeletNode) Execute

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

type SyncContainerd

type SyncContainerd struct {
	common.KubeAction
}

func (*SyncContainerd) Execute

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

type SyncCrictlBinaries

type SyncCrictlBinaries struct {
	common.KubeAction
}

func (*SyncCrictlBinaries) Execute

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

type SyncDockerBinaries

type SyncDockerBinaries struct {
	common.KubeAction
}

func (*SyncDockerBinaries) Execute

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

type UnCordonNode

type UnCordonNode struct {
	common.KubeAction
}

func (*UnCordonNode) Execute

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

type UninstallContainerModule

type UninstallContainerModule struct {
	common.KubeModule
	Skip bool
}

func (*UninstallContainerModule) Init

func (i *UninstallContainerModule) Init()

func (*UninstallContainerModule) IsSkip

func (i *UninstallContainerModule) IsSkip() bool