Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for informerClient (0.16 sec)

  1. pkg/kube/kclient/client.go

    	handler cache.ResourceEventHandler
    }
    
    type informerClient[T controllers.Object] struct {
    	informer      cache.SharedIndexInformer
    	startInformer func(stopCh <-chan struct{})
    	filter        func(t any) bool
    
    	handlerMu          sync.RWMutex
    	registeredHandlers []handlerRegistration
    }
    
    func (n *informerClient[T]) Get(name, namespace string) T {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 07:14:28 UTC 2024
    - 13K bytes
    - Viewed (0)
  2. pkg/kube/multicluster/secretcontroller.go

    			return nil
    		}
    		log.Infof("Successfully created in cluster kubeclient at %s", localKubeClient.RESTConfig().Host)
    		informerClient = localKubeClient
    	}
    
    	secrets := kclient.NewFiltered[*corev1.Secret](informerClient, kclient.Filter{
    		Namespace:     namespace,
    		LabelSelector: MultiClusterSecretLabel + "=true",
    	})
    
    	// init gauges
    	localClusters.Record(1.0)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 06 02:13:10 UTC 2024
    - 12.7K bytes
    - Viewed (0)
Back to top