jobdb

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 InsertJobParams struct {
	ID        string
	Type      string
	ArgsData  []byte
	Status    string
	Result    string
	Priority  int64
	CreatedAt time.Time
	UpdatedAt time.Time
}

type Job struct {
	ID        string
	Type      string
	ArgsData  []byte
	Status    string
	Result    string
	Priority  int64
	CreatedAt time.Time
	UpdatedAt time.Time
}

type ListAllJobsParams struct {
	Column1 interface{}
	Column2 interface{}
	Offset  int64
}

type ListJobsByStatusAndTypeParams struct {
	Status  string
	Type    string
	Column3 interface{}
	Column4 interface{}
	Offset  int64
}

type ListJobsByStatusParams struct {
	Status  string
	Column2 interface{}
	Column3 interface{}
	Offset  int64
}

type ListJobsByTypeParams struct {
	Type    string
	Column2 interface{}
	Column3 interface{}
	Offset  int64
}

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

type UpdateJobStatusParams struct {
	Status    string
	Result    string
	UpdatedAt time.Time
	ID        string
}

type UpsertJobParams struct {
	ID        string
	Type      string
	ArgsData  []byte
	Status    string
	Result    string
	Priority  int64
	CreatedAt time.Time
	UpdatedAt time.Time
}