internal

type ConsumeParams struct {
	Queue             string
	PoolSize          int
	Worker            func(context.Context, *Job) error
	VisibilityTimeout int64
	OnEmptySleep      time.Duration
}

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type DedupingKey interface {
	String() string
	ReplaceDuplicate() bool
}

type ErrorList []string

type FailJobParams struct {
	Errors ErrorList
	ID     int64
}

type GrabJobsParams struct {
	Queue        string
	ExecuteAfter int64
	Count        int64
}

type IgnoreDuplicate string

type Job struct {
	ID                int64
	Queue             string
	Job               string
	JobStatus         string
	ExecuteAfter      int64
	RemainingAttempts int64
	ConsumerFetchedAt int64
	FinishedAt        int64
	DedupingKey       string
	Errors            ErrorList
	CreatedAt         int64
	UpdatedAt         int64
}

type MarkJobsForConsumerParams struct {
	Queue        string
	ExecuteAfter int64
	Limit        int64
}

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

type QueueJobParams struct {
	Queue             string
	Job               string
	ExecuteAfter      int64
	RemainingAttempts int64
	DedupingKey       DedupingKey
}

type ReplaceDuplicate string

type ResetJobsParams struct {
	Queue             string
	ConsumerFetchedAt int64
}