application

package
v1.3.1-dev.11 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 26, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddEvent

func AddEvent(e models.Event, ctx context.Context, dic *di.Container) (id string, err errors.EdgeX)

The AddEvent function accepts the new event model from the controller functions and invokes addEvent function in the infrastructure layer

func AllEvents

func AllEvents(offset int, limit int, dic *di.Container) (events []dtos.Event, err errors.EdgeX)

AllEvents query events by offset and limit

func DeleteEventById

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

The DeleteEventById function accepts event id from the controller functions and invokes DeleteEventById function in the infrastructure layer to remove event

func DeleteEventsByDeviceName

func DeleteEventsByDeviceName(deviceName string, dic *di.Container) errors.EdgeX

The DeleteEventsByDeviceName function will be invoked by controller functions and then invokes DeleteEventsByDeviceName function in the infrastructure layer to remove all events/readings that are associated with the given deviceName

func DeletePushedEvents

func DeletePushedEvents(dic *di.Container) errors.EdgeX

The DeletePushedEvents function will be invoked by controller functions and then invokes DeletePushedEvents function in the infrastructure layer to remove all events that have been pushed (pushed timestamp is greater than zero)

func EventById

func EventById(id string, dic *di.Container) (dtos.Event, errors.EdgeX)

func EventCountByDevice

func EventCountByDevice(deviceName string, dic *di.Container) (uint32, errors.EdgeX)

func EventTotalCount

func EventTotalCount(dic *di.Container) (uint32, errors.EdgeX)

func EventsByDeviceName

func EventsByDeviceName(offset int, limit int, name string, dic *di.Container) (events []dtos.Event, err errors.EdgeX)

EventsByDeviceName query events with offset, limit and name

func EventsByTimeRange

func EventsByTimeRange(start int, end int, offset int, limit int, dic *di.Container) (events []dtos.Event, err errors.EdgeX)

EventsByTimeRange query events with offset, limit and time range

func UpdateEventPushedById

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

UpdateEventPushedById updates event pushed timestamp per incoming event id

Types

This section is empty.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL