- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 66 for mdfind (0.15 sec)
-
cmd/data-usage-cache.go
e.ReplicationStats = e.ReplicationStats.clone() } if e.AllTierStats != nil { e.AllTierStats = e.AllTierStats.clone() } return e } // find a path in the cache. // Returns nil if not found. func (d *dataUsageCache) find(path string) *dataUsageEntry { due, ok := d.Cache[hashPath(path).Key()] if !ok { return nil } return &due }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/erasure.go
permutes := r.Perm(len(buckets)) // Add new buckets first for _, idx := range permutes { b := buckets[idx] if e := oldCache.find(b.Name); e == nil { bucketCh <- b } } for _, idx := range permutes { b := buckets[idx] if e := oldCache.find(b.Name); e != nil { cache.replace(b.Name, dataUsageRoot, *e) bucketCh <- b } } xioutil.SafeClose(bucketCh)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
internal/config/identity/openid/jwks_test.go
_, err := jks.DecodePublicKey() if err != nil { t.Fatalf("Failed to decode key %d: %v", ii, err) } kids = append(kids, jks.Kid) } if len(kids) != 3 { t.Fatalf("Failed to find the expected number of kids: 3, got %d", len(kids)) } } // A.1 - Example public keys func TestPublicKey(t *testing.T) { const jsonkey = `{"keys": [ {"kty":"EC", "crv":"P-256",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 9.8K bytes - Viewed (0) -
cmd/metacache-set.go
case <-ctx.Done(): mu.Lock() done = true mu.Unlock() return metaCacheEntriesSorted{}, ctx.Err() case r := <-resultsDone: return r, resErr } } } // findFirstPart will find the part with 0 being the first that corresponds to the marker in the options. // io.ErrUnexpectedEOF is returned if the place containing the marker hasn't been scanned yet.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
var expiryRuleRemoved bool if len(meta.LifecycleConfigXML) > 0 { var lcCfg lifecycle.Lifecycle if err := xml.Unmarshal(meta.LifecycleConfigXML, &lcCfg); err != nil { return updatedAt, err } // find a single expiry rule set the flag for _, rl := range lcCfg.Rules { if !rl.Expiration.IsNull() || !rl.NoncurrentVersionExpiration.IsNull() { expiryRuleRemoved = true break } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
internal/s3select/unused-errors.go
return &s3Error{ code: "ParseExpectedDatePart", message: "Did not find the expected date part in the SQL expression.", statusCode: 400, cause: err, } } func errParseExpectedKeyword(err error) *s3Error { return &s3Error{ code: "ParseExpectedKeyword", message: "Did not find the expected keyword in the SQL expression.", statusCode: 400, cause: err, } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 17.5K bytes - Viewed (0) -
cmd/erasure-multipart.go
if err != nil { if errors.Is(err, errFileNotFound) { // An in-quorum errFileNotFound means that client stream // prematurely closed and we do not find any xl.meta or // part.1's - in such a scenario we must return as if client // disconnected. This means that erasure.Encode() CreateFile() // did not do anything.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
internal/config/config.go
name) return } s.Name = name } return } // CheckValidKeys - checks if inputs KVS has the necessary keys, // returns error if it find extra or superfluous keys. func CheckValidKeys(subSys string, kv KVS, validKVS KVS, deprecatedKeys ...string) error { nkv := KVS{} for _, kv := range kv { // Comment is a valid key, its also fully optional
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
"readwrite", "readonly", "writeonly", "diagnostics", "consoleAdmin", } for _, v := range defaultPolicies { if _, ok := policies[v]; !ok { c.Fatalf("Failed to find %s in policies list", v) } } bucket := getRandomBucketName() err = s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{}) if err != nil { c.Fatalf("bucket creat error: %v", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
if byID { var err error idx, err = strconv.Atoi(pool) if err != nil { // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL) return } } else { idx = globalEndpoints.GetPoolIdx(pool) if idx == -1 { // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0)