Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DatabaseConsumer ¶
type DatabaseConsumer struct {
// contains filtered or unexported fields
}
func NewDatabaseConsumer ¶
func NewDatabaseConsumer(er EventRaiser) *DatabaseConsumer
func (*DatabaseConsumer) SubscribeToDataEvent ¶
func (dc *DatabaseConsumer) SubscribeToDataEvent(eventName string)
type EventAggregator ¶
type EventAggregator struct {
// contains filtered or unexported fields
}
func NewEventAggregator ¶
func NewEventAggregator() *EventAggregator
func (*EventAggregator) AddListener ¶
func (ea *EventAggregator) AddListener(name string, f func(interface{}))
func (*EventAggregator) PublishEvent ¶
func (ea *EventAggregator) PublishEvent(name string, eventdata interface{})
type EventRaiser ¶
type EventRaiser interface {
AddListener(eventName string, f func(interface{}))
}
type MetricConsumer ¶
type MetricConsumer struct {
// contains filtered or unexported fields
}
func NewMetricConsumer ¶
func NewMetricConsumer(er EventRaiser) *MetricConsumer
func (*MetricConsumer) SubscribeToDataEvent ¶
func (mc *MetricConsumer) SubscribeToDataEvent(eventName string)
type QueueListener ¶
type QueueListener struct {
// contains filtered or unexported fields
}
func NewQueueListener ¶
func NewQueueListener(ea *EventAggregator) *QueueListener
func (*QueueListener) AddListener ¶
func (ql *QueueListener) AddListener(msgs <-chan amqp.Delivery)
func (*QueueListener) DiscoverSensor ¶
func (ql *QueueListener) DiscoverSensor()
func (*QueueListener) ListenForNewSource ¶
func (ql *QueueListener) ListenForNewSource()
Source Files ¶
Click to show internal directories.
Click to hide internal directories.