Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for tierStats (0.22 sec)

  1. cmd/data-usage-utils.go

    	// TierStats contains per-tier stats of all configured remote tiers
    	TierStats *allTierStats `json:"tierStats,omitempty"`
    }
    
    func (dui DataUsageInfo) tierStats() []madmin.TierInfo {
    	if dui.TierStats == nil {
    		return nil
    	}
    
    	if globalTierConfigMgr.Empty() {
    		return nil
    	}
    
    	ts := make(map[string]madmin.TierStats)
    	dui.TierStats.populateStats(ts)
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  2. cmd/data-usage-cache.go

    			NumObjects:  st.NumObjects,
    		}
    	}
    	return
    }
    
    // tierStats holds per-tier stats of a remote tier.
    type tierStats struct {
    	TotalSize   uint64 `msg:"ts"`
    	NumVersions int    `msg:"nv"`
    	NumObjects  int    `msg:"no"`
    }
    
    func (ts tierStats) add(u tierStats) tierStats {
    	return tierStats{
    		TotalSize:   ts.TotalSize + u.TotalSize,
    		NumVersions: ts.NumVersions + u.NumVersions,
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  3. cmd/tier-last-day-stats.go

    package cmd
    
    import (
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    //go:generate msgp -file=$GOFILE -unexported
    
    type lastDayTierStats struct {
    	Bins      [24]tierStats
    	UpdatedAt time.Time
    }
    
    func (l *lastDayTierStats) addStats(ts tierStats) {
    	now := time.Now()
    	l.forwardTo(now)
    
    	nowIdx := now.Hour()
    	l.Bins[nowIdx] = l.Bins[nowIdx].add(ts)
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  4. cmd/tier-handlers.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	tierStats := dui.tierStats()
    	dailyStats := globalNotificationSys.GetLastDayTierStats(ctx)
    	tierStats = dailyStats.addToTierInfo(tierStats)
    
    	data, err := json.Marshal(tierStats)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 15 19:52:44 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  5. cmd/data-usage-cache_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgtierStats(b *testing.B) {
    	v := tierStats{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgtierStats(b *testing.B) {
    	v := tierStats{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Jan 13 07:51:08 GMT 2024
    - 28.1K bytes
    - Viewed (0)
  6. cmd/object-api-datatypes.go

    	}
    	cinfo.UserDefined = make(map[string]string, len(o.UserDefined))
    	for k, v := range o.UserDefined {
    		cinfo.UserDefined[k] = v
    	}
    	return cinfo
    }
    
    func (o ObjectInfo) tierStats() tierStats {
    	ts := tierStats{
    		TotalSize:   uint64(o.Size),
    		NumVersions: 1,
    	}
    	// the current version of an object is accounted towards objects count
    	if o.IsLatest {
    		ts.NumObjects = 1
    	}
    	return ts
    }
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.8K bytes
    - Viewed (0)
  7. cmd/bucket-lifecycle.go

    					}
    				}
    			} else {
    				ts := tierStats{
    					TotalSize:   uint64(task.objInfo.Size),
    					NumVersions: 1,
    				}
    				if task.objInfo.IsLatest {
    					ts.NumObjects = 1
    				}
    				t.addLastDayStats(task.event.StorageClass, ts)
    			}
    			t.activeTasks.Add(-1)
    		}
    	}
    }
    
    func (t *transitionState) addLastDayStats(tier string, ts tierStats) {
    	t.lastDayMu.Lock()
    	defer t.lastDayMu.Unlock()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  8. cmd/data-usage-cache_gen.go

    				err = msgp.WrapError(err, "Tiers")
    				return
    			}
    			if z.Tiers == nil {
    				z.Tiers = make(map[string]tierStats, zb0002)
    			} else if len(z.Tiers) > 0 {
    				for key := range z.Tiers {
    					delete(z.Tiers, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    				var za0002 tierStats
    				za0001, err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "Tiers")
    					return
    				}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 100.8K bytes
    - Viewed (0)
  9. cmd/xl-storage.go

    		for _, tier := range globalTierConfigMgr.ListTiers() {
    			if sizeS.tiers == nil {
    				sizeS.tiers = make(map[string]tierStats)
    			}
    			sizeS.tiers[tier.Name] = tierStats{}
    		}
    		if sizeS.tiers != nil {
    			sizeS.tiers[storageclass.STANDARD] = tierStats{}
    			sizeS.tiers[storageclass.RRS] = tierStats{}
    		}
    
    		done := globalScannerMetrics.time(scannerMetricApplyAll)
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 82.4K bytes
    - Viewed (0)
  10. cmd/data-scanner.go

    	failedSize      int64
    	replicaSize     int64
    	replicaCount    int64
    	pendingCount    uint64
    	failedCount     uint64
    	replTargetStats map[string]replTargetSizeSummary
    	tiers           map[string]tierStats
    }
    
    // replTargetSizeSummary holds summary of replication stats by target
    type replTargetSizeSummary struct {
    	replicatedSize  int64
    	replicatedCount int64
    	pendingSize     int64
    	failedSize      int64
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 09:40:19 GMT 2024
    - 46.9K bytes
    - Viewed (0)
Back to top