var pvcObjectCountName … var pvcResources … const storageClassSuffix … // V1ResourceByStorageClass returns a quota resource name by storage class. func V1ResourceByStorageClass(storageClass string, resourceName corev1.ResourceName) corev1.ResourceName { … } // NewPersistentVolumeClaimEvaluator returns an evaluator that can evaluate persistent volume claims func NewPersistentVolumeClaimEvaluator(f quota.ListerForResourceFunc) quota.Evaluator { … } type pvcEvaluator … // Constraints verifies that all required resources are present on the item. func (p *pvcEvaluator) Constraints(required []corev1.ResourceName, item runtime.Object) error { … } // GroupResource that this evaluator tracks func (p *pvcEvaluator) GroupResource() schema.GroupResource { … } // Handles returns true if the evaluator should handle the specified operation. func (p *pvcEvaluator) Handles(a admission.Attributes) bool { … } // Matches returns true if the evaluator matches the specified quota with the provided input item func (p *pvcEvaluator) Matches(resourceQuota *corev1.ResourceQuota, item runtime.Object) (bool, error) { … } // MatchingScopes takes the input specified list of scopes and input object. Returns the set of scopes resource matches. func (p *pvcEvaluator) 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 *pvcEvaluator) UncoveredQuotaScopes(limitedScopes []corev1.ScopedResourceSelectorRequirement, matchedQuotaScopes []corev1.ScopedResourceSelectorRequirement) ([]corev1.ScopedResourceSelectorRequirement, error) { … } // MatchingResources takes the input specified list of resources and returns the set of resources it matches. func (p *pvcEvaluator) MatchingResources(items []corev1.ResourceName) []corev1.ResourceName { … } // Usage knows how to measure usage associated with item. func (p *pvcEvaluator) Usage(item runtime.Object) (corev1.ResourceList, error) { … } func (p *pvcEvaluator) getStorageUsage(pvc *corev1.PersistentVolumeClaim) *resource.Quantity { … } // UsageStats calculates aggregate usage for the object. func (p *pvcEvaluator) UsageStats(options quota.UsageStatsOptions) (quota.UsageStats, error) { … } var _ … func toExternalPersistentVolumeClaimOrError(obj runtime.Object) (*corev1.PersistentVolumeClaim, error) { … } // RequiresQuotaReplenish enables quota monitoring for PVCs. func RequiresQuotaReplenish(pvc, oldPVC *corev1.PersistentVolumeClaim) bool { … }
Codebase Browser
kubernetes