Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for GetConsumption (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top