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 responses.EventResponse, err edgexErr.EdgeX)
• func DeleteDevice(name string, dic *di.Container) errors.EdgeX
• func DeleteProvisionWatcher(name string, lc logger.LoggingClient) errors.EdgeX
• func SendEvent(event responses.EventResponse, correlationID string, lc logger.LoggingClient, ...)
• func UpdateDevice(updateDeviceRequest requests.UpdateDeviceRequest, dic *di.Container) errors.EdgeX
• func UpdateProfile(profileRequest requests.DeviceProfileRequest, lc logger.LoggingClient) errors.EdgeX
• func UpdateProvisionWatcher(updateProvisionWatcherRequest requests.UpdateProvisionWatcherRequest, ...) errors.EdgeX
• type CommandProcessor
  • func NewCommandProcessor(device *contract.Device, dr *contract.DeviceResource, correlationID string, ...) *CommandProcessor
  • func (c *CommandProcessor) ReadCommand() (res responses.EventResponse, e edgexErr.EdgeX)
  • func (c *CommandProcessor) ReadDeviceResource() (res responses.EventResponse, 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, dic *di.Container) (res responses.EventResponse, 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 SendEvent

func SendEvent(event responses.EventResponse, correlationID string, lc logger.LoggingClient, ec coredata.EventClient)

func UpdateDevice

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

func UpdateProfile

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

func UpdateProvisionWatcher

func UpdateProvisionWatcher(updateProvisionWatcherRequest requests.UpdateProvisionWatcherRequest, lc logger.LoggingClient) errors.EdgeX

Types

type CommandProcessor

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

func NewCommandProcessor

func NewCommandProcessor(device *contract.Device, dr *contract.DeviceResource, correlationID string, cmd string, params string, dic *di.Container) *CommandProcessor

func (*CommandProcessor) ReadCommand

func (c *CommandProcessor) ReadCommand() (res responses.EventResponse, e edgexErr.EdgeX)

func (*CommandProcessor) ReadDeviceResource

func (c *CommandProcessor) ReadDeviceResource() (res responses.EventResponse, e edgexErr.EdgeX)

func (*CommandProcessor) WriteCommand

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

func (*CommandProcessor) WriteDeviceResource

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