pgsql

package

Go to main page

Versions in this module

v0

v0.12.0

Nov 4, 2026

Changes in this version

type Executor

+ func (e *Executor) LeaderRequestResign(ctx context.Context, leaderID int64) (int64, error)

v0.11.0

Nov 2, 2026

v0.10.2

Oct 31, 2026

v0.10.1

Oct 29, 2026

v0.10.0

Oct 29, 2026

v0.9.0

Oct 28, 2026

Changes in this version

type Executor

+ func (e *Executor) JobClaimByID(ctx context.Context, params driver.JobClaimByIDParams) (*driver.JobLeaseRow, error)

+ func (e *Executor) JobExpireLeases(ctx context.Context, params driver.JobExpireLeasesParams) ([]*driver.JobRow, error)

+ func (e *Executor) JobLeaseRenew(ctx context.Context, params driver.JobLeaseRenewParams) (*driver.JobLeaseStatus, error)

+ func (e *Executor) PeriodicRegister(ctx context.Context, params driver.PeriodicRegisterParams) error

+ func (e *Executor) PeriodicRegistrations(ctx context.Context) ([]driver.PeriodicRegistrationRow, error)

v0.8.0

Oct 26, 2026

Changes in this version

+ const HistoryIndexCancelKey

+ func TagsJSON(tags []string) []byte

type Executor

+ func (e *Executor) JobDelete(ctx context.Context, id driver.JobID) (*driver.JobRow, error)

+ func (e *Executor) JobLogs(ctx context.Context, id driver.JobID) ([]driver.AttemptLog, error)

+ func (e *Executor) JobRecordProgress(ctx context.Context, params driver.JobRecordProgressParams) (*driver.Progress, error)

v0.7.0

Oct 14, 2026

Changes in this version

+ const HistoryIndexLockKey

type Executor

+ func (e *Executor) BatchSettle(ctx context.Context, params driver.BatchSettleParams) (driver.BatchSettleResult, error)

+ func (e *Executor) HistoryIndex(ctx context.Context, params driver.HistoryIndexParams) (driver.HistoryIndexResult, error)

+ func (e *Executor) JobRetryOrderingKey(ctx context.Context, params driver.JobRetryOrderingKeyParams) (int, error)

+ func (e *Executor) WorkflowPromoteReady(ctx context.Context, params driver.WorkflowPromoteParams) (driver.WorkflowPromoteResult, error)

v0.6.0

Oct 13, 2026

Changes in this version

type Executor

+ func (e *Executor) SchemaVersion(ctx context.Context) (int, error)

v0.5.0

Oct 3, 2026

v0.4.0

Oct 2, 2026

v0.3.1

Oct 2, 2026

v0.3.0

Oct 1, 2026

Changes in this version

type Executor

+ Schema *Schema

+ type Schema struct

+ Name string

+ func NewSchema(name string) *Schema

+ func (s *Schema) SQL(query string) string

+ func (s *Schema) Table(name string) string

+ func (s *Schema) Wrap(c Conn) Conn

v0.2.0

Oct 1, 2026

v0.1.2

Oct 1, 2026

v0.1.1

Sep 29, 2026

Changes in this version

+ const ClaimMax

v0.1.0

Sep 29, 2026

Changes in this version

+ const HistoryLockKey

+ const MigrationLockKey

+ const NotifySQL

+ var ErrNoRows = errors.New("pgsql: no rows")

+ func ArrayLiteral(v any) (literal string, ok bool)

+ func JobColumns(prefix string) string

+ func MigrationApply(ctx context.Context, conn Conn, version int, script string, up bool) (err error)

+ func MigrationVersions(ctx context.Context, conn Conn) ([]int, error)

+ type Conn interface

+ Begin func(ctx context.Context) (Tx, error)

+ Exec func(ctx context.Context, sql string, args ...any) (int64, error)

+ Query func(ctx context.Context, sql string, args ...any) (Rows, error)

+ QueryExec func(ctx context.Context, query string, queryArgs []any, exec string, ...) (Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...any) Row

+ type Executor struct

+ Conn Conn

+ InTx bool

+ func (e *Executor) AnalyzeForTest(ctx context.Context) error

+ func (e *Executor) BatchGet(ctx context.Context, id driver.JobID) (*driver.BatchRow, error)

+ func (e *Executor) BatchInsert(ctx context.Context, params driver.BatchInsertParams) (driver.JobID, error)

+ func (e *Executor) ClientDelete(ctx context.Context, clientID int64) error

+ func (e *Executor) ClientList(ctx context.Context) ([]*driver.ClientRow, error)

+ func (e *Executor) ClientPruneExpired(ctx context.Context) (int64, error)

+ func (e *Executor) ClientRegister(ctx context.Context, params driver.ClientRegisterParams) (int64, error)

+ func (e *Executor) ClientRenew(ctx context.Context, params driver.ClientRenewParams) (driver.ClientRenewResult, error)

+ func (e *Executor) HistoryMaintain(ctx context.Context, params driver.HistoryMaintainParams) (driver.HistoryMaintainResult, error)

+ func (e *Executor) JobAge(ctx context.Context, queue string, after time.Duration) (int64, error)

+ func (e *Executor) JobCancel(ctx context.Context, id driver.JobID) (*driver.JobRow, error)

+ func (e *Executor) JobClaim(ctx context.Context, params driver.JobClaimParams) (driver.JobClaimResult, error)

+ func (e *Executor) JobDiscardExpired(ctx context.Context, limit int) ([]*driver.JobRow, error)

+ func (e *Executor) JobFinalizeMany(ctx context.Context, params driver.JobFinalizeParams) ([]driver.JobID, error)

+ func (e *Executor) JobGet(ctx context.Context, id driver.JobID) (*driver.JobRow, error)

+ func (e *Executor) JobInsertCopy(context.Context, []driver.JobInsertParams, driver.JobInsertOpts) ([]driver.JobInsertResult, error)

+ func (e *Executor) JobInsertMany(ctx context.Context, params []driver.JobInsertParams, ...) ([]driver.JobInsertResult, error)

+ func (e *Executor) JobList(ctx context.Context, params driver.JobListParams) ([]*driver.JobRow, error)

+ func (e *Executor) JobRescueCandidates(ctx context.Context, params driver.JobRescueParams) ([]*driver.JobRow, error)

+ func (e *Executor) JobRetry(ctx context.Context, id driver.JobID) (*driver.JobRow, error)

+ func (e *Executor) JobsMaintain(ctx context.Context) (driver.JobsMaintainResult, error)

+ func (e *Executor) LeaderAttempt(ctx context.Context, params driver.LeaderParams) (bool, error)

+ func (e *Executor) LeaderResign(ctx context.Context, clientID int64) error

+ func (e *Executor) MessagePublish(ctx context.Context, p driver.MessagePublishParams) ([]driver.JobInsertResult, error)

+ func (e *Executor) Notify(ctx context.Context, channel string, payloads []string) error

+ func (e *Executor) Now(ctx context.Context) (time.Time, error)

+ func (e *Executor) PeriodicInsert(ctx context.Context, params driver.PeriodicInsertParams) (*driver.JobRow, bool, error)

+ func (e *Executor) PeriodicLastSlots(ctx context.Context) (map[string]time.Time, error)

+ func (e *Executor) QueueEnsure(ctx context.Context, names []string) error

+ func (e *Executor) QueueList(ctx context.Context) ([]*driver.QueueRow, error)

+ func (e *Executor) QueuePause(ctx context.Context, name string) error

+ func (e *Executor) QueueResume(ctx context.Context, name string) error

+ func (e *Executor) QueueSetLimits(ctx context.Context, l driver.QueueLimits) error

+ func (e *Executor) Stats(ctx context.Context) (*driver.Stats, error)

+ func (e *Executor) StreamAppend(ctx context.Context, params driver.StreamAppendParams) (*driver.StreamEvent, error)

+ func (e *Executor) StreamConsumerList(ctx context.Context) ([]*driver.StreamConsumerRow, error)

+ func (e *Executor) StreamConsumerSeek(ctx context.Context, name string, params driver.StreamSeekParams) error

+ func (e *Executor) StreamConsumerUpsert(ctx context.Context, consumers []driver.StreamConsumerRow) error

+ func (e *Executor) StreamPump(ctx context.Context, name string, limit int) (driver.StreamPumpResult, error)

+ func (e *Executor) StreamRead(ctx context.Context, params driver.StreamReadParams) ([]*driver.StreamEvent, error)

+ func (e *Executor) SubscriptionList(ctx context.Context) ([]*driver.SubscriptionRow, error)

+ func (e *Executor) SubscriptionUpsert(ctx context.Context, subs []driver.SubscriptionRow) error

+ func (e *Executor) WorkflowGet(ctx context.Context, id driver.JobID) (*driver.WorkflowRow, error)

+ func (e *Executor) WorkflowInsert(ctx context.Context, params driver.WorkflowInsertParams) (*driver.WorkflowInsertResult, error)

+ type Row interface

+ Scan func(dest ...any) error

+ type Rows interface

+ Close func()

+ Err func() error

+ Next func() bool

+ Scan func(dest ...any) error

+ type Tx interface

+ Commit func(ctx context.Context) error

+ Rollback func(ctx context.Context) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL