service

Documentation

Index

• type ClusterAllocationService
  • func NewClusterAllocationService(clusterContext context.ClusterContext, eventReporter reporter.EventReporter, ...) *ClusterAllocationService
  • func (allocationService *ClusterAllocationService) AllocateSpareClusterCapacity()
• type ClusterAvailableCapacityReport
• type ClusterUtilisationService
  • func NewClusterUtilisationService(clusterContext context.ClusterContext, ...) *ClusterUtilisationService
  • func (clusterUtilisationService *ClusterUtilisationService) GetAllAvailableProcessingNodes() ([]*v1.Node, error)
  • func (clusterUtilisationService *ClusterUtilisationService) GetAvailableClusterCapacity() (*ClusterAvailableCapacityReport, error)
  • func (clusterUtilisationService *ClusterUtilisationService) GetTotalAllocatableClusterCapacity() (*common.ComputeResources, 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 MetricsServerPodUtilisationService
  • func NewMetricsServerQueueUtilisationService(clusterContext context.ClusterContext, ...) *MetricsServerPodUtilisationService
  • func (q *MetricsServerPodUtilisationService) GetPodUtilisation(pod *v1.Pod) common.ComputeResources
  • func (q *MetricsServerPodUtilisationService) RefreshUtilisationData()
• type PodUtilisationService
• type StuckPodDetector
  • func NewPodProgressMonitorService(clusterContext context.ClusterContext, eventReporter reporter.EventReporter, ...) *StuckPodDetector
  • func (d *StuckPodDetector) HandleStuckPods()
• type UsageMetric
  • func (u *UsageMetric) DeepCopy() *UsageMetric
• type UtilisationService

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 ClusterAvailableCapacityReport

type ClusterAvailableCapacityReport struct {
	AvailableCapacity *common.ComputeResources
	NodeLabels        []map[string]string
	NodesSizes        []common.ComputeResources
}

type ClusterUtilisationService

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

func NewClusterUtilisationService

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

func (*ClusterUtilisationService) GetAllAvailableProcessingNodes

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

func (*ClusterUtilisationService) GetAvailableClusterCapacity

func (clusterUtilisationService *ClusterUtilisationService) GetAvailableClusterCapacity() (*ClusterAvailableCapacityReport, error)

func (*ClusterUtilisationService) GetTotalAllocatableClusterCapacity

func (clusterUtilisationService *ClusterUtilisationService) GetTotalAllocatableClusterCapacity() (*common.ComputeResources, 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,
	minimumJobSize common.ComputeResources) *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, nodeSizes []common.ComputeResources, leasedResourceByQueue map[string]common.ComputeResources) ([]*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, nodeSizes []common.ComputeResources, leasedResourceByQueue map[string]common.ComputeResources) ([]*api.Job, error)
	ReportDone(pods []*v1.Pod) error
}

type MetricsServerPodUtilisationService

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

func NewMetricsServerQueueUtilisationService

func NewMetricsServerQueueUtilisationService(clusterContext context.ClusterContext, metricsServerClient metrics_server.Interface) *MetricsServerPodUtilisationService

func (*MetricsServerPodUtilisationService) GetPodUtilisation

func (q *MetricsServerPodUtilisationService) GetPodUtilisation(pod *v1.Pod) common.ComputeResources

func (*MetricsServerPodUtilisationService) RefreshUtilisationData

func (q *MetricsServerPodUtilisationService) RefreshUtilisationData()

type PodUtilisationService

type PodUtilisationService interface {
	GetPodUtilisation(pod *v1.Pod) common.ComputeResources
}

type StuckPodDetector

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

func NewPodProgressMonitorService

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

func (*StuckPodDetector) HandleStuckPods

func (d *StuckPodDetector) HandleStuckPods()

type UsageMetric

type UsageMetric struct {
	ResourceUsed common.ComputeResources
}

func (*UsageMetric) DeepCopy

func (u *UsageMetric) DeepCopy() *UsageMetric

type UtilisationService

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