Documentation ¶
Index ¶
- Variables
- func Configure(cfg *memberlist.Config, h cluster.Handler, sh cluster.StateHandler)
- func Convert(m *memberlist.Node) *cluster.Node
- func Convert2(m *memberlist.Node) cluster.Node
- type Delegate
- func (d *Delegate) GetBroadcasts(overhead, limit int) [][]byte
- func (d *Delegate) NodeMeta(limit int) []byte
- func (d *Delegate) NotifyAlive(peer *memberlist.Node) error
- func (d *Delegate) NotifyJoin(n *memberlist.Node)
- func (d *Delegate) NotifyLeave(n *memberlist.Node)
- func (d *Delegate) NotifyMerge(peers []*memberlist.Node) error
- func (d *Delegate) NotifyMsg([]byte)
- func (d *Delegate) NotifyUpdate(n *memberlist.Node)
Constants ¶
This section is empty.
Variables ¶
View Source
var EBadMerge = errors.New("EBadMerge")
Functions ¶
func Configure ¶
func Configure(cfg *memberlist.Config, h cluster.Handler, sh cluster.StateHandler)
Types ¶
type Delegate ¶
type Delegate struct { cluster.StateHandler H cluster.Handler }
func (*Delegate) GetBroadcasts ¶
func (*Delegate) NotifyAlive ¶
func (d *Delegate) NotifyAlive(peer *memberlist.Node) error
func (*Delegate) NotifyJoin ¶
func (d *Delegate) NotifyJoin(n *memberlist.Node)
func (*Delegate) NotifyLeave ¶
func (d *Delegate) NotifyLeave(n *memberlist.Node)
func (*Delegate) NotifyMerge ¶
func (d *Delegate) NotifyMerge(peers []*memberlist.Node) error
func (*Delegate) NotifyUpdate ¶
func (d *Delegate) NotifyUpdate(n *memberlist.Node)
Click to show internal directories.
Click to hide internal directories.