websocket

package

v0.2.2-alpha Latest Latest Go to latest Published: Feb 10, 2023 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ConnectionCloseHandler func(code int, text string) error

type DecodeIngressFunc func(context.Context, []byte) (request interface{}, err error)

Decode request on receiving.

type EncodeEgressFunc func(context.Context, interface{}) (response []byte, err error)

Encode response before sending.

type RequestFunc func(context.Context, *http.Request) context.Context

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

func NewServer(
	e WebSocketEndpoint,
	dec DecodeIngressFunc,
	enc EncodeEgressFunc,
	options ...ServerOption,
) *Server

func (s Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ServerOption func(*Server)

func ServerBefore(before ...RequestFunc) ServerOption

func SetConnCloseHandler(handler ConnectionCloseHandler) ServerOption

func SetSocketConfig(socketConfig ...SocketConfigFunc) ServerOption

type SocketConfigFunc func(context.Context, *websocket.Conn)

type WebSocketEndpoint func(ctx context.Context) (ingress chan interface{}, egress chan interface{}, err error)