Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cluster

package

Go to main page

Versions in this module

v0

v0.1.1

Feb 7, 2018

Changes in this version

+ const ClientCAPath

+ const ClientCertPath

+ const ClientKeyPath

+ const DefaultDNSmasqImage

+ const DefaultIngressController

+ const DefaultKubernetesServicesSidecarImage

+ const IngressAddonResourceName

type Cluster

+ PrivateRegistriesMap map[string]v3.PrivateRegistry

+ func (c *Cluster) DeployAddons(ctx context.Context) error

+ func (c *Cluster) PrePullK8sImages(ctx context.Context) error

+ func (c *Cluster) SyncLabelsAndTaints(ctx context.Context) error

v0.1.1-rc2

Feb 7, 2018

v0.1.1-rc1

Feb 1, 2018

v0.1.0

Jan 24, 2018

Changes in this version

+ const APIRoot

+ const AWSCloudProvider

+ const AplineImage

+ const CNIImage

+ const CPPortListenContainer

+ const CalicoCNIImage

+ const CalicoCloudProvider

+ const CalicoControllersImage

+ const CalicoNetworkPlugin

+ const CalicoNodeImage

+ const Calicoctl

+ const CalicoctlImage

+ const CanalCNIImage

+ const CanalFlannelImage

+ const CanalFlannelImg

+ const CanalNetworkPlugin

+ const CanalNodeImage

+ const CertDownloaderImage

+ const ClientCA

+ const ClientCert

+ const ClientKey

+ const CloudProvider

+ const ClusterCIDR

+ const ControllerPort

+ const ControllersImage

+ const DNSMasqImage

+ const DefaultAplineImage

+ const DefaultAuthStrategy

+ const DefaultAuthorizationMode

+ const DefaultCalicoCNIImage

+ const DefaultCalicoControllersImage

+ const DefaultCalicoNodeImage

+ const DefaultCalicoctlImage

+ const DefaultCanalCNIImage

+ const DefaultCanalFlannelImage

+ const DefaultCanalNodeImage

+ const DefaultCertDownloaderImage

+ const DefaultClusterCIDR

+ const DefaultClusterConfig

+ const DefaultClusterDNSService

+ const DefaultClusterDomain

+ const DefaultClusterSSHKeyPath

+ const DefaultDNSMasqImage

+ const DefaultDockerSockPath

+ const DefaultEtcdImage

+ const DefaultFlannelCNIImage

+ const DefaultFlannelImage

+ const DefaultInfraContainerImage

+ const DefaultK8sImage

+ const DefaultKubeDNSAutoScalerImage

+ const DefaultKubeDNSImage

+ const DefaultKubeDNSSidecarImage

+ const DefaultNetworkCloudProvider

+ const DefaultNetworkPlugin

+ const DefaultNginxProxyImage

+ const DefaultServiceClusterIPRange

+ const DefaultServiceSidekickImage

+ const DefaultWeaveCNIImage

+ const DefaultWeaveImage

+ const EtcdEndpoints

+ const EtcdPort1

+ const EtcdPort2

+ const EtcdPortListenContainer

+ const FlannelCNIImage

+ const FlannelIface

+ const FlannelImage

+ const FlannelInterface

+ const FlannelNetworkPlugin

+ const FlannetVXLANPortUDP

+ const GetStateTimeout

+ const Image

+ const KubeAPIPort

+ const KubeCfg

+ const KubeDNSAddonResourceName

+ const KubeDNSAutoScalerImage

+ const KubeDNSImage

+ const KubeDNSSidecarImage

+ const KubeProxyPort

+ const KubeletPort

+ const KubernetesClientTimeOut

+ const LocalNodeAddress

+ const LocalNodeHostname

+ const LocalNodeUser

+ const NetworkPluginResourceName

+ const NginxProxyImage

+ const NodeImage

+ const NoneAuthorizationMode

+ const PortCheckContainer

+ const RBACConfig

+ const ScedulerPort

+ const ServiceSidekickImage

+ const StateConfigMapName

+ const UpdateStateTimeout

+ const UserAddonResourceName

+ const WeaveCNIImage

+ const WeaveImage

+ const WeaveNetworkPlugin

+ const WorkerPortListenContainer

+ const X509AuthenticationProvider

+ func CheckEtcdHostsChanged(kubeCluster, currentCluster *Cluster) error

+ func GetK8sVersion(localConfigPath string) (string, error)

+ func GetLocalKubeConfig(configPath, configDir string) string

+ func GetLocalRKEConfig() *v3.RancherKubernetesEngineConfig

+ func GetLocalRKENodeConfig() *v3.RKEConfigNode

+ func ParseConfig(clusterFile string) (*v3.RancherKubernetesEngineConfig, error)

+ func ReconcileCluster(ctx context.Context, kubeCluster, currentCluster *Cluster) error

+ func SetUpAuthentication(ctx context.Context, kubeCluster, currentCluster *Cluster) error

+ type Cluster struct

+ Certificates map[string]pki.CertificatePKI

+ ClusterCIDR string

+ ClusterDNSServer string

+ ClusterDomain string

+ ConfigPath string

+ ControlPlaneHosts []*hosts.Host

+ DockerDialerFactory hosts.DialerFactory

+ EtcdHosts []*hosts.Host

+ KubeClient *kubernetes.Clientset

+ KubernetesServiceIP net.IP

+ LocalConnDialerFactory hosts.DialerFactory

+ LocalKubeConfigPath string

+ WorkerHosts []*hosts.Host

+ func ParseCluster(ctx context.Context, rkeConfig *v3.RancherKubernetesEngineConfig, ...) (*Cluster, error)

+ func (c *Cluster) ApplyAuthzResources(ctx context.Context) error

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

+ func (c *Cluster) CheckClusterPorts(ctx context.Context, currentCluster *Cluster) error

+ func (c *Cluster) ClusterRemove(ctx context.Context) error

+ func (c *Cluster) DeployControlPlane(ctx context.Context) error

+ func (c *Cluster) DeployK8sAddOns(ctx context.Context) error

+ func (c *Cluster) DeployNetworkPlugin(ctx context.Context) error

+ func (c *Cluster) DeployUserAddOns(ctx context.Context) error

+ func (c *Cluster) DeployWorkerPlane(ctx context.Context) error

+ func (c *Cluster) GetClusterState(ctx context.Context) (*Cluster, error)

+ func (c *Cluster) InvertIndexHosts() error

+ func (c *Cluster) SaveClusterState(ctx context.Context, rkeConfig *v3.RancherKubernetesEngineConfig) error

+ func (c *Cluster) SetUpHosts(ctx context.Context) error

+ func (c *Cluster) StoreAddonConfigMap(ctx context.Context, addonYaml string, addonName string) error

+ func (c *Cluster) TunnelHosts(ctx context.Context, local bool) error

+ func (c *Cluster) ValidateCluster() error

v0.0.12-dev

Jan 15, 2018

v0.0.11-dev

Jan 12, 2018

v0.0.10-dev

Jan 12, 2018

v0.0.9-dev

Jan 2, 2018

v0.0.8-dev

Dec 5, 2017

v0.0.7-dev

Nov 29, 2017

v0.0.6-dev

Nov 28, 2017

v0.0.5-dev

Nov 26, 2017

v0.0.4-dev

Nov 22, 2017

v0.0.3-dev

Nov 22, 2017

v0.0.2-dev

Nov 18, 2017

v0.0.1-dev

Nov 15, 2017