import "k8s.io/kubernetes/cmd/kubeadm/app/util/etcd"
CreateDataDirectory creates the etcd data directory (commonly /var/lib/etcd) with the right permissions.
func GetClientURL(localEndpoint *kubeadmapi.APIEndpoint) string
GetClientURL creates an HTTPS URL that uses the configured advertise address and client port for the API controller
GetClientURLByIP creates an HTTPS URL based on an IP address and the client listening port.
func GetPeerURL(localEndpoint *kubeadmapi.APIEndpoint) string
GetPeerURL creates an HTTPS URL that uses the configured advertise address and peer port for the API controller
Client provides connection parameters for an etcd cluster
New creates a new EtcdCluster client
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.
AddMember notifies an existing etcd cluster that a new member is joining
CheckClusterHealth returns nil for status Up or error for status Down
GetMemberID returns the member ID of the given peer URL
ListMembers returns the member list.
RemoveMember notifies an etcd cluster to remove an existing member
Sync synchronizes client's endpoints with the known endpoints from the etcd membership.
WaitForClusterAvailable returns true if all endpoints in the cluster are available after retry attempts, an error is returned otherwise
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
Member struct defines an etcd member; it is used for avoiding to spread github.com/coreos/etcd dependency across kubeadm codebase
Package etcd imports 21 packages (graph) and is imported by 17 packages. Updated 2020-10-06. Refresh now. Tools for package owners.