Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler interface {
// HandleConnection is invoked when a new connection arrives
HandleConnection(connection conn.Connection)
// HandleMessage is invoked when a new message arrives.
HandleMessage(container *mux.MessageContainer, writer mux.ResponseWriter)
// OnEdgeNodeConnect is invoked when a new connection is established
OnEdgeNodeConnect(info *model.HubInfo, connection conn.Connection) error
// OnEdgeNodeDisconnect is invoked when a connection is lost
OnEdgeNodeDisconnect(info *model.HubInfo, connection conn.Connection)
// OnReadTransportErr is invoked when the connection read message err
OnReadTransportErr(nodeID, projectID string)
}
func NewMessageHandler ¶
func NewMessageHandler( KeepaliveInterval int, manager *session.Manager, reliableClient reliableclient.Interface, dispatcher dispatcher.MessageDispatcher, authorizer authorization.Authorizer) Handler
Click to show internal directories.
Click to hide internal directories.