Versions in this module Expand all Collapse all v0 v0.2.2 May 21, 2024 v0.2.1 Nov 6, 2023 v0.2.0 Apr 26, 2023 Changes in this version type UpdateStatusParams + LastError sql.NullString v0.1.3 Apr 24, 2023 v0.1.2 Apr 24, 2023 v0.1.1 Apr 24, 2023 v0.1.0 Apr 24, 2023 Changes in this version + type DBTX interface + Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error) + Query func(context.Context, string, ...interface{}) (pgx.Rows, error) + QueryRow func(context.Context, string, ...interface{}) pgx.Row + type EnqueueParams struct + JobType string + Metadata []byte + Payload []byte + Priority int16 + Queue string + RunAt time.Time + type GetTasksByStatusAndQueueNameParams struct + Column2 []string + Limit int32 + Offset int32 + Queue string + type GetTotalInfoByNameHistoryRow struct + Cnt int64 + Date time.Time + ErrCount int64 + Queue string + Status JobStatus + type GetTotalInfoByNameRow struct + Cnt int64 + ErrCount int64 + Queue string + Status JobStatus + type GetTotalInfoHistoryRow struct + Cnt int64 + Date time.Time + ErrCount int64 + Queue string + Status JobStatus + type GetTotalInfoRow struct + Cnt int64 + Queue string + Status JobStatus + type GetTotalInfoWithErrorsRow struct + Cnt int64 + Queue string + type Job struct + CreatedAt time.Time + ErrorCount int32 + ID int64 + JobType string + LastError sql.NullString + Metadata []byte + Payload []byte + Priority int16 + Queue string + RunAt time.Time + Status JobStatus + UpdatedAt time.Time + type JobStatus string + const JobStatusFailed + const JobStatusFinished + const JobStatusPending + const JobStatusProcessing + func (e *JobStatus) Scan(src interface{}) error + type NullJobStatus struct + JobStatus JobStatus + Valid bool + func (ns *NullJobStatus) Scan(value interface{}) error + func (ns NullJobStatus) Value() (driver.Value, error) + type Queries struct + func New(db DBTX) *Queries + func (q *Queries) Enqueue(ctx context.Context, arg EnqueueParams) error + func (q *Queries) GetJob(ctx context.Context, id int64) (Job, error) + func (q *Queries) GetTasksByStatusAndQueueName(ctx context.Context, arg GetTasksByStatusAndQueueNameParams) ([]Job, error) + func (q *Queries) GetTotalInfo(ctx context.Context) ([]GetTotalInfoRow, error) + func (q *Queries) GetTotalInfoByName(ctx context.Context, queue string) ([]GetTotalInfoByNameRow, error) + func (q *Queries) GetTotalInfoByNameHistory(ctx context.Context, queue string) ([]GetTotalInfoByNameHistoryRow, error) + func (q *Queries) GetTotalInfoHistory(ctx context.Context) ([]GetTotalInfoHistoryRow, error) + func (q *Queries) GetTotalInfoWithErrors(ctx context.Context) ([]GetTotalInfoWithErrorsRow, error) + func (q *Queries) JobToProcessing(ctx context.Context, dollar_1 []int64) error + func (q *Queries) Pool() *pgxpool.Pool + func (q *Queries) UpdateStatus(ctx context.Context, arg UpdateStatusParams) error + func (q *Queries) UpdateStatusError(ctx context.Context, arg UpdateStatusErrorParams) error + func (q *Queries) WithTx(tx pgx.Tx) *Queries + type UpdateStatusErrorParams struct + ErrorCount int32 + ID int64 + LastError sql.NullString + RunAt time.Time + type UpdateStatusParams struct + ID int64 + Status JobStatus