aaq_evaluator

Documentation

Index

• type AaqCalculator
• type AaqEvaluator
  • func NewAaqEvaluator(podLister v1.PodLister, aaqEvalRegistery Registry, clock clock.Clock) *AaqEvaluator
  • func (aaqe *AaqEvaluator) CalculatorUsage(pod *corev1.Pod, existingPods []*corev1.Pod) (corev1.ResourceList, error)
  • func (aaqe *AaqEvaluator) Constraints(_ []corev1.ResourceName, _ runtime.Object) error
  • func (aaqe *AaqEvaluator) GroupResource() schema.GroupResource
  • func (aaqe *AaqEvaluator) Handles(operation admission.Attributes) bool
  • func (aaqe *AaqEvaluator) Matches(resourceQuota *corev1.ResourceQuota, item runtime.Object) (bool, error)
  • func (aaqe *AaqEvaluator) MatchingResources(input []corev1.ResourceName) []corev1.ResourceName
  • func (aaqe *AaqEvaluator) MatchingScopes(item runtime.Object, scopes []corev1.ScopedResourceSelectorRequirement) ([]corev1.ScopedResourceSelectorRequirement, error)
  • func (aaqe *AaqEvaluator) UncoveredQuotaScopes(limitedScopes []corev1.ScopedResourceSelectorRequirement, ...) ([]corev1.ScopedResourceSelectorRequirement, error)
  • func (aaqe *AaqEvaluator) Usage(item runtime.Object) (corev1.ResourceList, error)
  • func (aaqe *AaqEvaluator) UsageStats(options v12.UsageStatsOptions) (v12.UsageStats, error)
• type AaqEvaluatorRegistry
  • func GetAaqEvaluatorsRegistry() *AaqEvaluatorRegistry
  • func (aaqe *AaqEvaluatorRegistry) Add(aaqCalculator AaqCalculator)
  • func (aaqe *AaqEvaluatorRegistry) Collect(numberOfRequestedEvaluatorsSidecars uint, timeout time.Duration) error
  • func (aaqe *AaqEvaluatorRegistry) Usage(pod *corev1.Pod, podsState []*corev1.Pod) (rlToRet corev1.ResourceList, acceptedErr error)
• type AaqSocketCalculator
  • func (aaqsc *AaqSocketCalculator) PodUsageFunc(pod *corev1.Pod, podsState []*corev1.Pod) (corev1.ResourceList, error, bool)
• type Registry

Types

type AaqCalculator

type AaqCalculator interface {
	PodUsageFunc(pod *corev1.Pod, podsState []*corev1.Pod) (corev1.ResourceList, error, bool)
}

type AaqEvaluator

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

func NewAaqEvaluator

func NewAaqEvaluator(podLister v1.PodLister, aaqEvalRegistery Registry, clock clock.Clock) *AaqEvaluator

NewAaqEvaluator returns an evaluator that can evaluate pods with apps consideration

func (*AaqEvaluator) CalculatorUsage

func (aaqe *AaqEvaluator) CalculatorUsage(pod *corev1.Pod, existingPods []*corev1.Pod) (corev1.ResourceList, error)

func (*AaqEvaluator) Constraints

func (aaqe *AaqEvaluator) Constraints(_ []corev1.ResourceName, _ runtime.Object) error

func (*AaqEvaluator) GroupResource

func (aaqe *AaqEvaluator) GroupResource() schema.GroupResource

func (*AaqEvaluator) Handles

func (aaqe *AaqEvaluator) Handles(operation admission.Attributes) bool

func (*AaqEvaluator) Matches

func (aaqe *AaqEvaluator) Matches(resourceQuota *corev1.ResourceQuota, item runtime.Object) (bool, error)

func (*AaqEvaluator) MatchingResources

func (aaqe *AaqEvaluator) MatchingResources(input []corev1.ResourceName) []corev1.ResourceName

func (*AaqEvaluator) MatchingScopes

func (aaqe *AaqEvaluator) MatchingScopes(item runtime.Object, scopes []corev1.ScopedResourceSelectorRequirement) ([]corev1.ScopedResourceSelectorRequirement, error)

func (*AaqEvaluator) UncoveredQuotaScopes

func (aaqe *AaqEvaluator) UncoveredQuotaScopes(limitedScopes []corev1.ScopedResourceSelectorRequirement, matchedQuotaScopes []corev1.ScopedResourceSelectorRequirement) ([]corev1.ScopedResourceSelectorRequirement, error)

func (*AaqEvaluator) Usage

func (aaqe *AaqEvaluator) Usage(item runtime.Object) (corev1.ResourceList, error)

func (*AaqEvaluator) UsageStats

func (aaqe *AaqEvaluator) UsageStats(options v12.UsageStatsOptions) (v12.UsageStats, error)

UsageStats calculates aggregate usage for the object.

type AaqEvaluatorRegistry

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

func GetAaqEvaluatorsRegistry

func GetAaqEvaluatorsRegistry() *AaqEvaluatorRegistry

func (*AaqEvaluatorRegistry) Add

func (aaqe *AaqEvaluatorRegistry) Add(aaqCalculator AaqCalculator)

func (*AaqEvaluatorRegistry) Collect

func (aaqe *AaqEvaluatorRegistry) Collect(numberOfRequestedEvaluatorsSidecars uint, timeout time.Duration) error

func (*AaqEvaluatorRegistry) Usage

func (aaqe *AaqEvaluatorRegistry) Usage(pod *corev1.Pod, podsState []*corev1.Pod) (rlToRet corev1.ResourceList, acceptedErr error)

type AaqSocketCalculator

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

func (*AaqSocketCalculator) PodUsageFunc

func (aaqsc *AaqSocketCalculator) PodUsageFunc(pod *corev1.Pod, podsState []*corev1.Pod) (corev1.ResourceList, error, bool)

type Registry

type Registry interface {
	Add(aaqCalculator AaqCalculator)
	Collect(numberOfRequestedEvaluatorsSidecars uint, timeout time.Duration) error
	Usage(*corev1.Pod, []*corev1.Pod) (corev1.ResourceList, error)
}