memberlist

Documentation

Index

• type KVMemberList
  • func NewKVMemberList(localPort int, kv kv.KV, hk *hook.Hooks, logger kitlog.Logger) *KVMemberList
  • func (ml *KVMemberList) GetMember(instanceID string) (m clustermodel.Member, ok bool)
  • func (ml *KVMemberList) GetMembers() map[string]clustermodel.Member
  • func (ml *KVMemberList) Start(ctx context.Context) error
  • func (ml *KVMemberList) Stop(ctx context.Context) error
• type MemberList
  • func NewNop() MemberList

Types

type KVMemberList

type KVMemberList struct {
	// contains filtered or unexported fields
}

KVMemberList keeps and manages cluster memberlist set.

func NewKVMemberList

func NewKVMemberList(localPort int, kv kv.KV, hk *hook.Hooks, logger kitlog.Logger) *KVMemberList

NewKVMemberList will create a new KVMemberList instance using the given configuration.

func (*KVMemberList) GetMember

func (ml *KVMemberList) GetMember(instanceID string) (m clustermodel.Member, ok bool)

GetMember returns cluster member info associated to an identifier.

func (*KVMemberList) GetMembers

func (ml *KVMemberList) GetMembers() map[string]clustermodel.Member

GetMembers returns all cluster registered members.

func (*KVMemberList) Start

func (ml *KVMemberList) Start(ctx context.Context) error

Start is used to join a cluster by registering instance member into the shared KV storage.

func (*KVMemberList) Stop

func (ml *KVMemberList) Stop(ctx context.Context) error

Stop unregisters instance member info from the cluster.

type MemberList

type MemberList interface {
	// GetMember returns cluster member info associated to an identifier.
	GetMember(instanceID string) (m clustermodel.Member, ok bool)

	// GetMembers returns all cluster registered members.
	GetMembers() map[string]clustermodel.Member

	// Start initializes memberlist.
	Start(ctx context.Context) error

	// Stop releases all underlying memberlist resources.
	Stop(ctx context.Context) error
}

MemberList defines cluster memberlist interface.

func NewNop

func NewNop() MemberList

NewNop returns a memberlist that doesn't do anything.