Versions in this module Expand all Collapse all v0 v0.3.1 Apr 30, 2017 Changes in this version + type GossipNodeSet struct + LogOutput io.Writer + func NewGossipNodeSet(name string, gossipHost string, gossipPort int, gossipSeed string, ...) *GossipNodeSet + func (g *GossipNodeSet) GetBroadcasts(overhead, limit int) [][]byte + func (g *GossipNodeSet) LocalState(join bool) []byte + func (g *GossipNodeSet) MergeRemoteState(buf []byte, join bool) + func (g *GossipNodeSet) NodeMeta(limit int) []byte + func (g *GossipNodeSet) Nodes() []*pilosa.Node + func (g *GossipNodeSet) NotifyMsg(b []byte) + func (g *GossipNodeSet) Open() error + func (g *GossipNodeSet) SendAsync(pb proto.Message) error + func (g *GossipNodeSet) SendSync(pb proto.Message) error + func (g *GossipNodeSet) Start(h pilosa.BroadcastHandler) error