Method NotificationDeleteBefore

riverdriver/river_driver_interface.go:273–273

NotificationDeleteBefore deletes notifications before a certain time horizon. A "notification" in this context refers to a row in `river_notification` which is a special table implemented in some databases (e.g. SQLite) that simulates Postgres' listen/notify when not available.

(ctx context.Context, params *NotificationDeleteBeforeParams)

	// which is a special table implemented in some databases (e.g. SQLite) that
	// simulates Postgres' listen/notify when not available.
	NotificationDeleteBefore(ctx context.Context, params *NotificationDeleteBeforeParams) (int, error)

	NotifyMany(ctx context.Context, params *NotifyManyParams) error
	PGAdvisoryXactLock(ctx context.Context, key int64) (*struct{}, error)