Documentation
¶
Index ¶
- type DBClient
- func (_m *DBClient) AddNotification(n models.Notification) (models.Notification, errors.EdgeX)
- func (_m *DBClient) AddSubscription(e models.Subscription) (models.Subscription, errors.EdgeX)
- func (_m *DBClient) AddTransmission(trans models.Transmission) (models.Transmission, errors.EdgeX)
- func (_m *DBClient) AllSubscriptions(offset int, limit int) ([]models.Subscription, errors.EdgeX)
- func (_m *DBClient) AllTransmissions(offset int, limit int) ([]models.Transmission, errors.EdgeX)
- func (_m *DBClient) CleanupNotificationsByAge(age int64) errors.EdgeX
- func (_m *DBClient) CloseSession()
- func (_m *DBClient) DeleteNotificationById(id string) errors.EdgeX
- func (_m *DBClient) DeleteProcessedNotificationsByAge(age int64) errors.EdgeX
- func (_m *DBClient) DeleteProcessedTransmissionsByAge(age int64) errors.EdgeX
- func (_m *DBClient) DeleteSubscriptionByName(name string) errors.EdgeX
- func (_m *DBClient) LatestNotificationByOffset(offset uint32) (models.Notification, errors.EdgeX)
- func (_m *DBClient) NotificationById(id string) (models.Notification, errors.EdgeX)
- func (_m *DBClient) NotificationCountByCategoriesAndLabels(categories []string, labels []string) (uint32, errors.EdgeX)
- func (_m *DBClient) NotificationCountByCategory(category string) (uint32, errors.EdgeX)
- func (_m *DBClient) NotificationCountByLabel(label string) (uint32, errors.EdgeX)
- func (_m *DBClient) NotificationCountByStatus(status string) (uint32, errors.EdgeX)
- func (_m *DBClient) NotificationCountByTimeRange(start int64, end int64) (uint32, errors.EdgeX)
- func (_m *DBClient) NotificationTotalCount() (uint32, errors.EdgeX)
- func (_m *DBClient) NotificationsByCategoriesAndLabels(offset int, limit int, categories []string, labels []string) ([]models.Notification, errors.EdgeX)
- func (_m *DBClient) NotificationsByCategory(offset int, limit int, category string) ([]models.Notification, errors.EdgeX)
- func (_m *DBClient) NotificationsByLabel(offset int, limit int, label string) ([]models.Notification, errors.EdgeX)
- func (_m *DBClient) NotificationsByStatus(offset int, limit int, status string) ([]models.Notification, errors.EdgeX)
- func (_m *DBClient) NotificationsByTimeRange(start int64, end int64, offset int, limit int) ([]models.Notification, errors.EdgeX)
- func (_m *DBClient) SubscriptionById(id string) (models.Subscription, errors.EdgeX)
- func (_m *DBClient) SubscriptionByName(name string) (models.Subscription, errors.EdgeX)
- func (_m *DBClient) SubscriptionCountByCategory(category string) (uint32, errors.EdgeX)
- func (_m *DBClient) SubscriptionCountByLabel(label string) (uint32, errors.EdgeX)
- func (_m *DBClient) SubscriptionCountByReceiver(receiver string) (uint32, errors.EdgeX)
- func (_m *DBClient) SubscriptionTotalCount() (uint32, errors.EdgeX)
- func (_m *DBClient) SubscriptionsByCategoriesAndLabels(offset int, limit int, categories []string, labels []string) ([]models.Subscription, errors.EdgeX)
- func (_m *DBClient) SubscriptionsByCategory(offset int, limit int, category string) ([]models.Subscription, errors.EdgeX)
- func (_m *DBClient) SubscriptionsByLabel(offset int, limit int, label string) ([]models.Subscription, errors.EdgeX)
- func (_m *DBClient) SubscriptionsByReceiver(offset int, limit int, receiver string) ([]models.Subscription, errors.EdgeX)
- func (_m *DBClient) TransmissionById(id string) (models.Transmission, errors.EdgeX)
- func (_m *DBClient) TransmissionCountByNotificationId(id string) (uint32, errors.EdgeX)
- func (_m *DBClient) TransmissionCountByStatus(status string) (uint32, errors.EdgeX)
- func (_m *DBClient) TransmissionCountBySubscriptionName(subscriptionName string) (uint32, errors.EdgeX)
- func (_m *DBClient) TransmissionCountByTimeRange(start int64, end int64) (uint32, errors.EdgeX)
- func (_m *DBClient) TransmissionTotalCount() (uint32, errors.EdgeX)
- func (_m *DBClient) TransmissionsByNotificationId(offset int, limit int, id string) ([]models.Transmission, errors.EdgeX)
- func (_m *DBClient) TransmissionsByStatus(offset int, limit int, status string) ([]models.Transmission, errors.EdgeX)
- func (_m *DBClient) TransmissionsBySubscriptionName(offset int, limit int, subscriptionName string) ([]models.Transmission, errors.EdgeX)
- func (_m *DBClient) TransmissionsByTimeRange(start int64, end int64, offset int, limit int) ([]models.Transmission, errors.EdgeX)
- func (_m *DBClient) UpdateNotification(s models.Notification) errors.EdgeX
- func (_m *DBClient) UpdateSubscription(s models.Subscription) errors.EdgeX
- func (_m *DBClient) UpdateTransmission(trans models.Transmission) errors.EdgeX
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DBClient ¶
DBClient is an autogenerated mock type for the DBClient type
func NewDBClient ¶
NewDBClient creates a new instance of DBClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*DBClient) AddNotification ¶
func (_m *DBClient) AddNotification(n models.Notification) (models.Notification, errors.EdgeX)
AddNotification provides a mock function with given fields: n
func (*DBClient) AddSubscription ¶
func (_m *DBClient) AddSubscription(e models.Subscription) (models.Subscription, errors.EdgeX)
AddSubscription provides a mock function with given fields: e
func (*DBClient) AddTransmission ¶
func (_m *DBClient) AddTransmission(trans models.Transmission) (models.Transmission, errors.EdgeX)
AddTransmission provides a mock function with given fields: trans
func (*DBClient) AllSubscriptions ¶
AllSubscriptions provides a mock function with given fields: offset, limit
func (*DBClient) AllTransmissions ¶
AllTransmissions provides a mock function with given fields: offset, limit
func (*DBClient) CleanupNotificationsByAge ¶
CleanupNotificationsByAge provides a mock function with given fields: age
func (*DBClient) CloseSession ¶
func (_m *DBClient) CloseSession()
CloseSession provides a mock function with given fields:
func (*DBClient) DeleteNotificationById ¶
DeleteNotificationById provides a mock function with given fields: id
func (*DBClient) DeleteProcessedNotificationsByAge ¶
DeleteProcessedNotificationsByAge provides a mock function with given fields: age
func (*DBClient) DeleteProcessedTransmissionsByAge ¶
DeleteProcessedTransmissionsByAge provides a mock function with given fields: age
func (*DBClient) DeleteSubscriptionByName ¶
DeleteSubscriptionByName provides a mock function with given fields: name
func (*DBClient) LatestNotificationByOffset ¶
LatestNotificationByOffset provides a mock function with given fields: offset
func (*DBClient) NotificationById ¶
NotificationById provides a mock function with given fields: id
func (*DBClient) NotificationCountByCategoriesAndLabels ¶
func (_m *DBClient) NotificationCountByCategoriesAndLabels(categories []string, labels []string) (uint32, errors.EdgeX)
NotificationCountByCategoriesAndLabels provides a mock function with given fields: categories, labels
func (*DBClient) NotificationCountByCategory ¶
NotificationCountByCategory provides a mock function with given fields: category
func (*DBClient) NotificationCountByLabel ¶
NotificationCountByLabel provides a mock function with given fields: label
func (*DBClient) NotificationCountByStatus ¶
NotificationCountByStatus provides a mock function with given fields: status
func (*DBClient) NotificationCountByTimeRange ¶
NotificationCountByTimeRange provides a mock function with given fields: start, end
func (*DBClient) NotificationTotalCount ¶
NotificationTotalCount provides a mock function with given fields:
func (*DBClient) NotificationsByCategoriesAndLabels ¶
func (_m *DBClient) NotificationsByCategoriesAndLabels(offset int, limit int, categories []string, labels []string) ([]models.Notification, errors.EdgeX)
NotificationsByCategoriesAndLabels provides a mock function with given fields: offset, limit, categories, labels
func (*DBClient) NotificationsByCategory ¶
func (_m *DBClient) NotificationsByCategory(offset int, limit int, category string) ([]models.Notification, errors.EdgeX)
NotificationsByCategory provides a mock function with given fields: offset, limit, category
func (*DBClient) NotificationsByLabel ¶
func (_m *DBClient) NotificationsByLabel(offset int, limit int, label string) ([]models.Notification, errors.EdgeX)
NotificationsByLabel provides a mock function with given fields: offset, limit, label
func (*DBClient) NotificationsByStatus ¶
func (_m *DBClient) NotificationsByStatus(offset int, limit int, status string) ([]models.Notification, errors.EdgeX)
NotificationsByStatus provides a mock function with given fields: offset, limit, status
func (*DBClient) NotificationsByTimeRange ¶
func (_m *DBClient) NotificationsByTimeRange(start int64, end int64, offset int, limit int) ([]models.Notification, errors.EdgeX)
NotificationsByTimeRange provides a mock function with given fields: start, end, offset, limit
func (*DBClient) SubscriptionById ¶
SubscriptionById provides a mock function with given fields: id
func (*DBClient) SubscriptionByName ¶
SubscriptionByName provides a mock function with given fields: name
func (*DBClient) SubscriptionCountByCategory ¶
SubscriptionCountByCategory provides a mock function with given fields: category
func (*DBClient) SubscriptionCountByLabel ¶
SubscriptionCountByLabel provides a mock function with given fields: label
func (*DBClient) SubscriptionCountByReceiver ¶
SubscriptionCountByReceiver provides a mock function with given fields: receiver
func (*DBClient) SubscriptionTotalCount ¶
SubscriptionTotalCount provides a mock function with given fields:
func (*DBClient) SubscriptionsByCategoriesAndLabels ¶
func (_m *DBClient) SubscriptionsByCategoriesAndLabels(offset int, limit int, categories []string, labels []string) ([]models.Subscription, errors.EdgeX)
SubscriptionsByCategoriesAndLabels provides a mock function with given fields: offset, limit, categories, labels
func (*DBClient) SubscriptionsByCategory ¶
func (_m *DBClient) SubscriptionsByCategory(offset int, limit int, category string) ([]models.Subscription, errors.EdgeX)
SubscriptionsByCategory provides a mock function with given fields: offset, limit, category
func (*DBClient) SubscriptionsByLabel ¶
func (_m *DBClient) SubscriptionsByLabel(offset int, limit int, label string) ([]models.Subscription, errors.EdgeX)
SubscriptionsByLabel provides a mock function with given fields: offset, limit, label
func (*DBClient) SubscriptionsByReceiver ¶
func (_m *DBClient) SubscriptionsByReceiver(offset int, limit int, receiver string) ([]models.Subscription, errors.EdgeX)
SubscriptionsByReceiver provides a mock function with given fields: offset, limit, receiver
func (*DBClient) TransmissionById ¶
TransmissionById provides a mock function with given fields: id
func (*DBClient) TransmissionCountByNotificationId ¶
TransmissionCountByNotificationId provides a mock function with given fields: id
func (*DBClient) TransmissionCountByStatus ¶
TransmissionCountByStatus provides a mock function with given fields: status
func (*DBClient) TransmissionCountBySubscriptionName ¶
func (_m *DBClient) TransmissionCountBySubscriptionName(subscriptionName string) (uint32, errors.EdgeX)
TransmissionCountBySubscriptionName provides a mock function with given fields: subscriptionName
func (*DBClient) TransmissionCountByTimeRange ¶
TransmissionCountByTimeRange provides a mock function with given fields: start, end
func (*DBClient) TransmissionTotalCount ¶
TransmissionTotalCount provides a mock function with given fields:
func (*DBClient) TransmissionsByNotificationId ¶
func (_m *DBClient) TransmissionsByNotificationId(offset int, limit int, id string) ([]models.Transmission, errors.EdgeX)
TransmissionsByNotificationId provides a mock function with given fields: offset, limit, id
func (*DBClient) TransmissionsByStatus ¶
func (_m *DBClient) TransmissionsByStatus(offset int, limit int, status string) ([]models.Transmission, errors.EdgeX)
TransmissionsByStatus provides a mock function with given fields: offset, limit, status
func (*DBClient) TransmissionsBySubscriptionName ¶
func (_m *DBClient) TransmissionsBySubscriptionName(offset int, limit int, subscriptionName string) ([]models.Transmission, errors.EdgeX)
TransmissionsBySubscriptionName provides a mock function with given fields: offset, limit, subscriptionName
func (*DBClient) TransmissionsByTimeRange ¶
func (_m *DBClient) TransmissionsByTimeRange(start int64, end int64, offset int, limit int) ([]models.Transmission, errors.EdgeX)
TransmissionsByTimeRange provides a mock function with given fields: start, end, offset, limit
func (*DBClient) UpdateNotification ¶
func (_m *DBClient) UpdateNotification(s models.Notification) errors.EdgeX
UpdateNotification provides a mock function with given fields: s
func (*DBClient) UpdateSubscription ¶
func (_m *DBClient) UpdateSubscription(s models.Subscription) errors.EdgeX
UpdateSubscription provides a mock function with given fields: s
func (*DBClient) UpdateTransmission ¶
func (_m *DBClient) UpdateTransmission(trans models.Transmission) errors.EdgeX
UpdateTransmission provides a mock function with given fields: trans