Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type QueueListener ¶
type QueueListener struct {
ScrapRequest *mysql.ScrapRequestModel
// contains filtered or unexported fields
}
func NewQueueListener ¶
func NewQueueListener(db *sql.DB) *QueueListener
func (*QueueListener) AddListener ¶
func (ql *QueueListener) AddListener(msgs <-chan amqp.Delivery)
func (*QueueListener) DiscoverSensors ¶
func (ql *QueueListener) DiscoverSensors()
func (*QueueListener) ListenForNewSource ¶
func (ql *QueueListener) ListenForNewSource()
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.