websocket

Documentation

Index

• type DataPack
  • func (dp *DataPack) GetHeadLen() uint32
  • func (dp *DataPack) Pack(m *common.Message) ([]byte, error)
  • func (dp *DataPack) Unpack(binaryData []byte) (*common.Message, error)
• type Msg
• type Server
  • func NewWebsocket() *Server
  • func (s *Server) AddRouter(msgId byte, router common.IRouter)
  • func (s *Server) GetConnMgr() *common.ConnManager
  • func (s *Server) ServeWebSocket(w http.ResponseWriter, req *http.Request)
  • func (s *Server) SetOnConnStart(hookFunc func(*common.Connection))
  • func (s *Server) SetOnConnStop(hookFunc func(*common.Connection))
  • func (s *Server) Start()
  • func (s *Server) Stop()

Types

type DataPack

type DataPack struct{}

func (*DataPack) GetHeadLen

func (dp *DataPack) GetHeadLen() uint32

func (*DataPack) Pack

func (dp *DataPack) Pack(m *common.Message) ([]byte, error)

func (*DataPack) Unpack

func (dp *DataPack) Unpack(binaryData []byte) (*common.Message, error)

type Msg

type Msg struct {
	Id   byte
	Data string
	Len  int64
}

type Server

type Server struct {
	ConnMgr     *common.ConnManager
	OnConnStart func(conn *common.Connection)
	OnConnStop  func(conn *common.Connection)
	// contains filtered or unexported fields
}

func NewWebsocket

func NewWebsocket() *Server

func (*Server) AddRouter

func (s *Server) AddRouter(msgId byte, router common.IRouter)

func (*Server) GetConnMgr

func (s *Server) GetConnMgr() *common.ConnManager

func (*Server) ServeWebSocket

func (s *Server) ServeWebSocket(w http.ResponseWriter, req *http.Request)

func (*Server) SetOnConnStart

func (s *Server) SetOnConnStart(hookFunc func(*common.Connection))

func (*Server) SetOnConnStop

func (s *Server) SetOnConnStop(hookFunc func(*common.Connection))

func (*Server) Start

func (s *Server) Start()

func (*Server) Stop

func (s *Server) Stop()