- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for oldregs (0.28 sec)
-
pkg/registry/discovery/endpointslice/strategy_test.go
testcases := []struct { name string hintsGateEnabled bool oldEPS *discovery.EndpointSlice newEPS *discovery.EndpointSlice expectedEPS *discovery.EndpointSlice }{ { name: "node name gate enabled, set on new EPS", oldEPS: &discovery.EndpointSlice{ Endpoints: []discovery.Endpoint{ { NodeName: nil, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.3K bytes - Viewed (0) -
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) -
pkg/controller/deployment/sync.go
func (dc *DeploymentController) syncStatusOnly(ctx context.Context, d *apps.Deployment, rsList []*apps.ReplicaSet) error { newRS, oldRSs, err := dc.getAllReplicaSetsAndSyncRevision(ctx, d, rsList, false) if err != nil { return err } allRSs := append(oldRSs, newRS) return dc.syncDeploymentStatus(ctx, allRSs, newRS, d) } // sync is responsible for reconciling deployments on scaling events or when they
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 24.5K bytes - Viewed (0) -
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) -
src/cmd/vendor/golang.org/x/mod/modfile/work.go
} } return nil } func (f *WorkFile) AddReplace(oldPath, oldVers, newPath, newVers string) error { return addReplace(f.Syntax, &f.Replace, oldPath, oldVers, newPath, newVers) } func (f *WorkFile) DropReplace(oldPath, oldVers string) error { for _, r := range f.Replace { if r.Old.Path == oldPath && r.Old.Version == oldVers { r.Syntax.markRemoved() *r = Replace{} } } return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 18:34:56 UTC 2024 - 7.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/util_test.go
} got := getWorkloadServiceEntries(ses, wle) if !reflect.DeepEqual(got, expected) { t.Errorf("recv unexpected se: %v", got) } } func TestCompareServiceEntries(t *testing.T) { oldSes := map[types.NamespacedName]*config.Config{ {Namespace: "default", Name: "se-1"}: {}, {Namespace: "default", Name: "se-2"}: {}, {Namespace: "default", Name: "se-3"}: {}, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 17 22:32:10 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/controller/deployment/util/deployment_util_test.go
newRSDup.CreationTimestamp = now oldDeployment := generateDeployment("nginx") oldDeployment.Spec.Template.Spec.Containers[0].Name = "nginx-old-1" oldRS := generateRS(oldDeployment) oldRS.Status.FullyLabeledReplicas = *(oldRS.Spec.Replicas) oldRS.CreationTimestamp = before tests := []struct { Name string deployment apps.Deployment rsList []*apps.ReplicaSet
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 37.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/compact.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 17 02:54:36 UTC 2022 - 5.6K bytes - Viewed (0) -
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) -
pilot/pkg/model/jwks_resolver.go
} // Sort both sets of keys by "kid (key ID)" to be able to directly compare oldKeys, oldKeysExists := oldJWKs["keys"].([]any) newKeys, newKeysExists := newJWKs["keys"].([]any) if oldKeysExists && newKeysExists { sort.Slice(oldKeys, func(i, j int) bool { key1, ok1 := oldKeys[i].(map[string]any) key2, ok2 := oldKeys[j].(map[string]any) if ok1 && ok2 { key1Id, kid1Exists := key1["kid"]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 20.3K bytes - Viewed (0)