websocket

Documentation

Index

• func Upgrade(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)
• type BroadcastNotification
  • func (bn BroadcastNotification) GetMessage() []byte
  • func (bn BroadcastNotification) GetScore() float64
  • func (bn BroadcastNotification) IsResend() bool
• type Client
  • func (c *Client) Read()
• type Notification
• type Pool
  • func NewPool(size int64) *Pool
  • func (pool *Pool) Start()
• type UserNotification
  • func (un UserNotification) GetMessage() []byte
  • func (un UserNotification) GetScore() float64
  • func (un UserNotification) IsResend() bool

Functions

func Upgrade

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

Upgrade ...

Types

type BroadcastNotification

type BroadcastNotification struct {
	Score  float64
	Msg    []byte
	Resend bool
}

BroadcastNotification ...

func (BroadcastNotification) GetMessage

func (bn BroadcastNotification) GetMessage() []byte

func (BroadcastNotification) GetScore

func (bn BroadcastNotification) GetScore() float64

func (BroadcastNotification) IsResend

func (bn BroadcastNotification) IsResend() bool

type Client

type Client struct {
	Conn  *websocket.Conn
	Pool  *Pool
	ID    *users.UserID
	Token string
	// contains filtered or unexported fields
}

Client ...

func (*Client) Read

func (c *Client) Read()

type Notification

type Notification interface {
	GetScore() float64
	GetMessage() []byte
	IsResend() bool
}

Notification

type Pool

type Pool struct {
	Register      chan *Client
	Unregister    chan *Client
	Login         chan *Client
	NotifyUser    chan UserNotification
	Broadcast     chan BroadcastNotification
	Clients       map[*Client]bool
	ClientMapping map[string]*Client
	Rclient       *redis.Client
	BufferSize    int64
}

Pool ...

func NewPool

func NewPool(size int64) *Pool

NewPool ...

func (*Pool) Start

func (pool *Pool) Start()

Start ...

type UserNotification

type UserNotification struct {
	ID     *users.UserID
	Score  float64
	Msg    []byte
	Resend bool
}

UserNotification ...

func (UserNotification) GetMessage

func (un UserNotification) GetMessage() []byte

func (UserNotification) GetScore

func (un UserNotification) GetScore() float64

func (UserNotification) IsResend

func (un UserNotification) IsResend() bool