Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ResetBeforeDate (0.18 sec)

  1. cmd/bucket-replication_test.go

    			rcfg: replicationConfig{
    				remotes: &madmin.BucketTargets{Targets: []madmin.BucketTarget{{
    					Arn:             "arn1",
    					ResetID:         "xyz",
    					ResetBeforeDate: UTCNow(),
    				}}},
    			},
    		},
    		{ // 6. existing object replication enabled, versioning enabled, replication status Failed & reset ID present
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 16 09:28:06 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils_gen.go

    		case "ResetID":
    			z.ResetID, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "ResetID")
    				return
    			}
    		case "ResetBeforeDate":
    			z.ResetBeforeDate, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "ResetBeforeDate")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				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)
  3. cmd/bucket-replication-handlers.go

    				Bucket: bucket,
    				Err:    fmt.Errorf("invalid query parameter older-than %s for %s : %w", durationStr, bucket, err),
    			}), r.URL)
    			return
    		}
    	}
    	resetBeforeDate := UTCNow().AddDate(0, 0, -1*int(days/24))
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL)
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    		ResetID:         resetID,
    		ResetBeforeDate: resetBeforeDate,
    	}
    	rs, ok := oi.UserDefined[targetResetHeader(arn)]
    	if !ok {
    		rs, ok = oi.UserDefined[xhttp.MinIOReplicationResetStatus] // for backward compatibility
    	}
    	if !ok { // existing object replication is enabled and object version is unreplicated so far.
    		if resetID != "" && oi.ModTime.Before(resetBeforeDate) { // trigger replication if `mc replicate reset` requested
    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-utils.go

    	return ok && v.Replicate
    }
    
    // ResyncTargetDecision is struct that represents resync decision for this target
    type ResyncTargetDecision struct {
    	Replicate       bool
    	ResetID         string
    	ResetBeforeDate time.Time
    }
    
    var errInvalidReplicateDecisionFormat = fmt.Errorf("ReplicateDecision has invalid format")
    
    // parse k-v pairs of target ARN to stringified ReplicateTargetDecision delimited by ',' into a
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  6. cmd/site-replication.go

    				Bucket:    bucket,
    			})
    			continue
    		}
    		target := globalBucketTargetSys.GetRemoteBucketTargetByArn(ctx, bucket, tgtArn)
    		target.ResetBeforeDate = UTCNow()
    		target.ResetID = rs.ResyncID
    		if err = globalBucketTargetSys.SetTarget(ctx, bucket, &target, true); err != nil {
    			res.Buckets = append(res.Buckets, madmin.ResyncBucketStatus{
    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