- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for cacheArgs (0.45 sec)
-
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) -
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) -
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) -
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) -
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) -
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)