Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ListTargets (0.09 sec)

  1. cmd/bucket-targets.go

    	m := make(map[string]epHealth, len(sys.hc))
    	for k, v := range sys.hc {
    		m[k] = v
    	}
    	return m
    }
    
    // ListTargets lists bucket targets across tenant or for individual bucket, and returns
    // results filtered by arnType
    func (sys *BucketTargetSys) ListTargets(ctx context.Context, bucket, arnType string) (targets []madmin.BucketTarget) {
    	h := sys.healthStats()
    
    	if bucket != "" {
    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/admin-bucket-handlers.go

    		}
    		if _, err := globalBucketMetadataSys.GetBucketTargetsConfig(bucket); err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    	}
    	targets := globalBucketTargetSys.ListTargets(ctx, bucket, arnType)
    	data, err := json.Marshal(targets)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    	// Write success response.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  3. cmd/site-replication.go

    func (c *SiteReplicationSys) RemoveRemoteTargetsForEndpoint(ctx context.Context, objectAPI ObjectLayer, endpoints []string, unlinkSelf bool) (err error) {
    	targets := globalBucketTargetSys.ListTargets(ctx, "", string(madmin.ReplicationService))
    	m := make(map[string]madmin.BucketTarget)
    	for _, t := range targets {
    		for _, endpoint := range endpoints {
    			ep, _ := url.Parse(endpoint)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    	pTimer := time.NewTimer(mrfQueueInterval)
    	defer pTimer.Stop()
    	for {
    		select {
    		case <-pTimer.C:
    			// skip healing if all targets are offline
    			var offlineCnt int
    			tgts := globalBucketTargetSys.ListTargets(p.ctx, "", "")
    			for _, tgt := range tgts {
    				if globalBucketTargetSys.isOffline(tgt.URL()) {
    					offlineCnt++
    				}
    			}
    			if len(tgts) == offlineCnt {
    				pTimer.Reset(mrfQueueInterval)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top