- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for expectedIds (0.15 sec)
-
pkg/registry/discovery/endpointslice/strategy_test.go
if !apiequality.Semantic.DeepEqual(tc.newEPS, tc.expectedEPS) { t.Errorf("Expected %+v\nGot: %+v", tc.expectedEPS, tc.newEPS) } }) } } func Test_dropTopologyOnV1(t *testing.T) { testcases := []struct { name string v1Request bool newEPS *discovery.EndpointSlice originalEPS *discovery.EndpointSlice expectedEPS *discovery.EndpointSlice }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.3K bytes - Viewed (0) -
cmd/object-api-putobject_test.go
expectedError: hash.BadDigest{ExpectedMD5: invalidMD5, CalculatedMD5: getMD5Hash(nilBytes)}, }, 25: { bucketName: bucket, objName: object, inputData: fiveMBBytes, inputMeta: invalidMD5Header, inputDataSize: int64(len(fiveMBBytes)), expectedMd5: getMD5Hash(fiveMBBytes), expectedError: hash.BadDigest{ExpectedMD5: invalidMD5, CalculatedMD5: getMD5Hash(fiveMBBytes)},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 25.8K bytes - Viewed (0) -
pkg/volume/git_repo/git_repo_test.go
} if fake.CommandCalls != len(expecteds) { allErrs = append(allErrs, fmt.Errorf("unexpected command calls in scenario: expected %d, saw: %d", len(expecteds), fake.CommandCalls)) } var expectedCmds [][]string for _, expected := range expecteds { expectedCmds = append(expectedCmds, expected.cmd) } if !reflect.DeepEqual(expectedCmds, fcmd.CombinedOutputLog) { allErrs = append(allErrs,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 08:26:26 UTC 2024 - 12K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion_test.go
t.Fatalf("service IP incorrect => %q, want %q", ips[0], ip) } actualIPs := service.ClusterVIPs.GetAddressesFor(clusterID) expectedIPs := []string{ip} if !reflect.DeepEqual(actualIPs, expectedIPs) { t.Fatalf("service IPs incorrect => %q, want %q", actualIPs, expectedIPs) } if !reflect.DeepEqual(service.Attributes.LabelSelectors, localSvc.Spec.Selector) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
setGws(c.NetworkGateways()) notifyCh <- struct{}{} }) expectGateways := func(t *testing.T, expectedGws int) { // wait for a notification assert.ChannelHasItem(t, notifyCh) if n := len(getGws()); n != expectedGws { t.Errorf("expected %d gateways but got %d", expectedGws, n) } } t.Run("add meshnetworks", func(t *testing.T) { addMeshNetworksFromRegistryGateway(t, c, meshNetworks)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/configuration/ExecuteUserLifecycleListenerBuildOperationIntegrationTest.groovy
} private static void verifyExpectedOps(List<BuildOperationRecord> ops, List<ExpectedOperation> expectedOps) { assert ops.size() == expectedOps.size() // no guarantees about listener execution order assert ops.find { op ->
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 11:16:24 UTC 2024 - 40.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go
) func verifyListPVs(t *testing.T, cache *PVAssumeCache, expectedPVs map[string]*v1.PersistentVolume, storageClassName string) { pvList := cache.ListPVs(storageClassName) if len(pvList) != len(expectedPVs) { t.Errorf("ListPVs() returned %v PVs, expected %v", len(pvList), len(expectedPVs)) } for _, pv := range pvList { expectedPV, ok := expectedPVs[pv.Name] if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/api/policy/v1/types.go
DesiredHealthy int32 `json:"desiredHealthy" protobuf:"varint,5,opt,name=desiredHealthy"` // total number of pods counted by this disruption budget ExpectedPods int32 `json:"expectedPods" protobuf:"varint,6,opt,name=expectedPods"` // Conditions contain conditions for PDB. The disruption controller sets the // DisruptionAllowed condition. The following are known values for the reason field
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 10.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) -
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)