eventstream

Documentation

Index

• func Handler(gate *msgs.Mux) func(w http.ResponseWriter, req *http.Request)
• func MonitorNode(gate *msgs.Mux, hc *http.Client, idhex *net.IPAddr) error

Functions

func Handler

func Handler(gate *msgs.Mux) func(w http.ResponseWriter, req *http.Request)

Used to receive (subscribe) to messages, using HTTP streaming protocol. TODO: pass the list of subscriptions, filter, 'start' message

func MonitorNode

func MonitorNode(gate *msgs.Mux, hc *http.Client, idhex *net.IPAddr) error