diff --git a/broadcast.go b/broadcast.go index f36533a7a..d4f75ebef 100644 --- a/broadcast.go +++ b/broadcast.go @@ -37,7 +37,7 @@ func (s *StaticNodeSet) Open() error { return nil } -// Join sets the NodeSet nodes to the slices of Nodes passed in. +// Join sets the NodeSet nodes to the slice of Nodes passed in. func (s *StaticNodeSet) Join(nodes []*Node) error { s.nodes = nodes return nil diff --git a/gossip/gossip.go b/gossip/gossip.go index c3da20cfa..a520548dc 100644 --- a/gossip/gossip.go +++ b/gossip/gossip.go @@ -39,7 +39,7 @@ func (g *GossipNodeSet) Nodes() []*pilosa.Node { return a } -// Start implements the BroadcastReceiver interface and starts listening for broadcast messages. +// Start implements the BroadcastReceiver interface and sets the BroadcastHandler func (g *GossipNodeSet) Start(h pilosa.BroadcastHandler) error { g.handler = h return nil diff --git a/httpbroadcast/messenger.go b/httpbroadcast/messenger.go index 566d39c22..92da723b9 100644 --- a/httpbroadcast/messenger.go +++ b/httpbroadcast/messenger.go @@ -106,7 +106,7 @@ func (h *HTTPBroadcaster) sendNodeMessage(node *pilosa.Node, msg []byte) error { return nil } -// HTTPBroadcastReceiver a Broadcaster that broadcasts messages over HTTP using the Pilosa Server. +// HTTPBroadcastReceiver handles incoming messages and pass them onto the implemented handler. type HTTPBroadcastReceiver struct { port string handler pilosa.BroadcastHandler @@ -179,7 +179,7 @@ func (h *HTTPNodeSet) Open() error { return nil } -// Join sets the NodeSet nodes to the slices of Nodes passed in. +// Join sets the NodeSet nodes to the slice of Nodes passed in. func (h *HTTPNodeSet) Join(nodes []*pilosa.Node) error { h.nodes = nodes return nil