etcd

Apr 15, 2019

Changes in this version

+ func IsEtcdListeningOnLocalHostOnly() bool

type Client

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

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

type ClusterInterrogator

+ GetMemberID func(peerURL string) (uint64, error)

+ RemoveMember func(id uint64) ([]Member, error)

Apr 15, 2019

Changes in this version

+ func GetClientURL(cfg *kubeadmapi.InitConfiguration) string

+ func GetClientURLByIP(ip string) string

+ func GetPeerURL(cfg *kubeadmapi.InitConfiguration) string

type Client

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

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

+ func (c *Client) Sync() error

type ClusterInterrogator

+ AddMember func(name string, peerAddrs string) ([]Member, error)

+ Sync func() error

+ type Member struct

+ Name string

+ PeerURL string

Feb 20, 2019

Changes in this version

+ func CheckConfigurationIsHA(cfg *kubeadmapi.Etcd) bool

Aug 8, 2018

Changes in this version

+ func PodManifestsHaveTLS(ManifestDir string) (bool, error)

+ type Client struct

+ Endpoints []string

+ TLS *tls.Config

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

+ func NewFromStaticPod(endpoints []string, manifestDir string, certificatesDir string) (*Client, error)

+ func (c Client) ClusterAvailable() (bool, error)

+ func (c Client) GetClusterStatus() (map[string]*clientv3.StatusResponse, error)

+ func (c Client) GetClusterVersions() (map[string]string, error)

+ func (c Client) GetVersion() (string, error)

+ func (c Client) HasTLS() bool

+ func (c Client) WaitForClusterAvailable(delay time.Duration, retries int, retryInterval time.Duration) (bool, error)

+ type ClusterInterrogator interface

+ ClusterAvailable func() (bool, error)

+ GetClusterStatus func() (map[string]*clientv3.StatusResponse, error)

+ GetClusterVersions func() (map[string]string, error)

+ GetVersion func() (string, error)

+ HasTLS func() bool

+ WaitForClusterAvailable func(delay time.Duration, retries int, retryInterval time.Duration) (bool, error)