- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for newErrs (0.33 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/lastappliedmanager.go
newLiveObj, newManaged, newErr := f.fieldManager.Apply(liveObj, newObj, managed, manager, force) // Upgrade the client-side apply annotation only from kubectl server-side-apply. // To opt-out of this behavior, users may specify a different field manager. if manager != "kubectl" { return newLiveObj, newManaged, newErr } // Check if we have conflicts if newErr == nil { return newLiveObj, newManaged, newErr }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/registry/apps/replicaset/strategy.go
func (rsStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) { newRS := obj.(*apps.ReplicaSet) oldRS := old.(*apps.ReplicaSet) // update is not allowed to set status newRS.Status = oldRS.Status pod.DropDisabledTemplateFields(&newRS.Spec.Template, &oldRS.Spec.Template) // Any changes to the spec increment the generation number, any changes to the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 16 21:06:43 UTC 2022 - 9.3K bytes - Viewed (0) -
pkg/controller/deployment/progress.go
// to deployment conditions. func (dc *DeploymentController) getReplicaFailures(allRSs []*apps.ReplicaSet, newRS *apps.ReplicaSet) []apps.DeploymentCondition { var conditions []apps.DeploymentCondition if newRS != nil { for _, c := range newRS.Status.Conditions { if c.Type != apps.ReplicaSetReplicaFailure { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 11:00:44 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/controller/deployment/recreate.go
if scaledDown { // Update DeploymentStatus. return dc.syncRolloutStatus(ctx, allRSs, newRS, d) } // Do not process a deployment when it has old pods running. if oldPodsRunning(newRS, oldRSs, podMap) { return dc.syncRolloutStatus(ctx, allRSs, newRS, d) } // If we need to create a new RS, create it now. if newRS == nil { newRS, oldRSs, err = dc.getAllReplicaSetsAndSyncRevision(ctx, d, rsList, true) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 13 20:32:13 UTC 2021 - 4.2K bytes - Viewed (0)