Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var AckChan = make(chan AckInfo)
Functions ¶
func AckHandler ¶
func AckHandler(ch <-chan AckInfo)
Types ¶
type Handler ¶
type Handler struct { PingChannel chan connection.Conn // contains filtered or unexported fields }
func NewHandler ¶
func NewHandler(pingC chan connection.Conn, collector collection.Collector) *Handler
func (*Handler) Ack ¶
func (h *Handler) Ack(conn connection.Conn, resChannel chan AckInfo, s serialization.SerializeFunc, messageType int, reqGuid string, timeConsumed time.Time) collection.AckFunc
func (*Handler) HandlerWSEvents ¶
func (h *Handler) HandlerWSEvents(w http.ResponseWriter, r *http.Request)
HandlerWSEvents handles the upgrade and the events sent by the peers
func (*Handler) Table ¶
func (h *Handler) Table() *connection.Table
Click to show internal directories.
Click to hide internal directories.