Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NewErrs (0.32 sec)

  1. operator/pkg/util/errs.go

    			return nil
    		}
    		return errors
    	}
    	return append(errors, err)
    }
    
    // AppendErrs appends newErrs to errors and returns the result.
    // If newErrs is empty, nothing is appended.
    func AppendErrs(errors []error, newErrs []error) Errors {
    	if len(newErrs) == 0 {
    		return errors
    	}
    	for _, e := range newErrs {
    		errors = AppendErr(errors, e)
    	}
    	if len(errors) == 0 {
    		return nil
    	}
    	return errors
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 29 20:42:01 UTC 2020
    - 3.1K bytes
    - Viewed (0)
  2. 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)
  3. operator/pkg/util/errs_test.go

    	if got, want := ToString(testErrs, defaultSeparator), wantStr; got != want {
    		t.Errorf("got: %s, want: %s", got, want)
    	}
    }
    
    func TestNewErrs(t *testing.T) {
    	errs := NewErrs(nil)
    	if errs != nil {
    		t.Errorf("got: %s, want: nil", errs)
    	}
    
    	errs = NewErrs(fmt.Errorf("err1"))
    	if got, want := errs.String(), "err1"; got != want {
    		t.Errorf("got: %s, want: %s", got, want)
    	}
    }
    
    func TestAppendErr(t *testing.T) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 29 20:42:01 UTC 2020
    - 3K bytes
    - Viewed (0)
  4. operator/pkg/validate/validate.go

    	}
    	if !util.IsPtr(structPtr) {
    		metrics.CRValidationErrorTotal.Increment()
    		return util.NewErrs(fmt.Errorf("validate path %s, value: %v, expected ptr, got %T", path, structPtr, structPtr))
    	}
    	structElems := reflect.ValueOf(structPtr).Elem()
    	if !util.IsStruct(structElems) {
    		metrics.CRValidationErrorTotal.Increment()
    		return util.NewErrs(fmt.Errorf("validate path %s, value: %v, expected struct, got %T", path, structElems, structElems))
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jan 12 16:04:15 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  5. operator/pkg/validate/common.go

    	scope.Debugf("validatePortNumberString %v:", val)
    	if !util.IsString(val) {
    		return util.NewErrs(fmt.Errorf("validatePortNumberString(%s) bad type %T, want string", path, val))
    	}
    	if val.(string) == "*" || val.(string) == "" {
    		return nil
    	}
    	intV, err := strconv.ParseInt(val.(string), 10, 32)
    	if err != nil {
    		return util.NewErrs(fmt.Errorf("%s : %s", path, err))
    	}
    	return validatePortNumber(path, intV)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Aug 10 15:35:03 UTC 2023
    - 11K bytes
    - Viewed (0)
  6. operator/pkg/patch/patch.go

    	bo := make(map[any]any)
    	by, err := base.YAML()
    	if err != nil {
    		return "", util.NewErrs(err)
    	}
    	// Use yaml2 specifically to allow interface{} as key which WritePathContext treats specially
    	err = yaml2.Unmarshal(by, &bo)
    	if err != nil {
    		return "", util.NewErrs(err)
    	}
    	for _, p := range patches {
    		v := p.Value.AsInterface()
    		if strings.TrimSpace(p.Path) == "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Aug 10 15:35:03 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  7. 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)
  8. operator/pkg/controlplane/control_plane.go

    	return nil
    }
    
    // RenderManifest returns a manifest rendered against
    func (i *IstioControlPlane) RenderManifest() (manifests name.ManifestMap, errsOut util.Errors) {
    	if !i.started {
    		return nil, util.NewErrs(fmt.Errorf("istioControlPlane must be Run before calling RenderManifest"))
    	}
    
    	manifests = make(name.ManifestMap)
    	for _, c := range i.components {
    		ms, err := c.RenderManifest()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 23 02:26:59 UTC 2022
    - 4K bytes
    - Viewed (0)
Back to top