Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ListBucketTargets (0.12 sec)

  1. cmd/bucket-targets.go

    						Avg:  hs.latency.avg,
    						Max:  hs.latency.peak,
    					}
    				}
    				targets = append(targets, t.Clone())
    			}
    		}
    	}
    	return
    }
    
    // ListBucketTargets - gets list of bucket targets for this bucket.
    func (sys *BucketTargetSys) ListBucketTargets(ctx context.Context, bucket string) (*madmin.BucketTargets, error) {
    	sys.RLock()
    	defer sys.RUnlock()
    
    	tgts, ok := sys.targetsMap[bucket]
    	if ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication-handlers.go

    	}
    	if _, err := globalBucketMetadataSys.Delete(ctx, bucket, bucketReplicationConfig); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	targets, err := globalBucketTargetSys.ListBucketTargets(ctx, bucket)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	for _, tgt := range targets.Targets {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  3. cmd/admin-bucket-handlers.go

    		default:
    			writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		}
    		return
    	}
    	targets, err := globalBucketTargetSys.ListBucketTargets(ctx, bucket)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	tgtBytes, err := json.Marshal(&targets)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    				hasRule = true
    				ruleARN = r.Destination.Bucket
    			}
    		}
    
    		ep, _ := url.Parse(peer.Endpoint)
    		var targets []madmin.BucketTarget
    		if targetsPtr, _ := globalBucketTargetSys.ListBucketTargets(ctx, bucket); targetsPtr != nil {
    			targets = targetsPtr.Targets
    		}
    		targetARN := ""
    		var updateTgt, updateBW bool
    		var targetToUpdate madmin.BucketTarget
    		for _, target := range targets {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    	if err != nil {
    		replLogIf(ctx, fmt.Errorf("replication resync of %s for arn %s failed with %w", opts.bucket, opts.arn, err))
    		return
    	}
    	tgts, err := globalBucketTargetSys.ListBucketTargets(ctx, opts.bucket)
    	if err != nil {
    		replLogIf(ctx, fmt.Errorf("replication resync of %s for arn %s failed  %w", opts.bucket, opts.arn, err))
    		return
    	}
    	rcfg := replicationConfig{
    		Config:  cfg,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  6. cmd/metacache-set.go

    	// Check if bucket is object locked.
    	rcfg, _ := globalBucketObjectLockSys.Get(o.Bucket)
    	replCfg, _, _ := globalBucketMetadataSys.GetReplicationConfig(ctx, o.Bucket)
    	tgts, _ := globalBucketTargetSys.ListBucketTargets(ctx, o.Bucket)
    	o.Lifecycle = lc
    	o.Versioning = vc
    	o.Replication = replicationConfig{
    		Config:  replCfg,
    		remotes: tgts,
    	}
    	o.Retention = rcfg
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    	if rcfg, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, cache.Info.Name); err == nil {
    		if rcfg.HasActiveRules("", true) {
    			tgts, err := globalBucketTargetSys.ListBucketTargets(ctx, cache.Info.Name)
    			if err == nil {
    				cache.Info.replication = replicationConfig{
    					Config:  rcfg,
    					remotes: tgts,
    				}
    			}
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top