ws_handle

Documentation

Index

• type WebSocketBroker
  • func New() WebSocketBroker
  • func (broker *WebSocketBroker) Add(conn *websocket.Conn) error
  • func (broker *WebSocketBroker) Close() error
  • func (broker *WebSocketBroker) RegisterHandle(handler models.MessageHandler, topics ...string)
  • func (broker *WebSocketBroker) RemoveHandler(topic string, handlerName string)

Types

type WebSocketBroker

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

func New

func New() WebSocketBroker

func (*WebSocketBroker) Add

func (broker *WebSocketBroker) Add(conn *websocket.Conn) error

func (*WebSocketBroker) Close

func (broker *WebSocketBroker) Close() error

func (*WebSocketBroker) RegisterHandle

func (broker *WebSocketBroker) RegisterHandle(handler models.MessageHandler, topics ...string)

func (*WebSocketBroker) RemoveHandler

func (broker *WebSocketBroker) RemoveHandler(topic string, handlerName string)