Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for HasSynced (0.14 sec)

  1. pkg/revisions/tag_watcher.go

    		return
    	}
    	// Notify handlers of initial state
    	p.notifyHandlers()
    	p.queue.Run(stopCh)
    }
    
    // AddHandler registers a new handler for updates to tag changes.
    func (p *tagWatcher) AddHandler(handler TagHandler) {
    	p.handlers = append(p.handlers, handler)
    }
    
    func (p *tagWatcher) HasSynced() bool {
    	return p.queue.HasSynced()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. pkg/kubelet/util/manager/watch_based_manager.go

    			// watches too often.
    			MinWatchTimeout: 30 * time.Minute,
    		},
    	)
    	item := &objectCacheItem{
    		refMap:    make(map[types.UID]int),
    		store:     store,
    		reflector: reflector,
    		hasSynced: func() (bool, error) { return store.hasSynced(), nil },
    		stopCh:    make(chan struct{}),
    	}
    
    	// Don't start reflector if Kubelet is already shutting down.
    	if !c.stopped {
    		go item.startReflector()
    	}
    	return item
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. pkg/kube/krt/informer.go

    		i.inf.AddEventHandler(informerEventHandler[I](func(o Event[I], initialSync bool) {
    			f([]Event[I]{o}, initialSync)
    		}))
    	}
    	return pollSyncer{
    		name: fmt.Sprintf("%v handler", i.name()),
    		f:    i.inf.HasSynced,
    	}
    }
    
    func informerEventHandler[I controllers.ComparableObject](handler func(o Event[I], initialSync bool)) cache.ResourceEventHandler {
    	return controllers.EventHandler[I]{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 11:01:46 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  4. pilot/pkg/config/kube/crdclient/client.go

    }
    
    func (cl *Client) informerSynced() bool {
    	for gk, ctl := range cl.allKinds() {
    		if !ctl.HasSynced() {
    			cl.logger.Infof("controller %q is syncing...", gk)
    			return false
    		}
    	}
    	return true
    }
    
    func (cl *Client) HasSynced() bool {
    	return cl.queue.HasSynced()
    }
    
    // Schemas for the store
    func (cl *Client) Schemas() collection.Schemas {
    	return cl.schemas
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 00:12:28 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  5. pkg/kube/kclient/client_test.go

    		tracker := assert.NewTracker[string](t)
    		wasm.AddEventHandler(clienttest.TrackerHandler(tracker))
    		go constantlyAccessForRaceDetection(stop, wasm)
    		c.RunAndWait(stop)
    		kube.WaitForCacheSync("test", test.NewStop(t), wasm.HasSynced)
    
    		wt.Create(&istioclient.WasmPlugin{
    			ObjectMeta: metav1.ObjectMeta{Name: "name", Namespace: "default"},
    		})
    		assert.EventuallyEqual(t, func() int {
    			return len(wasm.List("", klabels.Everything()))
    		}, 1)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jun 11 15:12:54 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  6. pkg/controller/statefulset/stateful_set.go

    				recorder),
    			NewRealStatefulSetStatusUpdater(kubeClient, setInformer.Lister()),
    			history.NewHistory(kubeClient, revInformer.Lister()),
    		),
    		pvcListerSynced: pvcInformer.Informer().HasSynced,
    		revListerSynced: revInformer.Informer().HasSynced,
    		queue: workqueue.NewTypedRateLimitingQueueWithConfig(
    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "statefulset"},
    		),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  7. pkg/controller/endpointslice/endpointslice_controller.go

    	c.servicesSynced = serviceInformer.Informer().HasSynced
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addPod,
    		UpdateFunc: c.updatePod,
    		DeleteFunc: c.deletePod,
    	})
    	c.podLister = podInformer.Lister()
    	c.podsSynced = podInformer.Informer().HasSynced
    
    	c.nodeLister = nodeInformer.Lister()
    	c.nodesSynced = nodeInformer.Informer().HasSynced
    
    	logger := klog.FromContext(ctx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  8. pkg/controller/nodeipam/node_ipam_controller.go

    		if err != nil {
    			return nil, err
    		}
    	}
    
    	ic.nodeLister = nodeInformer.Lister()
    	ic.nodeInformerSynced = nodeInformer.Informer().HasSynced
    
    	return ic, nil
    }
    
    // Run starts an asynchronous loop that monitors the status of cluster nodes.
    func (nc *Controller) Run(ctx context.Context) {
    	defer utilruntime.HandleCrash()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 16:18:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/informers.go

    	}
    	if util.PodRedirectionEnabled(ns, pod) {
    		return pod, nil
    	}
    	return nil, nil
    }
    
    func (s *InformerHandlers) Start() {
    	kube.WaitForCacheSync("informer", s.ctx.Done(), s.pods.HasSynced, s.namespaces.HasSynced)
    	go s.queue.Run(s.ctx.Done())
    }
    
    // Gets a point-in-time snapshot of all pods that are CURRENTLY ambient enabled
    // (as per control plane annotation)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  10. pilot/test/xds/fake.go

    	s.Start(stop)
    	cg.ServiceEntryRegistry.XdsUpdater = s
    	// Now that handlers are added, get everything started
    	cg.Run()
    	kubelib.WaitForCacheSync("fake", stop,
    		cg.Registry.HasSynced,
    		cg.Store().HasSynced)
    	cg.ServiceEntryRegistry.ResyncEDS()
    
    	// Send an update. This ensures that even if there are no configs provided, the push context is
    	// initialized.
    	s.ConfigUpdate(&model.PushRequest{Full: true})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 16:08:52 UTC 2024
    - 18.4K bytes
    - Viewed (0)
Back to top