service

Dec 5, 2023

Changes in this version

+ const ActiveDeadlineExceeded

Aug 31, 2023

Changes in this version

type LeaseRequest

+ MaxJobsToLease uint32

Jun 28, 2023

Changes in this version

+ const ErrorDuringIssueHandling

Jun 26, 2023

Changes in this version

+ type IssueHandler struct

+ func NewIssueHandler(jobRunState job.RunStateStore, clusterContext executorContext.ClusterContext, ...) *IssueHandler

+ func (p *IssueHandler) HandlePodIssues()

Mar 16, 2023

Changes in this version

+ func ExtractEssentialJobMetadata(jobRun *executorapi.JobRunLease) (*job.RunMeta, error)

+ type JobRequester struct

+ func NewJobRequester(clusterId executorContext.ClusterIdentity, ...) *JobRequester

+ func (r *JobRequester) RequestJobsRuns()

+ type LeaseRequest struct

+ AvailableResource armadaresource.ComputeResources

+ Nodes []*api.NodeInfo

+ UnassignedJobRunIds []armadaevents.Uuid

+ type LeaseResponse struct

+ LeasedRuns []*executorapi.JobRunLease

+ RunIdsToCancel []*armadaevents.Uuid

+ RunIdsToPreempt []*armadaevents.Uuid

Feb 8, 2023

Changes in this version

+ type IssueType int

+ const ExternallyDeleted

+ const StuckStartingUp

+ const StuckTerminating

+ const UnableToSchedule

+ type PodIssueService struct

+ func NewPodIssueService(clusterContext executorContext.ClusterContext, ...) *PodIssueService

+ func (p *PodIssueService) HandlePodIssues()

Jan 27, 2023

Changes in this version

+ func ProcessRunningJobsWithThreadPool(ctx context.Context, runningJobs []*job.RunningJob, maxThreadCount int, ...)

+ type ClusterAllocator interface

+ AllocateSpareClusterCapacity func()

+ type JobLeaseRequester struct

+ func NewJobLeaseRequester() *JobLeaseRequester

+ func (requester *JobLeaseRequester) LeaseJobRuns(availableResource *armadaresource.ComputeResources, nodes []*api.NodeInfo, ...) ([]*executorapi.JobRunLease, []*armadaevents.Uuid, error)

+ type LeaseRequester interface

+ LeaseJobRuns func(availableResource *armadaresource.ComputeResources, nodes []*api.NodeInfo, ...) ([]*executorapi.JobRunLease, []*armadaevents.Uuid, error)

+ type LegacyClusterAllocationService struct

+ func NewLegacyClusterAllocationService(clusterContext context.ClusterContext, eventReporter reporter.EventReporter, ...) *LegacyClusterAllocationService

+ func (allocationService *LegacyClusterAllocationService) AllocateSpareClusterCapacity()

Jan 23, 2023

Changes in this version

+ type ClusterAllocationService struct

+ func NewClusterAllocationService(clusterContext context.ClusterContext, eventReporter reporter.EventReporter, ...) *ClusterAllocationService

+ func (allocationService *ClusterAllocationService) AllocateSpareClusterCapacity()

+ type JobLeaseService struct

+ func NewJobLeaseService(clusterContext context2.ClusterContext, queueClient api.AggregatedQueueClient, ...) *JobLeaseService

+ func (jobLeaseService *JobLeaseService) RenewJobLeases(jobs []*job.RunningJob) ([]*job.RunningJob, error)

+ func (jobLeaseService *JobLeaseService) ReportDone(jobIds []string) error

+ func (jobLeaseService *JobLeaseService) RequestJobLeases(availableResource *common.ComputeResources, nodes []api.NodeInfo, ...) ([]*api.Job, error)

+ func (jobLeaseService *JobLeaseService) ReturnLease(pod *v1.Pod, reason string, jobRunAttempted bool) error

+ func (jobLeaseService *JobLeaseService) ReturnLeaseById(jobId string, kubernetesId string, nodeLabelsToAvoid *api.OrderedStringMap, ...) error

+ type JobManager struct

+ func NewJobManager(clusterIdentity context2.ClusterIdentity, jobContext job.JobContext, ...) *JobManager

+ func (m *JobManager) ManageJobLeases()

+ type LeaseService interface

+ RenewJobLeases func(jobs []*job.RunningJob) ([]*job.RunningJob, error)

+ ReportDone func(jobIds []string) error

+ RequestJobLeases func(availableResource *common.ComputeResources, nodes []api.NodeInfo, ...) ([]*api.Job, error)

+ ReturnLease func(pod *v1.Pod, reason string, jobRunAttempted bool) error

+ type ResourceCleanupService struct

+ func NewResourceCleanupService(clusterContext clusterContext.ClusterContext, ...) *ResourceCleanupService

+ func (r *ResourceCleanupService) CleanupResources()