Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for resyncTarget (0.73 sec)

  1. cmd/bucket-replication-utils_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgResyncTarget(b *testing.B) {
    	v := ResyncTarget{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgResyncTarget(b *testing.B) {
    	v := ResyncTarget{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Aug 22 23:53:06 GMT 2022
    - 23K 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
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 61.1K bytes
    - Viewed (0)
  3. 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"`
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  4. 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:
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Oct 28 04:08:53 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  5. 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)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top