Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getInformerFiltered (0.34 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)
Back to top