Versions in this module Expand all Collapse all v1 v1.16.3 Oct 23, 2019 Changes in this version + func CheckConfigurationIsHA(cfg *kubeadmapi.Etcd) bool + func GetClientURL(localEndpoint *kubeadmapi.APIEndpoint) string + func GetClientURLByIP(ip string) string + func GetPeerURL(localEndpoint *kubeadmapi.APIEndpoint) string + type Client struct + Endpoints []string + TLS *tls.Config + func New(endpoints []string, ca, cert, key string) (*Client, error) + func NewFromCluster(client clientset.Interface, certificatesDir string) (*Client, error) + func (c *Client) AddMember(name string, peerAddrs string) ([]Member, error) + func (c *Client) CheckClusterHealth() error + func (c *Client) GetClusterVersions() (map[string]string, error) + func (c *Client) GetMemberID(peerURL string) (uint64, error) + func (c *Client) GetVersion() (string, 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 interface + AddMember func(name string, peerAddrs string) ([]Member, error) + CheckClusterHealth func() error + GetClusterVersions func() (map[string]string, error) + GetMemberID func(peerURL string) (uint64, error) + GetVersion func() (string, error) + RemoveMember func(id uint64) ([]Member, error) + Sync func() error + WaitForClusterAvailable func(retries int, retryInterval time.Duration) (bool, error) + type Member struct + Name string + PeerURL string
Go to main page