- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 85 for expectedIds (0.45 sec)
-
staging/src/k8s.io/api/policy/v1beta1/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: Mon Aug 07 20:44:13 UTC 2023 - 11.1K 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) -
pkg/apis/policy/types.go
// current number of healthy pods CurrentHealthy int32 // minimum desired number of healthy pods DesiredHealthy int32 // total number of pods counted by this disruption budget ExpectedPods int32 // Conditions contain conditions for PDB // +optional Conditions []metav1.Condition } // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 20:44:13 UTC 2023 - 6.9K 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)