- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for retryCount (0.2 sec)
-
cmd/bucket-replication.go
Config: rcfg, remotes: tgts, }, retryCount) } // queueReplicationHeal enqueues objects that failed replication OR eligible for resyncing through // an ongoing resync operation or via existing objects replication configuration setting. func queueReplicationHeal(ctx context.Context, bucket string, oi ObjectInfo, rcfg replicationConfig, retryCount int) (roi ReplicateObjectInfo) { // ignore modtime zero objects
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) -
cmd/notification.go
wk, _ := workers.New(wks) return &NotificationGroup{errs: make([]NotificationPeerErr, nerrs), workers: wk, retryCount: 3} } // WithRetries sets the retry count for all function calls from the Go method. func (g *NotificationGroup) WithRetries(retryCount int) *NotificationGroup { if g != nil { g.retryCount = retryCount } return g } // Wait blocks until all function calls from the Go method have returned, then
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen.go
if err != nil { err = msgp.WrapError(err, "Entries", za0001, "Object") return } case "rc": za0002.RetryCount, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Entries", za0001, "RetryCount") return } default: err = dc.Skip() if err != nil { err = msgp.WrapError(err, "Entries", za0001) return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 61.1K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
// MRFReplicateEntry mrf entry to save to disk type MRFReplicateEntry struct { Bucket string `json:"bucket" msg:"b"` Object string `json:"object" msg:"o"` versionID string `json:"-"` RetryCount int `json:"retryCount" msg:"rc"` sz int64 `json:"-"` } // MRFReplicateEntries has the map of MRF entries to save to disk type MRFReplicateEntries struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
cmd/object-api-datatypes.go
VersionPurgeStatus VersionPurgeStatusType ReplicationState ReplicationState DeleteMarker bool OpType replication.Type EventType string RetryCount uint32 ResetID string Dsc ReplicateDecision ExistingObjResync ResyncDecision TargetArn string TargetStatuses map[string]replication.StatusType
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 20.8K bytes - Viewed (0) -
cmd/object-api-datatypes_gen.go
z.EventType, bts, err = msgp.ReadStringBytes(bts) if err != nil { err = msgp.WrapError(err, "EventType") return } case "RetryCount": z.RetryCount, bts, err = msgp.ReadUint32Bytes(bts) if err != nil { err = msgp.WrapError(err, "RetryCount") return } case "ResetID": z.ResetID, bts, err = msgp.ReadStringBytes(bts) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 69.8K bytes - Viewed (0)