Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for cachedHasSynced (0.22 sec)

  1. staging/src/k8s.io/apiserver/pkg/quota/v1/generic/evaluator.go

    			return nil, err
    		}
    		return &protectedLister{
    			hasSynced:   cachedHasSynced(informer.Informer().HasSynced),
    			notReadyErr: fmt.Errorf("%v not yet synced", gvr),
    			delegate:    informer.Lister(),
    		}, nil
    	}
    }
    
    // cachedHasSynced returns a function that calls hasSynced() until it returns true once, then returns true
    func cachedHasSynced(hasSynced func() bool) func() bool {
    	cache := &atomic.Bool{}
    	cache.Store(false)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 05 00:02:47 UTC 2023
    - 11.7K bytes
    - Viewed (0)
Back to top