websocket

Documentation

Index

• func RegisterHandler()
• func RegisterTransport()
• type Handler
  • func (h *Handler) BindContext(ctx context.Context, server core.Server)
  • func (h *Handler) Serve(ctx context.Context, conn *websocket.Conn)
  • func (h *Handler) ServeFastHTTP(ctx *fasthttp.RequestCtx)
  • func (h *Handler) ServeHTTP(response http.ResponseWriter, request *http.Request)
• type Transport
  • func (trans *Transport) Abort()
  • func (trans *Transport) Transport(ctx context.Context, request []byte) ([]byte, error)

Functions

func RegisterHandler

func RegisterHandler()

func RegisterTransport

func RegisterTransport()

Types

type Handler

type Handler struct {
	rpchttp.Handler
	Pool     core.WorkerPool
	OnAccept func(*websocket.Conn) *websocket.Conn
	OnClose  func(*websocket.Conn)
	OnError  func(*websocket.Conn, error)
}

func (*Handler) BindContext

func (h *Handler) BindContext(ctx context.Context, server core.Server)

BindContext to the websocket server.

func (*Handler) Serve

func (h *Handler) Serve(ctx context.Context, conn *websocket.Conn)

func (*Handler) ServeFastHTTP

func (h *Handler) ServeFastHTTP(ctx *fasthttp.RequestCtx)

ServeFastHTTP implements the fasthttp.RequestHandler.

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(response http.ResponseWriter, request *http.Request)

ServeHTTP implements the http.Handler interface.

type Transport

type Transport struct {
	OnConnect func(*websocket.Conn) *websocket.Conn
	OnClose   func(*websocket.Conn)
	// contains filtered or unexported fields
}

func (*Transport) Abort

func (trans *Transport) Abort()

func (*Transport) Transport

func (trans *Transport) Transport(ctx context.Context, request []byte) ([]byte, error)