Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Northbound ¶
type Northbound interface { Connect() error Disconnect() error CleanupGateway(gatewayID string) PublishUplink(message *types.UplinkMessage) error PublishStatus(message *types.StatusMessage) error SubscribeDownlink(gatewayID string) (<-chan *types.DownlinkMessage, error) UnsubscribeDownlink(gatewayID string) error }
Northbound backends talk to servers that are up the chain
type Southbound ¶
type Southbound interface { Connect() error Disconnect() error SubscribeConnect() (<-chan *types.ConnectMessage, error) UnsubscribeConnect() error SubscribeDisconnect() (<-chan *types.DisconnectMessage, error) UnsubscribeDisconnect() error SubscribeUplink(gatewayID string) (<-chan *types.UplinkMessage, error) UnsubscribeUplink(gatewayID string) error SubscribeStatus(gatewayID string) (<-chan *types.StatusMessage, error) UnsubscribeStatus(gatewayID string) error PublishDownlink(message *types.DownlinkMessage) error }
Southbound backends talk to gateways or servers that are down the chain
Directories ¶
Path | Synopsis |
---|---|
Package amqp connects to an AMQP server in order to communicate with a gateway.
|
Package amqp connects to an AMQP server in order to communicate with a gateway. |
Package mqtt connects to an MQTT broker in order to communicate with a gateway.
|
Package mqtt connects to an MQTT broker in order to communicate with a gateway. |
Click to show internal directories.
Click to hide internal directories.