memberlist

Documentation

Index

• Constants
• Variables
• func GetMyIpAddress(specifyIp string, port int) string
• func Init(isMon bool, isLeader bool, id uint64, advertiseAddr string, memberBindPort int, ...)
• func SetNotifyFunc(callback NotifyMemberEvent)
• type Member
  • func GetLeaderMon() *Member
  • func GetMemberByName(name string) *Member
  • func GetMembers() (members []Member)
  • func GetOsdMembers() (members []Member)
• type MemberDelegate
  • func (m *MemberDelegate) GetBroadcasts(overhead, limit int) [][]byte
  • func (m *MemberDelegate) LocalState(join bool) []byte
  • func (m *MemberDelegate) MergeRemoteState(s []byte, join bool)
  • func (m *MemberDelegate) NodeMeta(limit int) []byte
  • func (m *MemberDelegate) NotifyMsg(msg []byte)
• type MemberEventType
• type MonitorMergeDelegate
  • func (c *MonitorMergeDelegate) NotifyMerge(nodes []*memberlist.Node) error
• type NotifyMemberEvent

Constants

const (
	MEMBER_LIST_CHAN_EVENT_NUM = 16
)

Variables

var List *memberlist.Memberlist

var SetMonFollower func()

var SetMonLeader func()

Functions

func GetMyIpAddress

func GetMyIpAddress(specifyIp string, port int) string

func Init

func Init(isMon bool, isLeader bool, id uint64, advertiseAddr string, memberBindPort int, logger *log.Logger, join string)

func SetNotifyFunc

func SetNotifyFunc(callback NotifyMemberEvent)

Types

type Member

type Member struct {
	IsMon    bool
	IsLeader bool
	Name     string
	Addr     string
	Port     uint16
	RaftPort uint16
	ID       uint64
}

func GetLeaderMon

func GetLeaderMon() *Member

func GetMemberByName

func GetMemberByName(name string) *Member

func GetMembers

func GetMembers() (members []Member)

func GetOsdMembers

func GetOsdMembers() (members []Member)

type MemberDelegate

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

func (*MemberDelegate) GetBroadcasts

func (m *MemberDelegate) GetBroadcasts(overhead, limit int) [][]byte

func (*MemberDelegate) LocalState

func (m *MemberDelegate) LocalState(join bool) []byte

func (*MemberDelegate) MergeRemoteState

func (m *MemberDelegate) MergeRemoteState(s []byte, join bool)

func (*MemberDelegate) NodeMeta

func (m *MemberDelegate) NodeMeta(limit int) []byte

func (*MemberDelegate) NotifyMsg

func (m *MemberDelegate) NotifyMsg(msg []byte)

type MemberEventType

type MemberEventType int

const (
	MemberJoin MemberEventType = iota
	MemberLeave
	MemberUpdate
)

type MonitorMergeDelegate

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

func (*MonitorMergeDelegate) NotifyMerge

func (c *MonitorMergeDelegate) NotifyMerge(nodes []*memberlist.Node) error

type NotifyMemberEvent

type NotifyMemberEvent func(MemberEventType, Member) error