- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for Machen (0.24 sec)
-
internal/cachevalue/cache.go
// `.TnitOnce`. 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() (T, error)) *Cache[T] { return &Cache[T]{ ttl: ttl, updateFn: update, opts: opts, } } // InitOnce initializes the cache with a TTL and an update function. It is
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 4.2K bytes - Viewed (0) -
internal/config/cache/cache.go
BlockSize = "block_size" EnvEnable = "MINIO_CACHE_ENABLE" EnvEndpoint = "MINIO_CACHE_ENDPOINT" EnvBlockSize = "MINIO_CACHE_BLOCK_SIZE" ) // DefaultKVS - default KV config for cache settings var DefaultKVS = config.KVS{ config.KV{ Key: Enable, Value: "off", }, config.KV{ Key: Endpoint, Value: "", }, config.KV{ Key: BlockSize, Value: "", }, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
Netns: existing.Netns, } // already in cache return existing.Netns } log.Debug("netns inode mismatch, using the new one") } p.addToCacheUnderLock(uid, workload) return workload.Netns } // Update the cache with the given uid and nspath. Return the Netns for the given uid. // If uid is already present, a cached Netns is returned, and the given nspath is ignored.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
cmd/metacache-manager.go
if err != nil { return err } cache := *c if cache.status == scanStateNone || cache.fileNotFound { return errFileNotFound } if cache.status == scanStateSuccess || cache.status == scanStateStarted { if time.Since(cache.lastUpdate) > metacacheMaxRunningAge { // We got a stale entry, mark error on handling server. err := fmt.Errorf("timeout: list %s not updated", cache.id) cache.error = err.Error()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 5.2K bytes - Viewed (0) -
cmd/metacache-entries.go
return selected, true } // If cached is nil we shall skip the entry. if selected.cached == nil { return nil, false } // Merge if we have disagreement. // Create a new merged result. selected = &metaCacheEntry{ name: selected.name, reusable: true, cached: &xlMetaV2{metaV: selected.cached.metaV}, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
internal/http/dial_dnscache.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package http import ( "context" "net" "time" ) // LookupHost is a function to make custom lookupHost for optional cached DNS requests type LookupHost func(ctx context.Context, host string) (addrs []string, err error) // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 03 19:30:51 GMT 2023 - 2.6K bytes - Viewed (0) -
internal/config/cache/remote.go
package cache import ( "net/http" "regexp" "strconv" "time" "github.com/minio/minio/internal/amztime" xhttp "github.com/minio/minio/internal/http" ) //go:generate msgp -file=$GOFILE // ObjectInfo represents the object information cached remotely type ObjectInfo struct { Key string `json:"key"` Bucket string `json:"bucket"` ETag string `json:"etag"` ModTime time.Time `json:"modTime"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 22 21:46:17 GMT 2023 - 3.7K bytes - Viewed (0) -
cmd/bucket-quota.go
if len(dui.BucketsUsage) > 0 { internalLogOnceIf(GlobalContext, fmt.Errorf("unable to retrieve usage information for bucket: %s, relying on older value cached in-memory: err(%v)", bucket, err), "bucket-usage-cache-"+bucket) } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.3K bytes - Viewed (0) -
internal/config/heal/heal.go
// maximum sleep duration between objects to slow down heal operation. Sleep time.Duration `json:"sleep"` IOCount int `json:"iocount"` DriveWorkers int `json:"drive_workers"` // Cached value from Bitrot field cache struct { // -1: bitrot enabled, 0: bitrot disabled, > 0: bitrot cycle bitrotCycle time.Duration } } // BitrotScanCycle returns the configured cycle for the scanner healing // -1 for not enabled
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/object-api-datatypes.go
// what decoding mechanisms must be applied to obtain the object referenced // by the Content-Type header field. ContentEncoding string // Date and time at which the object is no longer able to be cached Expires time.Time // Cache-Control - Specifies caching behavior along the request/reply chain CacheControl string // Specify object storage class StorageClass string ReplicationStatusInternal string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0)