machine

Documentation

Index

• Constants
• func IsGPU(labels map[string]string) bool
• type Handler
• type Machine
  • func NewMachine(m platformv1.Machine, c *platformv1.Cluster, ...) (*Machine, error)
  • func (c *Machine) SetCondition(newCondition platformv1.MachineCondition)
• type Provider
  • func NewProvider() (*Provider, error)
  • func (p *Provider) EnsureCNIPlugins(m *Machine) error
  • func (p *Provider) EnsureClean(m *Machine) error
  • func (p *Provider) EnsureCopyFiles(m *Machine) error
  • func (p *Provider) EnsureDisableSwap(m *Machine) error
  • func (p *Provider) EnsureDocker(m *Machine) error
  • func (p *Provider) EnsureJoinNode(m *Machine) error
  • func (p *Provider) EnsureKernelModule(m *Machine) error
  • func (p *Provider) EnsureKubeadm(m *Machine) error
  • func (p *Provider) EnsureKubeconfig(m *Machine) error
  • func (p *Provider) EnsureKubelet(m *Machine) error
  • func (p *Provider) EnsureMarkNode(m *Machine) error
  • func (p *Provider) EnsureNodeReady(m *Machine) error
  • func (p *Provider) EnsurePostInstallHook(m *Machine) error
  • func (p *Provider) EnsurePreInstallHook(m *Machine) error
  • func (p *Provider) EnsurePreflight(m *Machine) error
  • func (p *Provider) EnsureRegistryHosts(m *Machine) error
  • func (p *Provider) EnsureSysctl(m *Machine) error
  • func (p *Provider) Name() string
  • func (p *Provider) OnInitialize(tkev1Machine platformv1.Machine, tkev1Cluster platformv1.Cluster, ...) (platformv1.Machine, error)
  • func (p *Provider) Validate(m platform.Machine) (field.ErrorList, error)

Constants

const (
	ReasonFailedProcess     = "FailedProcess"
	ReasonWaitingProcess    = "WaitingProcess"
	ReasonSuccessfulProcess = "SuccessfulProcess"

	ConditionTypeDone = "EnsureDone"
)

Functions

func IsGPU

func IsGPU(labels map[string]string) bool

Types

type Handler

type Handler func(*Machine) error

type Machine

type Machine struct {
	platformv1.Machine
	Cluster           *platformv1.Cluster
	ClusterCredential *platformv1.ClusterCredential
	*config.Config
	ssh.Interface
	ClientSet kubernetes.Interface
}

func NewMachine

func NewMachine(m platformv1.Machine, c *platformv1.Cluster, credential *platformv1.ClusterCredential, cfg *config.Config) (*Machine, error)

func (*Machine) SetCondition

func (c *Machine) SetCondition(newCondition platformv1.MachineCondition)

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider() (*Provider, error)

func (*Provider) EnsureCNIPlugins

func (p *Provider) EnsureCNIPlugins(m *Machine) error

func (*Provider) EnsureClean

func (p *Provider) EnsureClean(m *Machine) error

func (*Provider) EnsureCopyFiles

func (p *Provider) EnsureCopyFiles(m *Machine) error

func (*Provider) EnsureDisableSwap

func (p *Provider) EnsureDisableSwap(m *Machine) error

func (*Provider) EnsureDocker

func (p *Provider) EnsureDocker(m *Machine) error

func (*Provider) EnsureJoinNode

func (p *Provider) EnsureJoinNode(m *Machine) error

func (*Provider) EnsureKernelModule

func (p *Provider) EnsureKernelModule(m *Machine) error

func (*Provider) EnsureKubeadm

func (p *Provider) EnsureKubeadm(m *Machine) error

func (*Provider) EnsureKubeconfig

func (p *Provider) EnsureKubeconfig(m *Machine) error

func (*Provider) EnsureKubelet

func (p *Provider) EnsureKubelet(m *Machine) error

func (*Provider) EnsureMarkNode

func (p *Provider) EnsureMarkNode(m *Machine) error

func (*Provider) EnsureNodeReady

func (p *Provider) EnsureNodeReady(m *Machine) error

func (*Provider) EnsurePostInstallHook

func (p *Provider) EnsurePostInstallHook(m *Machine) error

func (*Provider) EnsurePreInstallHook

func (p *Provider) EnsurePreInstallHook(m *Machine) error

func (*Provider) EnsurePreflight

func (p *Provider) EnsurePreflight(m *Machine) error

func (*Provider) EnsureRegistryHosts

func (p *Provider) EnsureRegistryHosts(m *Machine) error

func (*Provider) EnsureSysctl

func (p *Provider) EnsureSysctl(m *Machine) error

func (*Provider) Name

func (p *Provider) Name() string

func (*Provider) OnInitialize

func (p *Provider) OnInitialize(tkev1Machine platformv1.Machine, tkev1Cluster platformv1.Cluster, credential platformv1.ClusterCredential) (platformv1.Machine, error)

func (*Provider) Validate

func (p *Provider) Validate(m platform.Machine) (field.ErrorList, error)