- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,663 for cachez (0.4 sec)
-
pilot/pkg/xds/debug.go
s.addDebugHandler(mux, internalMux, "/debug/cachez", "Info about the internal XDS caches", s.cachez) s.addDebugHandler(mux, internalMux, "/debug/cachez?sizes=true", "Info about the size of the internal XDS caches", s.cachez) s.addDebugHandler(mux, internalMux, "/debug/cachez?clear=true", "Clear the XDS caches", s.cachez) s.addDebugHandler(mux, internalMux, "/debug/configz", "Debug support for config", s.configz)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// since the watch-list is provided by the watch cache instruct // the reflector to issue a regular LIST against the store reflector.UseWatchList = ptr.To(false) cacher.watchCache = watchCache cacher.reflector = reflector go cacher.dispatchEvents() go progressRequester.Run(stopCh) cacher.stopWg.Add(1) go func() { defer cacher.stopWg.Done() defer cacher.terminateAllWatchers() wait.Until(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K 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/kubelet/container/cache.go
// Cache provides two methods to retrieve the PodStatus: the non-blocking Get() // and the blocking GetNewerThan() method. The component responsible for // populating the cache is expected to call Delete() to explicitly free the // cache entries. type Cache interface { Get(types.UID) (*PodStatus, error) // Set updates the cache by setting the PodStatus for the pod only // if the data is newer than the cache based on the provided
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 07:37:01 UTC 2023 - 6.6K bytes - Viewed (0) -
internal/cachevalue/cache.go
func New[T any]() *Cache[T] { return &Cache[T]{} } // NewFromFunc allocates a new cached value instance and initializes it with an // update function, making it ready for use. func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] { return &Cache[T]{ ttl: ttl, updateFn: update, opts: opts, } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K 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) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/cache.go
// unbounded growth on the cache - for a given info the transformer is always the same. // The key always corresponds to the exact same value, with the caveat that // since we use the value.Context.AuthenticatedData to overwrite old keys, // we always have to check that the info matches (to validate the transformer is correct). cache.AllowExpiredGet = true return &simpleCache{ cache: cache, ttl: ttl, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/cache.go
} func newSimpleCache(clock clock.Clock, ttl time.Duration, providerName string) *simpleCache { cache := utilcache.NewExpiringWithClock(clock) cache.AllowExpiredGet = true // for a given key, the value (the decryptTransformer) is always the same return &simpleCache{ cache: cache, ttl: ttl, hashPool: &sync.Pool{ New: func() interface{} { return sha256.New() }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 31 20:26:58 UTC 2023 - 3.5K bytes - Viewed (0) -
internal/config/cache/cache.go
// store and retrieve pre-condition check entities such as // Etag and ModTime of an object + version Endpoint string `json:"endpoint"` // BlockSize indicates the maximum object size below which // data is cached and fetched remotely from DRAM. BlockSize int64 // Is the HTTP client used for communicating with mcache server clnt *http.Client } var configLock sync.RWMutex
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.6K bytes - Viewed (0) -
src/cmd/go/internal/cache/cache.go
var out OutputID h.Sum(out[:0]) // Copy to cached output file (if not already present). if err := c.copyFile(file, out, size); err != nil { return out, size, err } // Add to cache index. return out, size, c.putIndexEntry(id, out, size, allowVerify) } // PutBytes stores the given bytes in the cache as the output for the action ID. func PutBytes(c Cache, id ActionID, data []byte) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Mar 09 14:19:39 UTC 2024 - 20.3K bytes - Viewed (0)