membership

Nov 17, 2020

Changes in this version

type MemberMetadata

+ Version string

Nov 16, 2020

Changes in this version

type Pool

+ GossipMembers func() []*memberlist.Node

Oct 16, 2020

Changes in this version

+ var ErrExistingClusterFound = errors.New("existing cluster found")

+ var ErrPeerDisabled = errors.New("peer disabled by healthchecks")

+ var ErrPeerNotFound = errors.New("peer not found")

+ func EncodeMD(id uint64, clusterName string, rpcAddress string) []byte

+ type MemberMetadata struct

+ ClusterName string

+ ID uint64

+ RPCAddress string

+ func DecodeMD(buf []byte) (MemberMetadata, error)

+ type MemberlistMemberProvider interface

+ Members func() []api.RaftContext

+ type Pool interface

+ Call func(id uint64, f func(*grpc.ClientConn) error) error

+ Join func(hosts []string) error

+ MemberCount func() int

+ Members func() []*api.Member

+ NodeMeta func(limit int) []byte

+ Shutdown func() error

+ UpdateMetadata func(meta []byte)

+ WaitForNodes func(ctx context.Context, clusterName, nodeName string, expectedNumber int, ...) ([]raft.Peer, error)

+ func New(id uint64, clusterName string, port int, advertiseAddr string, ...) Pool

+ type Recorder interface

+ NotifyGossipJoin func(id uint64)

+ NotifyGossipLeave func(id uint64)