Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

queue

package

Go to main page

Versions in this module

v0

v0.18.2

Sep 27, 2023

v0.18.1

Aug 22, 2022

v0.18.0

Aug 21, 2022

v0.17.1

Aug 10, 2022

v0.17.0

Aug 2, 2022

v0.16.1

Jul 21, 2022

v0.16.0

Jun 29, 2022

v0.15.1

May 8, 2022

v0.15.0

Mar 24, 2022

Changes in this version

+ var MigrationsFS embed.FS

+ func ConnectDB(config *DBConfig) (*sql.DB, error)

+ type CreateTaskParams struct

+ SDHash string

+ ULID string

+ URL string

+ Worker string

+ type DBConfig struct

+ func DefaultDBConfig() *DBConfig

+ func (c *DBConfig) ConnOpts(connOpts string) *DBConfig

+ func (c *DBConfig) DSN(dsn string) *DBConfig

+ func (c *DBConfig) GetFullDSN() string

+ func (c *DBConfig) Name(dbName string) *DBConfig

+ func (c *DBConfig) NoMigration() *DBConfig

+ type DBTX interface

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ type GetRunnableTaskByPayloadParams struct

+ SDHash string

+ URL string

+ type MarkDoneParams struct

+ Result sql.NullString

+ ULID string

+ type MarkFailedParams struct

+ Error sql.NullString

+ ULID string

+ type Migrator struct

+ func NewMigrator(db *sql.DB, fs embed.FS) Migrator

+ func (m Migrator) CreateDB(dbName string) error

+ func (m Migrator) DropDB(dbName string) error

+ func (m Migrator) MigrateDown(max int) (int, error)

+ func (m Migrator) MigrateUp() (int, error)

+ func (m Migrator) Truncate(tables []string) error

+ type MigratorCLI struct

+ MigrateDown struct{ ... }

+ MigrateUp struct{}

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) CreateTask(ctx context.Context, arg CreateTaskParams) (Task, error)

+ func (q *Queries) GetActiveTasks(ctx context.Context) ([]Task, error)

+ func (q *Queries) GetActiveTasksForWorker(ctx context.Context, worker string) ([]Task, error)

+ func (q *Queries) GetAllTasks(ctx context.Context) ([]Task, error)

+ func (q *Queries) GetRetriableTasks(ctx context.Context) ([]Task, error)

+ func (q *Queries) GetRunnableTaskByPayload(ctx context.Context, arg GetRunnableTaskByPayloadParams) (Task, error)

+ func (q *Queries) GetTask(ctx context.Context, ulid string) (Task, error)

+ func (q *Queries) GetTaskBySDHash(ctx context.Context, sdHash string) (Task, error)

+ func (q *Queries) MarkDone(ctx context.Context, arg MarkDoneParams) (Task, error)

+ func (q *Queries) MarkFailed(ctx context.Context, arg MarkFailedParams) (Task, error)

+ func (q *Queries) MarkRetrying(ctx context.Context, ulid string) (Task, error)

+ func (q *Queries) SetError(ctx context.Context, arg SetErrorParams) (Task, error)

+ func (q *Queries) SetStageProgress(ctx context.Context, arg SetStageProgressParams) (Task, error)

+ func (q *Queries) SetStatus(ctx context.Context, arg SetStatusParams) (Task, error)

+ func (q *Queries) WithTx(tx *sql.Tx) *Queries

+ type SetErrorParams struct

+ Error sql.NullString

+ ULID string

+ type SetStageProgressParams struct

+ Stage sql.NullString

+ StageProgress sql.NullInt32

+ ULID string

+ type SetStatusParams struct

+ Status Status

+ ULID string

+ type Status string

+ const StatusDone

+ const StatusErrored

+ const StatusFailed

+ const StatusNew

+ const StatusProcessing

+ const StatusRetrying

+ func (e *Status) Scan(src interface{}) error

+ type Task struct

+ CreatedAt time.Time

+ Error sql.NullString

+ ID int32

+ Result sql.NullString

+ Retries sql.NullInt32

+ SDHash string

+ Stage sql.NullString

+ StageProgress sql.NullInt32

+ Status Status

+ ULID string

+ URL string

+ UpdatedAt sql.NullTime

+ Worker string

+ type TestDBCleanup func() error

+ func CreateTestDB() (*sql.DB, TestDBCleanup, error)