sqlc

package

Go to main page

Versions in this module

v0

v0.1.16

Jun 26, 2023

v0.1.15

Jun 26, 2023

Changes in this version

type BatchCreateJobsParams

+ DeduplicationKey pgtype.Text

type CreateJobParams

+ DeduplicationKey pgtype.Text

type SearchJobsByMetaRow

+ DeduplicationKey pgtype.Text

type TinyJob

+ DeduplicationKey pgtype.Text

v0.1.14

Jun 22, 2023

v0.1.13

Jun 22, 2023

v0.1.12

May 12, 2023

v0.1.11

May 4, 2023

v0.1.10

Mar 30, 2023

Changes in this version

+ type BatchCreateJobsBatchResults struct

+ func (b *BatchCreateJobsBatchResults) Close() error

+ func (b *BatchCreateJobsBatchResults) Exec(f func(int, error))

+ type BatchCreateJobsParams struct

+ Executor string

+ Expr string

+ Meta []byte

+ Name interface{}

+ Owner interface{}

+ Retries interface{}

+ StartAt pgtype.Timestamptz

+ State string

+ Timeout interface{}

type Queries

+ func (q *Queries) BatchCreateJobs(ctx context.Context, arg []BatchCreateJobsParams) *BatchCreateJobsBatchResults

+ func (q *Queries) LastUpdate(ctx context.Context, executor string) (pgtype.Timestamptz, error)

type SearchJobsByMetaRow

+ UpdatedAt pgtype.Timestamptz

type TinyJob

+ UpdatedAt pgtype.Timestamptz

v0.1.9

Feb 21, 2023

v0.1.8

Feb 21, 2023

v0.1.7

Feb 18, 2023

v0.1.6

Feb 18, 2023

v0.1.5

Feb 18, 2023

v0.1.4

Feb 18, 2023

v0.1.3

Feb 18, 2023

v0.1.2

Feb 18, 2023

v0.1.1

Feb 18, 2023

v0.1.0

Feb 18, 2023

Changes in this version

+ func FromCtx(ctx context.Context) string

+ func NewCtx(ctx context.Context, owner string) context.Context

+ func NewScopedPgx(ctx context.Context, dsn string) (*pgxpool.Pool, error)

+ type BatchUpdateFailedJobsBatchResults struct

+ func (b *BatchUpdateFailedJobsBatchResults) Close() error

+ func (b *BatchUpdateFailedJobsBatchResults) Exec(f func(int, error))

+ type BatchUpdateFailedJobsParams struct

+ Executor string

+ Expr string

+ ID int64

+ State string

+ type BatchUpdateJobsBatchResults struct

+ func (b *BatchUpdateJobsBatchResults) Close() error

+ func (b *BatchUpdateJobsBatchResults) Exec(f func(int, error))

+ type BatchUpdateJobsParams struct

+ Executor string

+ Expr string

+ ID int64

+ Retries int32

+ State string

+ Status TinyStatus

+ type CountJobsInStatusParams struct

+ Executor string

+ Status TinyStatus

+ type CreateJobParams struct

+ Executor string

+ Expr string

+ Meta []byte

+ Name interface{}

+ Owner interface{}

+ Retries interface{}

+ StartAt pgtype.Timestamptz

+ State string

+ Timeout interface{}

+ type CronNextRunParams struct

+ Expr string

+ From pgtype.Timestamptz

+ 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

+ SendBatch func(context.Context, *pgx.Batch) pgx.BatchResults

+ type DeleteJobByIDParams struct

+ Executor string

+ ID int64

+ type DeleteJobByNameParams struct

+ Executor string

+ Name string

+ type FetchDueJobsParams struct

+ Executor string

+ Limit int32

+ type GetJobByIDParams struct

+ Executor string

+ ID int64

+ type GetJobByNameParams struct

+ Executor string

+ Name string

+ type NextParams struct

+ Expr string

+ From pgtype.Timestamptz

+ type NullTinyStatus struct

+ TinyStatus TinyStatus

+ Valid bool

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

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

+ type Querier interface

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

+ BeginTx func(ctx context.Context, opts pgx.TxOptions) (pgx.Tx, error)

+ Close func()

+ Exec func(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)

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

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

+ SendBatch func(ctx context.Context, batch *pgx.Batch) pgx.BatchResults

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) BatchUpdateFailedJobs(ctx context.Context, arg []BatchUpdateFailedJobsParams) *BatchUpdateFailedJobsBatchResults

+ func (q *Queries) BatchUpdateJobs(ctx context.Context, arg []BatchUpdateJobsParams) *BatchUpdateJobsBatchResults

+ func (q *Queries) CountJobsInStatus(ctx context.Context, arg CountJobsInStatusParams) (int64, error)

+ func (q *Queries) CreateJob(ctx context.Context, arg CreateJobParams) (TinyJob, error)

+ func (q *Queries) CronNextRun(ctx context.Context, arg CronNextRunParams) (pgtype.Timestamptz, error)

+ func (q *Queries) DeleteJobByID(ctx context.Context, arg DeleteJobByIDParams) (TinyJob, error)

+ func (q *Queries) DeleteJobByName(ctx context.Context, arg DeleteJobByNameParams) (TinyJob, error)

+ func (q *Queries) FetchDueJobs(ctx context.Context, arg FetchDueJobsParams) ([]TinyJob, error)

+ func (q *Queries) GetJobByID(ctx context.Context, arg GetJobByIDParams) (TinyJob, error)

+ func (q *Queries) GetJobByName(ctx context.Context, arg GetJobByNameParams) (TinyJob, error)

+ func (q *Queries) Next(ctx context.Context, arg NextParams) (pgtype.Timestamptz, error)

+ func (q *Queries) ResetTimeoutJobs(ctx context.Context, executor string) ([]int64, error)

+ func (q *Queries) RestartJob(ctx context.Context, arg RestartJobParams) (TinyJob, error)

+ func (q *Queries) SearchJobs(ctx context.Context, arg SearchJobsParams) ([]TinyJob, error)

+ func (q *Queries) SearchJobsByMeta(ctx context.Context, arg SearchJobsByMetaParams) ([]SearchJobsByMetaRow, error)

+ func (q *Queries) StopJob(ctx context.Context, arg StopJobParams) (TinyJob, error)

+ func (q *Queries) UpdateExprByID(ctx context.Context, arg UpdateExprByIDParams) (TinyJob, error)

+ func (q *Queries) UpdateJobByID(ctx context.Context, arg UpdateJobByIDParams) (TinyJob, error)

+ func (q *Queries) UpdateJobByName(ctx context.Context, arg UpdateJobByNameParams) (TinyJob, error)

+ func (q *Queries) UpdateStateByID(ctx context.Context, arg UpdateStateByIDParams) (TinyJob, error)

+ func (q *Queries) ValidateExprFormat(ctx context.Context, dollar_1 string) (bool, error)

+ func (q *Queries) WithTx(tx pgx.Tx) *Queries

+ type RestartJobParams struct

+ Executor string

+ ID int64

+ type ScopedPgx struct

+ type SearchJobsByMetaParams struct

+ Executor string

+ From pgtype.Timestamptz

+ IsOneShot bool

+ Limit int32

+ Name string

+ Offset int32

+ Query string

+ Statuses string

+ To pgtype.Timestamptz

+ type SearchJobsByMetaRow struct

+ CreatedAt pgtype.Timestamptz

+ ExecutionAmount int32

+ Executor string

+ Expr string

+ ID int64

+ LastRunAt pgtype.Timestamptz

+ Meta []byte

+ Name string

+ Owner string

+ Retries int32

+ RunAt pgtype.Timestamptz

+ StartAt pgtype.Timestamptz

+ State string

+ Status TinyStatus

+ Timeout int32

+ TotalCount int64

+ type SearchJobsParams struct

+ Executor string

+ Limit int32

+ Offset int32

+ Query string

+ type StopJobParams struct

+ Executor string

+ ID int64

+ type TinyJob struct

+ CreatedAt pgtype.Timestamptz

+ ExecutionAmount int32

+ Executor string

+ Expr string

+ ID int64

+ LastRunAt pgtype.Timestamptz

+ Meta []byte

+ Name string

+ Owner string

+ Retries int32

+ RunAt pgtype.Timestamptz

+ StartAt pgtype.Timestamptz

+ State string

+ Status TinyStatus

+ Timeout int32

+ type TinyStatus string

+ const TinyStatusFAILURE

+ const TinyStatusPAUSED

+ const TinyStatusPENDING

+ const TinyStatusREADY

+ const TinyStatusSUCCESS

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

+ type UpdateExprByIDParams struct

+ Executor string

+ Expr interface{}

+ ID int64

+ type UpdateJobByIDParams struct

+ Executor string

+ Expr interface{}

+ ID int64

+ State interface{}

+ Timeout interface{}

+ type UpdateJobByNameParams struct

+ Executor string

+ Expr interface{}

+ Name string

+ State interface{}

+ Timeout interface{}

+ type UpdateStateByIDParams struct

+ Executor string

+ ID int64

+ State interface{}

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