- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 50 for expectedIds (0.56 sec)
-
pkg/controller/replicaset/replica_set_test.go
// all of them have been observed. expectedPods = replicas - activePods if expectedPods > int32(burstReplicas) { expectedPods = int32(burstReplicas) } // This validates the ReplicaSet manager sync actually created pods err := validateSyncReplicaSet(&fakePodControl, int(expectedPods), 0, 0) if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
} if diff := cmp.Diff(test.want, res); diff != "" { t.Errorf("Unexpected status (-want, +got):\n%s", diff) } if len(deletedPodNames) != len(test.expectedPods) { t.Errorf("expected %v pods, got %v.", len(test.expectedPods), len(deletedPodNames)) } if diff := cmp.Diff(sets.List(patchedPodNames), sets.List(deletedPodNames)); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/registry/policy/poddisruptionbudget/strategy_test.go
Spec: pdb.Spec, Status: policy.PodDisruptionBudgetStatus{ DisruptionsAllowed: 1, CurrentHealthy: 3, DesiredHealthy: 3, ExpectedPods: 3, }, } // Nothing in Spec changes: OK Strategy.PrepareForUpdate(ctx, newPdb, pdb) errs = Strategy.ValidateUpdate(ctx, newPdb, pdb) if len(errs) != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 19.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
} } } func (env *testEnv) validateBind( t *testing.T, pod *v1.Pod, expectedPVs []*v1.PersistentVolume, expectedAPIPVs []*v1.PersistentVolume) { // Check pv cache pvCache := env.internalBinder.pvCache for _, pv := range expectedPVs { cachedPV, err := pvCache.GetPV(pv.Name) if err != nil { t.Errorf("GetPV %q returned error: %v", pv.Name, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
staging/src/k8s.io/api/policy/v1/generated.pb.go
return fmt.Errorf("proto: wrong wireType = %d for field ExpectedPods", wireType) } m.ExpectedPods = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowGenerated } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.ExpectedPods |= int32(b&0x7F) << shift if b < 0x80 { break }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 45.1K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
} return s } func TestKubeConfigOverride(t *testing.T) { var ( expectedQPS = float32(100) expectedBurst = 200 ) fakeRestConfig := &rest.Config{} client := kube.NewFakeClient() stopCh := test.NewStop(t) c := NewController(client, secretNamespace, "", mesh.NewFixedWatcher(nil), func(cfg *rest.Config) { cfg.QPS = expectedQPS cfg.Burst = expectedBurst })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
staging/src/k8s.io/api/policy/v1beta1/generated.pb.go
return fmt.Errorf("proto: wrong wireType = %d for field ExpectedPods", wireType) } m.ExpectedPods = 0 for shift := uint(0); ; shift += 7 { if shift >= 64 { return ErrIntOverflowGenerated } if iNdEx >= l { return io.ErrUnexpectedEOF } b := dAtA[iNdEx] iNdEx++ m.ExpectedPods |= int32(b&0x7F) << shift if b < 0x80 { break }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 45.2K bytes - Viewed (0) -
pkg/proxy/util/nodeport_addresses_test.go
} ips, err := npa.GetNodeIPs(nw) expectedIPs := tc.expected[family].ips // The fake InterfaceAddrs() never returns an error, so // the only error GetNodeIPs will return is "no // addresses found". if err != nil { t.Errorf("unexpected error: %v", err) } err = checkNodeIPs(expectedIPs, ips) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/model/virtualservice_test.go
configs := SelectVirtualServices(index, "some-ns", hostsByNamespace) expectedVS := []string{ virtualService1.Name, virtualService2.Name, virtualService4.Name, virtualService7.Name, virtualService8.Name, virtualService9.Name, } if len(expectedVS) != len(configs) { t.Fatalf("Unexpected virtualService, got %d, expected %d", len(configs), len(expectedVS)) } for i, config := range configs {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 60.6K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
inputReaderData string inputMd5 string inputSHA256 string inputDataSize int64 // flag indicating whether the test should pass. shouldPass bool // expected error output. expectedMd5 string expectedError error }{ // Test case 1-4. // Cases with invalid bucket name. {bucketName: ".test", objName: "obj", PartID: 1, expectedError: fmt.Errorf("%s", "Bucket name invalid: .test")},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 77.1K bytes - Viewed (0)