etcd

Documentation

Index

• Constants
• func CertsModuleForExternal(c *CertsModule) []task.Interface
• func CertsModuleForKubeKey(c *CertsModule) []task.Interface
• func GenerateAltName(k *common.KubeConf, runtime *connector.Runtime) *cert.AltNames
• func KubekeyCertEtcdAdmin(hostname string, altNames *certutil.AltNames) *certs.KubekeyCert
• func KubekeyCertEtcdCA() *certs.KubekeyCert
• func KubekeyCertEtcdClient(hostname string, altNames *certutil.AltNames) *certs.KubekeyCert
• func KubekeyCertEtcdMember(hostname string, altNames *certutil.AltNames) *certs.KubekeyCert
• type BackupETCD
  • func (b *BackupETCD) Execute(runtime connector.Runtime) error
• type BackupModule
  • func (b *BackupModule) Init()
  • func (p *BackupModule) IsSkip() bool
• type CertsModule
  • func (c *CertsModule) Init()
  • func (p *CertsModule) IsSkip() bool
• type CheckMember
  • func (c *CheckMember) Execute(runtime connector.Runtime) error
• type ConfigureModule
  • func (e *ConfigureModule) Init()
  • func (p *ConfigureModule) IsSkip() bool
• type EnableBackupETCDService
  • func (e *EnableBackupETCDService) Execute(runtime connector.Runtime) error
• type EtcdCluster
• type EtcdNode
• type FetchCerts
  • func (f *FetchCerts) Execute(runtime connector.Runtime) error
• type FetchCertsForExternalEtcd
  • func (f *FetchCertsForExternalEtcd) Execute(runtime connector.Runtime) error
• type FirstETCDNode
  • func (f *FirstETCDNode) PreCheck(runtime connector.Runtime) (bool, error)
• type GenerateAccessAddress
  • func (g *GenerateAccessAddress) Execute(runtime connector.Runtime) error
• type GenerateCerts
  • func (g *GenerateCerts) Execute(runtime connector.Runtime) error
• type GenerateConfig
  • func (g *GenerateConfig) Execute(runtime connector.Runtime) error
• type GetStatus
  • func (g *GetStatus) Execute(runtime connector.Runtime) error
• type HealthCheck
  • func (h *HealthCheck) Execute(runtime connector.Runtime) error
• type InstallETCDBinary
  • func (g *InstallETCDBinary) Execute(runtime connector.Runtime) error
• type InstallETCDBinaryModule
  • func (i *InstallETCDBinaryModule) Init()
  • func (p *InstallETCDBinaryModule) IsSkip() bool
• type JoinMember
  • func (j *JoinMember) Execute(runtime connector.Runtime) error
• type NodeETCDExist
  • func (n *NodeETCDExist) PreCheck(runtime connector.Runtime) (bool, error)
• type PreCheckModule
  • func (p *PreCheckModule) Init()
  • func (p *PreCheckModule) IsSkip() bool
• type RefreshConfig
  • func (r *RefreshConfig) Execute(runtime connector.Runtime) error
• type RestartETCD
  • func (r *RestartETCD) Execute(runtime connector.Runtime) error
• type SyncCertsFile
  • func (s *SyncCertsFile) Execute(runtime connector.Runtime) error

Constants

const (
	LocalCertsDir = "localCertsDir"
	CertsFileList = "certsFileList"

	NewCluster   = "new"
	ExistCluster = "existing"
)

Functions

func CertsModuleForExternal

func CertsModuleForExternal(c *CertsModule) []task.Interface

func CertsModuleForKubeKey

func CertsModuleForKubeKey(c *CertsModule) []task.Interface

func GenerateAltName

func GenerateAltName(k *common.KubeConf, runtime *connector.Runtime) *cert.AltNames

func KubekeyCertEtcdAdmin

func KubekeyCertEtcdAdmin(hostname string, altNames *certutil.AltNames) *certs.KubekeyCert

KubekeyCertEtcdAdmin is the definition of the cert for etcd admin.

func KubekeyCertEtcdCA

func KubekeyCertEtcdCA() *certs.KubekeyCert

KubekeyCertEtcdCA is the definition of the root CA used by the hosted etcd server.

func KubekeyCertEtcdClient

func KubekeyCertEtcdClient(hostname string, altNames *certutil.AltNames) *certs.KubekeyCert

KubekeyCertEtcdClient is the definition of the cert for etcd client.

func KubekeyCertEtcdMember

func KubekeyCertEtcdMember(hostname string, altNames *certutil.AltNames) *certs.KubekeyCert

KubekeyCertEtcdMember is the definition of the cert for etcd member.

Types

type BackupETCD

type BackupETCD struct {
	common.KubeAction
}

func (*BackupETCD) Execute

func (b *BackupETCD) Execute(runtime connector.Runtime) error

type BackupModule

type BackupModule struct {
	common.KubeModule
	Skip bool
}

func (*BackupModule) Init

func (b *BackupModule) Init()

func (*BackupModule) IsSkip

func (p *BackupModule) IsSkip() bool

type CertsModule

type CertsModule struct {
	common.KubeModule
	Skip bool
}

func (*CertsModule) Init

func (c *CertsModule) Init()

func (*CertsModule) IsSkip

func (p *CertsModule) IsSkip() bool

type CheckMember

type CheckMember struct {
	common.KubeAction
}

func (*CheckMember) Execute

func (c *CheckMember) Execute(runtime connector.Runtime) error

type ConfigureModule

type ConfigureModule struct {
	common.KubeModule
	Skip bool
}

func (*ConfigureModule) Init

func (e *ConfigureModule) Init()

func (*ConfigureModule) IsSkip

func (p *ConfigureModule) IsSkip() bool

type EnableBackupETCDService

type EnableBackupETCDService struct {
	common.KubeAction
}

func (*EnableBackupETCDService) Execute

func (e *EnableBackupETCDService) Execute(runtime connector.Runtime) error

type EtcdCluster

type EtcdCluster struct {
	// contains filtered or unexported fields
}

type EtcdNode

type EtcdNode struct {
	NodeName  string
	EtcdName  string
	EtcdExist bool
}

type FetchCerts

type FetchCerts struct {
	common.KubeAction
}

func (*FetchCerts) Execute

func (f *FetchCerts) Execute(runtime connector.Runtime) error

type FetchCertsForExternalEtcd

type FetchCertsForExternalEtcd struct {
	common.KubeAction
}

func (*FetchCertsForExternalEtcd) Execute

func (f *FetchCertsForExternalEtcd) Execute(runtime connector.Runtime) error

type FirstETCDNode

type FirstETCDNode struct {
	common.KubePrepare
	Not bool
}

func (*FirstETCDNode) PreCheck

func (f *FirstETCDNode) PreCheck(runtime connector.Runtime) (bool, error)

type GenerateAccessAddress

type GenerateAccessAddress struct {
	common.KubeAction
}

func (*GenerateAccessAddress) Execute

func (g *GenerateAccessAddress) Execute(runtime connector.Runtime) error

type GenerateCerts

type GenerateCerts struct {
	common.KubeAction
}

func (*GenerateCerts) Execute

func (g *GenerateCerts) Execute(runtime connector.Runtime) error

type GenerateConfig

type GenerateConfig struct {
	common.KubeAction
}

func (*GenerateConfig) Execute

func (g *GenerateConfig) Execute(runtime connector.Runtime) error

type GetStatus

type GetStatus struct {
	common.KubeAction
}

func (*GetStatus) Execute

func (g *GetStatus) Execute(runtime connector.Runtime) error

type HealthCheck

type HealthCheck struct {
	common.KubeAction
}

func (*HealthCheck) Execute

func (h *HealthCheck) Execute(runtime connector.Runtime) error

type InstallETCDBinary

type InstallETCDBinary struct {
	common.KubeAction
}

func (*InstallETCDBinary) Execute

func (g *InstallETCDBinary) Execute(runtime connector.Runtime) error

type InstallETCDBinaryModule

type InstallETCDBinaryModule struct {
	common.KubeModule
	Skip bool
}

func (*InstallETCDBinaryModule) Init

func (i *InstallETCDBinaryModule) Init()

func (*InstallETCDBinaryModule) IsSkip

func (p *InstallETCDBinaryModule) IsSkip() bool

type JoinMember

type JoinMember struct {
	common.KubeAction
}

func (*JoinMember) Execute

func (j *JoinMember) Execute(runtime connector.Runtime) error

type NodeETCDExist

type NodeETCDExist struct {
	common.KubePrepare
	Not bool
}

func (*NodeETCDExist) PreCheck

func (n *NodeETCDExist) PreCheck(runtime connector.Runtime) (bool, error)

type PreCheckModule

type PreCheckModule struct {
	common.KubeModule
	Skip bool
}

func (*PreCheckModule) Init

func (p *PreCheckModule) Init()

func (*PreCheckModule) IsSkip

func (p *PreCheckModule) IsSkip() bool

type RefreshConfig

type RefreshConfig struct {
	common.KubeAction
	ToExisting bool
}

func (*RefreshConfig) Execute

func (r *RefreshConfig) Execute(runtime connector.Runtime) error

type RestartETCD

type RestartETCD struct {
	common.KubeAction
}

func (*RestartETCD) Execute

func (r *RestartETCD) Execute(runtime connector.Runtime) error

type SyncCertsFile

type SyncCertsFile struct {
	common.KubeAction
}

func (*SyncCertsFile) Execute

func (s *SyncCertsFile) Execute(runtime connector.Runtime) error