package postgresql
import "git.sr.ht/~pingoo/stdx/queue/postgresql"
Index ¶
- Variables
- type PostgreSQLQueue
- func NewPostgreSQLQueue(db db.DB, logger *slog.Logger) *PostgreSQLQueue
- func (pgqueue *PostgreSQLQueue) Clear(ctx context.Context) error
- func (pgqueue *PostgreSQLQueue) DeleteJob(ctx context.Context, jobID guid.GUID) error
- func (pgqueue *PostgreSQLQueue) FailJob(ctx context.Context, job queue.Job) error
- func (pgqueue *PostgreSQLQueue) Pull(ctx context.Context, numberOfJobs int64) ([]queue.Job, error)
- func (pgqueue *PostgreSQLQueue) Push(ctx context.Context, tx db.Queryer, newJob queue.NewJobInput) (err error)
- func (pgqueue *PostgreSQLQueue) Stop(ctx context.Context)
Variables ¶
var ( ErrJobTypeIsNotValid = errors.New("queue.postgresql: job type is not valid") ErrJobDataIsNotValid = errors.New("queue.postgresql: job data is not valid") ErrJobRetryMaxIsNotValid = errors.New("queue.postgresql: retry_max is not valid") ErrJobRetryDelayIsNotValid = errors.New("queue.postgresql: retry_delay is not valid") ErrJobRetryStrategyIsNotValid = errors.New("queue.postgresql: retry_strategy is not valid") ErrJobTimeoutIsNotValid = errors.New("queue.postgresql: timeout is not valid") )
Types ¶
type PostgreSQLQueue ¶
type PostgreSQLQueue struct {
// contains filtered or unexported fields
}
func NewPostgreSQLQueue ¶
func NewPostgreSQLQueue(db db.DB, logger *slog.Logger) *PostgreSQLQueue
func (*PostgreSQLQueue) Clear ¶
func (pgqueue *PostgreSQLQueue) Clear(ctx context.Context) error
func (*PostgreSQLQueue) DeleteJob ¶
func (*PostgreSQLQueue) FailJob ¶
func (*PostgreSQLQueue) Pull ¶
pull fetches at most `number_of_jobs` from the queue.
func (*PostgreSQLQueue) Push ¶
func (pgqueue *PostgreSQLQueue) Push(ctx context.Context, tx db.Queryer, newJob queue.NewJobInput) (err error)
func (*PostgreSQLQueue) Stop ¶
func (pgqueue *PostgreSQLQueue) Stop(ctx context.Context)
Source Files ¶
postgresql.go
- Version
- v0.0.0-20240218134121-094174641f6e (latest)
- Published
- Feb 18, 2024
- Platform
- linux/amd64
- Imports
- 11 packages
- Last checked
- 4 months ago –
Tools for package owners.