backend

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
}

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
}