- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for HasAll (0.65 sec)
-
pkg/util/iptables/iptables_test.go
if !sets.New(fcmd.CombinedOutputLog[0]...).HasAll(iptablesCmd, "--version") { t.Errorf("%s runner instantiate: Expected cmd '%s --version', Got '%s'", protocol, iptablesCmd, fcmd.CombinedOutputLog[0]) } // Check that proper iptables restore version command was used during runner instantiation if !sets.New(fcmd.CombinedOutputLog[1]...).HasAll(iptablesRestoreCmd, "--version") {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 08 15:21:59 UTC 2023 - 46.3K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset/ipset_test.go
t.Errorf("expected success, got %v", err) } if fcmd.CombinedOutputCalls != 1 { t.Errorf("expected 1 CombinedOutput() calls, got %d", fcmd.CombinedOutputCalls) } if !sets.NewString(fcmd.CombinedOutputLog[0]...).HasAll("ipset", "flush", "FOOBAR") { t.Errorf("wrong CombinedOutput() log, got %s", fcmd.CombinedOutputLog[0]) } // Flush again err = runner.FlushSet("FOOBAR") if err != nil { t.Errorf("expected success, got %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 41.5K 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/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) -
pkg/scheduler/scheduler_test.go
}) // Validate the name of pods in waitingPods matches expectations. if actualPodNamesInWaitingPods.Len() != len(tc.expectPodNamesInWaitingPods) || !actualPodNamesInWaitingPods.HasAll(tc.expectPodNamesInWaitingPods...) { t.Fatalf("Unexpected waitingPods in scheduler profile %s, expect: %#v, got: %#v", fwk.ProfileName(), tc.expectPodNamesInWaitingPods, actualPodNamesInWaitingPods.List()) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/topology_hints_test.go
continue } if len(allocated) != tc.request { t.Errorf("%v. expected allocation size: %v but got: %v", tc.description, tc.request, len(allocated)) } if !allocated.HasAll(tc.expectedPreferredAllocation...) { t.Errorf("%v. expected preferred allocation: %v but not present in: %v", tc.description, tc.expectedPreferredAllocation, allocated.UnsortedList()) } alignment := make(map[int]int)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 47.5K bytes - Viewed (0)