- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ResetBeforeDate (0.18 sec)
-
cmd/bucket-replication_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Sep 16 09:28:06 UTC 2023 - 12.2K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)