Versions in this module Expand all Collapse all v1 v1.0.0 Jun 26, 2019 Changes in this version + const MsgFormatError + type EventHandle struct + Context *context.Context + EventQueue *channelq.ChannelEventQueue + Handlers []HandleFunc + KeepaliveInterval int + Nodes sync.Map + WriteTimeout int + func (eh *EventHandle) CancelNode(hi hubio.CloudHubIO, info *emodel.HubInfo, code ExitCode) + func (eh *EventHandle) EnrollNode(hi hubio.CloudHubIO, info *emodel.HubInfo) error + func (eh *EventHandle) GetNodeCount() int + func (eh *EventHandle) GetWorkload() (float64, error) + func (eh *EventHandle) Pub2Controller(info *emodel.HubInfo, msg *model.Message) error + func (eh *EventHandle) ServeConn(hi hubio.CloudHubIO, info *emodel.HubInfo) + type ExitCode int + type HandleFunc func(hi hubio.CloudHubIO, info *emodel.HubInfo, stop chan ExitCode) + type QuicHandle struct + EventHandler *EventHandle + KeepaliveChannel chan struct{} + NodeLimit int + var QuicHandler *QuicHandle + func (qh *QuicHandle) EventWriteLoop(hi hubio.CloudHubIO, info *emodel.HubInfo, stop chan ExitCode) + func (qh *QuicHandle) HandleServer(container *mux.MessageContainer, writer mux.ResponseWriter) + func (qh *QuicHandle) KeepaliveCheckLoop(hi hubio.CloudHubIO, info *emodel.HubInfo, stop chan ExitCode) + func (qh *QuicHandle) OnRegister(connection conn.Connection) + type WebsocketHandle struct + EventHandler *EventHandle + NodeLimit int + var WebSocketHandler *WebsocketHandle + func (wh *WebsocketHandle) EventReadLoop(hi hubio.CloudHubIO, info *emodel.HubInfo, stop chan ExitCode) + func (wh *WebsocketHandle) EventWriteLoop(hi hubio.CloudHubIO, info *emodel.HubInfo, stop chan ExitCode) + func (wh *WebsocketHandle) ServeEvent(w http.ResponseWriter, r *http.Request) + func (wh *WebsocketHandle) ServeQueueWorkload(w http.ResponseWriter, r *http.Request) v1.0.0-beta.0 Jun 21, 2019