gossip

type Delegate interface {
	// GossipStarted give the sender to delegate
	// announce gossip server started
	GossipStarted(*Sender)

	// Metadata get local node meta data
	Metadata(limit int) []byte
	// NotifyJoin notify node join or node online
	NotifyJoin(*Node)
	// NotifyJoin notify node leave or node offline
	NotifyLeave(*Node)
	// NotifyUpdate notify node's metadata updated
	NotifyUpdate(*Node)

	// PingPayload given the payload push to other node while pinging.
	// And payload will be compress by lzw default, then aes encrypt optionally,
	// the final size must less than udp packet max size limit
	PingPayload() []byte
	// NotifyPing notify that other node pushed it's payload to me while pinging
	NotifyPing(other *Node, payload []byte)

	// NotifyMessage notify received message
	NotifyMessage(msg []byte)
}

type Node struct {
	Name string
	Addr net.IP
	Port uint16
	Meta []byte
	RTT  time.Duration
	// contains filtered or unexported fields
}

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

type Server struct {
	Config *memberlist.Config
	// contains filtered or unexported fields
}