stream

Documentation

Index

• type Client
  • func (c *Client) Notify(t, b string)
  • func (c *Client) Send(msg string)
  • func (c *Client) UpdateInfo(info interface{})
• type Hub
  • func GetHub() Hub
• type StreamCotroller
  • func (w *StreamCotroller) Get()

Types

type Client

type Client struct {
	Session sockjs.Session
	//User *rbac.User
	Ip        string
	Referer   string
	UserAgent string
	Width     int
	Height    int
	Cookie    bool
	Language  string
	Platform  string
	Location  string
	Href      string
}

func (*Client) Notify

func (c *Client) Notify(t, b string)

func (*Client) Send

func (c *Client) Send(msg string)

func (*Client) UpdateInfo

func (c *Client) UpdateInfo(info interface{})

type Hub

type Hub interface {
	Broadcast(message string)
	Subscribe(command string, f func(client *Client, value interface{}))
	UnSubscribe(command string)
	AddClient(client *Client)
}

func GetHub

func GetHub() Hub

type StreamCotroller

type StreamCotroller struct {
	beego.Controller
}

func (*StreamCotroller) Get

func (w *StreamCotroller) Get()