distributor

Documentation

Overview

Package distributor is used to distribute messages through the ApplicationBackend.

Index

• type Distributor
  • func New() Distributor

Types

type Distributor

type Distributor interface {
	InputUplink(components.MessageUplinkI) (components.MessageUplinkI, error)
	InputDownlink(components.MessageDownLink)
	InputNewSensors(sensors []components.Sensor, devEUI string)
	DeleteSensors(sensors []components.Sensor, devEUI string)
}

Distributor is used to distribute messages through the system. When it receives a Uplink message, it transfers that to the restUplinkConnector and the DatabaseConnector. When receiving a Downlink message, it transfers that to the DatabaseConnector and the mqttDownlink Client. When the header comes in, it also sends messages to the restUplink that Sensors has been either removed in the node header.

func New

func New() Distributor

New Creates a new Distributor object.