factory

func CreateCleanHandler(
	ctx context.Context,
	db libkv.DB,
	bleveIndex bleve.Index,
	currentDateTime libtime.CurrentDateTime,
	defaultMaxAge libtime.Duration,
	defaultCleanLimit int,
) http.Handler

func CreateCleanerCron(
	sentryClient libsentry.Client,
	db libkv.DB,
	bleveIndex bleve.Index,
	currentDateTime libtime.CurrentDateTime,
	maxAge libtime.Duration,
	cleanLimit int,
	cronExpression libcron.Expression,
) run.Func

func CreateGetNotificationHandler(db libkv.DB) http.Handler

func CreateListNotificationsHandler(bleveIndex bleve.Index, db libkv.DB) http.Handler

func CreateNotificationConsumer(
	saramaClientProvider libkafka.SaramaClientProvider,
	bleveIndex bleve.Index,
	db libkv.DB,
	branch base.Branch,
	batchSize libkafka.BatchSize,
) run.Func

func CreateStatusHandler(bleveIndex bleve.Index, db libkv.DB) http.Handler

func NewNotificationCleaner(
	bleveIndex bleve.Index,
	currentDateTime libtime.CurrentDateTime,
) pkg.NotificationCleaner