poller

Documentation

Index

• type Client
• type Message
• type Poller
  • func NewPoller(timeout time.Duration) *Poller
  • func (this *Poller) Broadcast(name string, data interface{})
  • func (this *Poller) ServeHTTP(w http.ResponseWriter, r *http.Request)

Types

type Client

type Client struct {
	Tokens  map[string]int64
	Channel chan []Message
}

type Message

type Message struct {
	Version int64       `json:"version"`
	Name    string      `json:"name"`
	Data    interface{} `json:"data"`
	// contains filtered or unexported fields
}

type Poller

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

func NewPoller

func NewPoller(timeout time.Duration) *Poller

func (*Poller) Broadcast

func (this *Poller) Broadcast(name string, data interface{})

func (*Poller) ServeHTTP

func (this *Poller) ServeHTTP(w http.ResponseWriter, r *http.Request)