websocket

May 7, 2020

Changes in this version

+ type BroadcastNotification struct

+ Msg []byte

+ Resend bool

+ Score float64

+ func (bn BroadcastNotification) GetMessage() []byte

+ func (bn BroadcastNotification) GetScore() float64

+ func (bn BroadcastNotification) IsResend() bool

type Client

+ Token string

+ type Notification interface

+ GetMessage func() []byte

+ GetScore func() float64

+ IsResend func() bool

type Pool

+ BufferSize int64

+ ClientMapping map[string]*Client

+ Login chan *Client

+ NotifyUser chan UserNotification

+ Rclient *redis.Client

+ type UserNotification struct

+ ID *users.UserID

+ Msg []byte

+ Resend bool

+ Score float64

+ func (un UserNotification) GetMessage() []byte

+ func (un UserNotification) GetScore() float64

+ func (un UserNotification) IsResend() bool

Apr 7, 2020

Changes in this version

+ func Upgrade(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)

+ type Client struct

+ Conn *websocket.Conn

+ ID int

+ Pool *Pool

+ func (c *Client) Read()

+ type Message struct

+ Body string

+ Type int

+ type Pool struct

+ Broadcast chan []byte

+ Clients map[*Client]bool

+ Register chan *Client

+ Unregister chan *Client

+ func NewPool() *Pool

+ func (pool *Pool) Start()