Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for dui (0.02 sec)

  1. cmd/data-usage-utils.go

    	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)
    
    	infos := make([]madmin.TierInfo, 0, len(ts))
    	for tier, stats := range ts {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  2. cmd/metrics-v3-scanner.go

    	m.Set(scannerVersionsScanned, float64(globalScannerMetrics.lifetime(scannerMetricApplyVersion)))
    
    	dui, err := c.dataUsageInfo.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		m.Set(scannerLastActivitySeconds, time.Since(dui.LastUpdate).Seconds())
    	}
    
    	return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 19:29:25 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. cmd/bucket-quota.go

    func (sys *BucketQuotaSys) GetBucketUsageInfo(ctx context.Context, bucket string) BucketUsageInfo {
    	sys.Init(newObjectLayerFn())
    
    	dui, err := bucketStorageCache.GetWithCtx(ctx)
    	timedout := OperationTimedOut{}
    	if err != nil && !errors.Is(err, context.DeadlineExceeded) && !errors.As(err, &timedout) {
    		if len(dui.BucketsUsage) > 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Aug 06 23:48:58 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  4. cmd/data-usage.go

    	dataUsageCacheName = ".usage-cache.bin"
    )
    
    // storeDataUsageInBackend will store all objects sent on the dui channel until closed.
    func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) {
    	attempts := 1
    	for dataUsageInfo := range dui {
    		json := jsoniter.ConfigCompatibleWithStandardLibrary
    		dataUsageJSON, err := json.Marshal(dataUsageInfo)
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. cmd/tier-handlers.go

    	objAPI, _ := validateAdminReq(ctx, w, r, policy.ListTierAction)
    	if objAPI == nil {
    		return
    	}
    
    	dui, err := loadDataUsageFromBackend(ctx, objAPI)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	tierStats := dui.tierStats()
    	dailyStats := globalNotificationSys.GetLastDayTierStats(ctx)
    	tierStats = dailyStats.addToTierInfo(tierStats)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/SourceSinkTester.java

              + "risus tempor vehicula et a odio. Nam aliquet dolor viverra libero rutrum accumsan "
              + "quis in augue. Suspendisse id dui in lorem tristique placerat eget vel risus. Sed "
              + "metus neque, scelerisque in molestie ac, mattis quis lectus. Pellentesque viverra "
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  7. cmd/data-usage-cache.go

    		}
    	}
    }
    
    // dui converts the flattened version of the path to madmin.DataUsageInfo.
    // As a side effect d will be flattened, use a clone if this is not ok.
    func (d *dataUsageCache) dui(path string, buckets []BucketInfo) DataUsageInfo {
    	e := d.find(path)
    	if e == nil {
    		// No entry found, return empty.
    		return DataUsageInfo{}
    	}
    	flat := d.flatten(*e)
    	dui := DataUsageInfo{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  8. cmd/background-newdisks-heal-ops.go

    	})
    
    	// Load bucket totals
    	cache := dataUsageCache{}
    	if err := cache.load(ctx, z.serverPools[poolIdx].sets[setIdx], dataUsageCacheName); err == nil {
    		dataUsageInfo := cache.dui(dataUsageRoot, nil)
    		tracker.ObjectsTotalCount = dataUsageInfo.ObjectsTotalCount
    		tracker.ObjectsTotalSize = dataUsageInfo.ObjectsTotalSize
    	}
    
    	tracker.PoolIndex, tracker.SetIndex, tracker.DiskIndex = disk.GetDiskLoc()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  9. cmd/metrics-v2.go

    		if globalTierConfigMgr.Empty() {
    			return
    		}
    
    		dui, err := loadDataUsageFromBackend(ctx, objLayer)
    		if err != nil {
    			metricsLogIf(ctx, err)
    			return
    		}
    		// data usage has not captured any tier stats yet.
    		if dui.TierStats == nil {
    			return
    		}
    
    		return dui.tierMetrics()
    	})
    	return mg
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  10. cmd/admin-handlers.go

    		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
    				erasureSet.DeleteMarkersCount = dataUsageInfo.DeleteMarkersTotalCount
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
Back to top