Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for cacheArgs (0.45 sec)

  1. src/cmd/go/internal/test/test.go

    			"-test.failfast",
    			"-test.v",
    			"-test.fullpath":
    			// These are cacheable.
    			// Note that this list is documented above,
    			// so if you add to this list, update the docs too.
    			cacheArgs = append(cacheArgs, arg)
    
    		default:
    			// nothing else is cacheable
    			if cache.DebugTest {
    				fmt.Fprintf(os.Stderr, "testcache: caching disabled for test argument: %s\n", arg)
    			}
    			c.disableCache = true
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 14:34:32 UTC 2024
    - 71.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/authentication/token/cache/cached_token_authenticator.go

    func New(authenticator authenticator.Token, cacheErrs bool, successTTL, failureTTL time.Duration) authenticator.Token {
    	return newWithClock(authenticator, cacheErrs, successTTL, failureTTL, clock.RealClock{})
    }
    
    func newWithClock(authenticator authenticator.Token, cacheErrs bool, successTTL, failureTTL time.Duration, clock clock.Clock) authenticator.Token {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/cli-runtime/pkg/resource/crd_finder.go

    }
    
    func NewCRDFinder(getter CRDGetter) CRDFinder {
    	return &crdFinder{
    		getter: getter,
    	}
    }
    
    type crdFinder struct {
    	getter CRDGetter
    	cache  *[]schema.GroupKind
    }
    
    func (f *crdFinder) cacheCRDs() error {
    	if f.cache != nil {
    		return nil
    	}
    
    	list, err := f.getter()
    	if err != nil {
    		return err
    	}
    	f.cache = &list
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 19 14:05:43 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go

    	// When new REST storage is created, the storage cacher for the CR starts asynchronously.
    	// REST API operations return like list use the RV of etcd, but the storage cacher's reflector's list
    	// can get a different RV because etcd can be touched in between the initial list operation (if that's what you're doing first)
    	// and the storage cache reflector starting.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 19 02:01:40 UTC 2021
    - 21.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	"k8s.io/component-base/tracing"
    	"k8s.io/klog/v2"
    	"k8s.io/utils/clock"
    	"k8s.io/utils/ptr"
    )
    
    var (
    	emptyFunc = func(bool) {}
    )
    
    const (
    	// storageWatchListPageSize is the cacher's request chunk size of
    	// initial and resync watch lists to storage.
    	storageWatchListPageSize = int64(10000)
    	// defaultBookmarkFrequency defines how frequently watch bookmarks should be send
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    	eventHandler func(*watchCacheEvent)
    
    	// for testing timeouts.
    	clock clock.Clock
    
    	// An underlying storage.Versioner.
    	versioner storage.Versioner
    
    	// cacher's group resource
    	groupResource schema.GroupResource
    
    	// For testing cache interval invalidation.
    	indexValidator indexValidator
    
    	// Requests progress notification if there are requests waiting for watch
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 10:20:57 UTC 2024
    - 26.2K bytes
    - Viewed (0)
Back to top