etcd

Documentation

Index

• Variables
• func CreateSnapshot(ctx context.Context, log *zap.SugaredLogger, etcdConfig client.Config, ...) error
• func DecompressSnapshot(filename string) (string, error)
• 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
• type SnapshotOptions

Variables

var ValidCompressions = []string{"gzip"}

Functions

func CreateSnapshot

func CreateSnapshot(ctx context.Context, log *zap.SugaredLogger, etcdConfig client.Config, opt *SnapshotOptions) error

func DecompressSnapshot

func DecompressSnapshot(filename string) (string, 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

type SnapshotOptions

type SnapshotOptions struct {
	File        string
	Compression string
}