dbsqlc

Documentation

Index

• Variables
• type CreateTaskBatchResults
  • func (b *CreateTaskBatchResults) Close() error
  • func (b *CreateTaskBatchResults) QueryRow(f func(int, *Task, error))
• type CreateTaskParams
• type DBTX
• type NullTaskStatus
  • func (ns *NullTaskStatus) Scan(value interface{}) error
  • func (ns NullTaskStatus) Value() (driver.Value, error)
• type PopTasksWithConcurrencyParams
• type Queries
  • func New() *Queries
  • func (q *Queries) CreateTask(ctx context.Context, db DBTX, arg []CreateTaskParams) *CreateTaskBatchResults
  • func (q *Queries) PopTasks(ctx context.Context, db DBTX, limit pgtype.Int4) ([]*Task, error)
  • func (q *Queries) PopTasksWithConcurrency(ctx context.Context, db DBTX, arg PopTasksWithConcurrencyParams) ([]*Task, error)
  • func (q *Queries) UpdateTaskPtrs(ctx context.Context, db DBTX) (*TaskAddrPtr, error)
  • func (q *Queries) UpdateTaskStatus(ctx context.Context, db DBTX, arg UpdateTaskStatusParams) (*Task, error)
• type Task
• type TaskAddrPtr
• type TaskGroup
• type TaskStatus
  • func (e *TaskStatus) Scan(src interface{}) error
• type UpdateTaskStatusParams

Variables

var (
	ErrBatchAlreadyClosed = errors.New("batch already closed")
)

Types

type CreateTaskBatchResults

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

func (*CreateTaskBatchResults) Close

func (b *CreateTaskBatchResults) Close() error

func (*CreateTaskBatchResults) QueryRow

func (b *CreateTaskBatchResults) QueryRow(f func(int, *Task, error))

type CreateTaskParams

type CreateTaskParams struct {
	CreatedAt pgtype.Timestamp `json:"created_at"`
	Args      []byte           `json:"args"`
	GroupKey  string           `json:"group_key"`
}

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 NullTaskStatus

type NullTaskStatus struct {
	TaskStatus TaskStatus `json:"TaskStatus"`
	Valid      bool       `json:"valid"` // Valid is true if TaskStatus is not NULL
}

func (*NullTaskStatus) Scan

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

Scan implements the Scanner interface.

func (NullTaskStatus) Value

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

Value implements the driver Valuer interface.

type PopTasksWithConcurrencyParams

type PopTasksWithConcurrencyParams struct {
	Concurrency int32       `json:"concurrency"`
	Limit       pgtype.Int4 `json:"limit"`
}

type Queries

type Queries struct {
}

func New

func New() *Queries

func (*Queries) CreateTask

func (q *Queries) CreateTask(ctx context.Context, db DBTX, arg []CreateTaskParams) *CreateTaskBatchResults

func (*Queries) PopTasks

func (q *Queries) PopTasks(ctx context.Context, db DBTX, limit pgtype.Int4) ([]*Task, error)

func (*Queries) PopTasksWithConcurrency

func (q *Queries) PopTasksWithConcurrency(ctx context.Context, db DBTX, arg PopTasksWithConcurrencyParams) ([]*Task, error)

func (*Queries) UpdateTaskPtrs

func (q *Queries) UpdateTaskPtrs(ctx context.Context, db DBTX) (*TaskAddrPtr, error)

func (*Queries) UpdateTaskStatus

func (q *Queries) UpdateTaskStatus(ctx context.Context, db DBTX, arg UpdateTaskStatusParams) (*Task, error)

type Task

type Task struct {
	ID        int64            `json:"id"`
	CreatedAt pgtype.Timestamp `json:"created_at"`
	Status    TaskStatus       `json:"status"`
	Args      []byte           `json:"args"`
	GroupKey  pgtype.Text      `json:"group_key"`
}

type TaskAddrPtr

type TaskAddrPtr struct {
	MaxAssignedBlockAddr int64 `json:"max_assigned_block_addr"`
	OnerowID             bool  `json:"onerow_id"`
}

type TaskGroup

type TaskGroup struct {
	ID        int64       `json:"id"`
	GroupKey  pgtype.Text `json:"group_key"`
	BlockAddr pgtype.Int8 `json:"block_addr"`
}

type TaskStatus

type TaskStatus string

const (
	TaskStatusQUEUED    TaskStatus = "QUEUED"
	TaskStatusRUNNING   TaskStatus = "RUNNING"
	TaskStatusSUCCEEDED TaskStatus = "SUCCEEDED"
	TaskStatusFAILED    TaskStatus = "FAILED"
	TaskStatusCANCELLED TaskStatus = "CANCELLED"
)

func (*TaskStatus) Scan

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

type UpdateTaskStatusParams

type UpdateTaskStatusParams struct {
	Status NullTaskStatus `json:"status"`
	ID     pgtype.Int8    `json:"id"`
}