- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ResyncID (0.25 sec)
-
cmd/site-replication-utils.go
case ResyncStarted: sm.peerResyncMap[s.DeplID] = resyncState{resyncID: s.ResyncID, LastSaved: time.Time{}} sm.resyncStatus[s.ResyncID] = s case ResyncCompleted, ResyncCanceled, ResyncFailed: st, ok := sm.resyncStatus[s.ResyncID] if ok { st.LastUpdate = s.LastUpdate st.Status = s.Status return nil } sm.resyncStatus[s.ResyncID] = st return saveSiteResyncMetadata(GlobalContext, st, newObjectLayerFn())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
type TargetReplicationResyncStatus struct { StartTime time.Time `json:"startTime" msg:"st"` LastUpdate time.Time `json:"lastUpdated" msg:"lst"` // Resync ID assigned to this reset ResyncID string `json:"resyncID" msg:"id"` // ResyncBeforeDate - resync all objects created prior to this date ResyncBeforeDate time.Time `json:"resyncBeforeDate" msg:"rdt"` // Status of resync operation
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
cmd/bucket-replication-utils_gen.go
case "lst": z.LastUpdate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "LastUpdate") return } case "id": z.ResyncID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ResyncID") return } case "rdt": z.ResyncBeforeDate, err = dc.ReadTime() if err != nil { err = msgp.WrapError(err, "ResyncBeforeDate") return
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 61.1K bytes - Viewed (0) -
cmd/bucket-replication.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } if err := globalReplicationPool.Get().resyncer.start(ctx, objectAPI, resyncOpts{ bucket: bucket, arn: arn, resyncID: resetID, resyncBefore: resetBeforeDate, }); err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrBadRequest, InvalidArgument{ Bucket: bucket, Err: err, }), r.URL)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0) -
cmd/site-replication.go
bucket: bucket, arn: tgtArn, resyncID: rs.ResyncID, }); err != nil { res.Buckets = append(res.Buckets, madmin.ResyncBucketStatus{ ErrDetail: err.Error(), Bucket: bucket, }) continue } } res = madmin.SRResyncOpStatus{ Status: ResyncStarted.String(), OpType: "start", ResyncID: rs.ResyncID, Buckets: res.Buckets, }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0)