Versions in this module Expand all Collapse all v1 v1.15.1 Feb 17, 2020 v1.15.0 Feb 17, 2020 Changes in this version + const KubeDNSServiceAccountName + const KubeProxyClusterRoleName + const KubeProxyServiceAccountName + const MetadataLatest + const TaintsAnnotationKey + const VolStatusValue + const VolumeMetaDataFile + var Containerized = false + var RootFS = "/" + func BuildEtcdManifest(c *EtcdCluster) *v1.Pod + func DebugString(o interface{}) string + func ExecuteTemplate(key string, templateDefinition string, model interface{}) ([]byte, error) + func GetDropletInternalIP() (net.IP, error) + func NewNsEnterExec() mount.Exec + type ALIVolumes struct + func NewALIVolumes() (*ALIVolumes, error) + func (a *ALIVolumes) AttachVolume(volume *Volume) error + func (a *ALIVolumes) ClusterID() string + func (a *ALIVolumes) FindMountedVolume(volume *Volume) (string, error) + func (a *ALIVolumes) FindVolumes() ([]*Volume, error) + func (a *ALIVolumes) GossipSeeds() (gossip.SeedProvider, error) + func (a *ALIVolumes) InstanceID() string + func (a *ALIVolumes) InternalIP() net.IP + type AWSVolumes struct + func NewAWSVolumes() (*AWSVolumes, error) + func (a *AWSVolumes) AttachVolume(volume *Volume) error + func (a *AWSVolumes) ClusterID() string + func (a *AWSVolumes) FindVolumes() ([]*Volume, error) + func (a *AWSVolumes) GossipSeeds() (gossip.SeedProvider, error) + func (a *AWSVolumes) InstanceID() string + func (a *AWSVolumes) InternalIP() net.IP + func (v *AWSVolumes) FindMountedVolume(volume *Volume) (string, error) + type ByEtcdClusterName []*Volume + func (a ByEtcdClusterName) Len() int + func (a ByEtcdClusterName) Less(i, j int) bool + func (a ByEtcdClusterName) Swap(i, j int) + type DNSProvider interface + RemoveRecordsImmediate func(records []dns.Record) error + Replace func(fqdn string, values []string) error + Run func() + type DOVolumes struct + Cloud *digitalocean.Cloud + ClusterID string + func NewDOVolumes(clusterID string) (*DOVolumes, error) + func (d *DOVolumes) AttachVolume(volume *Volume) error + func (d *DOVolumes) FindMountedVolume(volume *Volume) (string, error) + func (d *DOVolumes) FindVolumes() ([]*Volume, error) + type EtcdCluster struct + BackupImage string + BackupStore string + CPURequest *resource.Quantity + ClientPort int + ClusterName string + ClusterToken string + DataDirName string + ElectionTimeout string + HeartbeatInterval string + ImageSource string + LogFile string + Me *EtcdNode + MemoryRequest *resource.Quantity + Nodes []*EtcdNode + PeerCA string + PeerCert string + PeerKey string + PeerPort int + PodName string + ProxyMode bool + Spec *etcd.EtcdClusterSpec + TLSAuth bool + TLSCA string + TLSCert string + TLSKey string + VolumeMountPath string + func (c *EtcdCluster) String() string + type EtcdController struct + func (k *EtcdController) RunSyncLoop() + type EtcdNode struct + InternalName string + Name string + func (e *EtcdNode) String() string + type GCEVolumes struct + func NewGCEVolumes() (*GCEVolumes, error) + func (a *GCEVolumes) ClusterID() string + func (a *GCEVolumes) InternalIP() net.IP + func (a *GCEVolumes) Project() string + func (g *GCEVolumes) GossipSeeds() (gossip.SeedProvider, error) + func (g *GCEVolumes) InstanceName() string + func (v *GCEVolumes) AttachVolume(volume *Volume) error + func (v *GCEVolumes) FindMountedVolume(volume *Volume) (string, error) + func (v *GCEVolumes) FindVolumes() ([]*Volume, error) + type GossipDnsProvider struct + DNSView *dns.DNSView + Zone dns.DNSZoneInfo + func (p *GossipDnsProvider) RemoveRecordsImmediate(records []k8sdns.Record) error + func (p *GossipDnsProvider) Replace(fqdn string, values []string) error + func (p *GossipDnsProvider) Run() + type InstanceMetadata struct + AvailabilityZone string + Hostname string + Name string + ProjectID string + ServerID string + UserMeta *Metadata + type KopsDnsProvider struct + DNSController *dns.DNSController + DNSScope dns.Scope + func (p *KopsDnsProvider) RemoveRecordsImmediate(records []dns.Record) error + func (p *KopsDnsProvider) Replace(fqdn string, values []string) error + func (p *KopsDnsProvider) Run() + type KubeBoot struct + ApplyTaints bool + Channels []string + DNS DNSProvider + EtcdBackupImage string + EtcdBackupStore string + EtcdElectionTimeout string + EtcdHeartbeatInterval string + EtcdImageSource string + InitializeRBAC bool + InternalDNSSuffix string + InternalIP net.IP + Kubernetes *KubernetesContext + ManageEtcd bool + Master bool + ModelDir string + PeerCA string + PeerCert string + PeerKey string + TLSAuth bool + TLSCA string + TLSCert string + TLSKey string + func (k *KubeBoot) BuildInternalDNSName(key string) string + func (k *KubeBoot) CreateInternalDNSNameRecord(fqdn string) error + func (k *KubeBoot) Init(volumesProvider Volumes) + func (k *KubeBoot) RunSyncLoop() + func (k *KubeBoot) String() string + type KubernetesContext struct + func NewKubernetesContext() *KubernetesContext + func (c *KubernetesContext) KubernetesClient() (kubernetes.Interface, error) + type Metadata struct + ClusterName string + type OpenstackVolumes struct + func NewOpenstackVolumes() (*OpenstackVolumes, error) + func (a *OpenstackVolumes) ClusterID() string + func (a *OpenstackVolumes) InternalIP() net.IP + func (a *OpenstackVolumes) Project() string + func (g *OpenstackVolumes) GossipSeeds() (gossip.SeedProvider, error) + func (g *OpenstackVolumes) InstanceName() string + func (v *OpenstackVolumes) AttachVolume(volume *Volume) error + func (v *OpenstackVolumes) FindMountedVolume(volume *Volume) (string, error) + func (v *OpenstackVolumes) FindVolumes() ([]*Volume, error) + type VSphereVolumes struct + func NewVSphereVolumes() (*VSphereVolumes, error) + func (v *VSphereVolumes) AttachVolume(volume *Volume) error + func (v *VSphereVolumes) FindMountedVolume(volume *Volume) (string, error) + func (v *VSphereVolumes) FindVolumes() ([]*Volume, error) + func (v *VSphereVolumes) InternalIp() net.IP + type Volume struct + AttachedTo string + ID string + Info VolumeInfo + LocalDevice string + Mountpoint string + Status string + func (v *Volume) String() string + type VolumeInfo struct + Description string + EtcdClusters []*etcd.EtcdClusterSpec + func (v *VolumeInfo) String() string + type VolumeMountController struct + type Volumes interface + AttachVolume func(volume *Volume) error + FindMountedVolume func(volume *Volume) (device string, err error) + FindVolumes func() ([]*Volume, error)