sql

package
v0.9.280 Latest Latest
Warning

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

Go to latest
Published: Dec 28, 2025 License: AGPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Checkpoint

type Checkpoint struct {
	ID   string
	Jid  string
	Path string
	Time time.Time
	Size int64
}

type CreateCheckpointParams

type CreateCheckpointParams struct {
	ID   string
	Jid  string
	Path string
	Time time.Time
	Size int64
}

type CreateHostParams

type CreateHostParams struct {
	ID            string
	Mac           string
	Hostname      string
	Os            string
	Platform      string
	Kernelversion string
	Kernelarch    string
	Cpuphysicalid string
	Cpuvendorid   string
	Cpufamily     string
	Cpucount      int64
	Memtotal      int64
}

type CreateJobParams

type CreateJobParams struct {
	Jid        string
	Type       string
	Gpuenabled int64
	Log        string
	Details    []byte
	Pid        int64
	Cmdline    string
	Starttime  time.Time
	Workingdir string
	Status     string
	Isrunning  int64
	Hostid     string
	Uids       string
	Gids       string
	Groups     string
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type Host

type Host struct {
	ID            string
	Mac           string
	Hostname      string
	Os            string
	Platform      string
	Kernelversion string
	Kernelarch    string
	Cpuphysicalid string
	Cpuvendorid   string
	Cpufamily     string
	Cpucount      int64
	Memtotal      int64
}

type Job

type Job struct {
	Jid        string
	Type       string
	Gpuenabled int64
	Log        string
	Details    []byte
	Pid        int64
	Cmdline    string
	Starttime  time.Time
	Workingdir string
	Status     string
	Isrunning  int64
	Hostid     string
	Uids       string
	Gids       string
	Groups     string
}

type ListJobsByHostIDsRow

type ListJobsByHostIDsRow struct {
	Job  Job
	Host Host
}

type ListJobsByIDsRow

type ListJobsByIDsRow struct {
	Job  Job
	Host Host
}

type ListJobsRow

type ListJobsRow struct {
	Job  Job
	Host Host
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) CreateCheckpoint

func (q *Queries) CreateCheckpoint(ctx context.Context, arg CreateCheckpointParams) error

func (*Queries) CreateHost

func (q *Queries) CreateHost(ctx context.Context, arg CreateHostParams) error

func (*Queries) CreateJob

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

func (*Queries) DeleteCheckpoint

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

func (*Queries) DeleteHost

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

func (*Queries) DeleteJob

func (q *Queries) DeleteJob(ctx context.Context, jid string) error

func (*Queries) ListCheckpoints

func (q *Queries) ListCheckpoints(ctx context.Context) ([]Checkpoint, error)

func (*Queries) ListCheckpointsByIDs

func (q *Queries) ListCheckpointsByIDs(ctx context.Context, ids []string) ([]Checkpoint, error)

func (*Queries) ListCheckpointsByJIDs

func (q *Queries) ListCheckpointsByJIDs(ctx context.Context, jids []string) ([]Checkpoint, error)

func (*Queries) ListHosts

func (q *Queries) ListHosts(ctx context.Context) ([]Host, error)

func (*Queries) ListHostsByIDs

func (q *Queries) ListHostsByIDs(ctx context.Context, ids []string) ([]Host, error)

func (*Queries) ListJobs

func (q *Queries) ListJobs(ctx context.Context) ([]ListJobsRow, error)

func (*Queries) ListJobsByHostIDs

func (q *Queries) ListJobsByHostIDs(ctx context.Context, hostIds []string) ([]ListJobsByHostIDsRow, error)

func (*Queries) ListJobsByIDs

func (q *Queries) ListJobsByIDs(ctx context.Context, ids []string) ([]ListJobsByIDsRow, error)

func (*Queries) UpdateCheckpoint

func (q *Queries) UpdateCheckpoint(ctx context.Context, arg UpdateCheckpointParams) error

func (*Queries) UpdateHost

func (q *Queries) UpdateHost(ctx context.Context, arg UpdateHostParams) error

func (*Queries) UpdateJob

func (q *Queries) UpdateJob(ctx context.Context, arg UpdateJobParams) error

func (*Queries) WithTx

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

type UpdateCheckpointParams

type UpdateCheckpointParams struct {
	Jid  string
	Path string
	Time time.Time
	Size int64
	ID   string
}

type UpdateHostParams

type UpdateHostParams struct {
	Mac           string
	Hostname      string
	Os            string
	Platform      string
	Kernelversion string
	Kernelarch    string
	Cpuphysicalid string
	Cpuvendorid   string
	Cpufamily     string
	Cpucount      int64
	Memtotal      int64
	ID            string
}

type UpdateJobParams

type UpdateJobParams struct {
	Type       string
	Gpuenabled int64
	Log        string
	Details    []byte
	Pid        int64
	Cmdline    string
	Starttime  time.Time
	Workingdir string
	Status     string
	Isrunning  int64
	Hostid     string
	Uids       string
	Gids       string
	Groups     string
	Jid        string
}

Jump to

Keyboard shortcuts

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