Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 42 for newErrs (0.16 sec)

  1. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/status_strategy.go

    	// ratcheting validation of x-kubernetes-list-type value map and set
    	if newErrs := structurallisttype.ValidateListSetsAndMaps(nil, a.structuralSchema, uNew.Object); len(newErrs) > 0 {
    		if oldErrs := structurallisttype.ValidateListSetsAndMaps(nil, a.structuralSchema, uOld.Object); len(oldErrs) == 0 {
    			errs = append(errs, newErrs...)
    		}
    	}
    
    	// validate x-kubernetes-validations rules
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 22:16:10 UTC 2023
    - 4.6K bytes
    - Viewed (0)
  2. operator/pkg/apis/istio/v1alpha1/validation/validation.go

    	validators := []FeatureValidator{
    		CheckServicePorts,
    		CheckAutoScaleAndReplicaCount,
    	}
    
    	for _, validator := range validators {
    		newErrs, newWarnings := validator(values, spec)
    		errs = util.AppendErrs(errs, newErrs)
    		warnings = append(warnings, newWarnings...)
    	}
    
    	return
    }
    
    // CheckAutoScaleAndReplicaCount warns when autoscaleEnabled is true and k8s replicaCount is set.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 20:02:28 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_test.go

    			vMod := make([][]xlMetaV2ShallowVersion, 0, len(vers))
    			for i, ver := range vers {
    				newVers := make([]xlMetaV2ShallowVersion, 0, len(ver))
    				for _, v := range ver {
    					v.header.Signature = [4]byte{byte(i + 10), 0, 0, 0}
    					newVers = append(newVers, v)
    				}
    				vMod = append(vMod, newVers)
    			}
    			merged := mergeXLV2Versions(i, false, 0, vMod...)
    			if len(merged) == 0 {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  4. pkg/controller/deployment/rolling.go

    	// Sync deployment status
    	return dc.syncRolloutStatus(ctx, allRSs, newRS, d)
    }
    
    func (dc *DeploymentController) reconcileNewReplicaSet(ctx context.Context, allRSs []*apps.ReplicaSet, newRS *apps.ReplicaSet, deployment *apps.Deployment) (bool, error) {
    	if *(newRS.Spec.Replicas) == *(deployment.Spec.Replicas) {
    		// Scaling not required.
    		return false, nil
    	}
    	if *(newRS.Spec.Replicas) > *(deployment.Spec.Replicas) {
    		// Scale down.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 07:09:11 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/cel/common/values.go

    			return types.NullValue
    		}
    		return types.NewErr("invalid data, got null for schema with nullable=false")
    	}
    	if schema.IsXIntOrString() {
    		switch v := unstructured.(type) {
    		case string:
    			return types.String(v)
    		case int:
    			return types.Int(v)
    		case int32:
    			return types.Int(v)
    		case int64:
    			return types.Int(v)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 23 22:30:17 UTC 2023
    - 20.5K bytes
    - Viewed (0)
  6. pkg/controller/deployment/sync_test.go

    				client:        &fake,
    				eventRecorder: &record.FakeRecorder{},
    			}
    
    			if test.newRS != nil {
    				desiredReplicas := *(test.oldDeployment.Spec.Replicas)
    				if desired, ok := test.desiredReplicasAnnotations[test.newRS.Name]; ok {
    					desiredReplicas = desired
    				}
    				deploymentutil.SetReplicasAnnotations(test.newRS, desiredReplicas, desiredReplicas+deploymentutil.MaxSurge(*test.oldDeployment))
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go

    			_, _, desiredPLNames, newBadPLNames := genPLs(rng, trialStep, persistingPLNames, 0)
    			_, _, newFTRs, newCatchAlls := genFSs(t, rng, trialStep, desiredPLNames, newBadPLNames, 0)
    			for j := 0; ; {
    				if testDebugLogs {
    					t.Logf("For %s, desiredPLNames=%#+v", trialStep, desiredPLNames)
    					t.Logf("For %s, newFTRs=%#+v", trialStep, newFTRs)
    				}
    				// Check that the latest digestion did the right thing
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 18.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/cel/composition.go

    	if a.result.Error != nil {
    		return types.NewErr("composited variable %q fails to compile: %v", a.name, a.result.Error)
    	}
    
    	v, details, err := a.result.Program.ContextEval(a.context, a.activation)
    	if details == nil {
    		return types.NewErr("unable to get evaluation details of variable %q", a.name)
    	}
    	costPtr := details.ActualCost()
    	if costPtr == nil {
    		return types.NewErr("unable to calculate cost of variable %q", a.name)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 13 21:06:39 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  9. pkg/controller/deployment/progress_test.go

    			fake := fake.Clientset{}
    			dc := &DeploymentController{
    				client: &fake,
    			}
    
    			if test.newRS != nil {
    				test.allRSs = append(test.allRSs, test.newRS)
    			}
    			_, ctx := ktesting.NewTestContext(t)
    			err := dc.syncRolloutStatus(ctx, test.allRSs, test.newRS, test.d)
    			if err != nil {
    				t.Error(err)
    			}
    
    			newCond := util.GetDeploymentCondition(test.d.Status, test.conditionType)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. pkg/controller/deployment/rolling_test.go

    		oldSelector := map[string]string{"foo": "old"}
    		newRS := rs("foo-new", test.newReplicas, newSelector, noTimestamp)
    		newRS.Status.AvailableReplicas = int32(test.readyPodsFromNewRS)
    		oldRS := rs("foo-old", test.oldReplicas, oldSelector, noTimestamp)
    		oldRS.Status.AvailableReplicas = int32(test.readyPodsFromOldRS)
    		oldRSs := []*apps.ReplicaSet{oldRS}
    		allRSs := []*apps.ReplicaSet{oldRS, newRS}
    		maxSurge := intstr.FromInt32(0)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 11K bytes
    - Viewed (0)
Back to top