- func ProcessReminderPostTxn(ctx context.Context, s Submitter, db db.DB, r *reminder.Reminder) error
- func Submit(ctx context.Context, s Submitter, payload *reminder.Payload, path TxnPath) error
- func SubmitBatch(ctx context.Context, sub Submitter, db db.DB, batch *reminder.Reminder) (int, error)
- func SubmitFromReminder(ctx context.Context, s Submitter, db db.DB, r *reminder.Reminder, t TxnPath) error
- type Submitter
- type TxnPath
ErrStaleReminder is returned by ProcessReminderPostTxn.
func ProcessReminderPostTxn ¶
ProcessReminderPostTxn is called right after the transaction that saves the reminder.
If the reminder is fresh enough, it means the sweeper hasn't picked it up yet and we can submit the task right now. This is the "happy" path. If the reminder is sufficiently old, or if SubmitFromReminder fails, we'll let the sweeper try to submit the task. It is the "sweep" path.
Returns ErrStaleReminder if the reminder is stale and should be handled by the sweeper.
Submit submits the prepared request through the given submitter.
Recognizes AlreadyExists as success. Annotates retriable errors with transient.Tag.
func SubmitBatch ¶
SubmitBatch process a batch of reminders by submitting corresponding tasks and deleting reminders.
Reminders batch will be modified to fetch Reminders' payloads. RAM usage is equivalent to O(total payload size of each Reminder in batch).
Logs errors inside. Returns the total number of successfully processed reminders.
Submitter is used by the dispatcher and the sweeper to submit tasks.
type TxnPath string
TxnPath indicates a code path a task can take.
Package db defines common database interface.
|Package db defines common database interface.|
Package lessor defines common lessor interface.
|Package lessor defines common lessor interface.|
Package partition encapsulates partitioning and querying large keyspace which can't be expressed even as uint64.
|Package partition encapsulates partitioning and querying large keyspace which can't be expressed even as uint64.|
Package reminder holds Reminder to avoid circular dependencies.
|Package reminder holds Reminder to avoid circular dependencies.|
Package testutil provides fakes for testing TQ guts.
|Package testutil provides fakes for testing TQ guts.|
Package workset contains a synchronized work queue implementation used by inproc sweeper.
|Package workset contains a synchronized work queue implementation used by inproc sweeper.|