Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for InitOnce (0.05 sec)

  1. cmd/data-usage_test.go

    				return
    			}
    			sizeS.totalSize = s.Size()
    			sizeS.versions++
    			return sizeS, nil
    		}
    		return
    	}
    	xls := xlStorage{drivePath: base, diskInfoCache: cachevalue.New[DiskInfo]()}
    	xls.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{}, func(ctx context.Context) (DiskInfo, error) {
    		return DiskInfo{Total: 1 << 40, Free: 1 << 40}, nil
    	})
    	weSleep := func() bool { return false }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    		}
    		info = *infop
    		if info.Error != "" {
    			return info, toStorageErr(errors.New(info.Error))
    		}
    		return info, nil
    	} // In all other cases cache the value upto 1sec.
    
    	client.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{},
    		func(ctx context.Context) (info DiskInfo, err error) {
    			ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			defer cancel()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	healthCheck  bool
    
    	metricsCache *cachevalue.Cache[DiskMetrics]
    	diskCtx      context.Context
    	diskCancel   context.CancelFunc
    }
    
    func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics {
    	p.metricsCache.InitOnce(5*time.Second,
    		cachevalue.Opts{},
    		func(ctx context.Context) (DiskMetrics, error) {
    			diskMetric := DiskMetrics{
    				LastMinute: make(map[string]AccElem, len(p.apiLatencies)),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
Back to top