Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for tier (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top