- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for RI (0.15 sec)
-
cmd/batch-handlers.go
JobType: ri.JobType, RetryAttempts: ri.RetryAttempts, Complete: ri.Complete, Failed: ri.Failed, StartTime: ri.StartTime, LastUpdate: ri.LastUpdate, Bucket: ri.Bucket, Object: ri.Object, Objects: ri.Objects, ObjectsFailed: ri.ObjectsFailed, BytesTransferred: ri.BytesTransferred, BytesFailed: ri.BytesFailed, }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
} // ToMRFEntry returns the relevant info needed by MRF func (ri ReplicateObjectInfo) ToMRFEntry() MRFReplicateEntry { return MRFReplicateEntry{ Bucket: ri.Bucket, Object: ri.Name, versionID: ri.VersionID, sz: ri.Size, RetryCount: int(ri.RetryCount), }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
internal/config/certs_test.go
IIj4neslnAvwQ8SN4XUpug+7pGF+2m/5UDwRzSUN1H2RfgWN95kqR+tYqCq/E+KO i0svzFrljSHswsFoPBqKngI7hHwc9QTt5q4frXwj9I4F6HHrTKZnC5M4ef26sbJ1 r7JRmkt0h/GfcS355b0uoBTtF1R8tSJo85Zh47wE+ucdjEvy9/pjnzKqIoJo9bNZ ri+ue7GhH5EUca1Kd10bH8FqTF+8AHh4yW6xMxSkSgFGp7KtraAVpdp+6kosymqh dz9VMjA8i28btfkS2isRaCpyumaFYJ3DJMFYhmeyt6gqYovmRLX0qrBf8nrkFTAA ZmykWsc8ErsCudxlDmKVemuyFL7jtm9IRPq+Jh+IrmixLJFx8PKkNAM6g+A8irx8
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 21.6K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
} case replication.Failed: if ri.OpType.IsDataReplication() && prevStatus == replication.Pending { rs.set(ri.Arn, ri.Size, ri.Duration, status, ri.OpType, ri.endpoint, ri.secure, ri.Err) } case replication.Replica: if ri.OpType == replication.ObjectReplicationType { rs.set(ri.Arn, ri.Size, 0, status, ri.OpType, "", false, ri.Err) } }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/batch-rotate.go
time.Sleep(wait) } }() } wk.Wait() ri.Complete = ri.ObjectsFailed == 0 ri.Failed = ri.ObjectsFailed > 0 globalBatchJobsMetrics.save(job.ID, ri) // persist in-memory state to disk. batchLogIf(ctx, ri.updateAfter(ctx, api, 0, job)) if err := r.Notify(ctx, ri); err != nil { batchLogIf(ctx, fmt.Errorf("unable to notify %v", err)) } cancel()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/batch-expire.go
} xioutil.SafeClose(expireCh) <-expireDoneCh // waits for the expire goroutine to complete wk.Wait() // waits for all expire workers to retire ri.Complete = ri.ObjectsFailed == 0 ri.Failed = ri.ObjectsFailed > 0 globalBatchJobsMetrics.save(job.ID, ri) // Close the saverQuitCh - this also triggers saving in-memory state // immediately one last time before we exit this method. xioutil.SafeClose(saverQuitCh)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/bucket-replication.go
} return } var ch, healCh chan<- ReplicationWorkerOperation switch ri.OpType { case replication.HealReplicationType, replication.ExistingObjectReplicationType: ch = p.mrfReplicaCh healCh = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size) default: ch = p.getWorkerCh(ri.Name, ri.Bucket, ri.Size) } if ch == nil && healCh == nil { return } select { case <-p.ctx.Done():
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/object-api-datatypes.go
// function is merely and optimization. func (ri ReplicateObjectInfo) ToObjectInfo() ObjectInfo { return ObjectInfo{ Name: ri.Name, Bucket: ri.Bucket, VersionID: ri.VersionID, ModTime: ri.ModTime, UserTags: ri.UserTags, Size: ri.Size, ActualSize: &ri.ActualSize,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
Marker: marker, InclDeleted: false, AskDisks: globalAPIConfig.getListQuorum(), } opts.setBucketMeta(ctx) ri := logger.GetReqInfo(ctx) hadoop := ri != nil && strings.Contains(ri.UserAgent, `Hadoop `) && strings.Contains(ri.UserAgent, "scala/") matches := func() bool { if prefix == "" { return false } // List of standard files supported by s3a
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 80.1K bytes - Viewed (0) -
cmd/testdata/xl-meta-merge.zip
%eOrñs{Bv€¡ûp@oK]^ô „TW`¼ ûR? ¨[tˆˆ‚«æq@Œ+_lpkSIˆ^ñ @I¾¦fW pPc{^<ˆâïò û@ ; OPmyßt}æ^IªêVkq ^pu²vñ^Ty[Sxi8¿l ’Œ€à@DK~Ô^zÜJ ¨™1|vž}û\–iY»ÕmP\ep—÷SlûY¡\ïTmG_s™Ùs`H{_}©GEì´Œ»SqòSa¸ïL}ÂbDR^Ì ÕO„V^e¼Bñjhñqkxé°{W_÷E@JˆVk<‚Åò y¦Õ^kh~ ô[Rg¢?qr› †ÕsHrïpŠQR¾xPe¨¹yndñ E¾Ri]Ü ª m|jqme¨àr 2Jdª}gVPªzæi¾LK^j¼VU VdC²HHg@e¼Yp8ì[Negz{Öa€uV¢Qrûcf¼csM¼SGTܤ%ûX; „^y²IRñre¸fO^ š -oCˆuMIV„åjypge†À¬õ Èû8}ûz}ô¼o~ t{_qLOrs|ôŠLurmmNmX˾@{ jsò*ñCixW{V sB ^øG²zjïûZk{2OlqhJ¦GÈ}CßTi@fa¨ª ñ~ EFL€B\G paxz¸D{¸ÜRCR„ns\Iå|i\I†Vñ¬B`w¾{ËKvK÷„jf²*...
ZIP Archive - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 30.2K bytes - Viewed (0)