cluster

package

v0.0.5-dev Latest Latest Go to latest Published: Nov 26, 2017 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/superseb/rke

Documentation ¶

Index ¶

Constants
func CheckEtcdHostsChanged(kubeCluster, currentCluster *Cluster) error
func CheckHostsChangedOnUpgrade(kubeCluster, currentCluster *Cluster) error
func GetK8sVersion(localConfigPath string) (string, error)
func GetLocalKubeConfig(configPath string) string
func ReconcileCluster(kubeCluster, currentCluster *Cluster) error
func SetUpAuthentication(kubeCluster, currentCluster *Cluster) error
type Cluster
- func ParseConfig(clusterFile string) (*Cluster, error)

Constants ¶

View Source

const (
	KubeDNSAddonResourceName = "rke-kubedns-addon"
	UserAddonResourceName    = "rke-user-addon"
)

View Source

const (
	X509AuthenticationProvider = "x509"
	DefaultClusterConfig       = "cluster.yml"
	StateConfigMapName         = "cluster-state"
	UpdateStateTimeout         = 30
	GetStateTimeout            = 30
	KubernetesClientTimeOut    = 30
)

View Source

const (
	DefaultSSHKeyPath = "/.ssh/id_rsa"
)

View Source

const (
	NetworkPluginResourceName = "rke-netwok-plugin"
)

Variables ¶

This section is empty.

Functions ¶

func CheckEtcdHostsChanged ¶

func CheckEtcdHostsChanged(kubeCluster, currentCluster *Cluster) error

func CheckHostsChangedOnUpgrade ¶

func CheckHostsChangedOnUpgrade(kubeCluster, currentCluster *Cluster) error

func GetK8sVersion ¶

func GetK8sVersion(localConfigPath string) (string, error)

func GetLocalKubeConfig ¶

func GetLocalKubeConfig(configPath string) string

func ReconcileCluster ¶

func ReconcileCluster(kubeCluster, currentCluster *Cluster) error

func SetUpAuthentication ¶

func SetUpAuthentication(kubeCluster, currentCluster *Cluster) error

Types ¶

type Cluster ¶

type Cluster struct {
	v1.RancherKubernetesEngineConfig `yaml:",inline"`
	ConfigPath                       string `yaml:"config_path"`
	LocalKubeConfigPath              string
	EtcdHosts                        []hosts.Host
	WorkerHosts                      []hosts.Host
	ControlPlaneHosts                []hosts.Host
	KubeClient                       *kubernetes.Clientset
	KubernetesServiceIP              net.IP
	Certificates                     map[string]pki.CertificatePKI
	ClusterDomain                    string
	ClusterCIDR                      string
	ClusterDNSServer                 string
}

func ParseConfig ¶

func ParseConfig(clusterFile string) (*Cluster, error)

func (*Cluster) ApplySystemAddonExcuteJob ¶

func (c *Cluster) ApplySystemAddonExcuteJob(addonJob string) error

func (*Cluster) ClusterDown ¶

func (c *Cluster) ClusterDown() error

func (*Cluster) ClusterUpgrade ¶

func (c *Cluster) ClusterUpgrade() error

func (*Cluster) DeployClusterPlanes ¶

func (c *Cluster) DeployClusterPlanes() error

func (*Cluster) DeployK8sAddOns ¶

func (c *Cluster) DeployK8sAddOns() error

func (*Cluster) DeployNetworkPlugin ¶

func (c *Cluster) DeployNetworkPlugin() error

func (*Cluster) DeployUserAddOns ¶

func (c *Cluster) DeployUserAddOns() error

func (*Cluster) GetClusterState ¶

func (c *Cluster) GetClusterState() (*Cluster, error)

func (*Cluster) InvertIndexHosts ¶

func (c *Cluster) InvertIndexHosts() error

func (*Cluster) SaveClusterState ¶

func (c *Cluster) SaveClusterState(clusterFile string) error

func (*Cluster) SetUpHosts ¶

func (c *Cluster) SetUpHosts() error

func (*Cluster) StoreAddonConfigMap ¶

func (c *Cluster) StoreAddonConfigMap(addonYaml string, addonName string) error

func (*Cluster) TunnelHosts ¶

func (c *Cluster) TunnelHosts() error

func (*Cluster) ValidateCluster ¶

func (c *Cluster) ValidateCluster() error

Source Files ¶

View all Source files

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