handler

Documentation

Index

• type Handler
  • func NewMessageHandler(KeepaliveInterval int, manager *session.Manager, ...) Handler

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