Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for SetTarget (0.16 sec)

  1. cmd/bucket-targets.go

    	if !ok {
    		return
    	}
    	for _, t := range tgts {
    		delete(sys.arnRemotesMap, t.Arn)
    	}
    	delete(sys.targetsMap, bucket)
    }
    
    // SetTarget - sets a new minio-go client target for this bucket.
    func (sys *BucketTargetSys) SetTarget(ctx context.Context, bucket string, tgt *madmin.BucketTarget, update bool) error {
    	if !tgt.Type.IsValid() && !update {
    		return BucketRemoteArnTypeInvalid{Bucket: bucket}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  2. cmd/admin-bucket-handlers.go

    	if target.BandwidthLimit > 0 && target.BandwidthLimit < 100*1000*1000 {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrReplicationBandwidthLimitError, err), r.URL)
    		return
    	}
    	if err = globalBucketTargetSys.SetTarget(ctx, bucket, &target, update); err != nil {
    		switch err.(type) {
    		case RemoteTargetConnectionErr:
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrReplicationRemoteConnectionError, err), r.URL)
    		default:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    				targetToUpdate.ReplicationSync = (peer.SyncState == madmin.SyncEnabled)
    			}
    			if updateBW {
    				targetToUpdate.BandwidthLimit = int64(peer.DefaultBandwidth.Limit)
    			}
    			err := globalBucketTargetSys.SetTarget(ctx, bucket, &targetToUpdate, true)
    			if err != nil {
    				return c.annotatePeerErr(peer.Name, "Bucket target update error", err)
    			}
    			targets, err := globalBucketTargetSys.ListBucketTargets(ctx, bucket)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  4. cmd/bucket-replication-handlers.go

    	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:
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrReplicationRemoteConnectionError, err), r.URL)
    		default:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 28 04:08:53 GMT 2023
    - 23.2K bytes
    - Viewed (0)
Back to top