Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for CrdWatcher (0.11 sec)

  1. pkg/kube/client.go

    	GatewayAPI() gatewayapiclient.Interface
    
    	// Informers returns an informer factory
    	Informers() informerfactory.InformerFactory
    
    	// CrdWatcher returns the CRD watcher for this client
    	CrdWatcher() kubetypes.CrdWatcher
    
    	// ObjectFilter returns an object filter that can be used to filter out unwanted objects based on configuration.
    	// This must be set on a client with SetObjectFilter.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 39K bytes
    - Viewed (0)
  2. pilot/pkg/bootstrap/configcontroller.go

    	if features.EnableGatewayAPI {
    		if s.statusManager == nil && features.EnableGatewayAPIStatus {
    			s.initStatusManager(args)
    		}
    		gwc := gateway.NewController(s.kubeClient, configController, s.kubeClient.CrdWatcher().WaitForCRD,
    			s.environment.CredentialsController, args.RegistryOptions.KubeOptions)
    		s.environment.GatewayAPIController = gwc
    		s.ConfigStores = append(s.ConfigStores, s.environment.GatewayAPIController)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  3. pkg/kube/kclient/client.go

    	c kube.Client,
    	gvr schema.GroupVersionResource,
    	informerType kubetypes.InformerType,
    	filter Filter,
    ) Informer[T] {
    	watcher := c.CrdWatcher()
    	if watcher == nil {
    		log.Fatalf("NewDelayedInformer called without a CrdWatcher enabled")
    	}
    	delay := newDelayedFilter(gvr, watcher)
    	inf := func() informerfactory.StartableInformer {
    		opts := ToOpts(c, gvr, filter)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 07:14:28 UTC 2024
    - 13K bytes
    - Viewed (0)
Back to top