dbsqlc

package

Go to main page

Versions in this module

v0

v0.0.22

Feb 19, 2024

v0.0.21

Feb 19, 2024

v0.0.20

Feb 15, 2024

v0.0.19

Feb 11, 2024

Changes in this version

type Queries

+ func (q *Queries) JobRetryImmediately(ctx context.Context, db DBTX, id int64) (*RiverJob, error)

v0.0.18

Jan 26, 2024

v0.0.17

Jan 23, 2024

Changes in this version

+ func JobRowsFromInternal(internal []*RiverJob) []*rivertype.JobRow

+ type JobCancelParams struct

+ CancelAttemptedAt []byte

+ ID int64

+ JobControlTopic string

type JobUpdateParams

+ FinalizedAt *time.Time

+ FinalizedAtDoUpdate bool

type Queries

+ func (q *Queries) JobCancel(ctx context.Context, db DBTX, arg JobCancelParams) (*RiverJob, error)

v0.0.16

Jan 6, 2024

Changes in this version

type JobScheduleParams

+ InsertTopic string

type LeadershipResignParams

+ LeadershipTopic string

v0.0.15

Dec 22, 2023

Changes in this version

type JobInsertManyParams

+ ScheduledAt time.Time

v0.0.14

Dec 13, 2023

v0.0.13

Dec 13, 2023

Changes in this version

+ type JobSetStateIfRunningParams struct

+ Error []byte

+ ErrorDoUpdate bool

+ FinalizedAt *time.Time

+ FinalizedAtDoUpdate bool

+ ID int64

+ MaxAttempts int16

+ MaxAttemptsUpdate bool

+ ScheduledAt time.Time

+ ScheduledAtDoUpdate bool

+ State JobState

+ type JobSetStateParams struct

+ Error []byte

+ ErrorDoUpdate bool

+ FinalizedAt *time.Time

+ FinalizedAtDoUpdate bool

+ ID int64

+ MaxAttempts int16

+ MaxAttemptsUpdate bool

+ ScheduledAt time.Time

+ ScheduledAtDoUpdate bool

+ State JobState

type Queries

+ func (q *Queries) JobSetState(ctx context.Context, db DBTX, arg JobSetStateParams) (*RiverJob, error)

+ func (q *Queries) JobSetStateIfRunning(ctx context.Context, db DBTX, arg JobSetStateIfRunningParams) (*RiverJob, error)

v0.0.12

Dec 3, 2023

v0.0.11

Dec 2, 2023

v0.0.10

Nov 26, 2023

v0.0.9

Nov 23, 2023

v0.0.8

Nov 22, 2023

v0.0.7

Nov 20, 2023

Changes in this version

type AttemptError

+ Attempt uint16

v0.0.6

Nov 20, 2023

Changes in this version

+ func AttemptErrorFromInternal(e *AttemptError) rivertype.AttemptError

+ func JobRowFromInternal(internal *RiverJob) *rivertype.JobRow

v0.0.5

Nov 19, 2023

v0.0.4

Nov 18, 2023

Changes in this version

+ type JobRescueManyParams struct

+ Error [][]byte

+ FinalizedAt []time.Time

+ ID []int64

+ ScheduledAt []time.Time

+ State []string

type Queries

+ func (q *Queries) JobRescueMany(ctx context.Context, db DBTX, arg JobRescueManyParams) error

v0.0.3

Nov 14, 2023

v0.0.2

Nov 13, 2023

v0.0.1

Nov 13, 2023

Changes in this version

+ type AttemptError struct

+ At time.Time

+ Error string

+ Num uint16

+ Trace string

+ type DBTX interface

+ CopyFrom func(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)

+ 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 JobCompleteManyParams struct

+ FinalizedAt []time.Time

+ ID []int64

+ type JobDeleteBeforeParams struct

+ CancelledFinalizedAtHorizon time.Time

+ CompletedFinalizedAtHorizon time.Time

+ DiscardedFinalizedAtHorizon time.Time

+ Max int64

+ type JobGetAvailableParams struct

+ LimitCount int32

+ Queue string

+ Worker string

+ type JobGetByKindAndUniquePropertiesParams struct

+ Args []byte

+ ByArgs bool

+ ByCreatedAt bool

+ ByQueue bool

+ ByState bool

+ CreatedAtEnd time.Time

+ CreatedAtStart time.Time

+ Kind string

+ Queue string

+ State []string

+ type JobGetStuckParams struct

+ LimitCount int32

+ StuckHorizon time.Time

+ type JobInsertManyParams struct

+ Args []byte

+ Errors []AttemptError

+ Kind string

+ MaxAttempts int16

+ Metadata []byte

+ Priority int16

+ Queue string

+ State JobState

+ Tags []string

+ type JobInsertParams struct

+ Args []byte

+ Attempt int16

+ AttemptedAt *time.Time

+ CreatedAt *time.Time

+ Errors [][]byte

+ FinalizedAt *time.Time

+ Kind string

+ MaxAttempts int16

+ Metadata []byte

+ Priority int16

+ Queue string

+ ScheduledAt *time.Time

+ State JobState

+ Tags []string

+ type JobScheduleParams struct

+ Max int64

+ Now time.Time

+ type JobSetCancelledIfRunningParams struct

+ Error []byte

+ FinalizedAt time.Time

+ ID int64

+ type JobSetCompletedIfRunningParams struct

+ FinalizedAt time.Time

+ ID int64

+ type JobSetCompletedParams struct

+ FinalizedAt time.Time

+ ID int64

+ type JobSetDiscardedIfRunningParams struct

+ Error []byte

+ FinalizedAt time.Time

+ ID int64

+ type JobSetDiscardedParams struct

+ Error []byte

+ FinalizedAt time.Time

+ ID int64

+ type JobSetErroredIfRunningParams struct

+ Error []byte

+ ID int64

+ ScheduledAt time.Time

+ type JobSetSnoozedIfRunningParams struct

+ ID int64

+ ScheduledAt time.Time

+ type JobState string

+ const JobStateAvailable

+ const JobStateCancelled

+ const JobStateCompleted

+ const JobStateDiscarded

+ const JobStateRetryable

+ const JobStateRunning

+ const JobStateScheduled

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

+ type JobUpdateParams struct

+ Attempt int16

+ AttemptDoUpdate bool

+ AttemptedAt *time.Time

+ AttemptedAtDoUpdate bool

+ ID int64

+ State JobState

+ StateDoUpdate bool

+ type JobUpdateStuckForDiscardParams struct

+ Errors [][]byte

+ ID []int64

+ type JobUpdateStuckForRetryParams struct

+ Errors [][]byte

+ ID []int64

+ ScheduledAt []time.Time

+ type LeadershipAttemptElectParams struct

+ LeaderID string

+ Name string

+ TTL time.Duration

+ type LeadershipAttemptReelectParams struct

+ LeaderID string

+ Name string

+ TTL time.Duration

+ type LeadershipResignParams struct

+ LeaderID string

+ Name string

+ type NullJobState struct

+ JobState JobState

+ Valid bool

+ func (ns *NullJobState) Scan(value interface{}) error

+ func (ns NullJobState) Value() (driver.Value, error)

+ type Queries struct

+ func New() *Queries

+ func (q *Queries) JobCompleteMany(ctx context.Context, db DBTX, arg JobCompleteManyParams) error

+ func (q *Queries) JobCountRunning(ctx context.Context, db DBTX) (int64, error)

+ func (q *Queries) JobDeleteBefore(ctx context.Context, db DBTX, arg JobDeleteBeforeParams) (int64, error)

+ func (q *Queries) JobGetAvailable(ctx context.Context, db DBTX, arg JobGetAvailableParams) ([]*RiverJob, error)

+ func (q *Queries) JobGetByID(ctx context.Context, db DBTX, id int64) (*RiverJob, error)

+ func (q *Queries) JobGetByIDMany(ctx context.Context, db DBTX, id []int64) ([]*RiverJob, error)

+ func (q *Queries) JobGetByKind(ctx context.Context, db DBTX, kind string) ([]*RiverJob, error)

+ func (q *Queries) JobGetByKindAndUniqueProperties(ctx context.Context, db DBTX, arg JobGetByKindAndUniquePropertiesParams) (*RiverJob, error)

+ func (q *Queries) JobGetByKindMany(ctx context.Context, db DBTX, kind []string) ([]*RiverJob, error)

+ func (q *Queries) JobGetStuck(ctx context.Context, db DBTX, arg JobGetStuckParams) ([]*RiverJob, error)

+ func (q *Queries) JobInsert(ctx context.Context, db DBTX, arg JobInsertParams) (*RiverJob, error)

+ func (q *Queries) JobInsertMany(ctx context.Context, db DBTX, arg []JobInsertManyParams) (int64, error)

+ func (q *Queries) JobSchedule(ctx context.Context, db DBTX, arg JobScheduleParams) (int64, error)

+ func (q *Queries) JobSetCancelledIfRunning(ctx context.Context, db DBTX, arg JobSetCancelledIfRunningParams) (*RiverJob, error)

+ func (q *Queries) JobSetCompleted(ctx context.Context, db DBTX, arg JobSetCompletedParams) (*RiverJob, error)

+ func (q *Queries) JobSetCompletedIfRunning(ctx context.Context, db DBTX, arg JobSetCompletedIfRunningParams) (*RiverJob, error)

+ func (q *Queries) JobSetDiscarded(ctx context.Context, db DBTX, arg JobSetDiscardedParams) (*RiverJob, error)

+ func (q *Queries) JobSetDiscardedIfRunning(ctx context.Context, db DBTX, arg JobSetDiscardedIfRunningParams) (*RiverJob, error)

+ func (q *Queries) JobSetErroredIfRunning(ctx context.Context, db DBTX, arg JobSetErroredIfRunningParams) (*RiverJob, error)

+ func (q *Queries) JobSetSnoozedIfRunning(ctx context.Context, db DBTX, arg JobSetSnoozedIfRunningParams) (*RiverJob, error)

+ func (q *Queries) JobUpdate(ctx context.Context, db DBTX, arg JobUpdateParams) (*RiverJob, error)

+ func (q *Queries) JobUpdateStuckForDiscard(ctx context.Context, db DBTX, arg JobUpdateStuckForDiscardParams) error

+ func (q *Queries) JobUpdateStuckForRetry(ctx context.Context, db DBTX, arg JobUpdateStuckForRetryParams) error

+ func (q *Queries) LeadershipAttemptElect(ctx context.Context, db DBTX, arg LeadershipAttemptElectParams) (int64, error)

+ func (q *Queries) LeadershipAttemptReelect(ctx context.Context, db DBTX, arg LeadershipAttemptReelectParams) (int64, error)

+ func (q *Queries) LeadershipDeleteExpired(ctx context.Context, db DBTX, name string) error

+ func (q *Queries) LeadershipResign(ctx context.Context, db DBTX, arg LeadershipResignParams) error

+ func (q *Queries) PGAdvisoryXactLock(ctx context.Context, db DBTX, key int64) error

+ func (q *Queries) RiverMigrationDeleteByVersionMany(ctx context.Context, db DBTX, version []int64) (*RiverMigration, error)

+ func (q *Queries) RiverMigrationGetAll(ctx context.Context, db DBTX) ([]*RiverMigration, error)

+ func (q *Queries) RiverMigrationInsert(ctx context.Context, db DBTX, version int64) (*RiverMigration, error)

+ func (q *Queries) RiverMigrationInsertMany(ctx context.Context, db DBTX, version []int64) ([]*RiverMigration, error)

+ type RiverJob struct

+ Args []byte

+ Attempt int16

+ AttemptedAt *time.Time

+ AttemptedBy []string

+ CreatedAt time.Time

+ Errors []AttemptError

+ FinalizedAt *time.Time

+ ID int64

+ Kind string

+ MaxAttempts int16

+ Metadata []byte

+ Priority int16

+ Queue string

+ ScheduledAt time.Time

+ State JobState

+ Tags []string

+ type RiverLeader struct

+ ElectedAt time.Time

+ ExpiresAt time.Time

+ LeaderID string

+ Name string

+ type RiverMigration struct

+ CreatedAt time.Time

+ ID int64

+ Version int64

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