Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GetRemoteBucketTargetByArn (0.42 sec)

  1. cmd/bucket-targets.go

    				sys.UpdateAllTargets(bucket, tgts)
    				sys.markRefreshDone(bucket, arn)
    			}
    		}
    		sys.incTargetErr(bucket, arn)
    	}()
    	return nil
    }
    
    // GetRemoteBucketTargetByArn returns BucketTarget for a ARN
    func (sys *BucketTargetSys) GetRemoteBucketTargetByArn(ctx context.Context, bucket, arn string) madmin.BucketTarget {
    	sys.RLock()
    	defer sys.RUnlock()
    	var tgt madmin.BucketTarget
    	for _, t := range sys.targetsMap[bucket] {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  2. cmd/admin-bucket-handlers.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrRemoteTargetDenyAddError, err), r.URL)
    		return
    	}
    
    	if update {
    		// overlay the updates on existing target
    		tgt := globalBucketTargetSys.GetRemoteBucketTargetByArn(ctx, bucket, target.Arn)
    		if tgt.Empty() {
    			writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrRemoteTargetNotFoundError, err), r.URL)
    			return
    		}
    		for _, op := range ops {
    			switch op {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  3. cmd/bucket-replication-handlers.go

    			Bucket: bucket,
    			Err:    fmt.Errorf("ARN should be specified for replication reset"),
    		}), r.URL)
    		return
    	}
    	var rinfo ResyncTargetsInfo
    	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})
    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)
  4. cmd/site-replication.go

    				ErrDetail: fmt.Sprintf("no valid remote target found for this peer %s (%s)", peer.Name, peer.DeploymentID),
    				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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 184.1K bytes
    - Viewed (1)
  5. cmd/bucket-replication.go

    	tgtArns := cfg.FilterTargetArns(topts)
    	tgts = &madmin.BucketTargets{Targets: make([]madmin.BucketTarget, len(tgtArns))}
    	for i, tgtArn := range tgtArns {
    		tgt := globalBucketTargetSys.GetRemoteBucketTargetByArn(ctx, bucket, tgtArn)
    		tgts.Targets[i] = tgt
    	}
    
    	return tgts
    }
    
    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