kubernetes: k8s.io/kubernetes/cmd/kubeadm/app/util/etcd Index | Files

package etcd

import "k8s.io/kubernetes/cmd/kubeadm/app/util/etcd"

Index

Package Files

etcd.go

func GetClientURL Uses

❖
func GetClientURL(localEndpoint *kubeadmapi.APIEndpoint) string

GetClientURL creates an HTTPS URL that uses the configured advertise address and client port for the API controller

func GetClientURLByIP Uses

❖
func GetClientURLByIP(ip string) string

GetClientURLByIP creates an HTTPS URL based on an IP address and the client listening port.

func GetPeerURL Uses

❖
func GetPeerURL(localEndpoint *kubeadmapi.APIEndpoint) string

GetPeerURL creates an HTTPS URL that uses the configured advertise address and peer port for the API controller

type Client Uses

❖
type Client struct {
    Endpoints []string
    TLS       *tls.Config
}

Client provides connection parameters for an etcd cluster

func New Uses

❖
func New(endpoints []string, ca, cert, key string) (*Client, error)

New creates a new EtcdCluster client

func NewFromCluster Uses

❖
func NewFromCluster(client clientset.Interface, certificatesDir string) (*Client, error)

NewFromCluster creates an etcd client for the etcd endpoints present in etcd member list. In order to compose this information, it will first discover at least one etcd endpoint to connect to. Once created, the client synchronizes client's endpoints with the known endpoints from the etcd membership API, since it is the authoritative source of truth for the list of available members.

func (*Client) AddMember Uses

❖
func (c *Client) AddMember(name string, peerAddrs string) ([]Member, error)

AddMember notifies an existing etcd cluster that a new member is joining

func (*Client) CheckClusterHealth Uses

❖
func (c *Client) CheckClusterHealth() error

CheckClusterHealth returns nil for status Up or error for status Down

func (*Client) GetMemberID Uses

❖
func (c *Client) GetMemberID(peerURL string) (uint64, error)

GetMemberID returns the member ID of the given peer URL

func (*Client) ListMembers Uses

❖
func (c *Client) ListMembers() ([]Member, error)

ListMembers returns the member list.

func (*Client) RemoveMember Uses

❖
func (c *Client) RemoveMember(id uint64) ([]Member, error)

RemoveMember notifies an etcd cluster to remove an existing member

func (*Client) Sync Uses

❖
func (c *Client) Sync() error

Sync synchronizes client's endpoints with the known endpoints from the etcd membership.

func (*Client) WaitForClusterAvailable Uses

❖
func (c *Client) WaitForClusterAvailable(retries int, retryInterval time.Duration) (bool, error)

WaitForClusterAvailable returns true if all endpoints in the cluster are available after retry attempts, an error is returned otherwise

type ClusterInterrogator Uses

❖
type ClusterInterrogator interface {
    CheckClusterHealth() error
    WaitForClusterAvailable(retries int, retryInterval time.Duration) (bool, error)
    Sync() error
    ListMembers() ([]Member, error)
    AddMember(name string, peerAddrs string) ([]Member, error)
    GetMemberID(peerURL string) (uint64, error)
    RemoveMember(id uint64) ([]Member, error)
}

ClusterInterrogator is an interface to get etcd cluster related information

type Member Uses

❖
type Member struct {
    Name    string
    PeerURL string
}

Member struct defines an etcd member; it is used for avoiding to spread github.com/coreos/etcd dependency across kubeadm codebase

Package etcd imports 20 packages (graph) and is imported by 10 packages. Updated 2020-07-03. Refresh now. Tools for package owners.