event

Documentation

Overview

Pub/sub messaging system using mongodb tailable cursor.

Index

• func Publish(db *database.Database, channel string, data interface{}) (err error)
• func Register(channel string, event string, callback func(*Event))
• func Subscribe(db *database.Database, channels []string, duration time.Duration, ...) (err error)
• type Dispatch
• type Event
• type Listener
  • func SubscribeListener(channels []string) (lst *Listener, err error)
  • func (l *Listener) Close()
  • func (l *Listener) Listen() chan *Event

Functions

func Publish

func Publish(db *database.Database, channel string, data interface{}) (
	err error)

func Register

func Register(channel string, event string, callback func(*Event))

func Subscribe

func Subscribe(db *database.Database, channels []string,
	duration time.Duration, onMsg func(*Event) bool) (err error)

Types

type Dispatch

type Dispatch struct {
	Type string `bson:"type" json:"type"`
}

type Event

type Event struct {
	Id        bson.ObjectId `bson:"_id,omitempty" json:"id"`
	Channel   string        `bson:"channel" json:"channel"`
	Timestamp time.Time     `bson:"timestamp" json:"timestamp"`
	Data      interface{}   `bson:"data" json:"data"`
}

type Listener

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

func SubscribeListener

func SubscribeListener(channels []string) (lst *Listener, err error)

func (*Listener) Close

func (l *Listener) Close()

func (*Listener) Listen

func (l *Listener) Listen() chan *Event