Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for getInformerFiltered (0.7 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top