websocket

Documentation

Index

• type EventsMixin
  • func (m *EventsMixin) Init(context moleculer.BrokerContext, s *WebSocketServer)
• type SocketMixin
• type TopicSubscription
• type WebSocketClient
• type WebSocketMixin
  • func (m *WebSocketMixin) RouterStarting(context moleculer.BrokerContext, router *mux.Router)
• type WebSocketServer
  • func (ps *WebSocketServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

Types

type EventsMixin

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

func (*EventsMixin) Init

func (m *EventsMixin) Init(context moleculer.BrokerContext, s *WebSocketServer)

type SocketMixin

type SocketMixin interface {
	// Init Initializes the Mixin.
	Init(moleculer.BrokerContext, *WebSocketServer)
}

type TopicSubscription

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

type WebSocketClient

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

type WebSocketMixin

type WebSocketMixin struct {
	Settings map[string]interface{}
	Mixins   []SocketMixin
	// contains filtered or unexported fields
}

func (*WebSocketMixin) RouterStarting

func (m *WebSocketMixin) RouterStarting(context moleculer.BrokerContext, router *mux.Router)

RouterStarting create a websocket server and add to the mux.router

type WebSocketServer

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

func (*WebSocketServer) ServeHTTP

func (ps *WebSocketServer) ServeHTTP(w http.ResponseWriter, r *http.Request)