Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrLimitReached = stderrors.New("limit reached")
ErrLimitReached is returned when the cleanup limit is reached during find operation
Functions ¶
This section is empty.
Types ¶
type NotificationCleaner ¶
type NotificationCleaner interface {
Clean(ctx context.Context, tx libkv.Tx, maxAge libtime.Duration, limit int) error
}
func NewNotificationCleaner ¶
func NewNotificationCleaner( currentDateTime libtime.CurrentDateTime, notificationIndexer index.NotificationIndexer, notificationStoreTx core.NotificationStoreTx, logSamplerFactory log.SamplerFactory, ) NotificationCleaner
type NotificationLoader ¶
type NotificationLoader interface {
GetAll(
ctx context.Context,
tx libkv.Tx,
baseIdentifiers base.Identifiers,
) ([]core.Notification, error)
}
func NewNotificationLoader ¶
func NewNotificationLoader( notificationGetterTx core.NotificationGetterTx, logSamplerFactory log.SamplerFactory, ) NotificationLoader
Click to show internal directories.
Click to hide internal directories.