websocket

Documentation

Index

• func Upgrade(w http.ResponseWriter, r *http.Request) (*websocket.Conn, error)
• type Client
  • func (c *Client) Read()
• type Message
• type Pool
  • func NewPool(conf config.AppConfig) *Pool
  • func (pool *Pool) Start()

Functions

func Upgrade

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

Types

type Client

type Client struct {
	ID            string
	Conn          *websocket.Conn
	Pool          *Pool
	Alias         string
	Subscriptions []*redis.PubSub
}

func (*Client) Read

func (c *Client) Read()

type Message

type Message struct {
	Type string `json:"type"`
	Body string `json:"body"`
}

type Pool

type Pool struct {
	Register   chan *Client
	Unregister chan *Client
	Clients    map[*Client]bool
	Redis      *redis.ClusterClient
	LogEntry   log.Entry
	Wait       *sync.WaitGroup
}

func NewPool

func NewPool(conf config.AppConfig) *Pool

func (*Pool) Start

func (pool *Pool) Start()