Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for FilterIfEnhancedFilteringEnabled (0.46 sec)

  1. pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go

    		FieldSelector: "metadata.name=" + CACertNamespaceConfigMap,
    		ObjectFilter:  kube.FilterIfEnhancedFilteringEnabled(kubeClient),
    	})
    	c.namespaces = kclient.NewFiltered[*v1.Namespace](kubeClient, kclient.Filter{
    		ObjectFilter: kube.FilterIfEnhancedFilteringEnabled(kubeClient),
    	})
    	// kube-system is not skipped to enable deploying ztunnel in that namespace
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
Back to top