ws

Documentation

Index

• func Broadcast(message interface{}, ignoreId string)
• func Close() error
• func Publish(channel string, message interface{}, ignoreId string)
• func SendMessage(clientId, channel string, message interface{}) bool
• func Subcribe(clientId string, channel string) bool
• func Unsubcribe(clientId string, channel string) bool
• type Channel
  • func GetChannels() []*Channel
  • func NewChanel(hub *Hub, name string) *Channel
  • func (ch *Channel) Unsubcribe(clientId string)
• type Client
  • func Connect(w http.ResponseWriter, r *http.Request) (*Client, error)
  • func GetClients() []*Client
  • func GetSubscribers(channel string) []*Client
  • func NewClient(hub *Hub, socket *websocket.Conn, id, name string) (*Client, bool)
  • func (c *Client) Channels() []*Channel
  • func (c *Client) Clear()
  • func (c *Client) Close()
  • func (c *Client) Read()
  • func (c *Client) SendMessage(message []byte)
  • func (c *Client) Subscribe(channel string)
  • func (c *Client) Subscribers(channels []string)
  • func (c *Client) Unsubscribe(channel string)
  • func (c *Client) Unsubscribers(channels []string)
  • func (c *Client) Write()
• type Conn
  • func Load() (*Conn, error)
• type Hub
  • func NewHub() *Hub
  • func (hub *Hub) Broadcast(message interface{}, ignoreId string)
  • func (hub *Hub) GetSubscribers(channel string) []*Client
  • func (hub *Hub) Publish(channel string, message interface{}, ignoreId string)
  • func (hub *Hub) Run()
  • func (hub *Hub) SendMessage(clientId, channel string, message interface{}) bool
  • func (hub *Hub) Subcribe(clientId string, channel string) bool
  • func (hub *Hub) Unsubcribe(clientId string, channel string) bool
• type WsMessage

Functions

func Broadcast

func Broadcast(message interface{}, ignoreId string)

func Close

func Close() error

func Publish

func Publish(channel string, message interface{}, ignoreId string)

func SendMessage

func SendMessage(clientId, channel string, message interface{}) bool

func Subcribe

func Subcribe(clientId string, channel string) bool

func Unsubcribe

func Unsubcribe(clientId string, channel string) bool

Types

type Channel

type Channel struct {
	Name        string
	Subscribers []*Client
	// contains filtered or unexported fields
}

func GetChannels

func GetChannels() []*Channel

func NewChanel

func NewChanel(hub *Hub, name string) *Channel

func (*Channel) Unsubcribe

func (ch *Channel) Unsubcribe(clientId string)

type Client

type Client struct {
	Id   string
	Name string
	Addr string
	// contains filtered or unexported fields
}

func Connect

func Connect(w http.ResponseWriter, r *http.Request) (*Client, error)

func GetClients

func GetClients() []*Client

func GetSubscribers

func GetSubscribers(channel string) []*Client

func NewClient

func NewClient(hub *Hub, socket *websocket.Conn, id, name string) (*Client, bool)

func (*Client) Channels

func (c *Client) Channels() []*Channel

func (*Client) Clear

func (c *Client) Clear()

func (*Client) Close

func (c *Client) Close()

func (*Client) Read

func (c *Client) Read()

func (*Client) SendMessage

func (c *Client) SendMessage(message []byte)

func (*Client) Subscribe

func (c *Client) Subscribe(channel string)

func (*Client) Subscribers

func (c *Client) Subscribers(channels []string)

func (*Client) Unsubscribe

func (c *Client) Unsubscribe(channel string)

func (*Client) Unsubscribers

func (c *Client) Unsubscribers(channels []string)

func (*Client) Write

func (c *Client) Write()

type Conn

type Conn struct {
	// contains filtered or unexported fields
}

func Load

func Load() (*Conn, error)

type Hub

type Hub struct {
	Id string
	// contains filtered or unexported fields
}

func NewHub

func NewHub() *Hub

func (*Hub) Broadcast

func (hub *Hub) Broadcast(message interface{}, ignoreId string)

func (*Hub) GetSubscribers

func (hub *Hub) GetSubscribers(channel string) []*Client

func (*Hub) Publish

func (hub *Hub) Publish(channel string, message interface{}, ignoreId string)

func (*Hub) Run

func (hub *Hub) Run()

func (*Hub) SendMessage

func (hub *Hub) SendMessage(clientId, channel string, message interface{}) bool

func (*Hub) Subcribe

func (hub *Hub) Subcribe(clientId string, channel string) bool

func (*Hub) Unsubcribe

func (hub *Hub) Unsubcribe(clientId string, channel string) bool

type WsMessage

type WsMessage struct {
	Type    string      `json:"type"`
	Payload interface{} `json:"payload"`
}