db

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 6, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CancelJobParams 

type CancelJobParams struct {
	ID        string             `json:"id"`
	UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}

type CompleteJobLockedParams 

type CompleteJobLockedParams struct {
	ID          string             `json:"id"`
	CompletedAt pgtype.Timestamptz `json:"completed_at"`
	UpdatedAt   pgtype.Timestamptz `json:"updated_at"`
	LockedBy    pgtype.Text        `json:"locked_by"`
}

type CompleteJobParams 

type CompleteJobParams struct {
	ID          string             `json:"id"`
	CompletedAt pgtype.Timestamptz `json:"completed_at"`
	UpdatedAt   pgtype.Timestamptz `json:"updated_at"`
}

type DBTX 

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 DeleteDeadJobParams 

type DeleteDeadJobParams struct {
	ID        string             `json:"id"`
	DeletedAt pgtype.Timestamptz `json:"deleted_at"`
}

type DeleteJobParams 

type DeleteJobParams struct {
	ID        string             `json:"id"`
	DeletedAt pgtype.Timestamptz `json:"deleted_at"`
}

type InsertJobParams 

type InsertJobParams struct {
	ID           string             `json:"id"`
	JobType      pgtype.Text        `json:"job_type"`
	Priority     int64              `json:"priority"`
	CreatedAt    pgtype.Timestamptz `json:"created_at"`
	UpdatedAt    pgtype.Timestamptz `json:"updated_at"`
	DeletedAt    pgtype.Timestamptz `json:"deleted_at"`
	Payload      pgtype.Text        `json:"payload"`
	Status       pgtype.Text        `json:"status"`
	CompletedAt  pgtype.Timestamptz `json:"completed_at"`
	ScheduledAt  pgtype.Timestamptz `json:"scheduled_at"`
	MaxRetries   pgtype.Int8        `json:"max_retries"`
	RetryCount   pgtype.Int8        `json:"retry_count"`
	ErrorMessage pgtype.Text        `json:"error_message"`
	LockedAt     pgtype.Timestamptz `json:"locked_at"`
	LockedBy     pgtype.Text        `json:"locked_by"`
	Timeout      pgtype.Int8        `json:"timeout"`
}

type Job 

type Job struct {
	ID           string             `json:"id"`
	JobType      pgtype.Text        `json:"job_type"`
	Priority     int64              `json:"priority"`
	CreatedAt    pgtype.Timestamptz `json:"created_at"`
	UpdatedAt    pgtype.Timestamptz `json:"updated_at"`
	DeletedAt    pgtype.Timestamptz `json:"deleted_at"`
	Payload      pgtype.Text        `json:"payload"`
	Status       pgtype.Text        `json:"status"`
	CompletedAt  pgtype.Timestamptz `json:"completed_at"`
	ScheduledAt  pgtype.Timestamptz `json:"scheduled_at"`
	MaxRetries   pgtype.Int8        `json:"max_retries"`
	RetryCount   pgtype.Int8        `json:"retry_count"`
	ErrorMessage pgtype.Text        `json:"error_message"`
	LockedAt     pgtype.Timestamptz `json:"locked_at"`
	LockedBy     pgtype.Text        `json:"locked_by"`
	Timeout      pgtype.Int8        `json:"timeout"`
}

type JobStatusCountsRow 

type JobStatusCountsRow struct {
	Status pgtype.Text `json:"status"`
	Count  int64       `json:"count"`
}

type ListJobsByStatusParams 

type ListJobsByStatusParams struct {
	Status pgtype.Text `json:"status"`
	Limit  int32       `json:"limit"`
	Offset int32       `json:"offset"`
}

type ListJobsByStatusTypeParams 

type ListJobsByStatusTypeParams struct {
	Status  pgtype.Text `json:"status"`
	JobType pgtype.Text `json:"job_type"`
	Limit   int32       `json:"limit"`
	Offset  int32       `json:"offset"`
}

type ListJobsByTypeParams 

type ListJobsByTypeParams struct {
	JobType pgtype.Text `json:"job_type"`
	Limit   int32       `json:"limit"`
	Offset  int32       `json:"offset"`
}

type ListJobsParams 

type ListJobsParams struct {
	Limit  int32 `json:"limit"`
	Offset int32 `json:"offset"`
}

type MarkJobDeadLockedParams 

type MarkJobDeadLockedParams struct {
	ID           string             `json:"id"`
	ErrorMessage pgtype.Text        `json:"error_message"`
	UpdatedAt    pgtype.Timestamptz `json:"updated_at"`
	LockedBy     pgtype.Text        `json:"locked_by"`
}

type MarkJobDeadParams 

type MarkJobDeadParams struct {
	ID           string             `json:"id"`
	ErrorMessage pgtype.Text        `json:"error_message"`
	UpdatedAt    pgtype.Timestamptz `json:"updated_at"`
}

type MarkJobFailedLockedParams 

type MarkJobFailedLockedParams struct {
	ID           string             `json:"id"`
	RetryCount   pgtype.Int8        `json:"retry_count"`
	ScheduledAt  pgtype.Timestamptz `json:"scheduled_at"`
	ErrorMessage pgtype.Text        `json:"error_message"`
	UpdatedAt    pgtype.Timestamptz `json:"updated_at"`
	LockedBy     pgtype.Text        `json:"locked_by"`
}

type MarkJobFailedParams 

type MarkJobFailedParams struct {
	ID           string             `json:"id"`
	RetryCount   pgtype.Int8        `json:"retry_count"`
	ScheduledAt  pgtype.Timestamptz `json:"scheduled_at"`
	ErrorMessage pgtype.Text        `json:"error_message"`
	UpdatedAt    pgtype.Timestamptz `json:"updated_at"`
}

type PurgeJobsByStatusParams 

type PurgeJobsByStatusParams struct {
	Status    pgtype.Text        `json:"status"`
	DeletedAt pgtype.Timestamptz `json:"deleted_at"`
}

type Queries 

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

func New 

func New(db DBTX) *Queries

func (*Queries) CancelJob 

func (q *Queries) CancelJob(ctx context.Context, arg CancelJobParams) (int64, error)

func (*Queries) CompleteJob 

func (q *Queries) CompleteJob(ctx context.Context, arg CompleteJobParams) error

func (*Queries) CompleteJobLocked 

func (q *Queries) CompleteJobLocked(ctx context.Context, arg CompleteJobLockedParams) (int64, error)

func (*Queries) DeadJobs 

func (q *Queries) DeadJobs(ctx context.Context) ([]Job, error)

func (*Queries) DeleteAllJobs 

func (q *Queries) DeleteAllJobs(ctx context.Context) error

func (*Queries) DeleteDeadJob 

func (q *Queries) DeleteDeadJob(ctx context.Context, arg DeleteDeadJobParams) (int64, error)

func (*Queries) DeleteJob 

func (q *Queries) DeleteJob(ctx context.Context, arg DeleteJobParams) (int64, error)

func (*Queries) GetDeadJob 

func (q *Queries) GetDeadJob(ctx context.Context, id string) (Job, error)

func (*Queries) GetJob 

func (q *Queries) GetJob(ctx context.Context, id string) (Job, error)

func (*Queries) InsertJob 

func (q *Queries) InsertJob(ctx context.Context, arg InsertJobParams) (Job, error)

func (*Queries) JobStatusCounts 

func (q *Queries) JobStatusCounts(ctx context.Context) ([]JobStatusCountsRow, error)

func (*Queries) ListJobs 

func (q *Queries) ListJobs(ctx context.Context, arg ListJobsParams) ([]Job, error)

func (*Queries) ListJobsByStatus 

func (q *Queries) ListJobsByStatus(ctx context.Context, arg ListJobsByStatusParams) ([]Job, error)

func (*Queries) ListJobsByStatusType 

func (q *Queries) ListJobsByStatusType(ctx context.Context, arg ListJobsByStatusTypeParams) ([]Job, error)

func (*Queries) ListJobsByType 

func (q *Queries) ListJobsByType(ctx context.Context, arg ListJobsByTypeParams) ([]Job, error)

func (*Queries) MarkJobDead 

func (q *Queries) MarkJobDead(ctx context.Context, arg MarkJobDeadParams) error

func (*Queries) MarkJobDeadLocked 

func (q *Queries) MarkJobDeadLocked(ctx context.Context, arg MarkJobDeadLockedParams) (int64, error)

func (*Queries) MarkJobFailed 

func (q *Queries) MarkJobFailed(ctx context.Context, arg MarkJobFailedParams) error

func (*Queries) MarkJobFailedLocked 

func (q *Queries) MarkJobFailedLocked(ctx context.Context, arg MarkJobFailedLockedParams) (int64, error)

func (*Queries) PurgeJobsByStatus 

func (q *Queries) PurgeJobsByStatus(ctx context.Context, arg PurgeJobsByStatusParams) (int64, error)

func (*Queries) QueryPendingJobs 

func (q *Queries) QueryPendingJobs(ctx context.Context) ([]Job, error)

func (*Queries) ResetJob 

func (q *Queries) ResetJob(ctx context.Context, arg ResetJobParams) (Job, error)

func (*Queries) ResetStaleJob 

func (q *Queries) ResetStaleJob(ctx context.Context, arg ResetStaleJobParams) error

func (*Queries) RetryAllDeadJobs 

func (q *Queries) RetryAllDeadJobs(ctx context.Context, updatedAt pgtype.Timestamptz) (int64, error)

func (*Queries) RetryDeadJob 

func (q *Queries) RetryDeadJob(ctx context.Context, arg RetryDeadJobParams) (Job, error)

func (*Queries) ScheduledJobs 

func (q *Queries) ScheduledJobs(ctx context.Context, scheduledAt pgtype.Timestamptz) ([]Job, error)

func (*Queries) SetJobRunning 

func (q *Queries) SetJobRunning(ctx context.Context, arg SetJobRunningParams) error

func (*Queries) StaleJobs 

func (q *Queries) StaleJobs(ctx context.Context, lockedAt pgtype.Timestamptz) ([]Job, error)

func (*Queries) WithTx 

func (q *Queries) WithTx(tx pgx.Tx) *Queries

type ResetJobParams 

type ResetJobParams struct {
	ID        string             `json:"id"`
	UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}

type ResetStaleJobParams 

type ResetStaleJobParams struct {
	ID        string             `json:"id"`
	UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}

type RetryDeadJobParams 

type RetryDeadJobParams struct {
	ID        string             `json:"id"`
	UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}

type SetJobRunningParams 

type SetJobRunningParams struct {
	ID        string             `json:"id"`
	LockedAt  pgtype.Timestamptz `json:"locked_at"`
	LockedBy  pgtype.Text        `json:"locked_by"`
	UpdatedAt pgtype.Timestamptz `json:"updated_at"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.