application

Documentation

Index

• func AddEvent(e models.Event, ctx context.Context, dic *di.Container) (id string, err errors.EdgeX)
• func AllEvents(offset int, limit int, dic *di.Container) (events []dtos.Event, err errors.EdgeX)
• func DeleteEventById(id string, dic *di.Container) errors.EdgeX
• func DeleteEventsByDeviceName(deviceName string, dic *di.Container) errors.EdgeX
• func DeletePushedEvents(dic *di.Container) errors.EdgeX
• func EventById(id string, dic *di.Container) (dtos.Event, errors.EdgeX)
• func EventCountByDevice(deviceName string, dic *di.Container) (uint32, errors.EdgeX)
• func EventTotalCount(dic *di.Container) (uint32, errors.EdgeX)
• func EventsByDeviceName(offset int, limit int, name string, dic *di.Container) (events []dtos.Event, err errors.EdgeX)
• func EventsByTimeRange(start int, end int, offset int, limit int, dic *di.Container) (events []dtos.Event, err errors.EdgeX)
• func ReadingTotalCount(dic *di.Container) (uint32, errors.EdgeX)
• func UpdateEventPushedById(id string, dic *di.Container) errors.EdgeX

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 ReadingTotalCount

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

ReadingTotalCount return the count of all of readings currently stored in the database and error if any

func UpdateEventPushedById

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

UpdateEventPushedById updates event pushed timestamp per incoming event id