Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for valueWatchers (0.22 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    type indexedWatchers struct {
    	allWatchers   map[namespacedName]watchersMap
    	valueWatchers map[string]watchersMap
    }
    
    func (i *indexedWatchers) addWatcher(w *cacheWatcher, number int, scope namespacedName, value string, supported bool) {
    	if supported {
    		if _, ok := i.valueWatchers[value]; !ok {
    			i.valueWatchers[value] = watchersMap{}
    		}
    		i.valueWatchers[value].addWatcher(w, number)
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_testing_utils_test.go

    		c.Lock()
    		defer c.Unlock()
    
    		if c.watchCache.resourceVersion < rv {
    			t.Fatalf("Can't compact into a future version: %v", resourceVersion)
    		}
    
    		if len(c.watchers.allWatchers) > 0 || len(c.watchers.valueWatchers) > 0 {
    			// We could consider terminating those watchers, but given
    			// watchcache doesn't really support compaction and we don't
    			// exercise it in tests, we just throw an error here.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 20:43:52 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  3. pilot/pkg/security/authz/matcher/metadata.go

    	if useExtendedJwt {
    		out.Value = &matcher.ValueMatcher{
    			MatchPattern: &matcher.ValueMatcher_OrMatch{
    				OrMatch: &matcher.OrMatcher{
    					ValueMatchers: []*matcher.ValueMatcher{
    						{
    							MatchPattern: &matcher.ValueMatcher_ListMatch{
    								ListMatch: listMatcher,
    							},
    						},
    						value,
    					},
    				},
    			},
    		}
    	} else {
    		out.Value = &matcher.ValueMatcher{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 25 10:39:25 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. pilot/pkg/security/authz/matcher/string.go

    func OrMatcher(matchers []*matcher.ValueMatcher) *matcher.ValueMatcher {
    	if len(matchers) == 1 {
    		return matchers[0]
    	}
    	return &matcher.ValueMatcher{
    		MatchPattern: &matcher.ValueMatcher_OrMatch{
    			OrMatch: &matcher.OrMatcher{
    				ValueMatchers: matchers,
    			},
    		},
    	}
    }
    
    // StringMatcherRegex creates a regex string matcher for regex.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 25 10:39:25 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    		cacher.Lock()
    		defer cacher.Unlock()
    
    		require.Equal(t, expectedWatchersCounter, len(cacher.watchers.allWatchers))
    		require.Equal(t, expectedValueWatchersCounter, len(cacher.watchers.valueWatchers))
    	}
    	assertCacherInternalState(0, 0)
    
    	var forgetWatcherFn func(bool)
    	var forgetCounter int
    	forgetWatcherWrapped := func(drainWatcher bool) {
    		forgetCounter++
    		forgetWatcherFn(drainWatcher)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  6. pilot/pkg/security/authz/builder/testdata/http/extended-allow-full-rule-out.yaml

                    - key: payload
                    - key: aud
                    value:
                      orMatch:
                        valueMatchers:
                        - listMatch:
                            oneOf:
                              orMatch:
                                valueMatchers:
                                - stringMatch:
                                    exact: audiences
                                - stringMatch:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 03 18:02:42 UTC 2024
    - 39K bytes
    - Viewed (0)
  7. pilot/pkg/security/authz/matcher/metadata_test.go

    				{
    					Segment: &matcher.MetadataMatcher_PathSegment_Key{
    						Key: "key2",
    					},
    				},
    			},
    			Value: &matcher.ValueMatcher{
    				MatchPattern: &matcher.ValueMatcher_ListMatch{
    					ListMatch: &matcher.ListMatcher{
    						MatchPattern: &matcher.ListMatcher_OneOf{
    							OneOf: &matcher.ValueMatcher{
    								MatchPattern: &matcher.ValueMatcher_StringMatch{
    									StringMatch: &matcher.StringMatcher{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Nov 20 22:15:12 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  8. pilot/pkg/security/authz/model/util.go

    	return MetadataValueMatcherForJWTClaim(claim, &matcherpb.ValueMatcher{
    		MatchPattern: &matcherpb.ValueMatcher_StringMatch{
    			StringMatch: m,
    		},
    	})
    }
    
    func MetadataValueMatcherForJWTClaim(claim string, m *matcherpb.ValueMatcher) *matcherpb.MetadataMatcher {
    	return &matcherpb.MetadataMatcher{
    		Filter: filters.EnvoyJwtFilterName,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Mar 25 10:39:25 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  9. pilot/pkg/security/authz/model/generator.go

    	}
    
    	matchers := []*matcherpb.ValueMatcher{}
    	for _, value := range values {
    		if strings.HasPrefix(value, "[") && strings.HasSuffix(value, "]") {
    			matchers = append(matchers, &matcherpb.ValueMatcher{
    				MatchPattern: &matcherpb.ValueMatcher_ListMatch{
    					ListMatch: &matcherpb.ListMatcher{
    						MatchPattern: &matcherpb.ListMatcher_OneOf{
    							OneOf: &matcherpb.ValueMatcher{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 03 18:02:42 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  10. pilot/pkg/security/authz/builder/extauthz.go

    				Segment: &envoy_type_matcher_v3.MetadataMatcher_PathSegment_Key{
    					Key: authzmodel.RBACExtAuthzShadowRulesStatPrefix + authzmodel.RBACShadowEffectivePolicyID,
    				},
    			},
    		},
    		Value: &envoy_type_matcher_v3.ValueMatcher{
    			MatchPattern: &envoy_type_matcher_v3.ValueMatcher_StringMatch{
    				StringMatch: &envoy_type_matcher_v3.StringMatcher{
    					MatchPattern: &envoy_type_matcher_v3.StringMatcher_Prefix{
    						Prefix: extAuthzMatchPrefix,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top