interfaces

Documentation

Index

• type DBClient

Types

type DBClient

type DBClient interface {
	CloseSession()

	AddSubscription(e models.Subscription) (models.Subscription, errors.EdgeX)
	SubscriptionById(id string) (models.Subscription, errors.EdgeX)
	AllSubscriptions(offset int, limit int) ([]models.Subscription, errors.EdgeX)
	SubscriptionByName(name string) (models.Subscription, errors.EdgeX)
	SubscriptionsByCategory(offset, limit int, category string) ([]models.Subscription, errors.EdgeX)
	SubscriptionsByLabel(offset, limit int, label string) ([]models.Subscription, errors.EdgeX)
	SubscriptionsByReceiver(offset, limit int, receiver string) ([]models.Subscription, errors.EdgeX)
	DeleteSubscriptionByName(name string) errors.EdgeX
	UpdateSubscription(s models.Subscription) errors.EdgeX
	SubscriptionsByCategoriesAndLabels(offset, limit int, categories []string, labels []string) ([]models.Subscription, errors.EdgeX)
	SubscriptionTotalCount() (uint32, errors.EdgeX)
	SubscriptionCountByCategory(category string) (uint32, errors.EdgeX)
	SubscriptionCountByLabel(label string) (uint32, errors.EdgeX)
	SubscriptionCountByReceiver(receiver string) (uint32, errors.EdgeX)

	AddNotification(n models.Notification) (models.Notification, errors.EdgeX)
	NotificationById(id string) (models.Notification, errors.EdgeX)
	NotificationsByCategory(offset, limit int, category string) ([]models.Notification, errors.EdgeX)
	NotificationsByLabel(offset, limit int, label string) ([]models.Notification, errors.EdgeX)
	NotificationsByStatus(offset, limit int, status string) ([]models.Notification, errors.EdgeX)
	NotificationsByTimeRange(start int64, end int64, offset int, limit int) ([]models.Notification, errors.EdgeX)
	DeleteNotificationById(id string) errors.EdgeX
	NotificationsByCategoriesAndLabels(offset, limit int, categories []string, labels []string) ([]models.Notification, errors.EdgeX)
	UpdateNotification(s models.Notification) errors.EdgeX
	CleanupNotificationsByAge(age int64) errors.EdgeX
	DeleteProcessedNotificationsByAge(age int64) errors.EdgeX
	NotificationCountByCategory(category string) (uint32, errors.EdgeX)
	NotificationCountByLabel(label string) (uint32, errors.EdgeX)
	NotificationCountByStatus(status string) (uint32, errors.EdgeX)
	NotificationCountByTimeRange(start int64, end int64) (uint32, errors.EdgeX)
	NotificationCountByCategoriesAndLabels(categories []string, labels []string) (uint32, errors.EdgeX)
	NotificationTotalCount() (uint32, errors.EdgeX)
	LatestNotificationByOffset(offset uint32) (models.Notification, errors.EdgeX)

	AddTransmission(trans models.Transmission) (models.Transmission, errors.EdgeX)
	UpdateTransmission(trans models.Transmission) errors.EdgeX
	TransmissionById(id string) (models.Transmission, errors.EdgeX)
	TransmissionsByTimeRange(start int64, end int64, offset int, limit int) ([]models.Transmission, errors.EdgeX)
	AllTransmissions(offset int, limit int) ([]models.Transmission, errors.EdgeX)
	TransmissionsByStatus(offset, limit int, status string) ([]models.Transmission, errors.EdgeX)
	DeleteProcessedTransmissionsByAge(age int64) errors.EdgeX
	TransmissionsBySubscriptionName(offset, limit int, subscriptionName string) ([]models.Transmission, errors.EdgeX)
	TransmissionTotalCount() (uint32, errors.EdgeX)
	TransmissionCountBySubscriptionName(subscriptionName string) (uint32, errors.EdgeX)
	TransmissionCountByStatus(status string) (uint32, errors.EdgeX)
	TransmissionCountByTimeRange(start int64, end int64) (uint32, errors.EdgeX)
	TransmissionsByNotificationId(offset, limit int, id string) ([]models.Transmission, errors.EdgeX)
	TransmissionCountByNotificationId(id string) (uint32, errors.EdgeX)
}