Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for InformerWatchNamespace (0.16 sec)

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

    		return !c.ignoredNamespaces.Contains(o.GetNamespace())
    	}))
    
    	c.namespaces.AddEventHandler(controllers.FilteredObjectSpecHandler(c.queue.AddObject, func(o controllers.Object) bool {
    		if features.InformerWatchNamespace != "" && features.InformerWatchNamespace != o.GetName() {
    			// We are only watching one namespace, and its not this one
    			return false
    		}
    		if c.ignoredNamespaces.Contains(o.GetName()) {
    			// skip special kubernetes system namespaces
    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. pkg/kube/kclient/client_test.go

    			},
    			want: kubetypes.InformerOptions{
    				Namespace: "foo",
    				Cluster:   c.ClusterID(),
    			},
    		},
    		{
    			name: "watch pods in the InformerWatchNamespace",
    			gvr:  gvr.Pod,
    			want: kubetypes.InformerOptions{
    				Namespace: features.InformerWatchNamespace,
    				Cluster:   c.ClusterID(),
    			},
    		},
    		{
    			name: "watch namespaces",
    			gvr:  gvr.Namespace,
    			want: kubetypes.InformerOptions{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 11 15:12:54 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  3. pilot/pkg/features/pilot.go

    	LocalClusterSecretWatcher = env.Register("LOCAL_CLUSTER_SECRET_WATCHER", false,
    		"If enabled, the cluster secret watcher will watch the namespace of the external cluster instead of config cluster").Get()
    
    	InformerWatchNamespace = env.Register("ISTIO_WATCH_NAMESPACE", "",
    		"If set, limit Kubernetes watches to a single namespace. "+
    			"Warning: only a single namespace can be set.").Get()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. pkg/kube/kclient/client.go

    }
    
    func ToOpts(c kube.Client, gvr schema.GroupVersionResource, filter Filter) kubetypes.InformerOptions {
    	ns := filter.Namespace
    	if !istiogvr.IsClusterScoped(gvr) && ns == "" {
    		ns = features.InformerWatchNamespace
    	}
    	return kubetypes.InformerOptions{
    		LabelSelector:   filter.LabelSelector,
    		FieldSelector:   filter.FieldSelector,
    		Namespace:       ns,
    		ObjectTransform: filter.ObjectTransform,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 07:14:28 UTC 2024
    - 13K bytes
    - Viewed (0)
Back to top