Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for oldKeys (0.18 sec)

  1. 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)
  2. pilot/pkg/config/file/store.go

    				}
    			}
    			s.shas[key] = r.sha
    		}
    		newKeys[key] = r.schema.GroupVersionKind()
    		if oldKeys != nil {
    			scope.Debugf("KubeSource.ApplyContent: Delete: %v/%v", r.schema.GroupVersionKind(), key)
    			delete(oldKeys, key)
    		}
    	}
    
    	for k, col := range oldKeys {
    		empty := ""
    		err := s.inner.Delete(col, k.fullName.Name.String(), k.fullName.Namespace.String(), &empty)
    		if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 17:36:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. pkg/kube/krt/collection.go

    				newRes, newExists := results[key]
    				// Find the old O object
    				oldRes, oldExists := h.collectionState.outputs[key]
    				e := Event[O]{}
    				if newExists && oldExists {
    					if equal(newRes, oldRes) {
    						// NOP change, skip
    						continue
    					}
    					e.Event = controllers.EventUpdate
    					e.New = &newRes
    					e.Old = &oldRes
    					h.collectionState.outputs[key] = newRes
    				} else if newExists {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  4. pilot/pkg/config/kube/crdclient/types.gen.go

    		}
    		patchBytes, err := genPatchBytes(oldRes, modRes, typ)
    		if err != nil {
    			return nil, err
    		}
    		return c.Istio().SecurityV1beta1().AuthorizationPolicies(orig.Namespace).
    			Patch(context.TODO(), orig.Name, typ, patchBytes, metav1.PatchOptions{FieldManager: "pilot-discovery"})
    	case gvk.DestinationRule:
    		oldRes := &apiistioioapinetworkingv1alpha3.DestinationRule{
    			ObjectMeta: origMeta,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 17:37:32 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  5. pkg/registry/discovery/endpointslice/strategy.go

    	newEPS := obj.(*discovery.EndpointSlice)
    	oldEPS := old.(*discovery.EndpointSlice)
    
    	// Increment generation if anything other than meta changed
    	// This needs to be changed if a status attribute is added to EndpointSlice
    	ogNewMeta := newEPS.ObjectMeta
    	ogOldMeta := oldEPS.ObjectMeta
    	newEPS.ObjectMeta = metav1.ObjectMeta{}
    	oldEPS.ObjectMeta = metav1.ObjectMeta{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 02 10:00:01 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. guava/src/com/google/common/collect/JdkBackedImmutableBiMap.java

          if (oldValue != null) {
            throw conflictException("key", e.getKey() + "=" + oldValue, entryArray[i]);
          }
          K oldKey = backwardDelegate.putIfAbsent(e.getValue(), e.getKey());
          if (oldKey != null) {
            throw conflictException("value", oldKey + "=" + e.getValue(), entryArray[i]);
          }
        }
        ImmutableList<Entry<K, V>> entryList = ImmutableList.asImmutableList(entryArray, n);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 28 18:11:09 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  9. 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)
  10. 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