ws

Documentation

Index

• type Channel
  • func NewChannel() (c *Channel)
  • func (c *Channel) AddClient(a string, w http.ResponseWriter, r *http.Request) (err error)
  • func (c *Channel) Close(a string)
  • func (c *Channel) NewChan(a string) (err error)
• type Client
• type Hub
  • func NewHub() (c *Hub)
• type Mess

Types

type Channel

type Channel struct {
	sync.RWMutex
	Chan map[string]*Mess
}

func NewChannel

func NewChannel() (c *Channel)

func (*Channel) AddClient

func (c *Channel) AddClient(a string, w http.ResponseWriter, r *http.Request) (err error)

func (*Channel) Close

func (c *Channel) Close(a string)

func (*Channel) NewChan

func (c *Channel) NewChan(a string) (err error)

type Client

type Client struct {
	Hh http.Header
	// contains filtered or unexported fields
}

type Hub

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

func NewHub

func NewHub() (c *Hub)

type Mess

type Mess struct {
	Hub    *Hub
	Client []*Client
	Close  chan bool
}