hosts

package

v0.1.6 Latest Latest Go to latest Published: Apr 27, 2018 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/thxcode/rancher-rke

Documentation ¶

Index ¶

Constants
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

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"
)

View Source

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

View Source

const (
	DockerDialerTimeout = 30
)

Variables ¶

This section is empty.

Functions ¶

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
}

func GetToAddHosts ¶

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

func GetToDeleteHosts ¶

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

func GetUniqueHostList ¶ added in v0.1.2

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

func NodesToHosts ¶ added in v0.1.2

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL