Documentation ¶
Index ¶
- type WsClient
- func (c *WsClient) Conn() (*websocket.Conn, error)
- func (c *WsClient) Publish(req isignal.PublishRequest) (isignal.PublishResponse, error)
- func (c *WsClient) Request(method string, req interface{}) (protoo.Message, error)
- func (c *WsClient) Subscribe(req isignal.SubscribeRequest) (isignal.SubscribeResponse, error)
- func (c *WsClient) UnPublish(streamId uint64) error
- func (c *WsClient) UnSubscribe(streamId uint64, subId string) error
- type WsClientOpt
- type WsServer
- type WsServerOpt
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WsClient ¶
type WsClient struct { WsClientOpt // contains filtered or unexported fields }
func NewWsClient ¶
func NewWsClient(opt WsClientOpt) *WsClient
func (*WsClient) Publish ¶ added in v1.0.3
func (c *WsClient) Publish(req isignal.PublishRequest) (isignal.PublishResponse, error)
func (*WsClient) Subscribe ¶ added in v1.0.3
func (c *WsClient) Subscribe(req isignal.SubscribeRequest) (isignal.SubscribeResponse, error)
type WsClientOpt ¶
type WsServer ¶
type WsServer struct { WsServerOpt // contains filtered or unexported fields }
func NewWsServer ¶
func NewWsServer(opt WsServerOpt) (*WsServer, error)
Click to show internal directories.
Click to hide internal directories.