etcd

package
v2.25.0-beta.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 1, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL