database

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type GoqueueJob struct {
	JobID        int32              `json:"job_id"`
	QueueName    string             `json:"queue_name"`
	CreatedAt    pgtype.Timestamp   `json:"created_at"`
	StartedAt    pgtype.Timestamp   `json:"started_at"`
	FinishedAt   pgtype.Timestamp   `json:"finished_at"`
	ScheduledAt  pgtype.Timestamp   `json:"scheduled_at"`
	MaxRetries   int32              `json:"max_retries"`
	RetryAttempt int32              `json:"retry_attempt"`
	RetryPolicy  GoqueueRetryPolicy `json:"retry_policy"`
	Status       GoqueueJobStatus   `json:"status"`
	Error        pgtype.Text        `json:"error"`
	Arguments    []byte             `json:"arguments"`
}

type GoqueueJobStatus string

type GoqueueQueue struct {
	QueueName string           `json:"queue_name"`
	IsFifo    bool             `json:"is_fifo"`
	CreatedAt pgtype.Timestamp `json:"created_at"`
}

type GoqueueRetryPolicy string

type InsertJobParams struct {
	QueueName   string             `json:"queue_name"`
	ScheduledAt pgtype.Timestamp   `json:"scheduled_at"`
	Arguments   []byte             `json:"arguments"`
	MaxRetries  int32              `json:"max_retries"`
	RetryPolicy GoqueueRetryPolicy `json:"retry_policy"`
}

type InsertQueueParams struct {
	QueueName string `json:"queue_name"`
	IsFifo    bool   `json:"is_fifo"`
}

type NullGoqueueJobStatus struct {
	GoqueueJobStatus GoqueueJobStatus `json:"goqueue_job_status"`
	Valid            bool             `json:"valid"` // Valid is true if GoqueueJobStatus is not NULL
}

type NullGoqueueRetryPolicy struct {
	GoqueueRetryPolicy GoqueueRetryPolicy `json:"goqueue_retry_policy"`
	Valid              bool               `json:"valid"` // Valid is true if GoqueueRetryPolicy is not NULL
}

type Querier interface {
	FetchJob(ctx context.Context, queueName string) (GoqueueJob, error)
	FetchJobLocked(ctx context.Context, queueName string) (GoqueueJob, error)
	GetQueue(ctx context.Context, queueName string) (GoqueueQueue, error)
	InsertJob(ctx context.Context, arg InsertJobParams) (GoqueueJob, error)
	InsertQueue(ctx context.Context, arg InsertQueueParams) (GoqueueQueue, error)
	LockQueue(ctx context.Context, hashtext string) (bool, error)
	RescheduleJob(ctx context.Context, arg RescheduleJobParams) (GoqueueJob, error)
	UpdateJob(ctx context.Context, arg UpdateJobParams) (GoqueueJob, error)
	UpdateJobFailed(ctx context.Context, arg UpdateJobFailedParams) (GoqueueJob, error)
	UpdateJobFinished(ctx context.Context, jobID int32) (GoqueueJob, error)
	UpdateJobStatus(ctx context.Context, arg UpdateJobStatusParams) (GoqueueJob, error)
}

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

type RescheduleJobParams struct {
	ScheduledAt pgtype.Timestamp `json:"scheduled_at"`
	JobID       int32            `json:"job_id"`
}

type UpdateJobFailedParams struct {
	Error pgtype.Text `json:"error"`
	JobID int32       `json:"job_id"`
}

type UpdateJobParams struct {
	CreatedAt  pgtype.Timestamp `json:"created_at"`
	FinishedAt pgtype.Timestamp `json:"finished_at"`
	Status     GoqueueJobStatus `json:"status"`
	Error      pgtype.Text      `json:"error"`
	Arguments  []byte           `json:"arguments"`
	JobID      int32            `json:"job_id"`
}

type UpdateJobStatusParams struct {
	Status GoqueueJobStatus `json:"status"`
	JobID  int32            `json:"job_id"`
}