var serviceObjectCountName … var serviceResources … // NewServiceEvaluator returns an evaluator that can evaluate services. func NewServiceEvaluator(f quota.ListerForResourceFunc) quota.Evaluator { … } type serviceEvaluator … // Constraints verifies that all required resources are present on the item func (p *serviceEvaluator) Constraints(required []corev1.ResourceName, item runtime.Object) error { … } // GroupResource that this evaluator tracks func (p *serviceEvaluator) GroupResource() schema.GroupResource { … } // Handles returns true of the evaluator should handle the specified operation. func (p *serviceEvaluator) Handles(a admission.Attributes) bool { … } // Matches returns true if the evaluator matches the specified quota with the provided input item func (p *serviceEvaluator) Matches(resourceQuota *corev1.ResourceQuota, item runtime.Object) (bool, error) { … } // MatchingResources takes the input specified list of resources and returns the set of resources it matches. func (p *serviceEvaluator) MatchingResources(input []corev1.ResourceName) []corev1.ResourceName { … } // MatchingScopes takes the input specified list of scopes and input object. Returns the set of scopes resource matches. func (p *serviceEvaluator) MatchingScopes(item runtime.Object, scopes []corev1.ScopedResourceSelectorRequirement) ([]corev1.ScopedResourceSelectorRequirement, error) { … } // UncoveredQuotaScopes takes the input matched scopes which are limited by configuration and the matched quota scopes. // It returns the scopes which are in limited scopes but don't have a corresponding covering quota scope func (p *serviceEvaluator) UncoveredQuotaScopes(limitedScopes []corev1.ScopedResourceSelectorRequirement, matchedQuotaScopes []corev1.ScopedResourceSelectorRequirement) ([]corev1.ScopedResourceSelectorRequirement, error) { … } // convert the input object to an internal service object or error. func toExternalServiceOrError(obj runtime.Object) (*corev1.Service, error) { … } // Usage knows how to measure usage associated with services func (p *serviceEvaluator) Usage(item runtime.Object) (corev1.ResourceList, error) { … } func portsWithNodePorts(svc *corev1.Service) *resource.Quantity { … } // UsageStats calculates aggregate usage for the object. func (p *serviceEvaluator) UsageStats(options quota.UsageStatsOptions) (quota.UsageStats, error) { … } var _ … // GetQuotaServiceType returns ServiceType if the service type is eligible to track against a quota, nor return "" func GetQuotaServiceType(service *corev1.Service) corev1.ServiceType { … }
Codebase Browser
kubernetes