Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for cacheSync (0.22 sec)

  1. pkg/controller/job/job_controller_test.go

    	gotExpectedUIDs = manager.finalizerExpectations.getExpectedUIDs(jobKey)
    	if diff := cmp.Diff(uids, gotExpectedUIDs); diff != "" {
    		t.Errorf("Different expectations for removed finalizers after syncJob and cacheSync (-want,+got):\n%s", diff)
    	}
    
    	// Change pods in different ways.
    
    	podsResource := schema.GroupVersionResource{Version: "v1", Resource: "pods"}
    
    	update := pods[0].DeepCopy()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  2. pkg/kube/client.go

    // This is only required in cases where fake clients are used without RunAndWait.
    func (c *client) WaitForCacheSync(name string, stop <-chan struct{}, cacheSyncs ...cache.InformerSynced) bool {
    	if c.informerWatchesPending == nil {
    		return WaitForCacheSync(name, stop, cacheSyncs...)
    	}
    	syncFns := append(cacheSyncs, func() bool {
    		return c.informerWatchesPending.Load() == 0
    	})
    	return WaitForCacheSync(name, stop, syncFns...)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 39K bytes
    - Viewed (0)
Back to top