Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for gvr (0.02 sec)

  1. pkg/kube/kclient/client_test.go

    			},
    		},
    		{
    			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{
    				Namespace: "",
    				Cluster:   c.ClusterID(),
    			},
    		},
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 11 15:12:54 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  2. pilot/test/xds/fake.go

    			MeshWatcher:     mesh.NewFixedWatcher(m),
    			CRDs: []schema.GroupVersionResource{
    				// Install all CRDs used (mostly in Ambient)
    				gvr.AuthorizationPolicy,
    				gvr.PeerAuthentication,
    				gvr.KubernetesGateway,
    				gvr.KubernetesGateway,
    				gvr.WorkloadEntry,
    				gvr.ServiceEntry,
    			},
    		})
    		stop := test.NewStop(t)
    		// start default client informers after creating ingress/secret controllers
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 16:08:52 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/crdclient/client.go

    	var kc kclient.Untyped
    	if s.IsBuiltin() {
    		kc = kclient.NewUntypedInformer(cl.client, gvr, filter)
    	} else {
    		kc = kclient.NewDelayedInformer[controllers.Object](
    			cl.client,
    			gvr,
    			kubetypes.StandardInformer,
    			filter,
    		)
    	}
    
    	kind := s.Kind()
    	kc.AddEventHandler(controllers.EventHandler[controllers.Object]{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  4. pkg/kube/krt/informer.go

    	}()
    	return h
    }
    
    // NewInformer creates a Collection[I] sourced from
    // the results of kube.Client querying resources of type I
    // from the API Server.
    //
    // Resources must have their GVR and GVK registered in the
    // kube.Client before this method is called, otherwise
    // NewInformer will panic.
    func NewInformer[I controllers.ComparableObject](c kube.Client, opts ...CollectionOption) Collection[I] {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top