Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/bucket-targets.go

    	sys.hMutex.RLock()
    	defer sys.hMutex.RUnlock()
    	m := make(map[string]epHealth, len(sys.hc))
    	maps.Copy(m, sys.hc)
    	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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 33.3K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
Back to top