hosts

Documentation

Index

• Constants
• func BastionHostWrapTransport(bastionHost v3.BastionHost) k8s.WrapTransport
• func DeleteNode(ctx context.Context, toDeleteHost *Host, kubeClient *kubernetes.Clientset, ...) error
• func IsHostListChanged(currentHosts, configHosts []*Host) bool
• func LocalConnFactory(h *Host) (func(network, address string) (net.Conn, error), error)
• func LocalHealthcheckFactory(h *Host) (func(network, address string) (net.Conn, error), error)
• func RemoveTaintFromHost(ctx context.Context, host *Host, taintKey string, ...) error
• func SSHFactory(h *Host) (func(network, address string) (net.Conn, error), error)
• type DialerFactory
• type Host
  • func GetToAddHosts(currentHosts, configHosts []*Host) []*Host
  • func GetToDeleteHosts(currentHosts, configHosts, inactiveHosts []*Host) []*Host
  • func GetUniqueHostList(etcdHosts, cpHosts, workerHosts []*Host) []*Host
  • func NodesToHosts(rkeNodes []v3.RKEConfigNode, nodeRole string) []*Host
  • func (h *Host) CleanUp(ctx context.Context, toCleanPaths []string, cleanerImage string, ...) error
  • func (h *Host) CleanUpAll(ctx context.Context, cleanerImage string, prsMap map[string]v3.PrivateRegistry, ...) error
  • func (h *Host) CleanUpControlHost(ctx context.Context, cleanerImage string, prsMap map[string]v3.PrivateRegistry) error
  • func (h *Host) CleanUpEtcdHost(ctx context.Context, cleanerImage string, prsMap map[string]v3.PrivateRegistry) error
  • func (h *Host) CleanUpWorkerHost(ctx context.Context, cleanerImage string, prsMap map[string]v3.PrivateRegistry) error
  • func (h *Host) TunnelUp(ctx context.Context, dialerFactory DialerFactory) error
  • func (h *Host) TunnelUpLocal(ctx context.Context) error

Constants

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

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

const (
	DockerDialerTimeout = 30
)

Functions

func BastionHostWrapTransport

func BastionHostWrapTransport(bastionHost v3.BastionHost) k8s.WrapTransport

func DeleteNode

func DeleteNode(ctx context.Context, toDeleteHost *Host, kubeClient *kubernetes.Clientset, hasAnotherRole bool, cloudProvider string) error

func IsHostListChanged

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

func LocalConnFactory

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

func LocalHealthcheckFactory

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

func RemoveTaintFromHost

func RemoveTaintFromHost(ctx context.Context, host *Host, taintKey string, kubeClient *kubernetes.Clientset) error

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
	LocalConnPort       int
	IsControl           bool
	IsWorker            bool
	IsEtcd              bool
	IgnoreDockerVersion bool
	ToAddEtcdMember     bool
	ExistingEtcdCluster bool
	SavedKeyPhrase      string
	ToAddLabels         map[string]string
	ToDelLabels         map[string]string
	ToAddTaints         []string
	ToDelTaints         []string
	DockerInfo          types.Info
	UpdateWorker        bool
	PrefixPath          string
	BastionHost         v3.BastionHost
}

func GetToAddHosts

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

func GetToDeleteHosts

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

func GetUniqueHostList

func GetUniqueHostList(etcdHosts, cpHosts, workerHosts []*Host) []*Host

func NodesToHosts

func NodesToHosts(rkeNodes []v3.RKEConfigNode, nodeRole string) []*Host

func (*Host) CleanUp

func (h *Host) CleanUp(ctx context.Context, toCleanPaths []string, cleanerImage string, prsMap map[string]v3.PrivateRegistry) error

func (*Host) CleanUpAll

func (h *Host) CleanUpAll(ctx context.Context, cleanerImage string, prsMap map[string]v3.PrivateRegistry, externalEtcd bool) error

func (*Host) CleanUpControlHost

func (h *Host) CleanUpControlHost(ctx context.Context, cleanerImage string, prsMap map[string]v3.PrivateRegistry) error

func (*Host) CleanUpEtcdHost

func (h *Host) CleanUpEtcdHost(ctx context.Context, cleanerImage string, prsMap map[string]v3.PrivateRegistry) error

func (*Host) CleanUpWorkerHost

func (h *Host) CleanUpWorkerHost(ctx context.Context, cleanerImage string, prsMap map[string]v3.PrivateRegistry) error

func (*Host) TunnelUp

func (h *Host) TunnelUp(ctx context.Context, dialerFactory DialerFactory) error

func (*Host) TunnelUpLocal

func (h *Host) TunnelUpLocal(ctx context.Context) error