Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ResyncID (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. cmd/bucket-replication.go

    	var errStr string
    	if err != nil {
    		errStr = err.Error()
    	}
    	funcName := fmt.Sprintf("replication.(resyncID=%s)", resyncID)
    	return madmin.TraceInfo{
    		TraceType: madmin.TraceReplicationResync,
    		Time:      startTime,
    		NodeName:  globalLocalNodeName,
    		FuncName:  funcName,
    		Duration:  duration,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
Back to top