- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for valueWatchers (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)