Broadcaster comment corrections

This commit is contained in:
Michael Baird 2017-04-25 22:25:10 -05:00
parent 6ea72a1657
commit 2f876c46a6
3 changed files with 4 additions and 4 deletions

View file

@ -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

View file

@ -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

View file

@ -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