httpbroadcast

Apr 30, 2017

Changes in this version

+ type HTTPBroadcastReceiver struct

+ func NewHTTPBroadcastReceiver(port string, logOutput io.Writer) *HTTPBroadcastReceiver

+ func (rec *HTTPBroadcastReceiver) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (rec *HTTPBroadcastReceiver) Start(b pilosa.BroadcastHandler) error

+ type HTTPBroadcaster struct

+ func NewHTTPBroadcaster(s *pilosa.Server, internalPort string) *HTTPBroadcaster

+ func (h *HTTPBroadcaster) SendAsync(pb proto.Message) error

+ func (h *HTTPBroadcaster) SendSync(pb proto.Message) error

+ type HTTPNodeSet struct

+ func NewHTTPNodeSet() *HTTPNodeSet

+ func (h *HTTPNodeSet) Join(nodes []*pilosa.Node) error

+ func (h *HTTPNodeSet) Nodes() []*pilosa.Node

+ func (h *HTTPNodeSet) Open() error