- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 70 for Marche (0.17 sec)
-
cmd/metacache-walk.go
DiskID string } // supported FS for Nlink optimization in readdir. const ( xfs = "XFS" ext4 = "EXT4" ) // WalkDir will traverse a directory and return all entries found. // On success a sorted meta cache stream will be returned. // Metadata has data stripped, if any. func (s *xlStorage) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) { legacyFS := !(s.fsType == xfs || s.fsType == ext4) s.RLock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/storage-interface.go
// returns 'nil' once healing is complete or if the disk // has never been replaced. Healing() *healingTracker DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) NSScanner(ctx context.Context, cache dataUsageCache, updates chan<- dataUsageEntry, scanMode madmin.HealScanMode, shouldSleep func() bool) (dataUsageCache, error) // Volume operations. MakeVol(ctx context.Context, volume string) (err error)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.9K bytes - Viewed (0) -
internal/kms/kes.go
return c, nil } // Request KES keep an up-to-date copy of the KMS master key to allow minio to start up even if KMS is down. The // cached key may still be evicted if the period of this function is longer than that of KES .cache.expiry.unused func (c *kesClient) refreshKMSMasterKeyCache(logger Logger) { ctx := context.Background() defaultCacheDuration := 10 * time.Second
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/metacache-bucket.go
b.debugf("cache %s not worth keeping", id) remove[id] = struct{}{} continue } if cache.id != id { logger.Info("cache ID mismatch %s != %s", id, cache.id) remove[id] = struct{}{} continue } if cache.bucket != b.bucket { logger.Info("cache bucket mismatch %s != %s", b.bucket, cache.bucket) remove[id] = struct{}{} continue } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.6K bytes - Viewed (0) -
cmd/iam-object-store.go
err := iamOS.loadMappedPolicy(ctx, svcParent, stsUser, false, cache.iamSTSPolicyMap) if err != nil && !errors.Is(err, errNoSuchPolicy) { return fmt.Errorf("unable to load the policy mapping for the STS user `%s`: %w", svcParent, err) } } } // Copy svcUsersMap to cache.iamUsersMap for k, v := range svcUsersMap { cache.iamUsersMap[k] = v } cache.buildUserGroupMemberships() return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/metacache-marker.go
s := o.Marker if !strings.Contains(s, "[minio_cache:"+markerTagVersion) { return } start := strings.LastIndex(s, "[") o.Marker = s[:start] end := strings.LastIndex(s, "]") tag := strings.Trim(s[start:end], "[]") tags := strings.Split(tag, ",") for _, tag := range tags { kv := strings.Split(tag, ":") if len(kv) < 2 { continue } switch kv[0] { case "minio_cache": if kv[1] != markerTagVersion {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/metrics-v3-types.go
// returned by these functions must be present in the `Descriptors` list. loader MetricsLoaderFn bucketLoader BucketMetricsLoaderFn // Cache for all metrics groups. Set via `.SetCache` method. cache *metricsCache // managed values follow: // map of metric descriptors by metric name. descriptorMap map[MetricName]MetricDescriptor
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:05:22 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/admin-handlers.go
} erasureSet, ok := poolInfo[d.SetIndex] if !ok { erasureSet.ID = d.SetIndex cache := dataUsageCache{} if err := cache.load(ctx, z.serverPools[d.PoolIndex].sets[d.SetIndex], dataUsageCacheName); err == nil { dataUsageInfo := cache.dui(dataUsageRoot, nil) erasureSet.ObjectsCount = dataUsageInfo.ObjectsTotalCount erasureSet.VersionsCount = dataUsageInfo.VersionsTotalCount
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
internal/http/headers.go
Location = "Location" CacheControl = "Cache-Control" ContentDisposition = "Content-Disposition" Authorization = "Authorization" Action = "Action" Range = "Range" ) // Non standard S3 HTTP response constants const ( XCache = "X-Cache" XCacheLookup = "X-Cache-Lookup" ) // Standard S3 HTTP request constants const (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 10.4K bytes - Viewed (1) -
cmd/postpolicyform.go
) // startWithConds - map which indicates if a given condition supports starts-with policy operator var startsWithConds = map[string]bool{ "$acl": true, "$bucket": false, "$cache-control": true, "$content-type": true, "$content-disposition": true, "$content-encoding": true, "$expires": true, "$key": true,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.2K bytes - Viewed (0)