- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for getInformerFiltered (0.43 sec)
-
pkg/config/schema/kubeclient/common_test.go
}, ) ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}} client := kube.NewFakeClient(ns) inf := GetInformerFiltered[*v1.NetworkPolicy](client, ktypes.InformerOptions{}) if inf.Informer == nil { t.Errorf("Expected valid informer, got empty") } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 1.8K bytes - Viewed (0) -
pkg/config/schema/kubeclient/common.go
// GatewayAPI returns the gateway-api kube client. GatewayAPI() gatewayapiclient.Interface // Informers returns an informer factory. Informers() informerfactory.InformerFactory } func GetInformerFiltered[T runtime.Object](c ClientGetter, opts ktypes.InformerOptions) informerfactory.StartableInformer { reg := typemap.Get[TypeRegistration[T]](registerTypes) if reg != nil { // This is registered type tr := *reg
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/config/schema/codegen/templates/clients.go.tmpl
case gvr.{{ .Resource.Identifier }}: return &{{ .IstioAwareClientImport }}.{{ .Resource.Kind }}{} {{- end }} {{- end }} default: panic(fmt.Sprintf("Unknown type %v", g)) } } func getInformerFiltered(c ClientGetter, opts ktypes.InformerOptions, g schema.GroupVersionResource) informerfactory.StartableInformer { var l func(options metav1.ListOptions) (runtime.Object, error)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 13:57:51 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/kube/kclient/client.go
// Use with caution. func NewFiltered[T controllers.ComparableObject](c kube.Client, filter Filter) Client[T] { gvr := types.MustToGVR[T](types.MustGVKFromType[T]()) inf := kubeclient.GetInformerFiltered[T](c, ToOpts(c, gvr, filter)) return &fullClient[T]{ writeClient: writeClient[T]{client: c}, Informer: newInformerClient[T](gvr, inf, filter), } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/config/schema/kubeclient/resources.gen.go
case gvr.WorkloadGroup: return &apiistioioapinetworkingv1alpha3.WorkloadGroup{} default: panic(fmt.Sprintf("Unknown type %v", g)) } } func getInformerFiltered(c ClientGetter, opts ktypes.InformerOptions, g schema.GroupVersionResource) informerfactory.StartableInformer { var l func(options metav1.ListOptions) (runtime.Object, error)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 13:57:51 UTC 2024 - 31.1K bytes - Viewed (0)