hub

package

v0.0.0-...-7fbc050 Latest Latest Go to latest Published: Aug 30, 2013 License: BSD-2-Clause Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var (
	Signon  = "_signon"
	Signoff = "_signoff"
)

This section is empty.

type Envelope struct {
	From, To Id
	Msg
}

type Grouper interface {
	GroupId() Id
	Group() []Id
}

type Hub struct {
	Add   chan Grouper
	Del   chan Grouper
	Route chan Envelope
	Send  chan Envelope
	// contains filtered or unexported fields
}

func New() *Hub

func (h *Hub) SendMsg(m Msg, to Id)

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

type Id int64

const (
	Route  Id = 0
	Group  Id = 1 << 32
	Except Id = 2 << 32
)

func (id Id) MarshalJSON() ([]byte, error)

func (id *Id) UnmarshalJSON(data []byte) error

type Msg struct {
	Head string
	Data *json.RawMessage `json:",omitempty"`
}

func Marshal(head string, v interface{}) (m Msg, err error)

func (m *Msg) Unmarshal(v interface{}) error