Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for resyncTarget (0.09 sec)

  1. cmd/bucket-replication-utils.go

    }
    
    // ResyncTargetsInfo holds a slice of targets with resync info per target
    type ResyncTargetsInfo struct {
    	Targets []ResyncTarget `json:"target,omitempty"`
    }
    
    // ResyncTarget is a struct representing the Target reset ID where target is identified by its Arn
    type ResyncTarget struct {
    	Arn       string    `json:"arn"`
    	ResetID   string    `json:"resetid"`
    	StartTime time.Time `json:"startTime"`
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils_gen.go

    func (z ResyncStatusType) Msgsize() (s int) {
    	s = msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *ResyncTarget) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 59.8K bytes
    - Viewed (0)
  3. cmd/bucket-replication-handlers.go

    	target := globalBucketTargetSys.GetRemoteBucketTargetByArn(ctx, bucket, tgtArns[0])
    	target.ResetBeforeDate = UTCNow().AddDate(0, 0, -1*int(days/24))
    	target.ResetID = resetID
    	rinfo.Targets = append(rinfo.Targets, ResyncTarget{Arn: tgtArns[0], ResetID: target.ResetID})
    	if err = globalBucketTargetSys.SetTarget(ctx, bucket, &target, true); err != nil {
    		switch err.(type) {
    		case RemoteTargetConnectionErr:
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    			continue
    		}
    		if !d.Replicate {
    			continue
    		}
    		r.targets[d.Arn] = resyncTarget(oi, tgt.Arn, tgt.ResetID, tgt.ResetBeforeDate, tgtStatuses[tgt.Arn])
    	}
    	return
    }
    
    func targetResetHeader(arn string) string {
    	return fmt.Sprintf("%s-%s", ReservedMetadataPrefixLower+ReplicationReset, arn)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
Back to top