Versions in this module Expand all Collapse all v0 v0.13.1 May 8, 2020 v0.13.0 May 8, 2020 Changes in this version + var Log = klogr.New() + func NewEtcdClient(endpoint string, dialer GRPCDial, tlsConfig *tls.Config) (*clientv3.Client, error) + type AlarmType int32 + const AlarmCorrupt + const AlarmNoSpace + const AlarmOk + type Client struct + Endpoint string + EtcdClient Etcd + IsLeader bool + LeaderID uint64 + MemberID uint64 + Name string + func NewClientWithEtcd(ctx context.Context, etcdClient Etcd) (*Client, error) + func (c *Client) Alarms(ctx context.Context) ([]MemberAlarm, error) + func (c *Client) Close() error + func (c *Client) Members(ctx context.Context) ([]*Member, error) + func (c *Client) MoveLeader(ctx context.Context, newLeaderID uint64) error + func (c *Client) RemoveMember(ctx context.Context, id uint64) error + func (c *Client) UpdateMemberPeerURLs(ctx context.Context, id uint64, peerURLs []string) ([]*Member, error) + type Etcd interface + AlarmList func(ctx context.Context) (*clientv3.AlarmResponse, error) + Close func() error + Endpoints func() []string + MemberList func(ctx context.Context) (*clientv3.MemberListResponse, error) + MemberRemove func(ctx context.Context, id uint64) (*clientv3.MemberRemoveResponse, error) + MemberUpdate func(ctx context.Context, id uint64, peerURLs []string) (*clientv3.MemberUpdateResponse, error) + MoveLeader func(ctx context.Context, id uint64) (*clientv3.MoveLeaderResponse, error) + Status func(ctx context.Context, endpoint string) (*clientv3.StatusResponse, error) + type EtcdBackoffAdapter struct + BackoffParams wait.Backoff + EtcdClient *clientv3.Client + Timeout time.Duration + func NewEtcdBackoffAdapter(c *clientv3.Client, options ...EtcdBackoffAdapterOption) *EtcdBackoffAdapter + func (e *EtcdBackoffAdapter) AlarmList(ctx context.Context) (*clientv3.AlarmResponse, error) + func (e *EtcdBackoffAdapter) Close() error + func (e *EtcdBackoffAdapter) MemberList(ctx context.Context) (*clientv3.MemberListResponse, error) + func (e *EtcdBackoffAdapter) MemberRemove(ctx context.Context, id uint64) (*clientv3.MemberRemoveResponse, error) + func (e *EtcdBackoffAdapter) MemberUpdate(ctx context.Context, id uint64, peerURLs []string) (*clientv3.MemberUpdateResponse, error) + func (e *EtcdBackoffAdapter) MoveLeader(ctx context.Context, id uint64) (*clientv3.MoveLeaderResponse, error) + type EtcdBackoffAdapterOption func(*EtcdBackoffAdapter) + func WithBackoff(backoff wait.Backoff) EtcdBackoffAdapterOption + func WithTimeout(timeout time.Duration) EtcdBackoffAdapterOption + type EtcdClientGenerator struct + func NewEtcdClientGenerator(clientset *kubernetes.Clientset, restConfig *rest.Config, ...) *EtcdClientGenerator + func (c *EtcdClientGenerator) ForLeader(ctx context.Context, nodes *corev1.NodeList) (*Client, error) + func (c *EtcdClientGenerator) ForNode(ctx context.Context, name string) (*Client, error) + type GRPCDial func(ctx context.Context, addr string) (net.Conn, error) + type Member struct + Alarms []AlarmType + ClientURLs []string + ClusterID uint64 + ID uint64 + IsLearner bool + Name string + PeerURLs []string + type MemberAlarm struct + MemberID uint64 + Type AlarmType