type ArrowerGueJobsWorkerPool struct {
	ID        string
	Queue     string
	Workers   int16
	GitHash   string
	JobTypes  []string
	CreatedAt pgtype.Timestamptz
	UpdatedAt pgtype.Timestamptz
}

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 InsertHistoryParams struct {
	JobID    string
	Priority int16
	RunAt    pgtype.Timestamptz
	JobType  string
	Args     []byte
	RunCount int32
	Queue    string
	RunError string
}

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

type UpdateHistoryParams struct {
	Success  bool
	JobID    string
	RunError string
	RunCount int32
}

type UpsertScheduleParams struct {
	Queue     string
	Spec      string
	JobType   string
	Args      []byte
	UpdatedAt pgtype.Timestamptz
}

type UpsertWorkerToPoolParams struct {
	ID        string
	Queue     string
	Workers   int16
	GitHash   string
	JobTypes  []string
	UpdatedAt pgtype.Timestamptz
}