websocket

Documentation

Index

• func DoConn(conn *conn.Conn)
• func GetStackInfo() string
• func HandleReadErr(conn *conn.Conn, err error)
• func RecoverPanic()
• type TcpHandler
  • func (*TcpHandler) OnConnect(c *gn.Conn)
• type Transpore
  • func (Transpore) Endpoint() string
  • func (Transpore) Kind() transport.Kind
  • func (Transpore) Operation() string
  • func (Transpore) ReplyHeader() transport.Header
  • func (Transpore) RequestHeader() transport.Header
• type WebSocketServer
  • func NewServer(s *service.ShopAdmin) *WebSocketServer
  • func (s *WebSocketServer) Endpoint() (*url.URL, error)
  • func (s *WebSocketServer) Start(ctx context.Context) error
  • func (s *WebSocketServer) Stop(ctx context.Context) error

Functions

func DoConn

func DoConn(conn *conn.Conn)

DoConn 处理连接

func GetStackInfo

func GetStackInfo() string

GetStackInfo 获取Panic堆栈信息

func HandleReadErr

func HandleReadErr(conn *conn.Conn, err error)

HandleReadErr 读取conn错误

func RecoverPanic

func RecoverPanic()

RecoverPanic 恢复panic

Types

type TcpHandler

type TcpHandler struct{}

func (*TcpHandler) OnConnect

func (*TcpHandler) OnConnect(c *gn.Conn)

type Transpore

type Transpore struct{}

func (Transpore) Endpoint

func (Transpore) Endpoint() string

func (Transpore) Kind

func (Transpore) Kind() transport.Kind

func (Transpore) Operation

func (Transpore) Operation() string

func (Transpore) ReplyHeader

func (Transpore) ReplyHeader() transport.Header

func (Transpore) RequestHeader

func (Transpore) RequestHeader() transport.Header

type WebSocketServer

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

func NewServer

func NewServer(s *service.ShopAdmin) *WebSocketServer

func (*WebSocketServer) Endpoint

func (s *WebSocketServer) Endpoint() (*url.URL, error)

func (*WebSocketServer) Start

func (s *WebSocketServer) Start(ctx context.Context) error

func (*WebSocketServer) Stop

func (s *WebSocketServer) Stop(ctx context.Context) error