queue

type JobStatus struct {
	JobID  int64
	Status rivertype.JobState
}

type Options struct {
	ScheduledAt time.Time
	MaxAttempts int
	Metadata    []byte
	Pending     bool
	Priority    int
	Queue       string
	Tags        []string
	UniqueOpts  river.UniqueOpts
}

type Repository[T river.JobArgs] struct {
	// contains filtered or unexported fields
}

type Worker[T river.JobArgs] interface {
	Put(ctx context.Context, args T) (int64, error)
	PutBatch(ctx context.Context, args ...T) ([]int64, error)
	PutWithOpts(ctx context.Context, options Options, args T) (int64, error)
	PutBatchWithOpts(ctx context.Context, options Options, args ...T) ([]int64, error)
	JobStatuses(ctx context.Context, ids ...int64) ([]JobStatus, error)
	FetchJobs(ctx context.Context, ids ...int64) ([]*rivertype.JobRow, error)
	FetchJob(ctx context.Context, id int64) (*rivertype.JobRow, error)
}