Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BackfillThreadWorker ¶ added in v0.0.10
type BackfillThreadWorker struct {
river.WorkerDefaults[background.BackfillThreadWorkerArgs]
// contains filtered or unexported fields
}
func New ¶
func New(bot *internal.Bot, slackIntegration slack_integration.Integration) *BackfillThreadWorker
func (*BackfillThreadWorker) NextRetry ¶ added in v0.0.10
func (w *BackfillThreadWorker) NextRetry(job *river.Job[background.BackfillThreadWorkerArgs]) time.Time
func (*BackfillThreadWorker) Work ¶ added in v0.0.10
func (w *BackfillThreadWorker) Work(ctx context.Context, job *river.Job[background.BackfillThreadWorkerArgs]) error
Click to show internal directories.
Click to hide internal directories.