README
¶
BBB Events
We are using the BBB redis, and monitor the akka messages.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrChannelClosed = errors.New("subscription channel disconnected")
)
Errors
Functions ¶
This section is empty.
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 ¶
NewMonitor creates a new monitor with a redis connection
Source Files
Click to show internal directories.
Click to hide internal directories.