database

Documentation

Index

• type DBTX
• type GetJobDetailsRow
• type GetJobStatesRow
• type Job
• type JobDeduplication
• type JobError
• type JobRun
• type JobSpec
• type Queries
  • func New(db DBTX) *Queries
  • func (q *Queries) GetJobDetails(ctx context.Context, jobIds []string) ([]GetJobDetailsRow, error)
  • func (q *Queries) GetJobRunsByJobIds(ctx context.Context, jobIds []string) ([]JobRun, error)
  • func (q *Queries) GetJobRunsByRunIds(ctx context.Context, runIds []string) ([]JobRun, error)
  • func (q *Queries) GetJobStates(ctx context.Context, jobIds []string) ([]GetJobStatesRow, error)
  • func (q *Queries) WithTx(tx pgx.Tx) *Queries
• type Queue

Types

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 GetJobDetailsRow

type GetJobDetailsRow struct {
	JobID              string           `db:"job_id"`
	Queue              string           `db:"queue"`
	Jobset             string           `db:"jobset"`
	Namespace          *string          `db:"namespace"`
	State              int16            `db:"state"`
	Submitted          pgtype.Timestamp `db:"submitted"`
	Cancelled          pgtype.Timestamp `db:"cancelled"`
	CancelReason       *string          `db:"cancel_reason"`
	LastTransitionTime pgtype.Timestamp `db:"last_transition_time"`
	LatestRunID        *string          `db:"latest_run_id"`
	JobSpec            []byte           `db:"job_spec"`
}

type GetJobStatesRow

type GetJobStatesRow struct {
	JobID string `db:"job_id"`
	State int16  `db:"state"`
}

type Job

type Job struct {
	JobID                     string           `db:"job_id"`
	Queue                     string           `db:"queue"`
	Owner                     string           `db:"owner"`
	Jobset                    string           `db:"jobset"`
	Cpu                       int64            `db:"cpu"`
	Memory                    int64            `db:"memory"`
	EphemeralStorage          int64            `db:"ephemeral_storage"`
	Gpu                       int64            `db:"gpu"`
	Priority                  int64            `db:"priority"`
	Submitted                 pgtype.Timestamp `db:"submitted"`
	Cancelled                 pgtype.Timestamp `db:"cancelled"`
	State                     int16            `db:"state"`
	LastTransitionTime        pgtype.Timestamp `db:"last_transition_time"`
	LastTransitionTimeSeconds int64            `db:"last_transition_time_seconds"`
	JobSpec                   []byte           `db:"job_spec"`
	Duplicate                 bool             `db:"duplicate"`
	PriorityClass             *string          `db:"priority_class"`
	LatestRunID               *string          `db:"latest_run_id"`
	CancelReason              *string          `db:"cancel_reason"`
	Namespace                 *string          `db:"namespace"`
	Annotations               []byte           `db:"annotations"`
}

type JobDeduplication

type JobDeduplication struct {
	DeduplicationID string           `db:"deduplication_id"`
	JobID           string           `db:"job_id"`
	Inserted        pgtype.Timestamp `db:"inserted"`
}

type JobError

type JobError struct {
	JobID string `db:"job_id"`
	Error []byte `db:"error"`
}

type JobRun

type JobRun struct {
	RunID       string           `db:"run_id"`
	JobID       string           `db:"job_id"`
	Cluster     string           `db:"cluster"`
	Node        *string          `db:"node"`
	Pending     pgtype.Timestamp `db:"pending"`
	Started     pgtype.Timestamp `db:"started"`
	Finished    pgtype.Timestamp `db:"finished"`
	JobRunState int16            `db:"job_run_state"`
	Error       []byte           `db:"error"`
	ExitCode    *int32           `db:"exit_code"`
	Leased      pgtype.Timestamp `db:"leased"`
	Debug       []byte           `db:"debug"`
}

type JobSpec

type JobSpec struct {
	JobID   string `db:"job_id"`
	JobSpec []byte `db:"job_spec"`
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) GetJobDetails

func (q *Queries) GetJobDetails(ctx context.Context, jobIds []string) ([]GetJobDetailsRow, error)

func (*Queries) GetJobRunsByJobIds

func (q *Queries) GetJobRunsByJobIds(ctx context.Context, jobIds []string) ([]JobRun, error)

func (*Queries) GetJobRunsByRunIds

func (q *Queries) GetJobRunsByRunIds(ctx context.Context, runIds []string) ([]JobRun, error)

func (*Queries) GetJobStates

func (q *Queries) GetJobStates(ctx context.Context, jobIds []string) ([]GetJobStatesRow, error)

func (*Queries) WithTx

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

type Queue

type Queue struct {
	Name       string `db:"name"`
	Definition []byte `db:"definition"`
}