Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for oldArgs (0.14 sec)

  1. pkg/controller/deployment/recreate_test.go

    		test := tests[i]
    
    		var oldRSs []*apps.ReplicaSet
    		var expected []runtime.Object
    
    		for n, size := range test.oldRSSizes {
    			rs := newReplicaSet(test.d, fmt.Sprintf("%s-%d", test.d.Name, n), size)
    			oldRSs = append(oldRSs, rs)
    
    			rsCopy := rs.DeepCopy()
    
    			zero := int32(0)
    			rsCopy.Spec.Replicas = &zero
    			expected = append(expected, rsCopy)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 08 09:10:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  2. pkg/controller/deployment/recreate.go

    	// Don't create a new RS if not already existed, so that we avoid scaling up before scaling down.
    	newRS, oldRSs, err := dc.getAllReplicaSetsAndSyncRevision(ctx, d, rsList, false)
    	if err != nil {
    		return err
    	}
    	allRSs := append(oldRSs, newRS)
    	activeOldRSs := controller.FilterActiveReplicaSets(oldRSs)
    
    	// scale down old replica sets.
    	scaledDown, err := dc.scaleDownOldReplicaSetsForRecreate(ctx, activeOldRSs, d)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 13 20:32:13 UTC 2021
    - 4.2K bytes
    - Viewed (0)
  3. operator/cmd/mesh/operator-dump.go

    		l.LogAndFatal(fmt.Errorf("unknown output format: %v", odArgs.common.outputFormat))
    	}
    
    	_, mstr, err := renderOperatorManifest(args, &odArgs.common)
    	if err != nil {
    		l.LogAndFatal(err)
    	}
    
    	var output string
    	if output, err = yamlToFormat(mstr, odArgs.common.outputFormat); err != nil {
    		l.LogAndFatal(err)
    	}
    	l.Print(output)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 23 17:08:31 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  4. operator/cmd/mesh/operator_test.go

    		},
    	}
    
    	cmd := "operator dump --hub " + odArgs.common.hub
    	cmd += " --tag " + odArgs.common.tag
    	cmd += " --imagePullSecrets " + strings.Join(odArgs.common.imagePullSecrets, ",")
    	cmd += " --operatorNamespace " + odArgs.common.operatorNamespace
    	cmd += " --watchedNamespaces " + odArgs.common.watchedNamespaces
    	cmd += " --manifests=" + string(snapshotCharts)
    	cmd += " --output " + odArgs.common.outputFormat
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 29 14:15:33 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  5. operator/cmd/mesh/operator.go

    	}
    
    	odArgs := &operatorDumpArgs{}
    	oiArgs := &operatorInitArgs{}
    	orArgs := &operatorRemoveArgs{}
    	args := &RootArgs{}
    
    	odc := operatorDumpCmd(args, odArgs)
    	oic := operatorInitCmd(ctx, args, oiArgs)
    	orc := operatorRemoveCmd(ctx, args, orArgs)
    
    	addFlags(odc, args)
    	addFlags(oic, args)
    	addFlags(orc, args)
    
    	addOperatorDumpFlags(odc, odArgs)
    	addOperatorInitFlags(oic, oiArgs)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Aug 29 14:15:33 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  6. pkg/config/analysis/incluster/controller.go

    			gvk := oldcfg.GroupVersionKind
    			if (gvk == config.GroupVersionKind{}) {
    				gvk = newcfg.GroupVersionKind
    			}
    			chKind <- gvk
    		})
    	}
    	oldmsgs := map[string]diag.Messages{}
    	pushFn := func(combinedKinds sets.Set[config.GroupVersionKind]) {
    		res, err := c.analyzer.ReAnalyzeSubset(combinedKinds, stop)
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 17:36:47 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/status_strategy.go

    	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)
  8. 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)
  9. pkg/config/schema/codegen/templates/crdclient.go.tmpl

    	case gvk.{{.Resource.Identifier}}:
    		oldRes := &{{ .IstioAwareClientImport }}.{{ .Resource.Kind }}{
    				ObjectMeta: origMeta,
    				Spec:       *(orig.Spec.(*{{ .ClientImport }}.{{.SpecType}})),
    		}
    		modRes := &{{ .IstioAwareClientImport }}.{{ .Resource.Kind }}{
    			ObjectMeta: modMeta,
    			Spec:       *(mod.Spec.(*{{ .ClientImport }}.{{.SpecType}})),
    		}
    		patchBytes, err := genPatchBytes(oldRes, modRes, typ)
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 13:57:51 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top