etcd

Documentation

Index

• type Cluster
  • func (e *Cluster) DeleteUnwantedDeadMembers(ctx context.Context, log *zap.SugaredLogger) (bool, error)
  • func (e *Cluster) Exists() bool
  • func (e *Cluster) GetEtcdClient(ctx context.Context, log *zap.SugaredLogger) (*client.Client, error)
  • func (e *Cluster) GetEtcdEndpointConfigs(ctx context.Context) ([]client.Config, error)
  • func (e *Cluster) GetMemberByName(ctx context.Context, log *zap.SugaredLogger, memberName string) (*etcdserverpb.Member, error)
  • func (e *Cluster) Init(ctx context.Context) (*kubermaticv1.Cluster, error)
  • func (e *Cluster) IsClusterHealthy(ctx context.Context, log *zap.SugaredLogger) (bool, error)
  • func (e *Cluster) JoinCluster(ctx context.Context, log *zap.SugaredLogger) error
  • func (e *Cluster) KubermaticCluster(ctx context.Context) (*kubermaticv1.Cluster, error)
  • func (e *Cluster) LogInitialState(log *zap.SugaredLogger)
  • func (e *Cluster) RemoveStaleMember(ctx context.Context, log *zap.SugaredLogger, memberID uint64) error
  • func (e *Cluster) SetClusterSize(ctx context.Context) error
  • func (e *Cluster) SetInitialMembers(ctx context.Context, log *zap.SugaredLogger)
  • func (e *Cluster) SetInitialState(ctx context.Context, log *zap.SugaredLogger, cluster *kubermaticv1.Cluster) error
  • func (e *Cluster) StartEtcdCmd(log *zap.SugaredLogger) (*exec.Cmd, error)
  • func (e *Cluster) UpdatePeerURLs(ctx context.Context, log *zap.SugaredLogger) error

Types

type Cluster

type Cluster struct {
	Cluster        string // given as a CLI flag
	CaCertFile     string
	ClientCertFile string
	ClientKeyFile  string

	PodName               string
	PodIP                 string
	EtcdctlAPIVersion     string
	DataDir               string
	Token                 string
	EnableCorruptionCheck bool
	// contains filtered or unexported fields
}

func (*Cluster) DeleteUnwantedDeadMembers

func (e *Cluster) DeleteUnwantedDeadMembers(ctx context.Context, log *zap.SugaredLogger) (bool, error)

func (*Cluster) Exists

func (e *Cluster) Exists() bool

func (*Cluster) GetEtcdClient

func (e *Cluster) GetEtcdClient(ctx context.Context, log *zap.SugaredLogger) (*client.Client, error)

func (*Cluster) GetEtcdEndpointConfigs

func (e *Cluster) GetEtcdEndpointConfigs(ctx context.Context) ([]client.Config, error)

GetEtcdEndpointClients returns a slice of client configs with each config pointing to exactly one of the automatically discovered etcd endpoints.

func (*Cluster) GetMemberByName

func (e *Cluster) GetMemberByName(ctx context.Context, log *zap.SugaredLogger, memberName string) (*etcdserverpb.Member, error)

func (*Cluster) Init

func (e *Cluster) Init(ctx context.Context) (*kubermaticv1.Cluster, error)

func (*Cluster) IsClusterHealthy

func (e *Cluster) IsClusterHealthy(ctx context.Context, log *zap.SugaredLogger) (bool, error)

func (*Cluster) JoinCluster

func (e *Cluster) JoinCluster(ctx context.Context, log *zap.SugaredLogger) error

func (*Cluster) KubermaticCluster

func (e *Cluster) KubermaticCluster(ctx context.Context) (*kubermaticv1.Cluster, error)

func (*Cluster) LogInitialState

func (e *Cluster) LogInitialState(log *zap.SugaredLogger)

func (*Cluster) RemoveStaleMember

func (e *Cluster) RemoveStaleMember(ctx context.Context, log *zap.SugaredLogger, memberID uint64) error

func (*Cluster) SetClusterSize

func (e *Cluster) SetClusterSize(ctx context.Context) error

func (*Cluster) SetInitialMembers

func (e *Cluster) SetInitialMembers(ctx context.Context, log *zap.SugaredLogger)

func (*Cluster) SetInitialState

func (e *Cluster) SetInitialState(ctx context.Context, log *zap.SugaredLogger, cluster *kubermaticv1.Cluster) error

func (*Cluster) StartEtcdCmd

func (e *Cluster) StartEtcdCmd(log *zap.SugaredLogger) (*exec.Cmd, error)

func (*Cluster) UpdatePeerURLs

func (e *Cluster) UpdatePeerURLs(ctx context.Context, log *zap.SugaredLogger) error