websocket

Documentation

Index

• func InitWebsocket(svcCtx *svc.ServiceContext, addrs []string, accept int) (err error)
• type CometServer
  • func NewCometServer(svcCtx *svc.ServiceContext) *CometServer
  • func (s *CometServer) ServeWebsocket(conn net.Conn, rp, wp *bytes.Pool, tr *xtime.Timer)

Functions

func InitWebsocket

func InitWebsocket(svcCtx *svc.ServiceContext, addrs []string, accept int) (err error)

InitWebsocket listen all tcp.bind and start accept connections.

Types

type CometServer

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

func NewCometServer

func NewCometServer(svcCtx *svc.ServiceContext) *CometServer

func (*CometServer) ServeWebsocket

func (s *CometServer) ServeWebsocket(conn net.Conn, rp, wp *bytes.Pool, tr *xtime.Timer)

ServeWebsocket serve a websocket connection.