wshub

Documentation

Index

• Constants
• type Hub
  • func New() *Hub
  • func (h *Hub) CloseSession(sessionID string)
  • func (h *Hub) Publish(id string, data []byte)
  • func (h *Hub) RegisterSession(w http.ResponseWriter, r *http.Request)
  • func (h *Hub) Run(registerFunc, unregisterFunc func(id string))
  • func (h *Hub) Subscribe() <-chan Message
• type Message
• type Session

Constants

const (
	PubAckOK     = "ok"
	PubAckFailed = "failed"
)

Types

type Hub

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

func New

func New() *Hub

func (*Hub) CloseSession

func (h *Hub) CloseSession(sessionID string)

func (*Hub) Publish

func (h *Hub) Publish(id string, data []byte)

func (*Hub) RegisterSession

func (h *Hub) RegisterSession(w http.ResponseWriter, r *http.Request)

func (*Hub) Run

func (h *Hub) Run(registerFunc, unregisterFunc func(id string))

func (*Hub) Subscribe

func (h *Hub) Subscribe() <-chan Message

type Message

type Message struct {
	ID   string // session id
	Data []byte
}

type Session

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