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