- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for tier (0.06 sec)
-
cmd/tier.go
Help: "Time taken by requests served by warm tier", Buckets: []float64{0.01, 0.1, 1, 2, 5, 10, 60, 5 * 60, 15 * 60, 30 * 60}, }, []string{"tier"}), } func (t *tierMetrics) Observe(tier string, dur time.Duration) { t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds()) } func (t *tierMetrics) logSuccess(tier string) { t.Lock() defer t.Unlock()Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/tier_test.go
package cmd import ( "testing" "time" ) func TestTierMetrics(t *testing.T) { tier := "WARM-1" globalTierMetrics.Observe(tier, 200*time.Millisecond) expSuccess := 10 expFailure := 5 for range expSuccess { globalTierMetrics.logSuccess(tier) } for range expFailure { globalTierMetrics.logFailure(tier) } metrics := globalTierMetrics.Report() var succ, fail float64 for _, metric := range metrics {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 1.5K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
} t.activeTasks.Add(-1) } } } func (t *transitionState) addLastDayStats(tier string, ts tierStats) { t.lastDayMu.Lock() defer t.lastDayMu.Unlock() if _, ok := t.lastDayStats[tier]; !ok { t.lastDayStats[tier] = &lastDayTierStats{} } t.lastDayStats[tier].addStats(ts) } func (t *transitionState) getDailyAllTierStats() DailyAllTierStats { t.lastDayMu.RLock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 33.7K bytes - Viewed (0) -
cmd/data-usage-cache.go
for tier, st := range other.Tiers { ats.Tiers[tier] = ats.Tiers[tier].add(st) } } func (ats *allTierStats) clone() *allTierStats { if ats == nil { return nil } dst := *ats dst.Tiers = make(map[string]tierStats, len(ats.Tiers)) maps.Copy(dst.Tiers, ats.Tiers) return &dst } func (ats *allTierStats) populateStats(stats map[string]madmin.TierStats) {Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.7K bytes - Viewed (0) -
cmd/erasure-metadata_test.go
} func TestTransitionInfoEquals(t *testing.T) { inputs := []struct { tier string remoteObjName string remoteVersionID string status string }{ { tier: "S3TIER-1", remoteObjName: mustGetUUID(), remoteVersionID: mustGetUUID(), status: "complete", }, { tier: "S3TIER-2", remoteObjName: mustGetUUID(),
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.4K bytes - Viewed (0) -
cmd/erasure-metadata.go
// from latestFileInfo to get the quorum return dataBlocks, writeQuorum, nil } const ( tierFVID = "tier-free-versionID" tierFVMarker = "tier-free-marker" tierSkipFVID = "tier-skip-fvid" ) // SetTierFreeVersionID sets free-version's versionID. This method is used by // object layer to pass down a versionID to set for a free-version that may be
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 21.3K bytes - Viewed (0) -
cmd/xl-storage-format-utils_test.go
} if i > 3 { // Simulate transition of a version transfi := fi transfi.TransitionStatus = lifecycle.TransitionComplete transfi.TransitionTier = "MINIO-TIER" transfi.TransitionedObjName = mustGetUUID() xl.DeleteVersion(transfi) fi.SetTierFreeVersionID(mustGetUUID()) // delete this version leading to a free version xl.DeleteVersion(fi)Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 7.1K bytes - Viewed (0) -
cmd/object-api-datatypes.go
CommonPrefixes []string EncodingType string // Not supported yet. } // TransitionedObject transitioned object tier and status. type TransitionedObject struct { Name string VersionID string Tier string FreeVersion bool Status string } // DeletedObjectInfo - container for list objects versions deleted objects.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 21.2K bytes - Viewed (0) -
cmd/api-headers.go
// https://docs.aws.amazon.com/AmazonS3/latest/API/API_HeadObject.html#API_HeadObject_ResponseSyntax w.Header()[xhttp.AmzStorageClass] = []string{filterStorageClass(ctx, objInfo.TransitionedObject.Tier)} } if lc, err := globalLifecycleSys.Get(objInfo.Bucket); err == nil { lc.SetPredictionHeaders(w, objInfo.ToLifecycleOpts()) } if v, ok := objInfo.UserDefined[ReservedMetadataPrefix+"compression"]; ok {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 8.6K bytes - Viewed (0) -
cmd/logging.go
} func stsLogIf(ctx context.Context, err error, errKind ...any) { logger.LogIf(ctx, "sts", err, errKind...) } func tierLogIf(ctx context.Context, err error, errKind ...any) { logger.LogIf(ctx, "tier", err, errKind...) } func kmsLogIf(ctx context.Context, err error, errKind ...any) { logger.LogIf(ctx, "kms", err, errKind...) } // KMSLogger permits access to kms module specific logging
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.8K bytes - Viewed (0)