ws

Documentation

Index

• type WsServer
  • func NewWsServer(context *lokas.Context) *WsServer
  • func (this *WsServer) Broadcast(sessionIds []util.ID, data []byte)
  • func (this *WsServer) GetActiveConnNum() int
  • func (this *WsServer) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (this *WsServer) Start(addr string) error
  • func (this *WsServer) Stop()

Types

type WsServer

type WsServer struct {
	lokas.Server
	Context *lokas.Context
	// contains filtered or unexported fields
}

func NewWsServer

func NewWsServer(context *lokas.Context) *WsServer

NewWsServer create a new websocket server

func (*WsServer) Broadcast

func (this *WsServer) Broadcast(sessionIds []util.ID, data []byte)

Broadcast broadcast data to all active connections

func (*WsServer) GetActiveConnNum

func (this *WsServer) GetActiveConnNum() int

GetActiveConnNum get count of active connections

func (*WsServer) ServeHTTP

func (this *WsServer) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP serve http request

func (*WsServer) Start

func (this *WsServer) Start(addr string) error

Start websocket server, and start default http server if addr is not empty

func (*WsServer) Stop

func (this *WsServer) Stop()

Stop websocket server, and the underline default http server