Documentation ¶
Index ¶
- Constants
- func BastionHostWrapTransport(bastionHost v3.BastionHost) (k8s.WrapTransport, error)
- func DeleteNode(ctx context.Context, toDeleteHost *Host, kubeClient *kubernetes.Clientset, ...) error
- func DindConnFactory(h *Host) (func(network, address string) (net.Conn, error), error)
- func DindHealthcheckConnFactory(h *Host) (func(network, address string) (net.Conn, error), error)
- func DoRunLogCleaner(ctx context.Context, host *Host, alpineImage string, ...) error
- func GetPrefixPath(osType, ClusterPrefixPath string) string
- func IsHostListChanged(currentHosts, configHosts []*Host) bool
- func IsNodeInList(host *Host, hostList []*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 DialersOptions
- type Host
- func GetHostListIntersect(a []*Host, b []*Host) []*Host
- func GetToAddHosts(currentHosts, configHosts []*Host) []*Host
- func GetToDeleteHosts(currentHosts, configHosts, inactiveHosts []*Host, includeInactive bool) []*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, clusterPrefixPath string, ...) error
- func (h *Host) TunnelUpLocal(ctx context.Context, clusterVersion string) error
Constants ¶
View Source
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" LogCleanerContainerName = "rke-log-cleaner" RKELogsPath = "/var/lib/rancher/rke/log" B2DOS = "Boot2Docker" B2DPrefixPath = "/mnt/sda1/rke" ROS = "RancherOS" ROSPrefixPath = "/opt/rke" CoreOS = "CoreOS" CoreOSPrefixPath = "/opt/rke" )
View Source
const (
DINDPort = "2375"
)
View Source
const (
DockerAPIVersion = "1.24"
)
View Source
const (
DockerDialerTimeout = 50
)
Variables ¶
This section is empty.
Functions ¶
func BastionHostWrapTransport ¶ added in v0.1.7
func BastionHostWrapTransport(bastionHost v3.BastionHost) (k8s.WrapTransport, error)
func DeleteNode ¶
func DindConnFactory ¶ added in v0.1.9
func DindHealthcheckConnFactory ¶ added in v0.1.9
func DoRunLogCleaner ¶ added in v0.1.8
func GetPrefixPath ¶ added in v0.1.8
func IsHostListChanged ¶
func IsNodeInList ¶ added in v0.1.10
func LocalConnFactory ¶
func LocalHealthcheckFactory ¶
func RemoveTaintFromHost ¶
Types ¶
type DialerFactory ¶
type DialersOptions ¶ added in v0.2.0
type DialersOptions struct { DockerDialerFactory DialerFactory LocalConnDialerFactory DialerFactory K8sWrapTransport k8s.WrapTransport }
func GetDialerOptions ¶ added in v0.2.0
func GetDialerOptions(d, l DialerFactory, w k8s.WrapTransport) DialersOptions
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 GetHostListIntersect ¶ added in v0.2.0
func GetToAddHosts ¶
func GetToDeleteHosts ¶
func GetUniqueHostList ¶ added in v0.1.2
func NodesToHosts ¶ added in v0.1.2
func NodesToHosts(rkeNodes []v3.RKEConfigNode, nodeRole string) []*Host
func (*Host) CleanUpAll ¶
func (*Host) CleanUpControlHost ¶
func (*Host) CleanUpEtcdHost ¶
func (*Host) CleanUpWorkerHost ¶
Click to show internal directories.
Click to hide internal directories.