service

Documentation

Index

• Constants
• type ClusterAllocationService
  • func NewClusterAllocationService(clusterContext context.ClusterContext, eventReporter reporter.EventReporter, ...) *ClusterAllocationService
  • func (allocationService *ClusterAllocationService) AllocateSpareClusterCapacity()
• type ClusterUtilisationService
  • func NewClusterUtilisationService(clusterContext context.ClusterContext, usageClient api.UsageClient, ...) *ClusterUtilisationService
  • func (clusterUtilisationService *ClusterUtilisationService) GetAllAvailableProcessingNodes() ([]*v1.Node, error)
  • func (clusterUtilisationService *ClusterUtilisationService) GetAvailableClusterCapacity() (*common.ComputeResources, []map[string]string, error)
  • func (clusterUtilisationService *ClusterUtilisationService) ReportClusterUtilisation()
• type JobLeaseService
  • func NewJobLeaseService(clusterContext context2.ClusterContext, queueClient api.AggregatedQueueClient, ...) *JobLeaseService
  • func (jobLeaseService *JobLeaseService) ManageJobLeases()
  • func (jobLeaseService *JobLeaseService) ReportDone(pods []*v1.Pod) error
  • func (jobLeaseService *JobLeaseService) RequestJobLeases(availableResource *common.ComputeResources, ...) ([]*api.Job, error)
  • func (jobLeaseService *JobLeaseService) ReturnLease(pod *v1.Pod) error
• type LeaseService
• type StuckPodDetector
  • func NewPodProgressMonitorService(clusterContext context.ClusterContext, eventReporter reporter.EventReporter, ...) *StuckPodDetector
  • func (podProgressMonitor *StuckPodDetector) HandleStuckPods()
• type UtilisationService

Constants

const PodNamePrefix string = "armada-"

Types

type ClusterAllocationService

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

func NewClusterAllocationService

func NewClusterAllocationService(
	clusterContext context.ClusterContext,
	eventReporter reporter.EventReporter,
	leaseService LeaseService,
	utilisationService UtilisationService) *ClusterAllocationService

func (*ClusterAllocationService) AllocateSpareClusterCapacity

func (allocationService *ClusterAllocationService) AllocateSpareClusterCapacity()

type ClusterUtilisationService

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

func NewClusterUtilisationService

func NewClusterUtilisationService(
	clusterContext context.ClusterContext,
	usageClient api.UsageClient,
	trackedNodeLabels []string) *ClusterUtilisationService

func (*ClusterUtilisationService) GetAllAvailableProcessingNodes

func (clusterUtilisationService *ClusterUtilisationService) GetAllAvailableProcessingNodes() ([]*v1.Node, error)

func (*ClusterUtilisationService) GetAvailableClusterCapacity

func (clusterUtilisationService *ClusterUtilisationService) GetAvailableClusterCapacity() (*common.ComputeResources, []map[string]string, error)

func (*ClusterUtilisationService) ReportClusterUtilisation

func (clusterUtilisationService *ClusterUtilisationService) ReportClusterUtilisation()

type JobLeaseService

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

func NewJobLeaseService

func NewJobLeaseService(
	clusterContext context2.ClusterContext,
	queueClient api.AggregatedQueueClient,
	minimumPodAge time.Duration,
	failedPodExpiry time.Duration) *JobLeaseService

func (*JobLeaseService) ManageJobLeases

func (jobLeaseService *JobLeaseService) ManageJobLeases()

func (*JobLeaseService) ReportDone

func (jobLeaseService *JobLeaseService) ReportDone(pods []*v1.Pod) error

func (*JobLeaseService) RequestJobLeases

func (jobLeaseService *JobLeaseService) RequestJobLeases(availableResource *common.ComputeResources, availableLabels []map[string]string) ([]*api.Job, error)

func (*JobLeaseService) ReturnLease

func (jobLeaseService *JobLeaseService) ReturnLease(pod *v1.Pod) error

type LeaseService

type LeaseService interface {
	ReturnLease(pod *v1.Pod) error
	RequestJobLeases(availableResource *common.ComputeResources, availableLabels []map[string]string) ([]*api.Job, error)
	ReportDone(pods []*v1.Pod) error
}

type StuckPodDetector

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

func NewPodProgressMonitorService

func NewPodProgressMonitorService(
	clusterContext context.ClusterContext,
	eventReporter reporter.EventReporter,
	jobLeaseService LeaseService) *StuckPodDetector

func (*StuckPodDetector) HandleStuckPods

func (podProgressMonitor *StuckPodDetector) HandleStuckPods()

type UtilisationService

type UtilisationService interface {
	GetAvailableClusterCapacity() (*common.ComputeResources, []map[string]string, error)
	GetAllAvailableProcessingNodes() ([]*v1.Node, error)
}