postgres

Documentation

Index

• type CreateTaskParams
• type DBTX
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) CreateTask(ctx context.Context, arg CreateTaskParams) (int32, error)
  • func (q *Queries) DeleteTask(ctx context.Context, id int32) error
  • func (q *Queries) GetTaskState(ctx context.Context, id int32) (string, error)
  • func (q *Queries) SetStateToDone(ctx context.Context, id int32) (int32, error)
  • func (q *Queries) SetStateToProcessing(ctx context.Context, id int32) (int32, error)
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type Task

Types

type CreateTaskParams

type CreateTaskParams struct {
	Type  int32
	Value int32
}

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
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CreateTask

func (q *Queries) CreateTask(ctx context.Context, arg CreateTaskParams) (int32, error)

func (*Queries) DeleteTask

func (q *Queries) DeleteTask(ctx context.Context, id int32) error

func (*Queries) GetTaskState

func (q *Queries) GetTaskState(ctx context.Context, id int32) (string, error)

func (*Queries) SetStateToDone

func (q *Queries) SetStateToDone(ctx context.Context, id int32) (int32, error)

func (*Queries) SetStateToProcessing

func (q *Queries) SetStateToProcessing(ctx context.Context, id int32) (int32, error)

func (*Queries) WithTx

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

type Task

type Task struct {
	ID             int32
	Type           int32
	Value          int32
	State          string
	CreationTime   float64
	LastUpdateTime float64
}