database

Dec 3, 2024

Changes in this version

type Job

+ BidPrice float64

type SelectInitialJobsRow

+ BidPrice float64

type SelectUpdatedJobsRow

+ BidPrice float64

Nov 25, 2024

Changes in this version

+ type ExecutorSetting struct

+ CordonReason string

+ Cordoned bool

+ ExecutorID string

+ SetAtTime time.Time

+ SetByUser string

type Queries

+ func (q *Queries) SelectJobsByExecutorAndQueues(ctx context.Context, arg SelectJobsByExecutorAndQueuesParams) ([]Job, error)

+ func (q *Queries) SelectLeasedJobsByQueue(ctx context.Context, queue []string) ([]Job, error)

+ func (q *Queries) SelectPendingJobsByQueue(ctx context.Context, queue []string) ([]Job, error)

+ func (q *Queries) SelectQueuedJobsByQueue(ctx context.Context, queue []string) ([]Job, error)

+ func (q *Queries) SelectRunningJobsByQueue(ctx context.Context, queue []string) ([]Job, error)

+ type SelectJobsByExecutorAndQueuesParams struct

+ Executor string

+ Queues []string

Nov 11, 2024

Changes in this version

type JobRepository

+ FetchInitialJobs func(ctx *armadacontext.Context) ([]Job, []Run, error)

type PostgresJobRepository

+ func (r *PostgresJobRepository) FetchInitialJobs(ctx *armadacontext.Context) ([]Job, []Run, error)

type Queries

+ func (q *Queries) SelectAllJobsByExecutorAndQueues(ctx context.Context, executor string, queues []string) ([]Job, error)

+ func (q *Queries) SelectAllJobsByQueueAndJobState(ctx context.Context, queue string, ...) ([]Job, error)

+ func (q *Queries) SelectInitialJobs(ctx context.Context, arg SelectInitialJobsParams) ([]SelectInitialJobsRow, error)

+ func (q *Queries) SelectInitialRuns(ctx context.Context, arg SelectInitialRunsParams) ([]Run, error)

+ func (q *Queries) SelectLatestJobRunSerial(ctx context.Context) (int64, error)

+ func (q *Queries) SelectLatestJobSerial(ctx context.Context) (int64, error)

+ type SelectInitialJobsParams struct

+ Limit int32

+ Serial int64

+ type SelectInitialJobsRow struct

+ CancelByJobsetRequested bool

+ CancelRequested bool

+ Cancelled bool

+ Failed bool

+ JobID string

+ JobSet string

+ Pools []string

+ Priority int64

+ Queue string

+ Queued bool

+ QueuedVersion int32

+ SchedulingInfo []byte

+ SchedulingInfoVersion int32

+ Serial int64

+ Submitted int64

+ Succeeded bool

+ Validated bool

+ func (row SelectInitialJobsRow) GetSerial() int64

+ type SelectInitialRunsParams struct

+ JobIds []string

+ Limit int32

+ Serial int64

Oct 22, 2024

Changes in this version

type ExecutorSettings

+ SetAtTime time.Time

+ SetByUser string

type UpsertExecutorSettingsParams

+ SetAtTime time.Time

+ SetByUser string

Oct 17, 2024

Changes in this version

+ type DeleteExecutorSettingsParams struct

+ ExecutorID string

type ExecutorRepository

+ GetExecutorSettings func(ctx *armadacontext.Context) ([]*schedulerobjects.ExecutorSettings, error)

+ type ExecutorSettings struct

+ CordonReason string

+ Cordoned bool

+ ExecutorId string

type PostgresExecutorRepository

+ func (r *PostgresExecutorRepository) GetExecutorSettings(ctx *armadacontext.Context) ([]*schedulerobjects.ExecutorSettings, error)

type Queries

+ func (q *Queries) DeleteExecutorSettings(ctx context.Context, arg DeleteExecutorSettingsParams) error

+ func (q *Queries) SelectAllExecutorSettings(ctx context.Context) ([]ExecutorSettings, error)

+ func (q *Queries) UpsertExecutorSettings(ctx context.Context, arg UpsertExecutorSettingsParams) error

+ type UpsertExecutorSettingsParams struct

+ CordonReason string

+ Cordoned bool

+ ExecutorID string

Oct 9, 2024

Changes in this version

type JobRunLease

+ Pool string

Jul 9, 2024

Changes in this version

type Run

+ Pool string

May 29, 2024

Changes in this version

type Job

+ Pools []string

type SelectUpdatedJobsRow

+ Pools []string

May 19, 2024

Changes in this version

+ type MarkJobsCancelRequestedByIdParams struct

+ JobIds []string

+ JobSet string

+ Queue string

type UpdateJobPriorityByIdParams

+ JobIds []string

+ JobSet string

+ Queue string

May 13, 2024

Changes in this version

type Job

+ Validated bool

type Queries

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

type SelectUpdatedJobsRow

+ Validated bool

Apr 16, 2024

Changes in this version

+ type MarkJobRunsPreemptRequestedByJobIdParams struct

+ JobIds []string

+ JobSet string

+ Queue string

type Queries

+ func (q *Queries) MarkJobRunsPreemptRequestedByJobId(ctx context.Context, arg MarkJobRunsPreemptRequestedByJobIdParams) error

type Run

+ PreemptRequested bool

+ Queue string

Feb 1, 2024

Changes in this version

type JobRunLease

+ PodRequirementsOverlay []byte

type Run

+ PodRequirementsOverlay []byte

Jan 17, 2024

Changes in this version

type Run

+ Pending bool

+ Preempted bool

+ PreemptedTimestamp *time.Time

Dec 19, 2023

Changes in this version

type Run

+ ScheduledAtPriority *int32

Oct 20, 2023

Changes in this version

type Queries

+ func (q *Queries) SetLeasedTime(ctx context.Context, arg SetLeasedTimeParams) error

+ func (q *Queries) SetPendingTime(ctx context.Context, arg SetPendingTimeParams) error

+ func (q *Queries) SetRunningTime(ctx context.Context, arg SetRunningTimeParams) error

+ func (q *Queries) SetTerminatedTime(ctx context.Context, arg SetTerminatedTimeParams) error

type Run

+ LeasedTimestamp *time.Time

+ PendingTimestamp *time.Time

+ RunningTimestamp *time.Time

+ TerminatedTimestamp *time.Time

+ type SetLeasedTimeParams struct

+ LeasedTimestamp *time.Time

+ RunID uuid.UUID

+ type SetPendingTimeParams struct

+ PendingTimestamp *time.Time

+ RunID uuid.UUID

+ type SetRunningTimeParams struct

+ RunID uuid.UUID

+ RunningTimestamp *time.Time

+ type SetTerminatedTimeParams struct

+ RunID uuid.UUID

+ TerminatedTimestamp *time.Time

May 20, 2023

Changes in this version

+ type MarkJobsCancelRequestedBySetAndQueuedStateParams struct

+ JobSet string

+ Queue string

+ QueuedStates []bool

type Queries

+ func (q *Queries) MarkJobsCancelRequestedBySetAndQueuedState(ctx context.Context, arg MarkJobsCancelRequestedBySetAndQueuedStateParams) error

type UpdateJobPriorityByJobSetParams

+ Queue string

May 8, 2023

Changes in this version

type Job

+ Queued bool

+ QueuedVersion int32

+ SchedulingInfoVersion int32

type Queries

+ func (q *Queries) MarkJobRunsAttemptedById(ctx context.Context, runIds []uuid.UUID) error

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

+ func (q *Queries) UpdateJobQueued(ctx context.Context, arg UpdateJobQueuedParams) error

+ func (q *Queries) UpdateJobSchedulingInfo(ctx context.Context, arg UpdateJobSchedulingInfoParams) error

type Run

+ RunAttempted bool

type SelectUpdatedJobsRow

+ Queued bool

+ QueuedVersion int32

+ SchedulingInfoVersion int32

+ type UpdateJobQueuedParams struct

+ JobID string

+ Queued bool

+ QueuedVersion int32

+ type UpdateJobSchedulingInfoParams struct

+ JobID string

+ SchedulingInfo []byte

+ SchedulingInfoVersion int32

Feb 23, 2023

Changes in this version

type Job

+ CancelByJobsetRequested bool

type JobRunLease

+ Node string

type Run

+ Created int64

+ Node string

type SelectUpdatedJobsRow

+ CancelByJobsetRequested bool

Feb 8, 2023

Changes in this version

+ type RedisExecutorRepository struct

+ func NewRedisExecutorRepository(db redis.UniversalClient, schedulerName string) *RedisExecutorRepository

+ func (r *RedisExecutorRepository) GetExecutors(_ context.Context) ([]*schedulerobjects.Executor, error)

+ func (r *RedisExecutorRepository) GetLastUpdateTimes(_ context.Context) (map[string]time.Time, error)

+ func (r *RedisExecutorRepository) StoreExecutor(_ context.Context, executor *schedulerobjects.Executor) error

Feb 2, 2023

Changes in this version

+ type InsertMarkerParams struct

+ Created time.Time

+ GroupID uuid.UUID

+ PartitionID int32

type Queries

+ func (q *Queries) InsertMarker(ctx context.Context, arg InsertMarkerParams) error

Jan 27, 2023

Changes in this version

+ func PruneDb(ctx ctx.Context, db *pgx.Conn, batchLimit int, ...) error

type JobRunError

+ JobID string

+ type LegacyQueueRepository struct

+ func NewLegacyQueueRepository(db redis.UniversalClient) *LegacyQueueRepository

+ func (r *LegacyQueueRepository) GetAllQueues() ([]*Queue, error)

type Marker

+ Created time.Time

type Queries

+ func (q *Queries) DeleteOldMarkers(ctx context.Context, cutoff time.Time) error

+ func (q *Queries) MarkJobRunsReturnedById(ctx context.Context, runIds []uuid.UUID) error

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

+ func (q *Queries) MarkJobsCancelRequestedBySets(ctx context.Context, jobSets []string) error

+ func (q *Queries) SelectAllJobIds(ctx context.Context) ([]string, error)

+ func (q *Queries) SelectAllMarkers(ctx context.Context) ([]Marker, error)

+ func (q *Queries) SelectAllRunErrors(ctx context.Context) ([]JobRunError, error)

+ func (q *Queries) SelectAllRunIds(ctx context.Context) ([]uuid.UUID, error)

Jan 23, 2023

Changes in this version

+ func Migrate(ctx context.Context, db pgxtype.Querier) error

+ func WithTestDb(action func(queries *Queries, db *pgxpool.Pool) error) error

+ type DBTX interface

+ Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)

+ Query func(context.Context, string, ...interface{}) (pgx.Rows, error)

+ QueryRow func(context.Context, string, ...interface{}) pgx.Row

+ type Executor struct

+ ExecutorID string

+ LastRequest []byte

+ LastUpdated time.Time

+ type ExecutorRepository interface

+ GetExecutors func(ctx context.Context) ([]*schedulerobjects.Executor, error)

+ GetLastUpdateTimes func(ctx context.Context) (map[string]time.Time, error)

+ StoreExecutor func(ctx context.Context, executor *schedulerobjects.Executor) error

+ type Job struct

+ CancelRequested bool

+ Cancelled bool

+ Failed bool

+ Groups []byte

+ JobID string

+ JobSet string

+ LastModified time.Time

+ Priority int64

+ Queue string

+ SchedulingInfo []byte

+ Serial int64

+ SubmitMessage []byte

+ Submitted int64

+ Succeeded bool

+ UserID string

+ func (job Job) GetSerial() int64

+ func (job Job) InTerminalState() bool

+ type JobRepository interface

+ CountReceivedPartitions func(ctx context.Context, groupId uuid.UUID) (uint32, error)

+ FetchJobRunErrors func(ctx context.Context, runIds []uuid.UUID) (map[uuid.UUID]*armadaevents.JobRunErrors, error)

+ FetchJobRunLeases func(ctx context.Context, executor string, maxResults int, ...) ([]*JobRunLease, error)

+ FetchJobUpdates func(ctx context.Context, jobSerial int64, jobRunSerial int64) ([]Job, []Run, error)

+ FindInactiveRuns func(ctx context.Context, runIds []uuid.UUID) ([]uuid.UUID, error)

+ type JobRunError struct

+ Error []byte

+ LastModified time.Time

+ RunID uuid.UUID

+ Serial int64

+ type JobRunLease struct

+ Groups []byte

+ JobSet string

+ Queue string

+ RunID uuid.UUID

+ SubmitMessage []byte

+ UserID string

+ type Marker struct

+ GroupID uuid.UUID

+ PartitionID int32

+ type PostgresExecutorRepository struct

+ func NewPostgresExecutorRepository(db *pgxpool.Pool, compressor compress.Compressor, ...) *PostgresExecutorRepository

+ func (r *PostgresExecutorRepository) GetExecutors(ctx context.Context) ([]*schedulerobjects.Executor, error)

+ func (r *PostgresExecutorRepository) GetLastUpdateTimes(ctx context.Context) (map[string]time.Time, error)

+ func (r *PostgresExecutorRepository) StoreExecutor(ctx context.Context, executor *schedulerobjects.Executor) error

+ type PostgresJobRepository struct

+ func NewPostgresJobRepository(db *pgxpool.Pool, batchSize int32) *PostgresJobRepository

+ func (r *PostgresJobRepository) CountReceivedPartitions(ctx context.Context, groupId uuid.UUID) (uint32, error)

+ func (r *PostgresJobRepository) FetchJobRunErrors(ctx context.Context, runIds []uuid.UUID) (map[uuid.UUID]*armadaevents.JobRunErrors, error)

+ func (r *PostgresJobRepository) FetchJobRunLeases(ctx context.Context, executor string, maxResults int, ...) ([]*JobRunLease, error)

+ func (r *PostgresJobRepository) FetchJobUpdates(ctx context.Context, jobSerial int64, jobRunSerial int64) ([]Job, []Run, error)

+ func (r *PostgresJobRepository) FindInactiveRuns(ctx context.Context, runIds []uuid.UUID) ([]uuid.UUID, error)

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) CountGroup(ctx context.Context, groupID uuid.UUID) (int64, error)

+ func (q *Queries) FindActiveRuns(ctx context.Context, runIds []uuid.UUID) ([]uuid.UUID, error)

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

+ func (q *Queries) MarkJobRunsCancelledBySets(ctx context.Context, jobSets []string) error

+ func (q *Queries) MarkJobRunsFailedById(ctx context.Context, runIds []uuid.UUID) error

+ func (q *Queries) MarkJobRunsRunningById(ctx context.Context, runIds []uuid.UUID) error

+ func (q *Queries) MarkJobRunsSucceededById(ctx context.Context, runIds []uuid.UUID) error

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

+ func (q *Queries) MarkJobsCancelledBySets(ctx context.Context, jobSets []string) error

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

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

+ func (q *Queries) SelectAllExecutors(ctx context.Context) ([]Executor, error)

+ func (q *Queries) SelectExecutorUpdateTimes(ctx context.Context) ([]SelectExecutorUpdateTimesRow, error)

+ func (q *Queries) SelectJobsForExecutor(ctx context.Context, arg SelectJobsForExecutorParams) ([]SelectJobsForExecutorRow, error)

+ func (q *Queries) SelectNewJobs(ctx context.Context, arg SelectNewJobsParams) ([]Job, error)

+ func (q *Queries) SelectNewRuns(ctx context.Context, arg SelectNewRunsParams) ([]Run, error)

+ func (q *Queries) SelectNewRunsForJobs(ctx context.Context, arg SelectNewRunsForJobsParams) ([]Run, error)

+ func (q *Queries) SelectRunErrorsById(ctx context.Context, runIds []uuid.UUID) ([]JobRunError, error)

+ func (q *Queries) SelectUpdatedJobs(ctx context.Context, arg SelectUpdatedJobsParams) ([]SelectUpdatedJobsRow, error)

+ func (q *Queries) UpdateJobPriorityById(ctx context.Context, arg UpdateJobPriorityByIdParams) error

+ func (q *Queries) UpdateJobPriorityByJobSet(ctx context.Context, arg UpdateJobPriorityByJobSetParams) error

+ func (q *Queries) UpsertExecutor(ctx context.Context, arg UpsertExecutorParams) error

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

+ type Queue struct

+ Name string

+ Weight float64

+ type QueueRepository interface

+ GetAllQueues func() ([]*Queue, error)

+ type Run struct

+ Cancelled bool

+ Executor string

+ Failed bool

+ JobID string

+ JobSet string

+ LastModified time.Time

+ Returned bool

+ RunID uuid.UUID

+ Running bool

+ Serial int64

+ Succeeded bool

+ func (run Run) GetSerial() int64

+ type SelectExecutorUpdateTimesRow struct

+ ExecutorID string

+ LastUpdated time.Time

+ type SelectJobsForExecutorParams struct

+ Executor string

+ RunIds []uuid.UUID

+ type SelectJobsForExecutorRow struct

+ Groups []byte

+ JobSet string

+ Queue string

+ RunID uuid.UUID

+ SubmitMessage []byte

+ UserID string

+ type SelectNewJobsParams struct

+ Limit int32

+ Serial int64

+ type SelectNewRunsForJobsParams struct

+ JobIds []string

+ Serial int64

+ type SelectNewRunsParams struct

+ Limit int32

+ Serial int64

+ type SelectUpdatedJobsParams struct

+ Limit int32

+ Serial int64

+ type SelectUpdatedJobsRow struct

+ CancelRequested bool

+ Cancelled bool

+ Failed bool

+ JobID string

+ JobSet string

+ Priority int64

+ Queue string

+ SchedulingInfo []byte

+ Serial int64

+ Submitted int64

+ Succeeded bool

+ func (row SelectUpdatedJobsRow) GetSerial() int64

+ type UpdateJobPriorityByIdParams struct

+ JobID string

+ Priority int64

+ type UpdateJobPriorityByJobSetParams struct

+ JobSet string

+ Priority int64

+ type UpsertExecutorParams struct

+ ExecutorID string

+ LastRequest []byte

+ UpdateTime time.Time