Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for dui (0.2 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  2. cmd/bucket-quota.go

    func (sys *BucketQuotaSys) GetBucketUsageInfo(bucket string) (BucketUsageInfo, error) {
    	dui, err := bucketStorageCache.Get()
    	timedout := OperationTimedOut{}
    	if err != nil && !errors.Is(err, context.DeadlineExceeded) && !errors.As(err, &timedout) {
    		if len(dui.BucketsUsage) > 0 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  3. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  4. 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)
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Feb 15 19:52:44 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  5. 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 "
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 27 18:57:08 GMT 2022
    - 4.9K bytes
    - Viewed (0)
  6. 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{
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  7. android/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 "
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 27 18:57:08 GMT 2022
    - 4.9K 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()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.7K 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
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
Back to top