iot

Dec 19, 2023

Changes in this version

+ func DeviceTypesEndpoints(control *Controller, router *httprouter.Router)

+ func DevicesEndpoints(control *Controller, router *httprouter.Router)

+ func HubsEndpoints(control *Controller, router *httprouter.Router)

+ func LocalDevicesEndpoints(control *Controller, router *httprouter.Router)

+ func Mock(ctx context.Context, config configuration.Config) (deviceManagerUrl string, deviceRepoUrl string, err error)

+ func MockWithoutKafka(ctx context.Context) (deviceManagerUrl string, deviceRepoUrl string, err error)

+ func ProtocolsEndpoints(control *Controller, router *httprouter.Router)

+ type Controller struct

+ func (this *Controller) DeviceLocalIdToId(id string) (result string, err error, code int)

+ func (this *Controller) PublishDeviceCreate(device model.Device) (result interface{}, err error, code int)

+ func (this *Controller) PublishDeviceDelete(id string) (err error, code int)

+ func (this *Controller) PublishDeviceTypeCreate(devicetype model.DeviceType) (result interface{}, err error, code int)

+ func (this *Controller) PublishDeviceTypeDelete(id string) (err error, code int)

+ func (this *Controller) PublishDeviceTypeUpdate(id string, devicetype model.DeviceType) (result interface{}, err error, code int)

+ func (this *Controller) PublishDeviceUpdate(id string, device model.Device) (result interface{}, err error, code int)

+ func (this *Controller) PublishHubCreate(hub model.Hub) (result interface{}, err error, code int)

+ func (this *Controller) PublishHubDelete(id string) (err error, code int)

+ func (this *Controller) PublishHubUpdate(id string, hub model.Hub) (result interface{}, err error, code int)

+ func (this *Controller) PublishProtocolCreate(protocol model.Protocol) (result interface{}, err error, code int)

+ func (this *Controller) PublishProtocolDelete(id string) (err error, code int)

+ func (this *Controller) PublishProtocolUpdate(id string, protocol model.Protocol) (result interface{}, err error, code int)

+ func (this *Controller) ReadDevice(id string) (result interface{}, err error, code int)

+ func (this *Controller) ReadDeviceType(id string) (result interface{}, err error, code int)

+ func (this *Controller) ReadHub(id string) (result interface{}, err error, code int)

+ func (this *Controller) ReadProtocol(id string) (result interface{}, err error, code int)

+ type LoggerMiddleWare struct

+ func NewLogger(handler http.Handler, logLevel string) *LoggerMiddleWare

+ func (this *LoggerMiddleWare) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type MockProducer struct

+ func (this MockProducer) Close()

+ func (this MockProducer) Log(logger *log.Logger)

+ func (this MockProducer) Produce(topic string, message string) (err error)

+ func (this MockProducer) ProduceWithKey(topic string, message string, key string) (err error)