websockets

Documentation

Index

• type ServerClient
  • func NewServerClient(conn *websocket.Conn, server *WebSocketServer, ...) *ServerClient
  • func (c *ServerClient) Listen()
  • func (c *ServerClient) SendMessage(message []byte) error
• type WebSocketServer
  • func NewWebSocketServer(bindAddress string, processor ports.WebsocketServerEventProcessor, ...) *WebSocketServer
  • func (server *WebSocketServer) Broadcast(message []byte) int
  • func (server *WebSocketServer) HandleWebSocket(w http.ResponseWriter, r *http.Request)
  • func (server *WebSocketServer) Run(ctx context.Context)
• type WebsocketProxy
  • func NewWebsocketProxy(dsn string, protocol ports.DistributedSearchProtocol) *WebsocketProxy
  • func (w *WebsocketProxy) AddStorage(storage ports.Storage)
  • func (w *WebsocketProxy) Start(ctx context.Context) (err error)

Types

type ServerClient

type ServerClient struct {
	Conn           *websocket.Conn
	Server         *WebSocketServer
	EventProcessor ports.WebsocketServerEventProcessor
	// contains filtered or unexported fields
}

func NewServerClient

func NewServerClient(conn *websocket.Conn, server *WebSocketServer, eventProcessor ports.WebsocketServerEventProcessor) *ServerClient

NewServerClient creates a new client

func (*ServerClient) Listen

func (c *ServerClient) Listen()

Listen for the close event in a separate goroutine

func (*ServerClient) SendMessage

func (c *ServerClient) SendMessage(message []byte) error

type WebSocketServer

type WebSocketServer struct {
	Clients        map[*ServerClient]bool
	Register       chan *ServerClient
	Unregister     chan *ServerClient
	Mutex          sync.Mutex
	Upgrader       websocket.Upgrader
	EventProcessor ports.WebsocketServerEventProcessor
	// contains filtered or unexported fields
}

func NewWebSocketServer

func NewWebSocketServer(bindAddress string, processor ports.WebsocketServerEventProcessor, monitor ports.WebsocketServerMonitor) *WebSocketServer

func (*WebSocketServer) Broadcast

func (server *WebSocketServer) Broadcast(message []byte) int

func (*WebSocketServer) HandleWebSocket

func (server *WebSocketServer) HandleWebSocket(w http.ResponseWriter, r *http.Request)

func (*WebSocketServer) Run

func (server *WebSocketServer) Run(ctx context.Context)

type WebsocketProxy

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

func NewWebsocketProxy

func NewWebsocketProxy(dsn string, protocol ports.DistributedSearchProtocol) *WebsocketProxy

NewWebsocketProxy creates a new WebsocketProxy

func (*WebsocketProxy) AddStorage

func (w *WebsocketProxy) AddStorage(storage ports.Storage)

func (*WebsocketProxy) Start

func (w *WebsocketProxy) Start(ctx context.Context) (err error)