application

Documentation

Index

• func AddDevice(addDeviceRequest requests.AddDeviceRequest, dic *di.Container) errors.EdgeX
• func AddProfile(profileRequest requests.DeviceProfileRequest, lc logger.LoggingClient) errors.EdgeX
• func CommandHandler(isRead bool, sendEvent bool, correlationID string, vars map[string]string, ...) (event *dtos.Event, err edgexErr.EdgeX)
• func DeleteDevice(id string, dic *di.Container) errors.EdgeX
• func DeleteProfile(id string, dic *di.Container) errors.EdgeX
• func SendEvent(event *dtos.Event, 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
• type CommandProcessor
  • func NewCommandProcessor(device *contract.Device, dr *contract.DeviceResource, correlationID string, ...) *CommandProcessor
  • func (c *CommandProcessor) ReadCommand() (*dtos.Event, edgexErr.EdgeX)
  • func (c *CommandProcessor) ReadDeviceResource() (*dtos.Event, 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 AddProfile

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

func CommandHandler

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

func DeleteDevice

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

func DeleteProfile

func DeleteProfile(id string, dic *di.Container) errors.EdgeX

func SendEvent

func SendEvent(event *dtos.Event, 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

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() (*dtos.Event, edgexErr.EdgeX)

func (*CommandProcessor) ReadDeviceResource

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

func (*CommandProcessor) WriteCommand

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

func (*CommandProcessor) WriteDeviceResource

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