Documentation
¶
Index ¶
- func ConsumeFromStreamProvider(consumer chan dc.DeviceMessage, plog log.Logger)
- func NewDeviceSourceService(cfg cc.Config, repo dc.Repository, stream StreamProvider, plog log.Logger) dc.DeviceEventProvider
- func Start(dfg cc.Config, repo dc.Repository, dProvider StreamProvider) (dc.DeviceEventProvider, error)
- func Stop()
- type StreamProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConsumeFromStreamProvider ¶
func ConsumeFromStreamProvider(consumer chan dc.DeviceMessage, plog log.Logger)
ConsumeFromDeviceStream - Stream Listener
func NewDeviceSourceService ¶
func NewDeviceSourceService(cfg cc.Config, repo dc.Repository, stream StreamProvider, plog log.Logger) dc.DeviceEventProvider
*
- NewDeviceSourceService() *
- Create a New NewDeviceSourceService and initializes it.
func Start ¶
func Start(dfg cc.Config, repo dc.Repository, dProvider StreamProvider) (dc.DeviceEventProvider, error)
* Start() * * Initialize this service
Types ¶
type StreamProvider ¶
type StreamProvider interface {
ActivateNotifications() chan dc.DeviceMessage
GetPublishChannel() chan dc.DeviceMessage
GetNotifyChannel() chan dc.DeviceMessage
CreateQueueDeviceMessage(qmsg dc.QueueMessage) dc.DeviceMessage
CreateDemoDeviceMessage(topic string, payload []byte, idCounter uint16, retained bool, qos byte) dc.DeviceMessage
}
Message Interface for MQTT and Demo
Source Files
Click to show internal directories.
Click to hide internal directories.