collection

Documentation

Index

• type AppCollector
  • func NewMqttAppCollector(ctx log.Interface, mqttBroker string, eui types.AppEUI, key string, ...) AppCollector
• type DataStorage

Types

type AppCollector

type AppCollector interface {
	Start() error
	Stop()
}

AppCollector represents a collector for application data

func NewMqttAppCollector

func NewMqttAppCollector(ctx log.Interface, mqttBroker string, eui types.AppEUI, key string, storage DataStorage) AppCollector

NewMqttAppCollector instantiates a new AppCollector instance using MQTT

type DataStorage

type DataStorage interface {
	Save(appEUI types.AppEUI, devEUI types.DevEUI, t time.Time, fields map[string]interface{}) error
	Close() error
}

DataStorage provides methods to select and save data