mlist

Aug 8, 2024

Changes in this version

+ func GetGRPCPortFromBindPort(bindPort int) int

+ func GetRaftPortFromBindPort(bindPort int) int

Jul 11, 2023

Changes in this version

type Membership

+ func (m *Membership) Join(existing []string) (int, error)

+ func (m *Membership) Leave() error

May 12, 2023

Changes in this version

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelWarn

+ func NewOptions(opts ...Option) *memberlist.Config

+ type Broadcast struct

+ func (b *Broadcast) Finished()

+ func (b *Broadcast) Invalidates(other memberlist.Broadcast) bool

+ func (b *Broadcast) Message() []byte

+ type Delegate struct

+ Broadcasts *memberlist.TransmitLimitedQueue

+ LocalNode *memberlist.Node

+ State map[string]int64

+ func NewDelegate(inboundMsgCh chan<- []byte) *Delegate

+ func (d *Delegate) BindMqttServer(server *mqtt.Server)

+ func (d *Delegate) Broadcast(data []byte)

+ func (d *Delegate) GetBroadcasts(overhead, limit int) [][]byte

+ func (d *Delegate) InitBroadcasts(list *memberlist.Memberlist)

+ func (d *Delegate) LocalState(join bool) []byte

+ func (d *Delegate) MergeRemoteState(buf []byte, join bool)

+ func (d *Delegate) NodeMeta(limit int) []byte

+ func (d *Delegate) NotifyMsg(msg []byte)

+ func (d *Delegate) Stop()

+ type Membership struct

+ func New(config *config.Cluster, inboundMsgCh chan<- []byte) *Membership

+ func (m *Membership) BindMqttServer(server *mqtt.Server)

+ func (m *Membership) Broadcast(msg []byte)

+ func (m *Membership) EventChan() <-chan *mb.Event

+ func (m *Membership) GetNodeByIP(ipAddr net.IP) *memberlist.Node

+ func (m *Membership) LocalAddr() string

+ func (m *Membership) LocalName() string

+ func (m *Membership) LocalNode() *memberlist.Node

+ func (m *Membership) Members() []mb.Member

+ func (m *Membership) NumMembers() int

+ func (m *Membership) SendToNode(nodeName string, msg []byte) error

+ func (m *Membership) SendToOthers(msg []byte)

+ func (m *Membership) Setup() error

+ func (m *Membership) Stat() map[string]int64

+ func (m *Membership) Stop()

+ type NodeEvents struct

+ func NewEvents() *NodeEvents

+ func (n *NodeEvents) NotifyJoin(node *memberlist.Node)

+ func (n *NodeEvents) NotifyLeave(node *memberlist.Node)

+ func (n *NodeEvents) NotifyUpdate(node *memberlist.Node)

+ type Option func(conf *memberlist.Config)

+ func WithAdvertiseAddr(advertiseAddr string) Option

+ func WithAdvertisePort(advertisePort int) Option

+ func WithBindAddr(bindAddr string) Option

+ func WithBindPort(bindPort int) Option

+ func WithCIDRsAllowed(ips []net.IPNet) Option

+ func WithDelegate(delegate memberlist.Delegate) Option

+ func WithEvent(event memberlist.EventDelegate) Option

+ func WithHandoffQueueDepth(depth int) Option

+ func WithLogOutput(writer io.Writer, level string) Option

+ func WithNodeName(name string) Option

+ func WithPushPullInterval(interval int) Option

+ func WithSecretKey(secretKey []byte) Option

+ func WithUDPBufferSize(size int) Option

+ type RoundRobinBalancer struct

+ func NewRoundRobinBalancer(m *Membership) *RoundRobinBalancer

+ func (r *RoundRobinBalancer) Get() *memberlist.Node