etcd

Documentation

Index

• type Client
  • func NewClient(endpoints []string) (client *Client, err error)
  • func NewClientFromControlPlaneIPs(ctx context.Context, creds *x509.PEMEncodedCertificateAndKey, ...) (client *Client, err error)
  • func (c *Client) ForfeitLeadership(ctx context.Context) (string, error)
  • func (c *Client) LeaveCluster(ctx context.Context) error
  • func (c *Client) ValidateForUpgrade(ctx context.Context, config config.Provider, preserve bool) error

Types

type Client

type Client struct {
	*clientv3.Client
}

Client is a wrapper around the official etcd client.

func NewClient

func NewClient(endpoints []string) (client *Client, err error)

NewClient initializes and returns an etcd client configured to talk to a local endpoint.

func NewClientFromControlPlaneIPs

func NewClientFromControlPlaneIPs(ctx context.Context, creds *x509.PEMEncodedCertificateAndKey, endpoint *url.URL) (client *Client, err error)

NewClientFromControlPlaneIPs initializes and returns an etcd client configured to talk to all members.

func (*Client) ForfeitLeadership

func (c *Client) ForfeitLeadership(ctx context.Context) (string, error)

ForfeitLeadership transfers leadership from the current member to another member.

nolint: gocyclo

func (*Client) LeaveCluster

func (c *Client) LeaveCluster(ctx context.Context) error

LeaveCluster removes the current member from the etcd cluster.

nolint: gocyclo

func (*Client) ValidateForUpgrade

func (c *Client) ValidateForUpgrade(ctx context.Context, config config.Provider, preserve bool) error

ValidateForUpgrade validates the etcd cluster state to ensure that performing an upgrade is safe.