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 errors.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, sourceName string, correlationID string, body string, ...) *CommandProcessor
  • func (c *CommandProcessor) ReadDeviceCommand() (res *dtos.Event, e errors.EdgeX)
  • func (c *CommandProcessor) ReadDeviceResource() (res *dtos.Event, e errors.EdgeX)
  • func (c *CommandProcessor) WriteDeviceCommand() errors.EdgeX
  • func (c *CommandProcessor) WriteDeviceResource() errors.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 errors.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, sourceName string, correlationID string, body string, attributes string, dic *di.Container) *CommandProcessor

func (*CommandProcessor) ReadDeviceCommand

func (c *CommandProcessor) ReadDeviceCommand() (res *dtos.Event, e errors.EdgeX)

func (*CommandProcessor) ReadDeviceResource

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

func (*CommandProcessor) WriteDeviceCommand

func (c *CommandProcessor) WriteDeviceCommand() errors.EdgeX

func (*CommandProcessor) WriteDeviceResource

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