Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for OneTermEqualSelector (0.22 sec)

  1. staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go

    		listOptions.FieldSelector = fields.OneTermEqualSelector("metadata.name", c.configmapName).String()
    	})
    
    	c.configmapInformer.AddEventHandler(cache.FilteringResourceEventHandler{
    		FilterFunc: func(obj interface{}) bool {
    			if cast, ok := obj.(*corev1.ConfigMap); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_linux.go

    	// for podCIDR to be assigned, instead of assuming that the Get() on startup will have it.
    	ctx, cancelFunc := context.WithTimeout(ctx, timeoutForNodePodCIDR)
    	defer cancelFunc()
    
    	fieldSelector := fields.OneTermEqualSelector("metadata.name", nodeName).String()
    	lw := &cache.ListWatch{
    		ListFunc: func(options metav1.ListOptions) (object runtime.Object, e error) {
    			options.FieldSelector = fieldSelector
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  3. cmd/kube-proxy/app/server.go

    	currentNodeInformerFactory := informers.NewSharedInformerFactoryWithOptions(s.Client, s.Config.ConfigSyncPeriod.Duration,
    		informers.WithTweakListOptions(func(options *metav1.ListOptions) {
    			options.FieldSelector = fields.OneTermEqualSelector("metadata.name", s.NodeRef.Name).String()
    		}))
    	nodeConfig := config.NewNodeConfig(ctx, currentNodeInformerFactory.Core().V1().Nodes(), s.Config.ConfigSyncPeriod.Duration)
    	// https://issues.k8s.io/111321
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
Back to top