Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for targetsMap (0.1 sec)

  1. cmd/bucket-targets.go

    	sys.RLock()
    	defer sys.RUnlock()
    
    	tgts, ok := sys.targetsMap[bucket]
    	if ok {
    		return &madmin.BucketTargets{Targets: tgts}, nil
    	}
    	return nil, BucketRemoteTargetNotFound{Bucket: bucket}
    }
    
    // Delete clears targets present for a bucket
    func (sys *BucketTargetSys) Delete(bucket string) {
    	sys.Lock()
    	defer sys.Unlock()
    	tgts, ok := sys.targetsMap[bucket]
    	if !ok {
    		return
    	}
    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-utils.go

    	if d.targetsMap == nil {
    		d.targetsMap = make(map[string]replicateTargetDecision)
    	}
    	d.targetsMap[t.Arn] = t
    }
    
    // PendingStatus returns a stringified representation of internal replication status with all targets marked as `PENDING`
    func (d ReplicateDecision) PendingStatus() string {
    	b := new(bytes.Buffer)
    	for _, k := range d.targetsMap {
    		if k.Replicate {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  3. cmd/bucket-replication_test.go

    			},
    			rcfg: replicationConfig{remotes: &madmin.BucketTargets{Targets: []madmin.BucketTarget{{
    				Arn: "arn1",
    			}}}},
    			dsc:          ReplicateDecision{targetsMap: map[string]replicateTargetDecision{"arn1": newReplicateTargetDecision("arn1", true, false)}},
    			expectedSync: true,
    		},
    
    		{ // 2. replication status Failed
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Sep 16 09:28:06 UTC 2023
    - 12.2K bytes
    - Viewed (0)
  4. cmd/bucket-replication-handlers.go

    			Bucket: bucket,
    			Err:    fmt.Errorf("replication resync status not available for %s (%s)", arn, err.Error()),
    		}), r.URL)
    		return
    	}
    
    	var rinfo ResyncTargetsInfo
    	for tarn, st := range brs.TargetsMap {
    		if arn != "" && tarn != arn {
    			continue
    		}
    		rinfo.Targets = append(rinfo.Targets, ResyncTarget{
    			Arn:             tarn,
    			ResetID:         st.ResyncID,
    			StartTime:       st.StartTime,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top