wsconn

Documentation

Index

• type WsClient
  • func NewWsClient(opt WsClientOpt) (*WsClient, error)
  • func (c *WsClient) Close() error
  • func (c *WsClient) Request(method string, req interface{}) (protoo.Message, error)
• type WsClientOpt
• type WsServer
  • func NewWsServer(opt WsServerOpt) (*WsServer, error)
  • func (w *WsServer) Start()
• type WsServerOpt

Types

type WsClient

type WsClient struct {
	WsClientOpt

	sync.Mutex
	// contains filtered or unexported fields
}

func NewWsClient

func NewWsClient(opt WsClientOpt) (*WsClient, error)

func (*WsClient) Close

func (c *WsClient) Close() error

func (*WsClient) Request

func (c *WsClient) Request(method string, req interface{}) (protoo.Message, error)

type WsClientOpt

type WsClientOpt struct {
	Addr        string
	Path        string
	QueryFields map[string]string
}

type WsServer

type WsServer struct {
	WsServerOpt
	// contains filtered or unexported fields
}

func NewWsServer

func NewWsServer(opt WsServerOpt) (*WsServer, error)

func (*WsServer) Start

func (w *WsServer) Start()

type WsServerOpt

type WsServerOpt struct {
	PingInterval   time.Duration
	PongWait       time.Duration
	Conn           *websocket.Conn
	RequestHandler func(message protoo.Message) *protoo.Message
}