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 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 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 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 UpdateEventPushedById

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

UpdateEventPushedById updates event pushed timestamp per incoming event id