Versions in this module Expand all Collapse all v0 v0.2.3 Sep 17, 2024 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
Go to main page