hosts

Documentation

Index

• Constants
• func DeleteNode(toDeleteHost *Host, kubeClient *kubernetes.Clientset, hasAnotherRole bool) error
• func HealthcheckFactory(h *Host) (func(network, address string) (net.Conn, error), error)
• func IsHostListChanged(currentHosts, configHosts []*Host) bool
• func SSHFactory(h *Host) (func(network, address string) (net.Conn, error), error)
• type DialerFactory
• type Host
  • func GetToDeleteHosts(currentHosts, configHosts []*Host) []*Host
  • func (h *Host) CleanUp(toCleanPaths []string, cleanerImage string) error
  • func (h *Host) CleanUpAll(cleanerImage string) error
  • func (h *Host) CleanUpControlHost(workerRole, cleanerImage string) error
  • func (h *Host) CleanUpWorkerHost(controlRole, cleanerImage string) error
  • func (h *Host) TunnelUp(dialerFactory DialerFactory) error

Constants

const (
	ToCleanEtcdDir       = "/var/lib/etcd"
	ToCleanSSLDir        = "/etc/kubernetes/ssl"
	ToCleanCNIConf       = "/etc/cni"
	ToCleanCNIBin        = "/opt/cni"
	ToCleanCalicoRun     = "/var/run/calico"
	CleanerContainerName = "kube-cleaner"
)

const (
	DockerAPIVersion = "1.24"
	K8sVersion       = "1.8"
)

Functions

func DeleteNode

func DeleteNode(toDeleteHost *Host, kubeClient *kubernetes.Clientset, hasAnotherRole bool) error

func HealthcheckFactory

func HealthcheckFactory(h *Host) (func(network, address string) (net.Conn, error), error)

func IsHostListChanged

func IsHostListChanged(currentHosts, configHosts []*Host) bool

func SSHFactory

func SSHFactory(h *Host) (func(network, address string) (net.Conn, error), error)

Types

type DialerFactory

type DialerFactory func(h *Host) (func(network, address string) (net.Conn, error), error)

type Host

type Host struct {
	v3.RKEConfigNode
	DClient             *client.Client
	HealthcheckPort     int
	IsControl           bool
	IsWorker            bool
	IgnoreDockerVersion bool
}

func GetToDeleteHosts

func GetToDeleteHosts(currentHosts, configHosts []*Host) []*Host

func (*Host) CleanUp

func (h *Host) CleanUp(toCleanPaths []string, cleanerImage string) error

func (*Host) CleanUpAll

func (h *Host) CleanUpAll(cleanerImage string) error

func (*Host) CleanUpControlHost

func (h *Host) CleanUpControlHost(workerRole, cleanerImage string) error

func (*Host) CleanUpWorkerHost

func (h *Host) CleanUpWorkerHost(controlRole, cleanerImage string) error

func (*Host) TunnelUp

func (h *Host) TunnelUp(dialerFactory DialerFactory) error