service

Documentation

Index

• func Negation(boolean bool) bool
• type QueueListener
  • func NewQueueListener(db *sql.DB) *QueueListener
  • func (ql *QueueListener) AddListener(msgs <-chan amqp.Delivery)
  • func (ql *QueueListener) DiscoverSensors()
  • func (ql *QueueListener) ListenForNewSource()

Functions

func Negation

func Negation(boolean bool) bool

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()