- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for fsquota (0.12 sec)
-
pkg/volume/emptydir/empty_dir.go
// above. hasQuotas, err := fsquota.SupportsQuotas(ed.mounter, dir) if err != nil { klog.V(3).Infof("Unable to check for quota support on %s: %s", dir, err.Error()) } else if hasQuotas { klog.V(4).Infof("emptydir trying to assign quota %v on %s", mounterSize, dir) if err := fsquota.AssignQuota(ed.mounter, dir, ed.pod.UID, mounterSize); err != nil { klog.V(3).Infof("Set quota on %s failed %s", dir, err.Error())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 19K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota_linux.go
// From fsquota point of view each volume is attached to a // single unique pod. // If we decide later that we want to assign one quota for all // volumes in a pod, we can simply use poduid parameter directly // If and when we decide permanently that we're going to adopt // one quota per volume, we can rip all of the pod code out. externalPodUid := poduid internalPodUid, ok := dirPodMap[path] if ok {
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/project.go
See the License for the specific language governing permissions and limitations under the License. */ package fsquota import ( "bufio" "fmt" "os" "path/filepath" "regexp" "strconv" "sync" "golang.org/x/sys/unix" "k8s.io/kubernetes/pkg/volume/util/fsquota/common" ) var projectsFile = "/etc/projects" var projidFile = "/etc/projid"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/volume/util/fsquota/quota_linux_test.go
limitations under the License. */ package fsquota import ( "fmt" "os" "strings" "testing" "k8s.io/mount-utils" "k8s.io/apimachinery/pkg/api/resource" "k8s.io/apimachinery/pkg/types" utilfeature "k8s.io/apiserver/pkg/util/feature" featuregatetesting "k8s.io/component-base/featuregate/testing" "k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/volume/util/fsquota/common" )
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/kubelet/cm/helpers_linux.go
MinQuotaPeriod = 1000 ) // MilliCPUToQuota converts milliCPU to CFS quota and period values. // Input parameters and resulting value is number of microseconds. func MilliCPUToQuota(milliCPU int64, period int64) (quota int64) { // CFS quota is measured in two values: // - cfs_period_us=100ms (the amount of time to measure usage across given by period) // - cfs_quota=20ms (the amount of cpu time allowed to be used across a period)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 11:52:28 UTC 2023 - 9.8K 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/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) -
pkg/kubelet/kuberuntime/helpers_linux_test.go
{ msg: "1500 input 150k quota and default period", input: int64(1500), expected: int64(150000), period: uint64(100000), }} { t.Run(testCase.msg, func(t *testing.T) { quota := milliCPUToQuota(testCase.input, int64(testCase.period)) if quota != testCase.expected { t.Errorf("Input %v and %v, expected quota %v, but got quota %v", testCase.input, testCase.period, testCase.expected, quota) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/quota/v1/generic/evaluator.go
func (o *objectCountEvaluator) UsageStats(options quota.UsageStatsOptions) (quota.UsageStats, error) { return CalculateUsageStats(options, o.listFuncByNamespace, MatchesNoScopeFunc, o.Usage) } // Verify implementation of interface at compile time. var _ quota.Evaluator = &objectCountEvaluator{} // NewObjectCountEvaluator returns an evaluator that can perform generic
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 05 00:02:47 UTC 2023 - 11.7K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods.go
"k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apiserver/pkg/admission" quota "k8s.io/apiserver/pkg/quota/v1" "k8s.io/apiserver/pkg/quota/v1/generic" "k8s.io/apiserver/pkg/util/feature" "k8s.io/utils/clock" resourcehelper "k8s.io/kubernetes/pkg/api/v1/resource" api "k8s.io/kubernetes/pkg/apis/core"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 05 00:02:47 UTC 2023 - 17.4K bytes - Viewed (0)