- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for elapsed (0.23 sec)
-
cmd/rebalance-admin.go
totalBytesToRebal := float64(ps.InitCapacity)*meta.PercentFreeGoal - float64(ps.InitFreeSpace) elapsed := time.Since(ps.Info.StartTime) eta := time.Duration(totalBytesToRebal * float64(elapsed) / float64(ps.Bytes)) if !ps.Info.EndTime.IsZero() { stopTime = ps.Info.EndTime } if !stopTime.IsZero() { // rebalance is stopped or completed elapsed = stopTime.Sub(ps.Info.StartTime) eta = 0 }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Dec 22 00:56:43 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/endpoint.go
) if orchestrated && hostResolveToLocalhost(endpoints[i]) { // time elapsed timeElapsed := time.Since(startTime) // log error only if more than a second has elapsed if timeElapsed > time.Second { reqInfo.AppendTags("elapsedTime", humanize.RelTime(startTime, startTime.Add(timeElapsed), "elapsed", "", )) ctx := logger.SetReqInfo(GlobalContext,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
internal/dsync/dsync_test.go
wg.Wait() // We expect at least 3 x 2 x testDrwMutexAcquireTimeout to have passed elapsed := time.Since(started) if elapsed < expect { t.Errorf("expected at least %v time have passed, however %v passed", expect, elapsed) } t.Logf("expected at least %v time have passed, %v passed", expect, elapsed) } // Test two locks for different resources, both succeed
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
cmd/admin-handlers_test.go
// printEntries(exp) // printEntries(got) for i, e := range exp { if !e.Timestamp.Equal(got[i].Timestamp) { return i, false } // Skip checking elapsed since it's time sensitive. // if e.Elapsed != got[i].Elapsed { // return false // } if e.Resource != got[i].Resource { return i, false } if e.Type != got[i].Type { return i, false }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/prepare-storage.go
logger.Info("Waiting for a minimum of %d drives to come online (elapsed %s)\n", len(endpoints)/2, getElapsedTime()) case errErasureWriteQuorum: // no quorum available continue to wait for minimum number of servers. logger.Info("Waiting for a minimum of %d drives to come online (elapsed %s)\n", (len(endpoints)/2)+1, getElapsedTime()) case errErasureV3ThisEmpty: // need to wait for this error to be healed, so continue. default:
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
docs/batch-jobs/README.md
``` ### Real-time 'status' for a batch job ``` mc batch status myminio/ E24HH4nNMcgY5taynaPfxu ●∙∙ Objects: 28766 Versions: 28766 Throughput: 3.0 MiB/s Transferred: 406 MiB Elapsed: 2m14.227222868s CurrObjName: share/doc/xml-core/examples/foo.xmlcatalogs ``` ### 'describe' the batch job yaml. ``` mc batch describe myminio/ E24HH4nNMcgY5taynaPfxu replicate: apiVersion: v1
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Oct 06 06:00:43 GMT 2022 - 4.8K bytes - Viewed (0) -
cmd/metrics.go
dur = time.Since(bgSeq.lastHealActivity) } ch <- prometheus.MustNewConstMetric( prometheus.NewDesc( prometheus.BuildFQName(healMetricsNamespace, "time", "since_last_activity"), "Time elapsed (in nano seconds) since last self healing activity. This is set to -1 until initial self heal activity", nil, nil), prometheus.GaugeValue, float64(dur), ) for k, v := range bgSeq.getScannedItemsMap() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
internal/dsync/drwmutex.go
// lockBlocking will try to acquire either a read or a write lock // // The function will loop using a built-in timing randomized back-off // algorithm until either the lock is acquired successfully or more // time has elapsed than the timeout value. func (dm *DRWMutex) lockBlocking(ctx context.Context, lockLossCallback func(), id, source string, isReadLock bool, opts Options) (locked bool) { restClnts, _ := dm.clnt.GetLockers()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/metrics-v2.go
} } func getUsageLastScanActivityMD() MetricDescription { return MetricDescription{ Namespace: minioMetricNamespace, Subsystem: usageSubsystem, Name: lastActivityTime, Help: "Time elapsed (in nano seconds) since last scan activity.", Type: gaugeMetric, } } func getBucketUsageQuotaTotalBytesMD() MetricDescription { return MetricDescription{ Namespace: bucketMetricNamespace,
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) -
docs/metrics/prometheus/list.md
| `minio_heal_objects_total` | Objects scanned in current self healing run. | | `minio_heal_time_last_activity_nano_seconds` | Time elapsed (in nano seconds) since last self healing activity. | ## Inter Node Metrics | Name | Description |
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2)