Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for TargetsMap (0.21 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 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 May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 61.1K bytes
    - Viewed (0)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  4. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
Back to top