sqlc

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 18, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FromCtx 

func FromCtx(ctx context.Context) string

func NewCtx 

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

func NewScopedPgx 

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

Types

type BatchUpdateFailedJobsBatchResults 

type BatchUpdateFailedJobsBatchResults struct {
	// contains filtered or unexported fields
}

func (*BatchUpdateFailedJobsBatchResults) Close 

func (b *BatchUpdateFailedJobsBatchResults) Close() error

func (*BatchUpdateFailedJobsBatchResults) Exec 

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

type BatchUpdateFailedJobsParams 

type BatchUpdateFailedJobsParams struct {
	State    string `json:"state"`
	Expr     string `json:"expr"`
	ID       int64  `json:"id"`
	Executor string `json:"executor"`
}

type BatchUpdateJobsBatchResults 

type BatchUpdateJobsBatchResults struct {
	// contains filtered or unexported fields
}

func (*BatchUpdateJobsBatchResults) Close 

func (b *BatchUpdateJobsBatchResults) Close() error

func (*BatchUpdateJobsBatchResults) Exec 

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

type BatchUpdateJobsParams 

type BatchUpdateJobsParams struct {
	State    string     `json:"state"`
	Expr     string     `json:"expr"`
	Status   TinyStatus `json:"status"`
	Retries  int32      `json:"retries"`
	ID       int64      `json:"id"`
	Executor string     `json:"executor"`
}

type CountJobsInStatusParams 

type CountJobsInStatusParams struct {
	Executor string     `json:"executor"`
	Status   TinyStatus `json:"status"`
}

type CreateJobParams 

type CreateJobParams struct {
	Expr     string             `json:"expr"`
	State    string             `json:"state"`
	Executor string             `json:"executor"`
	StartAt  pgtype.Timestamptz `json:"start_at"`
	Meta     []byte             `json:"meta"`
	Name     interface{}        `json:"name"`
	Timeout  interface{}        `json:"timeout"`
	Owner    interface{}        `json:"owner"`
	Retries  interface{}        `json:"retries"`
}

type CronNextRunParams 

type CronNextRunParams struct {
	From pgtype.Timestamptz `json:"from"`
	Expr string             `json:"expr"`
}

type DBTX 

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	SendBatch(context.Context, *pgx.Batch) pgx.BatchResults
}

type DeleteJobByIDParams 

type DeleteJobByIDParams struct {
	ID       int64  `json:"id"`
	Executor string `json:"executor"`
}

type DeleteJobByNameParams 

type DeleteJobByNameParams struct {
	Name     string `json:"name"`
	Executor string `json:"executor"`
}

type FetchDueJobsParams 

type FetchDueJobsParams struct {
	Limit    int32  `json:"limit"`
	Executor string `json:"executor"`
}

type GetJobByIDParams 

type GetJobByIDParams struct {
	ID       int64  `json:"id"`
	Executor string `json:"executor"`
}

type GetJobByNameParams 

type GetJobByNameParams struct {
	Name     string `json:"name"`
	Executor string `json:"executor"`
}

type NextParams 

type NextParams struct {
	From pgtype.Timestamptz `json:"from"`
	Expr string             `json:"expr"`
}

type NullTinyStatus 

type NullTinyStatus struct {
	TinyStatus TinyStatus
	Valid      bool // Valid is true if TinyStatus is not NULL
}

func (*NullTinyStatus) Scan 

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

Scan implements the Scanner interface.

func (NullTinyStatus) Value 

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

Value implements the driver Valuer interface.

type Querier 

type Querier interface {
	Begin(ctx context.Context) (pgx.Tx, error)
	BeginTx(ctx context.Context, opts pgx.TxOptions) (pgx.Tx, error)
	Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
	SendBatch(ctx context.Context, batch *pgx.Batch) pgx.BatchResults
	Close()
}

Querier provides abstraction for passing both pgxpool.Conn, pgx.Conn and pgx.Tx as possible datasources

type Queries 

type Queries struct {
	// contains filtered or unexported fields
}

func New 

func New(db DBTX) *Queries

func (*Queries) BatchUpdateFailedJobs 

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

func (*Queries) BatchUpdateJobs 

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

func (*Queries) CountJobsInStatus 

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

func (*Queries) CreateJob 

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

on conflict on constraint job_name_owner_key do ...

func (*Queries) CronNextRun 

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

func (*Queries) DeleteJobByID 

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

func (*Queries) DeleteJobByName 

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

func (*Queries) FetchDueJobs 

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

func (*Queries) GetJobByID 

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

func (*Queries) GetJobByName 

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

func (*Queries) Next 

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

func (*Queries) ResetTimeoutJobs 

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

func (*Queries) RestartJob 

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

func (*Queries) SearchJobs 

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

TODO: This query is not working with dynamic params 🤔

func (*Queries) SearchJobsByMeta 

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

func (*Queries) StopJob 

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

Cannot stop a currently running task as it is outside of control for now Possible to add a notification system to listen on those kind of events

func (*Queries) UpdateExprByID 

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

func (*Queries) UpdateJobByID 

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

func (*Queries) UpdateJobByName 

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

TODO: Implement search

func (*Queries) UpdateStateByID 

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

func (*Queries) ValidateExprFormat 

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

func (*Queries) WithTx 

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

type RestartJobParams 

type RestartJobParams struct {
	ID       int64  `json:"id"`
	Executor string `json:"executor"`
}

type ScopedPgx 

type ScopedPgx struct {
	*pgxpool.Pool
}

ScopedPgx is a scoped connection pool that only leverages a lower privileges postgres role that is subject to RLS

type SearchJobsByMetaParams 

type SearchJobsByMetaParams struct {
	Offset    int32              `json:"offset"`
	Limit     int32              `json:"limit"`
	Query     string             `json:"query"`
	Statuses  string             `json:"statuses"`
	From      pgtype.Timestamptz `json:"from"`
	To        pgtype.Timestamptz `json:"to"`
	Name      string             `json:"name"`
	IsOneShot bool               `json:"is_one_shot"`
	Executor  string             `json:"executor"`
}

type SearchJobsByMetaRow 

type SearchJobsByMetaRow struct {
	ID              int64              `json:"id"`
	Expr            string             `json:"expr"`
	RunAt           pgtype.Timestamptz `json:"run_at"`
	LastRunAt       pgtype.Timestamptz `json:"last_run_at"`
	CreatedAt       pgtype.Timestamptz `json:"created_at"`
	StartAt         pgtype.Timestamptz `json:"start_at"`
	ExecutionAmount int32              `json:"execution_amount"`
	Retries         int32              `json:"retries"`
	Name            string             `json:"name"`
	Meta            []byte             `json:"meta"`
	Timeout         int32              `json:"timeout"`
	Status          TinyStatus         `json:"status"`
	State           string             `json:"state"`
	Executor        string             `json:"executor"`
	Owner           string             `json:"owner"`
	TotalCount      int64              `json:"total_count"`
}

type SearchJobsParams 

type SearchJobsParams struct {
	Offset   int32  `json:"offset"`
	Limit    int32  `json:"limit"`
	Executor string `json:"executor"`
	Query    string `json:"query"`
}

type StopJobParams 

type StopJobParams struct {
	ID       int64  `json:"id"`
	Executor string `json:"executor"`
}

type TinyJob 

type TinyJob struct {
	ID              int64              `json:"id"`
	Expr            string             `json:"expr"`
	RunAt           pgtype.Timestamptz `json:"run_at"`
	LastRunAt       pgtype.Timestamptz `json:"last_run_at"`
	CreatedAt       pgtype.Timestamptz `json:"created_at"`
	StartAt         pgtype.Timestamptz `json:"start_at"`
	ExecutionAmount int32              `json:"execution_amount"`
	Retries         int32              `json:"retries"`
	Name            string             `json:"name"`
	Meta            []byte             `json:"meta"`
	Timeout         int32              `json:"timeout"`
	Status          TinyStatus         `json:"status"`
	State           string             `json:"state"`
	Executor        string             `json:"executor"`
	Owner           string             `json:"owner"`
}

type TinyStatus 

type TinyStatus string
const (
	TinyStatusREADY   TinyStatus = "READY"
	TinyStatusPENDING TinyStatus = "PENDING"
	TinyStatusFAILURE TinyStatus = "FAILURE"
	TinyStatusSUCCESS TinyStatus = "SUCCESS"
	TinyStatusPAUSED  TinyStatus = "PAUSED"
)

func (*TinyStatus) Scan 

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

type UpdateExprByIDParams 

type UpdateExprByIDParams struct {
	ID       int64       `json:"id"`
	Executor string      `json:"executor"`
	Expr     interface{} `json:"expr"`
}

type UpdateJobByIDParams 

type UpdateJobByIDParams struct {
	ID       int64       `json:"id"`
	Executor string      `json:"executor"`
	Expr     interface{} `json:"expr"`
	State    interface{} `json:"state"`
	Timeout  interface{} `json:"timeout"`
}

type UpdateJobByNameParams 

type UpdateJobByNameParams struct {
	Name     string      `json:"name"`
	Executor string      `json:"executor"`
	Expr     interface{} `json:"expr"`
	State    interface{} `json:"state"`
	Timeout  interface{} `json:"timeout"`
}

type UpdateStateByIDParams 

type UpdateStateByIDParams struct {
	ID       int64       `json:"id"`
	Executor string      `json:"executor"`
	State    interface{} `json:"state"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.