- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for GetConsumption (0.18 sec)
-
pkg/volume/util/fsquota/quota_unsupported.go
} // AssignQuota -- dummy implementation func AssignQuota(_ mount.Interface, _ string, _ types.UID, _ *resource.Quantity) error { return errNotImplemented } // GetConsumption -- dummy implementation func GetConsumption(_ string) (*resource.Quantity, error) { return nil, errNotImplemented } // GetInodes -- dummy implementation func GetInodes(_ string) (*resource.Quantity, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 28 06:09:31 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/volume/util/fsquota/common/quota_common_linux.go
QuotaIDIsInUse(id QuotaID) (bool, error) // GetConsumption returns the consumption (in bytes) of the // directory, determined by the implementation's quota-based // mechanism. If it is unable to do so using that mechanism, // it should return an error and allow higher layers to // enumerate the directory. GetConsumption(path string, id QuotaID) (int64, error)
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_test.go
} return fail case "Set": err = fakeAssignQuota(testcase.path, testcase.poduid, testcase.bytes) case "Clear": err = fakeClearQuota(testcase.path) case "GetConsumption": _, err = GetConsumption(testcase.path) case "GetInodes": _, err = GetInodes(testcase.path) default: t.Errorf("Case %v (%s, %s, %v) unknown operation %s", seq, testcase.name, testcase.path, true, testcase.op)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 20.7K bytes - Viewed (0) -
pkg/volume/util/fsquota/common/quota_common_linux_impl.go
} klog.V(4).Infof("getQuantity %s %d %s %d => %d %v", mountpoint, id, xfsQuotaArg, multiplier, size, err) return size * multiplier, nil } // 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) }
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/volume/util/fsquota/quota.go
// and return it. AssignQuota(m mount.Interface, path string, poduid types.UID, bytes *resource.Quantity) error // Get the quota-based storage consumption for the path GetConsumption(path string) (*resource.Quantity, error) // Get the quota-based inode consumption for the path GetInodes(path string) (*resource.Quantity, error) // Remove the quota from a path
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/volume/util/fsquota/quota_linux.go
return nil } removeProjectID(path, id) } return fmt.Errorf("assign quota FAILED %v", err) } // GetConsumption -- retrieve the consumption (in bytes) of the directory func GetConsumption(path string) (*resource.Quantity, error) { // Note that we actually need to hold the lock at least through // running the quota command, so it can't get recycled behind our back
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/fs/fs.go
// A nil quantity or error means that the path does not support quotas // or xfs_quota tool is missing and we should use other mechanisms. startTime := time.Now() consumption, _ := fsquota.GetConsumption(path) if consumption != nil { usage.Bytes = consumption.Value() defer servermetrics.CollectVolumeStatCalDuration("fsquota", startTime) } else { defer servermetrics.CollectVolumeStatCalDuration("du", startTime)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 20 02:56:02 UTC 2022 - 3.8K bytes - Viewed (0)