utilisation

Documentation

Index

• func GetAllocationByQueue(pods []*v1.Pod) map[string]armadaresource.ComputeResources
• func GetAllocationByQueueAndPriority(pods []*v1.Pod) map[string]map[int32]armadaresource.ComputeResources
• type ClusterAvailableCapacityReport
• type ClusterUtilisationService
  • func NewClusterUtilisationService(clusterContext context.ClusterContext, ...) *ClusterUtilisationService
  • func (clusterUtilisationService *ClusterUtilisationService) GetAllNodeGroupAllocationInfo(legacy bool) ([]*NodeGroupAllocationInfo, error)
  • func (cls *ClusterUtilisationService) GetAvailableClusterCapacity(legacy bool) (*ClusterAvailableCapacityReport, error)
  • func (clusterUtilisationService *ClusterUtilisationService) ReportClusterUtilisation()
• type NodeGroupAllocationInfo
• type PodUtilisationService
• type PodUtilisationServiceImpl
  • func NewPodUtilisationService(clusterContext cluster_context.ClusterContext, ...) *PodUtilisationServiceImpl
  • func (q *PodUtilisationServiceImpl) GetPodUtilisation(pod *v1.Pod) *domain.UtilisationData
  • func (q *PodUtilisationServiceImpl) RefreshUtilisationData()
• type UtilisationEventReporter
  • func NewUtilisationEventReporter(clusterContext clusterContext.ClusterContext, ...) *UtilisationEventReporter
  • func (r *UtilisationEventReporter) ReportUtilisationEvents()
• type UtilisationService

Functions

func GetAllocationByQueue

func GetAllocationByQueue(pods []*v1.Pod) map[string]armadaresource.ComputeResources

func GetAllocationByQueueAndPriority

func GetAllocationByQueueAndPriority(pods []*v1.Pod) map[string]map[int32]armadaresource.ComputeResources

Types

type ClusterAvailableCapacityReport

type ClusterAvailableCapacityReport struct {
	AvailableCapacity *armadaresource.ComputeResources
	Nodes             []api.NodeInfo
}

type ClusterUtilisationService

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

func NewClusterUtilisationService

func NewClusterUtilisationService(
	clusterContext context.ClusterContext,
	queueUtilisationService PodUtilisationService,
	nodeInfoService node.NodeInfoService,
	usageClient api.UsageClient,
	trackedNodeLabels []string,
	nodeIdLabel string,
	minimumResourcesMarkedAllocatedToNonArmadaPodsPerNode armadaresource.ComputeResources,
	minimumResourcesMarkedAllocatedToNonArmadaPodsPerNodePriority int32,
) *ClusterUtilisationService

func (*ClusterUtilisationService) GetAllNodeGroupAllocationInfo

func (clusterUtilisationService *ClusterUtilisationService) GetAllNodeGroupAllocationInfo(legacy bool) ([]*NodeGroupAllocationInfo, error)

GetAllNodeGroupAllocationInfo returns allocation information for all nodes on the cluster. NodeGroupCapacity is the total capacity of a nodegroup (including cordoned nodes) NodeGroupAllocatableCapacity is the capacity available to armada on schedulable nodes NodeGroupCordonedCapacity is the resource in use by armada on unschedulable nodes

func (*ClusterUtilisationService) GetAvailableClusterCapacity

func (cls *ClusterUtilisationService) GetAvailableClusterCapacity(legacy bool) (*ClusterAvailableCapacityReport, error)

func (*ClusterUtilisationService) ReportClusterUtilisation

func (clusterUtilisationService *ClusterUtilisationService) ReportClusterUtilisation()

type NodeGroupAllocationInfo

type NodeGroupAllocationInfo struct {
	NodeType                     *api.NodeTypeIdentifier
	Nodes                        []*v1.Node
	NodeGroupCapacity            armadaresource.ComputeResources
	NodeGroupAllocatableCapacity armadaresource.ComputeResources
	NodeGroupCordonedCapacity    armadaresource.ComputeResources
}

type PodUtilisationService

type PodUtilisationService interface {
	GetPodUtilisation(pod *v1.Pod) *domain.UtilisationData
}

type PodUtilisationServiceImpl

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

func NewPodUtilisationService

func NewPodUtilisationService(
	clusterContext cluster_context.ClusterContext,
	nodeInfoService node.NodeInfoService,
	customConfigs []configuration.CustomUsageMetrics,
	httpClient *http.Client,
) *PodUtilisationServiceImpl

func (*PodUtilisationServiceImpl) GetPodUtilisation

func (q *PodUtilisationServiceImpl) GetPodUtilisation(pod *v1.Pod) *domain.UtilisationData

func (*PodUtilisationServiceImpl) RefreshUtilisationData

func (q *PodUtilisationServiceImpl) RefreshUtilisationData()

type UtilisationEventReporter

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

func NewUtilisationEventReporter

func NewUtilisationEventReporter(
	clusterContext clusterContext.ClusterContext,
	podUtilisation PodUtilisationService,
	eventReporter reporter.EventReporter,
	reportingPeriod time.Duration,
	legacyMode bool,
) *UtilisationEventReporter

func (*UtilisationEventReporter) ReportUtilisationEvents

func (r *UtilisationEventReporter) ReportUtilisationEvents()

type UtilisationService

type UtilisationService interface {
	GetAvailableClusterCapacity(legacy bool) (*ClusterAvailableCapacityReport, error)
	GetAllNodeGroupAllocationInfo(legacy bool) ([]*NodeGroupAllocationInfo, error)
}