- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,831 for kcache (0.27 sec)
-
pkg/controller/volume/attachdetach/attach_detach_controller.go
podIndexer kcache.Indexer nodeLister corelisters.NodeLister nodesSynced kcache.InformerSynced csiNodeLister storagelistersv1.CSINodeLister csiNodeSynced kcache.InformerSynced // csiDriverLister is the shared CSIDriver lister used to fetch and store // CSIDriver objects from the API server. It is shared with other controllers // and therefore the CSIDriver objects in its store should be treated as immutable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" kcache "k8s.io/client-go/tools/cache" "k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller/volume/attachdetach/cache" controllervolumetesting "k8s.io/kubernetes/pkg/controller/volume/attachdetach/testing" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/csi"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
src/runtime/mcache.go
var emptymspan mspan func allocmcache() *mcache { var c *mcache systemstack(func() { lock(&mheap_.lock) c = (*mcache)(mheap_.cachealloc.alloc()) c.flushGen.Store(mheap_.sweepgen) unlock(&mheap_.lock) }) for i := range c.alloc { c.alloc[i] = &emptymspan } c.nextSample = nextSample() return c } // freemcache releases resources associated with this // mcache and puts the object onto a free list. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 10K bytes - Viewed (0) -
src/cmd/go/internal/cache/cache.go
// Package cache implements a build artifact cache. package cache import ( "bytes" "crypto/sha256" "encoding/hex" "errors" "fmt" "internal/godebug" "io" "io/fs" "os" "path/filepath" "strconv" "strings" "time" "cmd/go/internal/lockedfile" "cmd/go/internal/mmap" ) // An ActionID is a cache action key, the hash of a complete description of a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Mar 09 14:19:39 UTC 2024 - 20.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
* default, OkHttp will perform lazy initialization upon the first usage of the cache. */ @Throws(IOException::class) fun initialize() { cache.initialize() } /** * Closes the cache and deletes all of its stored values. This will delete all files in the cache * directory including files that weren't created by the cache. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 26.8K bytes - Viewed (0) -
pkg/wasm/cache.go
// sha256 scheme prefix sha256SchemePrefix = "sha256:" ) // Cache models a Wasm module cache. type Cache interface { Get(url string, opts GetOptions) (string, error) Cleanup() } // LocalFileCache for downloaded Wasm modules. Currently it stores the Wasm module as local file. type LocalFileCache struct { // Map from Wasm module checksum to cache entry. modules map[moduleKey]*cacheEntry // Map from tagged URL to checksum
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 13.3K bytes - Viewed (0) -
src/cmd/go/internal/modfetch/cache.go
if err != nil { return "", err } return sum, nil } var errNotCached = fmt.Errorf("not in cache") // readDiskStat reads a cached stat result from disk, // returning the name of the cache file and the result. // If the read fails, the caller can use // writeDiskStat(file, info) to write a new cache entry. func readDiskStat(ctx context.Context, path, rev string) (file string, info *RevInfo, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 18:15:22 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
// DO NOT use outside of tests. func (cache *cacheImpl) NodeCount() int { cache.mu.RLock() defer cache.mu.RUnlock() return len(cache.nodes) } // PodCount returns the number of pods in the cache (including those from deleted nodes). // DO NOT use outside of tests. func (cache *cacheImpl) PodCount() (int, error) { cache.mu.RLock() defer cache.mu.RUnlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
cmd/data-usage-cache.go
// dataUsageCacheV2 contains a cache of data usage entries version 2. type dataUsageCacheV2 struct { Info dataUsageCacheInfo Cache map[string]dataUsageEntryV2 } // dataUsageCacheV3 contains a cache of data usage entries version 3. type dataUsageCacheV3 struct { Info dataUsageCacheInfo Cache map[string]dataUsageEntryV3 } // dataUsageCacheV4 contains a cache of data usage entries version 4.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 10 14:49:50 UTC 2024 - 42.8K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
r.qCache.Lock() defer r.qCache.Unlock() v, ok := r.qCache.bucketStats[bucket] if !ok { v = newInQueueStats(r.registry, bucket) } atomic.AddInt64(&v.nowBytes, sz) atomic.AddInt64(&v.nowCount, 1) r.qCache.bucketStats[bucket] = v atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, sz) atomic.AddInt64(&r.qCache.srQueueStats.nowCount, 1) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0)