completer

type BatchCompleter struct {
	// contains filtered or unexported fields
}

type Completer interface {
	Start(ctx context.Context) error
	Stop()
	Complete(taskID int64) error
	Fail(taskID int64, message string) error
	Retry(taskID int64, blockedTill time.Time, message string) error
	Snooze(taskID int64, blockedTill time.Time) error
}

type Config struct {
	FlushInterval  time.Duration
	FlushThreshold int
	MaxBatchSize   int
	MaxBacklog     int
	Logger         *slog.Logger
}

type FailRequest struct {
	Message string
}

type RetryRequest struct {
	BlockedTill time.Time
	Message     string
}

type SnoozeRequest struct {
	BlockedTill time.Time
}