- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for FilterIfEnhancedFilteringEnabled (0.33 sec)
-
pilot/pkg/config/kube/crdclient/client.go
extraFilter = of.ObjectFilter.Filter } var namespaceFilter kubetypes.DynamicObjectFilter if !s.IsClusterScoped() { namespaceFilter = kube.FilterIfEnhancedFilteringEnabled(cl.client) } filter := kubetypes.Filter{ObjectFilter: composeFilters(namespaceFilter, cl.inRevision, extraFilter)} var kc kclient.Untyped if s.IsBuiltin() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
pkg/kube/client.go
if port, err := strconv.Atoi(v); err == nil { return port } } return 15014 } // FilterIfEnhancedFilteringEnabled returns the namespace filter if EnhancedResourceScoping is enabled, otherwise a NOP filter. func FilterIfEnhancedFilteringEnabled(k Client) kubetypes.DynamicObjectFilter { if features.EnableEnhancedResourceScoping { return k.ObjectFilter() } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller.go
webhookConfig func() inject.WebhookConfig, injectionHandler func(fn func()), tw revisions.TagWatcher, revision string, ) *DeploymentController { filter := kclient.Filter{ObjectFilter: kube.FilterIfEnhancedFilteringEnabled(client)} gateways := kclient.NewFiltered[*gateway.Gateway](client, filter) gatewayClasses := kclient.New[*gateway.GatewayClass](client) dc := &DeploymentController{ client: client,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 26.3K bytes - Viewed (0)