websockets

Documentation

Index

• type WebsocketManager
  • func NewWebsocketManager() *WebsocketManager
  • func (wm *WebsocketManager) FindMatchingHandler(socketName string, eventType websocketspb.WebsocketEventType) (*WorkerConnection, error)
  • func (wm *WebsocketManager) HandleEvents(stream websocketspb.WebsocketHandler_HandleEventsServer) error
  • func (wm *WebsocketManager) HandleRequest(request *websocketspb.ServerMessage) (*websocketspb.ClientMessage, error)
  • func (wm *WebsocketManager) WorkerCount() int
• type WebsocketRequestHandler
• type WorkerConnection

Types

type WebsocketManager

type WebsocketManager struct {
	// contains filtered or unexported fields
}

WebsocketManager manages connections and event handlers for websockets

func NewWebsocketManager

func NewWebsocketManager() *WebsocketManager

NewWebsocketManager creates a new instance of WebsocketManager

func (*WebsocketManager) FindMatchingHandler

func (wm *WebsocketManager) FindMatchingHandler(socketName string, eventType websocketspb.WebsocketEventType) (*WorkerConnection, error)

FindMatchingHandler returns a handler for a specific socket and event type, or an error if not found

func (*WebsocketManager) HandleEvents

func (wm *WebsocketManager) HandleEvents(stream websocketspb.WebsocketHandler_HandleEventsServer) error

ManageEventHandlers handles the registration of new websocket event handlers

func (*WebsocketManager) HandleRequest

func (wm *WebsocketManager) HandleRequest(request *websocketspb.ServerMessage) (*websocketspb.ClientMessage, error)

HandleRequest handles incoming requests and forwards them to the appropriate handler

func (*WebsocketManager) WorkerCount

func (wm *WebsocketManager) WorkerCount() int

WorkerCount returns the total number of websocket handlers

type WebsocketRequestHandler

type WebsocketRequestHandler interface {
	websocketspb.WebsocketHandlerServer
	HandleRequest(request *websocketspb.ServerMessage) (*websocketspb.ClientMessage, error)
	WorkerCount() int
}

type WorkerConnection

type WorkerConnection = workers.WorkerRequestBroker[*websocketspb.ServerMessage, *websocketspb.ClientMessage]

WorkerConnection manages communication between websocket and worker