- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for startSize (0.18 sec)
-
cmd/erasure-server-pool-decom.go
"github.com/minio/pkg/v2/env" "github.com/minio/pkg/v2/workers" ) // PoolDecommissionInfo currently decommissioning information type PoolDecommissionInfo struct { StartTime time.Time `json:"startTime" msg:"st"` StartSize int64 `json:"startSize" msg:"ss"` TotalSize int64 `json:"totalSize" msg:"ts"` CurrentSize int64 `json:"currentSize" msg:"cs"` Complete bool `json:"complete" msg:"cmp"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/batch-handlers.go
func (m *batchJobMetrics) trace(d batchJobMetric, job string, attempts int) func(info objTraceInfoer, err error) { startTime := time.Now() return func(info objTraceInfoer, err error) { duration := time.Since(startTime) if globalTrace.NumSubscribers(madmin.TraceBatch) > 0 { globalTrace.Publish(batchJobTrace(d, job, startTime, duration, info, attempts, err)) return } switch d { case batchJobMetricReplication:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/bucket-replication.go
startTime := time.Now() return func(err error) { duration := time.Since(startTime) if globalTrace.NumSubscribers(madmin.TraceReplicationResync) > 0 { globalTrace.Publish(replicationResyncTrace(resyncID, startTime, duration, path, err)) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
istioctl/pkg/waypoint/waypoint.go
if errors.IsNotFound(err) { return fmt.Errorf("missing Kubernetes Gateway CRDs need to be installed before applying a waypoint: %s", err) } return err } if waitReady { startTime := time.Now() ticker := time.NewTicker(1 * time.Second) defer ticker.Stop() for range ticker.C { programmed := false
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/site-replication.go
TotBuckets: len(buckets), BucketStatuses: make(map[string]ResyncStatusType), } for _, bi := range buckets { s.BucketStatuses[bi.Name] = ResyncPending } s.ResyncID = mustGetUUID() s.StartTime = now s.LastUpdate = now return s } // load site resync metadata from disk func loadSiteResyncMetadata(ctx context.Context, objAPI ObjectLayer, dID string) (rs SiteResyncStatus, e error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1)