network

package

v1.0.4-0...-7069f2b Latest Latest Go to latest Published: Sep 2, 2020 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

Amqp handles the connection, queues and exchanges declared

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

NewAmqp constructs the AMQP connection handler

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

OnMessage receive messages and put them on channel

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

Start starts the handler

func (a *Amqp) Stop()

Stop closes the connection started

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

DataPublish represents the incoming publish data command

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

DeviceUnregistered represents the incoming unregistered device event

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

InMsg represents the message received from the AMQP broker