- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 35 for HasAll (0.12 sec)
-
pkg/apis/core/v1/helper/qos/qos.go
if _, exists := limits[name]; !exists { limits[name] = delta } else { delta.Add(limits[name]) limits[name] = delta } } } if !qosLimitsFound.HasAll(string(v1.ResourceMemory), string(v1.ResourceCPU)) { isGuaranteed = false } } if len(requests) == 0 && len(limits) == 0 { return v1.PodQOSBestEffort } // Check is requests match limits for all resources.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 04:01:46 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/apis/core/helper/qos/qos.go
if _, exists := limits[name]; !exists { limits[name] = delta } else { delta.Add(limits[name]) limits[name] = delta } } } if !qosLimitsFound.HasAll(string(core.ResourceMemory), string(core.ResourceCPU)) { isGuaranteed = false } } if len(requests) == 0 && len(limits) == 0 { return core.PodQOSBestEffort }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 04:01:46 UTC 2023 - 3.7K bytes - Viewed (0) -
operator/cmd/mesh/test-util_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 15.3K bytes - Viewed (0) -
pkg/kubelet/config/config.go
return false } c.sourcesLock.Lock() defer c.sourcesLock.Unlock() klog.V(5).InfoS("Looking for sources, have seen", "sources", sets.List(c.sources), "seenSources", seenSources) return seenSources.HasAll(sets.List(c.sources)...) && c.pods.seenSources(sets.List(c.sources)...) } // Updates returns a channel of updates to the configuration, properly denormalized. func (c *PodConfig) Updates() <-chan kubetypes.PodUpdate {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/reset_test.go
if !expected.Equal(data.ignorePreflightErrors) { t.Errorf("Invalid ignore preflight errors. Expected: %v. Actual: %v", sets.List(expected), sets.List(data.ignorePreflightErrors)) } if data.cfg != nil && !expected.HasAll(data.cfg.NodeRegistration.IgnorePreflightErrors...) { t.Errorf("Invalid ignore preflight errors in InitConfiguration. Expected: %v. Actual: %v", sets.List(expected), data.cfg.NodeRegistration.IgnorePreflightErrors) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 13:42:50 UTC 2024 - 8.5K bytes - Viewed (0) -
plugin/pkg/admission/resourcequota/admission_test.go
) actionSet := sets.NewString() for _, action := range kubeClient.Actions() { actionSet.Insert(strings.Join([]string{action.GetVerb(), action.GetResource().Resource, action.GetSubresource()}, "-")) } if !actionSet.HasAll(expectedActionSet.List()...) { t.Errorf("Expected actions:\n%v\n but got:\n%v\nDifference:\n%v", expectedActionSet, actionSet, expectedActionSet.Difference(actionSet)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 84.1K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/init_test.go
if !expected.Equal(data.ignorePreflightErrors) { t.Errorf("Invalid ignore preflight errors. Expected: %v. Actual: %v", sets.List(expected), sets.List(data.ignorePreflightErrors)) } if !expected.HasAll(data.cfg.NodeRegistration.IgnorePreflightErrors...) { t.Errorf("Invalid ignore preflight errors in InitConfiguration. Expected: %v. Actual: %v", sets.List(expected), data.cfg.NodeRegistration.IgnorePreflightErrors) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 12:26:20 UTC 2024 - 11.9K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/join_test.go
if !expected.Equal(data.ignorePreflightErrors) { t.Errorf("Invalid ignore preflight errors. Expected: %v. Actual: %v", sets.List(expected), sets.List(data.ignorePreflightErrors)) } if !expected.HasAll(data.cfg.NodeRegistration.IgnorePreflightErrors...) { t.Errorf("Invalid ignore preflight errors in JoinConfiguration. Expected: %v. Actual: %v", sets.List(expected), data.cfg.NodeRegistration.IgnorePreflightErrors) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 12:26:20 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/token.go
func (r *TokenREST) isKubeAudiences(tokenAudience []string) bool { // tokenAudiences must be a strict subset of apiserver audiences return r.audsSet.HasAll(tokenAudience...)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 05 10:24:31 UTC 2024 - 10K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/validation/validation.go
// ValidateDryRun validates that a dryRun query param only contains allowed values. func ValidateDryRun(fldPath *field.Path, dryRun []string) field.ErrorList { allErrs := field.ErrorList{} if !allowedDryRunValues.HasAll(dryRun...) { allErrs = append(allErrs, field.NotSupported(fldPath, dryRun, allowedDryRunValues.List())) } return allErrs }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 01:52:02 UTC 2022 - 13.5K bytes - Viewed (0)