events

README

BBB Events

We are using the BBB redis, and monitor the akka messages.

Documentation

Index

• Variables
• type Message
• type MessageCore
• type MessageEnvelope
• type Monitor
  • func NewMonitor(rdb *redis.Client) *Monitor
  • func (m *Monitor) Subscribe() chan bbb.Event

Variables

var (
	ErrChannelClosed = errors.New("subscription channel disconnected")
)

Errors

Types

type Message

type Message struct {
	Envelope *MessageEnvelope `json:"envelope"`
	Core     *MessageCore     `json:"core"`
}

A Message represents an akka message on the channel

type MessageCore

type MessageCore struct {
	Header map[string]interface{} `json:"header"`
	Body   map[string]interface{} `json:"body"`
}

The MessageCore is a "core-message"

type MessageEnvelope

type MessageEnvelope struct {
	Name      string            `json:"name"`
	Routing   map[string]string `json:"routing"`
	Timestamp int               `json:"timestamp"`
}

MessageEnvelope of the akka message

type Monitor

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

A Monitor is connected to a redis server and is listening for BBB events.

func NewMonitor

func NewMonitor(rdb *redis.Client) *Monitor

NewMonitor creates a new monitor with a redis connection

func (*Monitor) Subscribe

func (m *Monitor) Subscribe() chan bbb.Event

Subscribe subscribes to the redis store and retrievs messsges. These are decoded and returned through a channel.