- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for InitOnce (0.05 sec)
-
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) -
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) -
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)