Documentation
¶
Index ¶
- func AddNotification(n models.Notification, ctx context.Context, dic *di.Container) (id string, edgeXerr errors.EdgeX)
- func AddSubscription(d models.Subscription, ctx context.Context, dic *di.Container) (id string, edgeXerr errors.EdgeX)
- func AllSubscriptions(offset, limit int, dic *di.Container) (subscriptions []dtos.Subscription, err errors.EdgeX)
- func AllTransmissions(offset, limit int, dic *di.Container) (transmissions []dtos.Transmission, err errors.EdgeX)
- func CleanupNotificationsByAge(age int64, dic *di.Container) errors.EdgeX
- func DeleteNotificationById(id string, dic *di.Container) errors.EdgeX
- func DeleteProcessedNotificationsByAge(age int64, dic *di.Container) errors.EdgeX
- func DeleteProcessedTransmissionsByAge(age int64, dic *di.Container) errors.EdgeX
- func DeleteSubscriptionByName(name string, ctx context.Context, dic *di.Container) errors.EdgeX
- func NotificationById(id string, dic *di.Container) (notification dtos.Notification, edgeXerr errors.EdgeX)
- func NotificationsByCategory(offset, limit int, category string, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
- func NotificationsByLabel(offset, limit int, label string, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
- func NotificationsByStatus(offset, limit int, status string, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
- func NotificationsBySubscriptionName(offset, limit int, subscriptionName string, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
- func NotificationsByTimeRange(start int, end int, offset int, limit int, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
- func PatchSubscription(ctx context.Context, dto dtos.UpdateSubscription, dic *di.Container) errors.EdgeX
- func SubscriptionByName(name string, dic *di.Container) (subscription dtos.Subscription, err errors.EdgeX)
- func SubscriptionsByCategory(offset, limit int, category string, dic *di.Container) (subscriptions []dtos.Subscription, err errors.EdgeX)
- func SubscriptionsByLabel(offset, limit int, label string, dic *di.Container) (subscriptions []dtos.Subscription, err errors.EdgeX)
- func SubscriptionsByReceiver(offset, limit int, receiver string, dic *di.Container) (subscriptions []dtos.Subscription, err errors.EdgeX)
- func TransmissionById(id string, dic *di.Container) (trans dtos.Transmission, edgeXerr errors.EdgeX)
- func TransmissionsByStatus(offset, limit int, status string, dic *di.Container) (transmissions []dtos.Transmission, err errors.EdgeX)
- func TransmissionsBySubscriptionName(offset, limit int, subscriptionName string, dic *di.Container) (transmissions []dtos.Transmission, err errors.EdgeX)
- func TransmissionsByTimeRange(start int, end int, offset int, limit int, dic *di.Container) (transmissions []dtos.Transmission, err errors.EdgeX)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddNotification ¶
func AddNotification(n models.Notification, ctx context.Context, dic *di.Container) (id string, edgeXerr errors.EdgeX)
The AddNotification function accepts the new Notification model from the controller function and then invokes AddNotification function of infrastructure layer to add new Notification
func AddSubscription ¶
func AddSubscription(d models.Subscription, ctx context.Context, dic *di.Container) (id string, edgeXerr errors.EdgeX)
The AddSubscription function accepts the new Subscription model from the controller function and then invokes AddSubscription function of infrastructure layer to add new Subscription
func AllSubscriptions ¶
func AllSubscriptions(offset, limit int, dic *di.Container) (subscriptions []dtos.Subscription, err errors.EdgeX)
AllSubscriptions queries subscriptions by offset and limit
func AllTransmissions ¶
func AllTransmissions(offset, limit int, dic *di.Container) (transmissions []dtos.Transmission, err errors.EdgeX)
AllTransmissions queries transmissions by offset and limit
func CleanupNotificationsByAge ¶
CleanupNotificationsByAge invokes the infrastructure layer function to remove notifications that are older than age. And the corresponding transmissions will also be deleted Age is supposed in milliseconds since modified timestamp.
func DeleteNotificationById ¶
DeleteNotificationById deletes the notification by id and all of its associated transmissions
func DeleteProcessedNotificationsByAge ¶
DeleteProcessedNotificationsByAge invokes the infrastructure layer function to remove processed notifications that are older than age. And the corresponding transmissions will also be deleted Age is supposed in milliseconds since modified timestamp.
func DeleteProcessedTransmissionsByAge ¶
DeleteProcessedTransmissionsByAge invokes the infrastructure layer function to remove the processed transmissions that are older than age. Age is supposed in milliseconds since created timestamp.
func DeleteSubscriptionByName ¶
DeleteSubscriptionByName deletes the subscription by name
func NotificationById ¶
func NotificationById(id string, dic *di.Container) (notification dtos.Notification, edgeXerr errors.EdgeX)
NotificationById queries notification by ID
func NotificationsByCategory ¶
func NotificationsByCategory(offset, limit int, category string, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
NotificationsByCategory queries notifications with offset, limit, and category
func NotificationsByLabel ¶
func NotificationsByLabel(offset, limit int, label string, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
NotificationsByLabel queries notifications with offset, limit, and label
func NotificationsByStatus ¶
func NotificationsByStatus(offset, limit int, status string, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
NotificationsByStatus queries notifications with offset, limit, and status
func NotificationsBySubscriptionName ¶
func NotificationsBySubscriptionName(offset, limit int, subscriptionName string, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
NotificationsBySubscriptionName queries notifications by offset, limit and subscriptionName
func NotificationsByTimeRange ¶
func NotificationsByTimeRange(start int, end int, offset int, limit int, dic *di.Container) (notifications []dtos.Notification, err errors.EdgeX)
NotificationsByTimeRange query notifications with offset, limit and time range
func PatchSubscription ¶
func PatchSubscription(ctx context.Context, dto dtos.UpdateSubscription, dic *di.Container) errors.EdgeX
PatchSubscription executes the PATCH operation with the subscription DTO to replace the old data
func SubscriptionByName ¶
func SubscriptionByName(name string, dic *di.Container) (subscription dtos.Subscription, err errors.EdgeX)
SubscriptionByName queries subscription by name
func SubscriptionsByCategory ¶
func SubscriptionsByCategory(offset, limit int, category string, dic *di.Container) (subscriptions []dtos.Subscription, err errors.EdgeX)
SubscriptionsByCategory queries subscriptions with offset, limit, and category
func SubscriptionsByLabel ¶
func SubscriptionsByLabel(offset, limit int, label string, dic *di.Container) (subscriptions []dtos.Subscription, err errors.EdgeX)
SubscriptionsByLabel queries subscriptions with offset, limit, and label
func SubscriptionsByReceiver ¶
func SubscriptionsByReceiver(offset, limit int, receiver string, dic *di.Container) (subscriptions []dtos.Subscription, err errors.EdgeX)
SubscriptionsByReceiver queries subscriptions with offset, limit, and receiver
func TransmissionById ¶
func TransmissionById(id string, dic *di.Container) (trans dtos.Transmission, edgeXerr errors.EdgeX)
TransmissionById invokes the infrastructure layer function to query transmission by ID
func TransmissionsByStatus ¶
func TransmissionsByStatus(offset, limit int, status string, dic *di.Container) (transmissions []dtos.Transmission, err errors.EdgeX)
TransmissionsByStatus queries transmissions with offset, limit, and status
func TransmissionsBySubscriptionName ¶
func TransmissionsBySubscriptionName(offset, limit int, subscriptionName string, dic *di.Container) (transmissions []dtos.Transmission, err errors.EdgeX)
TransmissionsBySubscriptionName queries transmissions with offset, limit, and subscription name
Types ¶
This section is empty.
Source Files
Directories