From acc4b022d78cb77881996ba0081355d5aaef1db8 Mon Sep 17 00:00:00 2001 From: Michael Baird Date: Mon, 24 Apr 2017 13:57:35 -0500 Subject: [PATCH] added Join method to Static Nodeset so that Status is calculated with the local node --- broadcast.go | 5 +++++ server/server.go | 1 + 2 files changed, 6 insertions(+) diff --git a/broadcast.go b/broadcast.go index 5a1600fbb..9e04d04f6 100644 --- a/broadcast.go +++ b/broadcast.go @@ -34,6 +34,11 @@ func (s *StaticNodeSet) Open() error { return nil } +func (s *StaticNodeSet) Join(nodes []*Node) error { + s.nodes = nodes + return nil +} + // Broadcaster is an interface for broadcasting messages. type Broadcaster interface { SendSync(pb proto.Message) error diff --git a/server/server.go b/server/server.go index 153f2dc23..d5983d7c3 100644 --- a/server/server.go +++ b/server/server.go @@ -163,6 +163,7 @@ func (m *Command) SetupServer() error { m.Server.Broadcaster = pilosa.NopBroadcaster m.Server.Cluster.NodeSet = pilosa.NewStaticNodeSet() m.Server.BroadcastReceiver = pilosa.NopBroadcastReceiver + m.Server.Cluster.NodeSet.(*pilosa.StaticNodeSet).Join(m.Server.Cluster.Nodes) default: return fmt.Errorf("'%v' is not a supported value for broadcaster type.", m.Config.Cluster.Type) }