Documentation ¶
Index ¶
- func RegisterChannelCreator(prefix string, fn channelCreator)
- func RemoveSubscriberAllChannels(client *Client)
- type Channel
- func (c *Channel) AddMessage(msg *message.WebSocketMessage)
- func (c *Channel) AddSubscriber(client *Client)
- func (c *Channel) GetID() string
- func (c *Channel) MessagesChan() chan *message.WebSocketMessage
- func (c *Channel) RemoveSubscriber(ID string)
- func (c *Channel) SubScribeChan() chan *Client
- func (c *Channel) UnsubscribeChan() chan string
- type Client
- type ClientRequest
- type IChannel
- type Server
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterChannelCreator ¶
func RegisterChannelCreator(prefix string, fn channelCreator)
func RemoveSubscriberAllChannels ¶
func RemoveSubscriberAllChannels(client *Client)
Types ¶
type Channel ¶
type Channel struct { ID string Clients sync.Map Subscribe chan *Client Unsubscribe chan string Messages chan *message.WebSocketMessage }
Channel is a basic type implemented IChannel
func (*Channel) AddMessage ¶
func (c *Channel) AddMessage(msg *message.WebSocketMessage)
func (*Channel) AddSubscriber ¶
func (*Channel) MessagesChan ¶
func (c *Channel) MessagesChan() chan *message.WebSocketMessage
func (*Channel) RemoveSubscriber ¶
func (*Channel) SubScribeChan ¶
func (*Channel) UnsubscribeChan ¶
type Client ¶
type Client struct { ID string Conn clientConn LoginAddresses map[string]struct{} // mu sync.Mutex // for orderbook channel Group int Depth int Interval int // contains filtered or unexported fields }
func (*Client) AddLoginAddress ¶
func (*Client) CheckLogin ¶
type ClientRequest ¶
type IChannel ¶
type IChannel interface { GetID() string // Thread safe calls AddSubscriber(*Client) RemoveSubscriber(string) AddMessage(message *message.WebSocketMessage) UnsubscribeChan() chan string SubScribeChan() chan *Client MessagesChan() chan *message.WebSocketMessage // contains filtered or unexported methods }
Click to show internal directories.
Click to hide internal directories.