Documentation
¶
Index ¶
- Variables
- func CreateDataDirectory(dir string) error
- func GetClientURL(localEndpoint *kubeadmapi.APIEndpoint) string
- func GetClientURLByDomain(domain string) string
- func GetClientURLByIP(ip string) string
- func GetPeerURL(localEndpoint *kubeadmapi.APIEndpoint) string
- func GetPeerURLByDomain(domain string) string
- func GetPeerURLByIP(ip string) string
- type Client
- func (c *Client) AddMember(name string, peerAddrs string) ([]Member, error)
- func (c *Client) AddMemberAsLearner(name string, peerAddrs string) ([]Member, error)
- func (c *Client) CheckClusterHealth() error
- func (c *Client) GetMemberID(peerURL string) (uint64, error)
- func (c *Client) ListMembers() ([]Member, error)
- func (c *Client) MemberPromote(learnerID uint64) error
- func (c *Client) RemoveMember(id uint64) ([]Member, error)
- func (c *Client) Sync() error
- func (c *Client) WaitForClusterAvailable(retries int, retryInterval time.Duration) (bool, error)
- type ClusterInterrogator
- type Member
Constants ¶
This section is empty.
Variables ¶
var ErrNoMemberIDForPeerURL = errors.New("no member id found for peer URL")
Functions ¶
func CreateDataDirectory ¶
CreateDataDirectory creates the etcd data directory (commonly /var/lib/etcd) with the right permissions.
func GetClientURL ¶
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 GetClientURLByDomain ¶
func GetClientURLByIP ¶
GetClientURLByIP creates an HTTPS URL based on an IP address and the client listening port.
func GetPeerURL ¶
func GetPeerURL(localEndpoint *kubeadmapi.APIEndpoint) string
GetPeerURL creates an HTTPS URL that uses the configured advertise address and peer port for the API controller
func GetPeerURLByDomain ¶
func GetPeerURLByIP ¶
Types ¶
type Client ¶
type Client struct {
Endpoints []string
// contains filtered or unexported fields
}
Client provides connection parameters for an etcd cluster
func NewFromCluster ¶
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) AddMemberAsLearner ¶
AddMemberAsLearner adds a new learner member into the etcd cluster.
func (*Client) CheckClusterHealth ¶
CheckClusterHealth returns nil for status Up or error for status Down
func (*Client) GetMemberID ¶
GetMemberID returns the member ID of the given peer URL
func (*Client) ListMembers ¶
ListMembers returns the member list.
func (*Client) MemberPromote ¶
MemberPromote promotes a member as a voting member. If the given member ID is already a voting member this method will return early and do nothing.
func (*Client) RemoveMember ¶
RemoveMember notifies an etcd cluster to remove an existing member
type ClusterInterrogator ¶
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)
AddMemberAsLearner(name string, peerAddrs string) ([]Member, error)
MemberPromote(learnerID uint64) error
GetMemberID(peerURL string) (uint64, error)
RemoveMember(id uint64) ([]Member, error)
}
ClusterInterrogator is an interface to get etcd cluster related information
Source Files