cluster

Documentation

Index

• Constants
• 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)
  • func (c *Cluster) ApplySystemAddonExcuteJob(addonJob string) error
  • func (c *Cluster) ClusterDown() error
  • func (c *Cluster) ClusterUpgrade() error
  • func (c *Cluster) DeployClusterPlanes() error
  • func (c *Cluster) DeployK8sAddOns() error
  • func (c *Cluster) DeployNetworkPlugin() error
  • func (c *Cluster) DeployUserAddOns() error
  • func (c *Cluster) GetClusterState() (*Cluster, error)
  • func (c *Cluster) InvertIndexHosts() error
  • func (c *Cluster) SaveClusterState(clusterFile string) error
  • func (c *Cluster) SetUpHosts() error
  • func (c *Cluster) StoreAddonConfigMap(addonYaml string, addonName string) error
  • func (c *Cluster) TunnelHosts() error
  • func (c *Cluster) ValidateCluster() error

Constants

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

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

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

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

Functions

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