Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for TargetsMap (0.34 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
    	}
    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)
  2. cmd/bucket-replication-utils_gen.go

    			var zb0002 uint32
    			zb0002, err = dc.ReadMapHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "TargetsMap")
    				return
    			}
    			if z.TargetsMap == nil {
    				z.TargetsMap = make(map[string]TargetReplicationResyncStatus, zb0002)
    			} else if len(z.TargetsMap) > 0 {
    				for key := range z.TargetsMap {
    					delete(z.TargetsMap, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 61.1K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils_test.go

    			}
    			continue
    		}
    		if len(dsc.targetsMap) != len(test.expDsc.targetsMap) {
    			t.Errorf("Test%d (%s): Invalid number of entries in targetsMap  got %d , want %d", i+1, test.name, len(dsc.targetsMap), len(test.expDsc.targetsMap))
    		}
    		for arn, tdsc := range dsc.targetsMap {
    			expDsc, ok := test.expDsc.targetsMap[arn]
    			if !ok || expDsc != tdsc {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Aug 08 20:27:40 GMT 2023
    - 9.3K bytes
    - Viewed (0)
  4. 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
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Sep 16 09:28:06 GMT 2023
    - 12.2K bytes
    - Viewed (0)
  5. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 26.2K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    		})
    		return
    	}
    	ctx = lkctx.Context()
    	defer lk.Unlock(lkctx)
    
    	rinfos := replicatedInfos{Targets: make([]replicatedTargetInfo, 0, len(dsc.targetsMap))}
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	for _, tgtEntry := range dsc.targetsMap {
    		if !tgtEntry.Replicate {
    			continue
    		}
    		// if dobj.TargetArn is not empty string, this is a case of specific target being re-synced.
    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)
  7. 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,
    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)
  8. cmd/site-replication.go

    			m, ok := globalReplicationPool.resyncer.statusMap[bucket]
    			if !ok {
    				m = newBucketResyncStatus(bucket)
    			}
    			if st, ok := m.TargetsMap[t.Arn]; ok {
    				st.LastUpdate = UTCNow()
    				st.ResyncStatus = ResyncCanceled
    				m.TargetsMap[t.Arn] = st
    				m.LastUpdate = UTCNow()
    			}
    			globalReplicationPool.resyncer.statusMap[bucket] = m
    			globalReplicationPool.resyncer.Unlock()
    		}
    	}
    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)
Back to top