dbsqlc

package

Go to main page

Versions in this module

v0

v0.29.0

Dec 22, 2025

Changes in this version

+ type JobUpdateFullParams struct

+ Attempt int16

+ AttemptDoUpdate bool

+ AttemptedAt *time.Time

+ AttemptedAtDoUpdate bool

+ AttemptedBy []string

+ AttemptedByDoUpdate bool

+ Errors []string

+ ErrorsDoUpdate bool

+ FinalizedAt *time.Time

+ FinalizedAtDoUpdate bool

+ ID int64

+ MaxAttempts int16

+ MaxAttemptsDoUpdate bool

+ Metadata string

+ MetadataDoUpdate bool

+ State RiverJobState

+ StateDoUpdate bool

type JobUpdateParams

+ MetadataDoMerge bool

type Queries

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

v0.29.0-rc.1

Dec 4, 2025

v0.28.0

Nov 24, 2025

v0.27.1

Nov 21, 2025

v0.27.0

Nov 17, 2025

v0.26.0

Oct 8, 2025

v0.25.0

Sep 15, 2025

Changes in this version

type JobUpdateParams

+ MaxAttempts int16

+ MaxAttemptsDoUpdate bool

+ Metadata string

+ MetadataDoUpdate bool

v0.24.0

Aug 16, 2025

Changes in this version

+ type IndexesExistParams struct

+ IndexNames []string

+ Schema sql.NullString

+ type IndexesExistRow struct

+ Exists bool

+ IndexName string

+ type JobCountByAllStatesRow struct

+ Count int64

+ State RiverJobState

+ type JobCountByQueueAndStateRow struct

+ CountAvailable int64

+ CountRunning int64

+ Queue string

type JobDeleteBeforeParams

+ CancelledDoDelete interface{}

+ CompletedDoDelete interface{}

+ DiscardedDoDelete interface{}

+ QueuesExcluded []string

+ QueuesIncluded []string

type JobGetAvailableParams

+ MaxAttemptedBy int32

+ MaxToLock int32

type JobInsertFastManyParams

+ ID []int64

+ type JobKindListParams struct

+ After interface{}

+ Exclude []string

+ Match interface{}

+ Max int32

type Queries

+ func (q *Queries) IndexesExist(ctx context.Context, db DBTX, arg *IndexesExistParams) ([]*IndexesExistRow, error)

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

+ func (q *Queries) JobCountByQueueAndState(ctx context.Context, db DBTX, queueNames []string) ([]*JobCountByQueueAndStateRow, error)

+ func (q *Queries) JobDeleteMany(ctx context.Context, db DBTX, max int32) ([]*RiverJob, error)

+ func (q *Queries) JobKindList(ctx context.Context, db DBTX, arg *JobKindListParams) ([]string, error)

+ func (q *Queries) QueueNameList(ctx context.Context, db DBTX, arg *QueueNameListParams) ([]string, error)

+ type QueueNameListParams struct

+ After string

+ Exclude []string

+ Match string

+ Max int32

v0.23.1

Jun 4, 2025

v0.23.0

Jun 4, 2025

Changes in this version

+ type IndexExistsParams struct

+ Index string

+ Schema sql.NullString

type JobCancelParams

+ Now *time.Time

+ type JobInsertFullManyParams struct

+ Args []string

+ Attempt []int16

+ AttemptedAt []time.Time

+ CreatedAt []time.Time

+ FinalizedAt []time.Time

+ Kind []string

+ MaxAttempts []int16

+ Metadata []string

+ Priority []int16

+ Queue []string

+ ScheduledAt []time.Time

+ State []string

+ Tags []string

+ UniqueKey []string

+ UniqueStates []int32

+ type JobRetryParams struct

+ ID int64

+ Now *time.Time

type JobSetStateIfRunningManyParams

+ Now *time.Time

type Queries

+ func (q *Queries) IndexExists(ctx context.Context, db DBTX, arg *IndexExistsParams) (bool, error)

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

+ type QueuePauseParams struct

+ Name string

+ Now *time.Time

+ type QueueResumeParams struct

+ Name string

+ Now *time.Time

v0.22.0

May 10, 2025

v0.21.0

May 3, 2025

Changes in this version

type JobCancelParams

+ Schema sql.NullString

type LeaderAttemptElectParams

+ Now *time.Time

type LeaderAttemptReelectParams

+ Now *time.Time

type LeaderInsertParams

+ Now *time.Time

type LeaderResignParams

+ Schema sql.NullString

type PGNotifyManyParams

+ Schema sql.NullString

type Queries

+ func (q *Queries) SchemaGetExpired(ctx context.Context, db DBTX, arg *SchemaGetExpiredParams) ([]string, error)

type QueueCreateOrSetUpdatedAtParams

+ Now *time.Time

+ type SchemaGetExpiredParams struct

+ BeforeName interface{}

+ Prefix interface{}

v0.20.2

Apr 9, 2025

v0.20.0

Apr 4, 2025

Changes in this version

type Queries

+ func (q *Queries) QueueUpdate(ctx context.Context, db DBTX, arg *QueueUpdateParams) (*RiverQueue, error)

+ type QueueUpdateParams struct

+ Metadata string

+ MetadataDoUpdate bool

+ Name string

v0.19.0

Mar 17, 2025

Changes in this version

type Queries

+ func (q *Queries) JobList(ctx context.Context, db DBTX, max int32) ([]*RiverJob, error)

v0.18.0

Feb 20, 2025

Changes in this version

type JobInsertFastManyNoReturningParams

+ CreatedAt []time.Time

type JobInsertFastManyParams

+ CreatedAt []time.Time

type JobSetStateIfRunningManyParams

+ MetadataDoMerge []bool

+ MetadataUpdates []string

type JobUpdateParams

+ AttemptedBy []string

+ AttemptedByDoUpdate bool

v0.17.0

Feb 15, 2025

Changes in this version

type JobInsertFullParams

+ AttemptedBy []string

v0.16.0

Jan 28, 2025

Changes in this version

type JobSetStateIfRunningManyParams

+ Attempt []int32

+ AttemptDoUpdate []bool

+ SnoozeDoIncrement []bool

type JobSetStateIfRunningParams

+ Attempt int16

+ AttemptUpdate bool

+ SnoozeDoIncrement bool

v0.15.0

Dec 27, 2024

v0.14.3

Dec 15, 2024

v0.14.2

Nov 16, 2024

v0.14.1

Nov 4, 2024

v0.14.0

Nov 3, 2024

v0.13.0

Oct 8, 2024

Changes in this version

type JobGetAvailableParams

+ Now *time.Time

v0.13.0-rc.1

Oct 5, 2024

v0.12.1

Sep 26, 2024

Changes in this version

+ type JobSetStateIfRunningManyParams struct

+ Errors []string

+ ErrorsDoUpdate []bool

+ FinalizedAt []time.Time

+ FinalizedAtDoUpdate []bool

+ IDs []int64

+ MaxAttempts []int32

+ MaxAttemptsDoUpdate []bool

+ ScheduledAt []time.Time

+ ScheduledAtDoUpdate []bool

+ State []string

type Queries

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

v0.12.0

Sep 23, 2024

Changes in this version

+ type JobInsertFastManyNoReturningParams struct

+ Args []string

+ Kind []string

+ MaxAttempts []int16

+ Metadata []string

+ Priority []int16

+ Queue []string

+ ScheduledAt []time.Time

+ State []RiverJobState

+ Tags []string

+ UniqueKey [][]byte

+ UniqueStates []pgtypealias.Bits

type JobInsertFastManyParams

+ UniqueKey [][]byte

+ UniqueStates []pgtypealias.Bits

+ type JobInsertFastManyRow struct

+ RiverJob RiverJob

+ UniqueSkippedAsDuplicate bool

type JobInsertFastParams

+ UniqueKey []byte

+ UniqueStates pgtypealias.Bits

+ type JobInsertFastRow struct

+ RiverJob RiverJob

+ UniqueSkippedAsDuplicate bool

type JobInsertFullParams

+ UniqueStates pgtypealias.Bits

+ type JobScheduleRow struct

+ ConflictDiscarded bool

+ RiverJob RiverJob

type Queries

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

type RiverJob

+ UniqueStates pgtypealias.Bits

v0.12.0-rc.1

Sep 22, 2024

v0.11.4

Aug 20, 2024

v0.11.3

Aug 19, 2024

v0.11.2

Aug 9, 2024

v0.11.1

Aug 6, 2024

v0.11.0

Aug 3, 2024

v0.10.2

Aug 1, 2024

v0.10.1

Jul 24, 2024

Changes in this version

type JobInsertUniqueRow

+ RiverJob RiverJob

v0.10.0

Jul 19, 2024

Changes in this version

+ type ClientCreateOrSetUpdatedAtParams struct

+ ID string

+ Metadata string

+ PausedAt *time.Time

+ UpdatedAt *time.Time

+ type ClientQueueCreateOrSetUpdatedAtManyParams struct

+ Metadata string

+ Name []string

+ PausedAt *time.Time

+ RiverClientID string

+ UpdatedAt *time.Time

+ type ColumnExistsParams struct

+ ColumnName interface{}

+ TableName interface{}

+ type JobInsertFastManyParams struct

+ Args []string

+ Kind []string

+ MaxAttempts []int16

+ Metadata []string

+ Priority []int16

+ Queue []string

+ ScheduledAt []time.Time

+ State []RiverJobState

+ Tags []string

type JobInsertFullParams

+ UniqueKey []byte

+ type JobInsertUniqueParams struct

+ Args string

+ CreatedAt *time.Time

+ FinalizedAt *time.Time

+ Kind string

+ MaxAttempts int16

+ Metadata string

+ Priority int16

+ Queue string

+ ScheduledAt *time.Time

+ State RiverJobState

+ Tags []string

+ UniqueKey []byte

+ type JobInsertUniqueRow struct

+ Args string

+ Attempt int16

+ AttemptedAt *time.Time

+ AttemptedBy []string

+ CreatedAt time.Time

+ Errors []string

+ FinalizedAt *time.Time

+ ID int64

+ Kind string

+ MaxAttempts int16

+ Metadata string

+ Priority int16

+ Queue string

+ ScheduledAt time.Time

+ State RiverJobState

+ Tags []string

+ UniqueKey []byte

+ UniqueSkippedAsDuplicate bool

type JobUpdateParams

+ UniqueKey []byte

+ UniqueKeyDoUpdate bool

+ type NullRiverJobState struct

+ RiverJobState RiverJobState

+ Valid bool

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

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

type Queries

+ func (q *Queries) ClientCreateOrSetUpdatedAt(ctx context.Context, db DBTX, arg *ClientCreateOrSetUpdatedAtParams) (*RiverClient, error)

+ func (q *Queries) ClientQueueCreateOrSetUpdatedAtMany(ctx context.Context, db DBTX, arg *ClientQueueCreateOrSetUpdatedAtManyParams) (*RiverClientQueue, error)

+ func (q *Queries) ColumnExists(ctx context.Context, db DBTX, arg *ColumnExistsParams) (bool, error)

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

+ func (q *Queries) JobInsertUnique(ctx context.Context, db DBTX, arg *JobInsertUniqueParams) (*JobInsertUniqueRow, error)

+ func (q *Queries) QueueCreateOrSetUpdatedAt(ctx context.Context, db DBTX, arg *QueueCreateOrSetUpdatedAtParams) (*RiverQueue, error)

+ func (q *Queries) QueueDeleteExpired(ctx context.Context, db DBTX, arg *QueueDeleteExpiredParams) ([]*RiverQueue, error)

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

+ func (q *Queries) QueueList(ctx context.Context, db DBTX, limitCount int32) ([]*RiverQueue, error)

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

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

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

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

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

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

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

+ type QueueCreateOrSetUpdatedAtParams struct

+ Metadata string

+ Name string

+ PausedAt *time.Time

+ UpdatedAt *time.Time

+ type QueueDeleteExpiredParams struct

+ Max int64

+ UpdatedAtHorizon time.Time

+ type RiverClient struct

+ CreatedAt time.Time

+ ID string

+ Metadata string

+ PausedAt *time.Time

+ UpdatedAt time.Time

+ type RiverClientQueue struct

+ CreatedAt time.Time

+ MaxWorkers int64

+ Metadata string

+ Name string

+ NumJobsCompleted int64

+ NumJobsRunning int64

+ RiverClientID string

+ UpdatedAt time.Time

type RiverJob

+ UniqueKey []byte

+ type RiverJobState string

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

type RiverMigration

+ Line string

+ type RiverMigrationDeleteAssumingMainManyRow struct

+ CreatedAt time.Time

+ Version int64

+ type RiverMigrationDeleteByLineAndVersionManyParams struct

+ Line string

+ Version []int64

+ type RiverMigrationGetAllAssumingMainRow struct

+ CreatedAt time.Time

+ Version int64

+ type RiverMigrationInsertManyAssumingMainRow struct

+ CreatedAt time.Time

+ Version int64

+ type RiverMigrationInsertManyParams struct

+ Line string

+ Version []int64

+ type RiverMigrationInsertParams struct

+ Line string

+ Version int64

+ type RiverQueue struct

+ CreatedAt time.Time

+ Metadata string

+ Name string

+ PausedAt *time.Time

+ UpdatedAt time.Time

v0.9.0

Jul 4, 2024

v0.8.0

Jun 26, 2024

Changes in this version

type JobInsertFastParams

+ CreatedAt *time.Time

v0.7.0

Jun 14, 2024

Changes in this version

type Queries

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

v0.6.1

May 21, 2024

v0.6.0

May 9, 2024

v0.5.0

May 3, 2024

Changes in this version

type JobCancelParams

+ ControlTopic string

type JobState

+ const RiverJobStatePending

+ type PGNotifyManyParams struct

+ Payload []string

+ Topic string

type Queries

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

v0.4.1

Apr 23, 2024

v0.4.0

Apr 21, 2024

v0.3.0

Apr 16, 2024

v0.2.0

Mar 29, 2024

v0.1.0

Mar 17, 2024

Changes in this version

+ type JobSetCompleteIfRunningManyParams struct

+ FinalizedAt []time.Time

+ ID []int64

type Queries

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

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

v0.0.25

Mar 2, 2024

v0.0.24

Mar 1, 2024

v0.0.23

Feb 29, 2024

Changes in this version

+ type AttemptError struct

+ At time.Time

+ Attempt uint16

+ Error string

+ Trace string

+ type JobCancelParams struct

+ CancelAttemptedAt json.RawMessage

+ ID int64

+ JobControlTopic string

+ type JobDeleteBeforeParams struct

+ CancelledFinalizedAtHorizon time.Time

+ CompletedFinalizedAtHorizon time.Time

+ DiscardedFinalizedAtHorizon time.Time

+ Max int64

+ type JobGetAvailableParams struct

+ AttemptedBy string

+ Max int32

+ Queue string

+ type JobGetByKindAndUniquePropertiesParams struct

+ Args []byte

+ ByArgs bool

+ ByCreatedAt bool

+ ByQueue bool

+ ByState bool

+ CreatedAtBegin time.Time

+ CreatedAtEnd time.Time

+ Kind string

+ Queue string

+ State []string

+ type JobGetStuckParams struct

+ Max int32

+ StuckHorizon time.Time

+ type JobInsertFastParams struct

+ Args json.RawMessage

+ FinalizedAt *time.Time

+ Kind string

+ MaxAttempts int16

+ Metadata json.RawMessage

+ Priority int16

+ Queue string

+ ScheduledAt *time.Time

+ State JobState

+ Tags []string

+ type JobInsertFullParams struct

+ Args json.RawMessage

+ Attempt int16

+ AttemptedAt *time.Time

+ CreatedAt *time.Time

+ Errors []json.RawMessage

+ FinalizedAt *time.Time

+ Kind string

+ MaxAttempts int16

+ Metadata json.RawMessage

+ Priority int16

+ Queue string

+ ScheduledAt *time.Time

+ State JobState

+ Tags []string

+ type JobRescueManyParams struct

+ Error []json.RawMessage

+ FinalizedAt []time.Time

+ ID []int64

+ ScheduledAt []time.Time

+ State []string

+ type JobScheduleParams struct

+ InsertTopic string

+ Max int64

+ Now time.Time

+ type JobSetStateIfRunningParams struct

+ Error json.RawMessage

+ ErrorDoUpdate bool

+ FinalizedAt *time.Time

+ FinalizedAtDoUpdate bool

+ ID int64

+ MaxAttempts int16

+ MaxAttemptsUpdate bool

+ ScheduledAt *time.Time

+ ScheduledAtDoUpdate bool

+ State JobState

+ type JobState string

+ const RiverJobStateAvailable

+ const RiverJobStateCancelled

+ const RiverJobStateCompleted

+ const RiverJobStateDiscarded

+ const RiverJobStateRetryable

+ const RiverJobStateRunning

+ const RiverJobStateScheduled

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

+ type JobUpdateParams struct

+ Attempt int16

+ AttemptDoUpdate bool

+ AttemptedAt *time.Time

+ AttemptedAtDoUpdate bool

+ Errors []json.RawMessage

+ ErrorsDoUpdate bool

+ FinalizedAt *time.Time

+ FinalizedAtDoUpdate bool

+ ID int64

+ State JobState

+ StateDoUpdate bool

+ type LeaderAttemptElectParams struct

+ LeaderID string

+ Name string

+ TTL time.Duration

+ type LeaderAttemptReelectParams struct

+ LeaderID string

+ Name string

+ TTL time.Duration

+ type LeaderInsertParams struct

+ ElectedAt *time.Time

+ ExpiresAt *time.Time

+ LeaderID string

+ Name string

+ TTL time.Duration

+ type LeaderResignParams struct

+ LeaderID string

+ LeadershipTopic 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 PGNotifyParams struct

+ Payload string

+ Topic string

type Queries

+ func (q *Queries) JobCancel(ctx context.Context, db DBTX, arg *JobCancelParams) (*RiverJob, 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) 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) JobInsertFast(ctx context.Context, db DBTX, arg *JobInsertFastParams) (*RiverJob, error)

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

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

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

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

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

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

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

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

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

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

+ func (q *Queries) LeaderInsert(ctx context.Context, db DBTX, arg *LeaderInsertParams) (*RiverLeader, error)

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

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

+ func (q *Queries) PGNotify(ctx context.Context, db DBTX, arg *PGNotifyParams) 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 json.RawMessage

+ Priority int16

+ Queue string

+ ScheduledAt time.Time

+ State JobState

+ Tags []string

+ type RiverLeader struct

+ ElectedAt time.Time

+ ExpiresAt time.Time

+ LeaderID string

+ Name string

v0.0.22

Feb 19, 2024

v0.0.21

Feb 19, 2024

v0.0.20

Feb 15, 2024

v0.0.19

Feb 11, 2024

v0.0.18

Jan 26, 2024

v0.0.17

Jan 23, 2024

v0.0.16

Jan 6, 2024

v0.0.15

Dec 22, 2023

v0.0.14

Dec 13, 2023

v0.0.13

Dec 13, 2023

Changes in this version

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

+ func New() *Queries

+ 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)

+ func (q *Queries) TableExists(ctx context.Context, db DBTX, tableName string) (bool, error)

+ type RiverMigration struct

+ CreatedAt time.Time

+ ID int64

+ Version int64

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