mlst

package
v0.0.0-...-060dca9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2018 License: MIT Imports: 4 Imported by: 0

Documentation

Index

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)

func Convert

func Convert(m *memberlist.Node) *cluster.Node

func Convert2

func Convert2(m *memberlist.Node) cluster.Node

Types

type Delegate

type Delegate struct {
	cluster.StateHandler
	H cluster.Handler
}

func (*Delegate) GetBroadcasts

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

func (*Delegate) NodeMeta

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

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) NotifyMsg

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

func (*Delegate) NotifyUpdate

func (d *Delegate) NotifyUpdate(n *memberlist.Node)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL