application

Documentation

Index

• func AddDevice(addDeviceRequest requests.AddDeviceRequest, dic *di.Container) errors.EdgeX
• func AddProvisionWatcher(addProvisionWatcherRequest requests.AddProvisionWatcherRequest, ...) errors.EdgeX
• func CommandHandler(isRead bool, sendEvent bool, correlationID string, vars map[string]string, ...) (res *dtos.Event, err edgexErr.EdgeX)
• func DeleteDevice(name string, dic *di.Container) errors.EdgeX
• func DeleteProvisionWatcher(name string, lc logger.LoggingClient) errors.EdgeX
• func UpdateDevice(updateDeviceRequest requests.UpdateDeviceRequest, dic *di.Container) errors.EdgeX
• func UpdateDeviceService(updateDeviceServiceRequest requests.UpdateDeviceServiceRequest, ...) errors.EdgeX
• func UpdateProfile(profileRequest requests.DeviceProfileRequest, lc logger.LoggingClient) errors.EdgeX
• func UpdateProvisionWatcher(updateProvisionWatcherRequest requests.UpdateProvisionWatcherRequest, ...) errors.EdgeX
• type CommandProcessor
  • func NewCommandProcessor(device models.Device, dr models.DeviceResource, correlationID string, ...) *CommandProcessor
  • func (c *CommandProcessor) ReadCommand() (res *dtos.Event, e edgexErr.EdgeX)
  • func (c *CommandProcessor) ReadDeviceResource() (res *dtos.Event, e edgexErr.EdgeX)
  • func (c *CommandProcessor) WriteCommand() edgexErr.EdgeX
  • func (c *CommandProcessor) WriteDeviceResource() edgexErr.EdgeX

Functions

func AddDevice

func AddDevice(addDeviceRequest requests.AddDeviceRequest, dic *di.Container) errors.EdgeX

func AddProvisionWatcher

func AddProvisionWatcher(addProvisionWatcherRequest requests.AddProvisionWatcherRequest, lc logger.LoggingClient) errors.EdgeX

func CommandHandler

func CommandHandler(isRead bool, sendEvent bool, correlationID string, vars map[string]string, body string, attributes string, dic *di.Container) (res *dtos.Event, err edgexErr.EdgeX)

func DeleteDevice

func DeleteDevice(name string, dic *di.Container) errors.EdgeX

func DeleteProvisionWatcher

func DeleteProvisionWatcher(name string, lc logger.LoggingClient) errors.EdgeX

func UpdateDevice

func UpdateDevice(updateDeviceRequest requests.UpdateDeviceRequest, dic *di.Container) errors.EdgeX

func UpdateDeviceService

func UpdateDeviceService(updateDeviceServiceRequest requests.UpdateDeviceServiceRequest, dic *di.Container) errors.EdgeX

func UpdateProfile

func UpdateProfile(profileRequest requests.DeviceProfileRequest, lc logger.LoggingClient) errors.EdgeX

func UpdateProvisionWatcher

func UpdateProvisionWatcher(updateProvisionWatcherRequest requests.UpdateProvisionWatcherRequest, dic *di.Container) errors.EdgeX

Types

type CommandProcessor

type CommandProcessor struct {
	// contains filtered or unexported fields
}

func NewCommandProcessor

func NewCommandProcessor(device models.Device, dr models.DeviceResource, correlationID string, cmd string, body string, attributes string, dic *di.Container) *CommandProcessor

func (*CommandProcessor) ReadCommand

func (c *CommandProcessor) ReadCommand() (res *dtos.Event, e edgexErr.EdgeX)

func (*CommandProcessor) ReadDeviceResource

func (c *CommandProcessor) ReadDeviceResource() (res *dtos.Event, e edgexErr.EdgeX)

func (*CommandProcessor) WriteCommand

func (c *CommandProcessor) WriteCommand() edgexErr.EdgeX

func (*CommandProcessor) WriteDeviceResource

func (c *CommandProcessor) WriteDeviceResource() edgexErr.EdgeX