Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for set_target (0.2 sec)

  1. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Oct 28 04:08:53 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  2. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 15:50:16 GMT 2024
    - 184.1K bytes
    - Viewed (1)
  3. cmd/bucket-replication.go

    				default:
    				}
    			}
    			if c.EndpointURL().String() == clnt.EndpointURL().String() {
    				selfTarget, _ := isLocalHost(clnt.EndpointURL().Hostname(), clnt.EndpointURL().Port(), globalMinioPort)
    				if !sameTarget {
    					sameTarget = selfTarget
    				}
    				continue
    			}
    		}
    	}
    
    	if len(arns) == 0 {
    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)
  4. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  5. 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 Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 32.5K bytes
    - Viewed (0)
Back to top