package application

import "github.com/edgexfoundry/device-sdk-go/internal/v2/application"

Index

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

Source Files

callback.go command.go

Version
v1.4.0 (latest)
Published
Dec 21, 2020
Platform
linux/amd64
Imports
26 packages
Last checked
4 days ago

Tools for package owners.