- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 787 for quotas (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/resource_access_test.go
go func() { defer wg.Done() quotas, err := accessor.GetQuotas(testNamespace1) if err != nil { t.Errorf("unexpected error: %v", err) } if len(quotas) != len(resourceQuotas) { t.Errorf("Expected %d resource quotas, got %d", len(resourceQuotas), len(quotas)) } for _, q := range quotas { if q.Namespace != testNamespace1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 13:54:56 UTC 2024 - 7.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go
// and the running quota doesn't change. If it did fit, check to see if any quota was changed. If there was no quota change // mark the waiter as succeeded. If some quota did change, update the running quotas // 2. If no running quota was changed, return now since no updates are needed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 25.8K bytes - Viewed (0) -
pkg/volume/util/fsquota/common/quota_common_linux.go
// mechanism supported by Linux type LinuxVolumeQuotaApplier interface { // GetQuotaOnDir gets the quota ID (if any) that applies to // this directory GetQuotaOnDir(path string) (QuotaID, error) // SetQuotaOnDir applies the specified quota ID to a directory. // Negative value for bytes means that a non-enforcing quota // should be applied (perhaps by setting a quota too large to // be hit)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 28 06:09:31 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota_linux.go
// never have been one, and we have no way to know otherwise klog.V(3).Infof("clearQuotaOnDir fails %v", err) return nil } // SupportsQuotas -- Does the path support quotas // Cache the applier for paths that support quotas. For paths that don't, // don't cache the result because nothing will clean it up. // However, do cache the device->applier map; the number of devices // is bounded.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 07 08:07:51 UTC 2023 - 14.1K bytes - Viewed (0) -
pkg/volume/util/fsquota/common/quota_common_linux_impl.go
} // GetConsumption returns the consumption in bytes if available via quotas func (v linuxVolumeQuotaApplier) GetConsumption(_ string, id QuotaID) (int64, error) { return getQuantity(v.mountpoint, id, "-b", 1024, v.allowEmptyOutput) } // GetInodes returns the inodes in use if available via quotas func (v linuxVolumeQuotaApplier) GetInodes(_ string, id QuotaID) (int64, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 9.1K bytes - Viewed (0) -
pkg/config/analysis/analyzers/testdata/deprecation.yaml
port: number: 9080 --- apiVersion: config.istio.io/v1alpha2 kind: QuotaSpec metadata: name: request-count namespace: istio-system spec: rules: - quotas: - charge: 1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 17 12:28:05 UTC 2021 - 1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/resource_access.go
return quota } cachedQuota := uncastCachedQuota.(*corev1.ResourceQuota) if etcdVersioner.CompareResourceVersion(quota, cachedQuota) >= 0 { e.updatedQuotas.Remove(key) return quota } return cachedQuota } func (e *quotaAccessor) GetQuotas(namespace string) ([]corev1.ResourceQuota, error) { // determine if there are any quotas in this namespace // if there are no quotas, we don't need to do anything
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 13:54:56 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota.go
) // Interface -- quota interface type Interface interface { // GetQuotaOnDir gets the quota ID (if any) that applies to // this directory GetQuotaOnDir(m mount.Interface, path string) (common.QuotaID, error) // Does the path provided support quotas, and if so, what types SupportsQuotas(m mount.Interface, path string) (bool, error) // Assign a quota (picked by the quota mechanism) to a path, // and return it.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 28 06:09:31 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/registry/core/resourcequota/storage/storage.go
"k8s.io/kubernetes/pkg/registry/core/resourcequota" "sigs.k8s.io/structured-merge-diff/v4/fieldpath" ) // REST implements a RESTStorage for resource quotas. type REST struct { *genericregistry.Store } // NewREST returns a RESTStorage object that will work against resource quotas. func NewREST(optsGetter generic.RESTOptionsGetter) (*REST, *StatusREST, error) { store := &genericregistry.Store{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:19 UTC 2022 - 4.2K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
// We are only interested in observing updates to quota.spec to drive updates to quota.status. // We ignore all updates to quota.Status because they are all driven by this controller. // IMPORTANT: // We do not use this function to queue up a full quota recalculation. To do so, would require // us to enqueue all quota.Status updates, and since quota.Status updates involve additional queries
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0)