Versions in this module Expand all Collapse all v0 v0.1.1 Jun 23, 2024 v0.1.0 Jun 23, 2024 v0.0.1 Jun 21, 2024 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 JobCountByQueueAndStateRow struct + AvailableJobsCount int64 + Queue string + RunningJobsCount int64 + type JobCountByStateRow struct + Count int64 + State RiverJobState + type JobListWorkflowParams struct + PaginationLimit int32 + PaginationOffset int64 + WorkflowID string + type NullRiverJobState struct + RiverJobState RiverJobState + Valid bool + func (ns *NullRiverJobState) Scan(value interface{}) error + func (ns NullRiverJobState) Value() (driver.Value, error) + type Queries struct + func New(db DBTX) *Queries + func (q *Queries) JobCountByQueueAndState(ctx context.Context, queueNames []string) ([]JobCountByQueueAndStateRow, error) + func (q *Queries) JobCountByState(ctx context.Context) ([]JobCountByStateRow, error) + func (q *Queries) JobListWorkflow(ctx context.Context, arg JobListWorkflowParams) ([]RiverJob, error) + func (q *Queries) WithTx(tx pgx.Tx) *Queries + type RiverJob struct + Args []byte + Attempt int16 + AttemptedAt pgtype.Timestamptz + AttemptedBy []string + CreatedAt pgtype.Timestamptz + Errors [][]byte + FinalizedAt pgtype.Timestamptz + ID int64 + Kind string + MaxAttempts int16 + Metadata []byte + Priority int16 + Queue string + ScheduledAt pgtype.Timestamptz + State RiverJobState + Tags []string + type RiverJobState string + const RiverJobStateAvailable + const RiverJobStateCancelled + const RiverJobStateCompleted + const RiverJobStateDiscarded + const RiverJobStatePending + const RiverJobStateRetryable + const RiverJobStateRunning + const RiverJobStateScheduled + func (e *RiverJobState) Scan(src interface{}) error + type RiverLeader struct + ElectedAt pgtype.Timestamptz + ExpiresAt pgtype.Timestamptz + LeaderID string + Name string + type RiverQueue struct + CreatedAt pgtype.Timestamptz + Metadata []byte + Name string + PausedAt pgtype.Timestamptz + UpdatedAt pgtype.Timestamptz
Go to main page