service

Documentation

Index

• Constants
• func ExtractEssentialJobMetadata(jobRun *executorapi.JobRunLease) (*job.RunMeta, error)
• type ClusterAllocationService
  • func NewClusterAllocationService(clusterId executorContext.ClusterIdentity, ...) *ClusterAllocationService
  • func (allocationService *ClusterAllocationService) AllocateSpareClusterCapacity()
• type ClusterAllocator
• type IssueHandler
  • func NewIssueHandler(jobRunState job.RunStateStore, clusterContext executorContext.ClusterContext, ...) (*IssueHandler, error)
  • func (p *IssueHandler) HandlePodIssues()
• type JobLeaseRequester
  • func NewJobLeaseRequester(executorApiClient executorapi.ExecutorApiClient, ...) *JobLeaseRequester
  • func (requester *JobLeaseRequester) LeaseJobRuns(ctx *armadacontext.Context, request *LeaseRequest) (*LeaseResponse, error)
• type JobRequester
  • func NewJobRequester(clusterId executorContext.ClusterIdentity, ...) *JobRequester
  • func (r *JobRequester) RequestJobsRuns()
• type LeaseRequest
• type LeaseRequester
• type LeaseResponse
• type ResourceCleanupService
  • func NewResourceCleanupService(clusterContext clusterContext.ClusterContext, ...) (*ResourceCleanupService, error)
  • func (r *ResourceCleanupService) CleanupResources()

Constants

const (
	UnableToSchedule podIssueType = iota
	StuckStartingUp
	StuckTerminating
	ActiveDeadlineExceeded
	ExternallyDeleted
	ErrorDuringIssueHandling
)

Functions

func ExtractEssentialJobMetadata

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

Types

type ClusterAllocationService

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

func NewClusterAllocationService

func NewClusterAllocationService(
	clusterId executorContext.ClusterIdentity,
	eventReporter reporter.EventReporter,
	jobRunStateManager job.RunStateStore,
	submitter job.Submitter,
	clusterHealthMonitor healthmonitor.HealthMonitor,
) *ClusterAllocationService

func (*ClusterAllocationService) AllocateSpareClusterCapacity

func (allocationService *ClusterAllocationService) AllocateSpareClusterCapacity()

type ClusterAllocator

type ClusterAllocator interface {
	AllocateSpareClusterCapacity()
}

type IssueHandler

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

func NewIssueHandler

func NewIssueHandler(
	jobRunState job.RunStateStore,
	clusterContext executorContext.ClusterContext,
	eventReporter reporter.EventReporter,
	stateChecksConfig configuration.StateChecksConfiguration,
	pendingPodChecker podchecks.PodChecker,
	stuckTerminatingPodExpiry time.Duration,
) (*IssueHandler, error)

func (*IssueHandler) HandlePodIssues

func (p *IssueHandler) HandlePodIssues()

type JobLeaseRequester

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

func NewJobLeaseRequester

func NewJobLeaseRequester(
	executorApiClient executorapi.ExecutorApiClient,
	clusterIdentity clusterContext.ClusterIdentity,
	minimumJobSize armadaresource.ComputeResources,
) *JobLeaseRequester

func (*JobLeaseRequester) LeaseJobRuns

func (requester *JobLeaseRequester) LeaseJobRuns(ctx *armadacontext.Context, request *LeaseRequest) (*LeaseResponse, error)

type JobRequester

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

func NewJobRequester

func NewJobRequester(
	clusterId executorContext.ClusterIdentity,
	eventReporter reporter.EventReporter,
	leaseRequester LeaseRequester,
	jobRunStateStore job.RunStateStore,
	utilisationService utilisation.UtilisationService,
	podDefaults *configuration.PodDefaults,
	maxLeasedJobs int,
) *JobRequester

func (*JobRequester) RequestJobsRuns

func (r *JobRequester) RequestJobsRuns()

type LeaseRequest

type LeaseRequest struct {
	AvailableResource   armadaresource.ComputeResources
	Nodes               []*executorapi.NodeInfo
	UnassignedJobRunIds []armadaevents.Uuid
	MaxJobsToLease      uint32
}

type LeaseRequester

type LeaseRequester interface {
	LeaseJobRuns(ctx *armadacontext.Context, request *LeaseRequest) (*LeaseResponse, error)
}

type LeaseResponse

type LeaseResponse struct {
	LeasedRuns      []*executorapi.JobRunLease
	RunIdsToCancel  []*armadaevents.Uuid
	RunIdsToPreempt []*armadaevents.Uuid
}

type ResourceCleanupService

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

func NewResourceCleanupService

func NewResourceCleanupService(
	clusterContext clusterContext.ClusterContext,
	kubernetesConfiguration configuration.KubernetesConfiguration,
) (*ResourceCleanupService, error)

func (*ResourceCleanupService) CleanupResources

func (r *ResourceCleanupService) CleanupResources()

CleanupResources

• This function finds and delete old resources. It does this in two ways:
• - By deleting all expired terminated pods
• - Deleting non-expired terminated pods when then MaxTerminatedPods limit is exceeded