network

Documentation

Index

• type Amqp
  • func NewAmqp(url string, logger logging.Logger) *Amqp
  • func (a *Amqp) OnMessage(msgChan chan InMsg, queueName, exchangeName, exchangeType, key string) error
  • func (a *Amqp) Start(started chan bool)
  • func (a *Amqp) Stop()
• type DataPublish
• type DeviceUnregistered
• type InMsg

Types

type Amqp

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

Amqp handles the connection, queues and exchanges declared

func NewAmqp

func NewAmqp(url string, logger logging.Logger) *Amqp

NewAmqp constructs the AMQP connection handler

func (*Amqp) OnMessage

func (a *Amqp) OnMessage(msgChan chan InMsg, queueName, exchangeName, exchangeType, key string) error

OnMessage receive messages and put them on channel

func (*Amqp) Start

func (a *Amqp) Start(started chan bool)

Start starts the handler

func (*Amqp) Stop

func (a *Amqp) Stop()

Stop closes the connection started

type DataPublish

type DataPublish struct {
	ID   string             `json:"id"`
	Data []entities.Payload `json:"data"`
}

DataPublish represents the incoming publish data command

type DeviceUnregistered

type DeviceUnregistered struct {
	ID string `json:"id"`
}

DeviceUnregistered represents the incoming unregistered device event

type InMsg

type InMsg struct {
	Exchange   string
	RoutingKey string
	Headers    map[string]interface{}
	Body       []byte
}

InMsg represents the message received from the AMQP broker