Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for targetsMap (0.16 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K 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.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    			m, ok := globalReplicationPool.Get().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.Get().resyncer.statusMap[bucket] = m
    			globalReplicationPool.Get().resyncer.Unlock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/util/ParameterUtilTest.java

            Map<String, Object> targetMap = new HashMap<>();
            targetMap.put("existing", "value");
            String configParam = "new.param=value\nconfig.setting=true";
            ParameterUtil.loadConfigParams(targetMap, configParam);
            assertEquals(3, targetMap.size());
            assertEquals("value", targetMap.get("existing"));
            assertEquals("value", targetMap.get("new.param"));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 22.6K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/it/admin/PluginTests.java

            final Map<String, Object> targetMap =
                    available.stream().filter(map -> !map.get("name").toString().startsWith("fess-")).toList().get(0);
            final Artifact target = getArtifactFromMap(targetMap);
    
            // Install
            {
                checkPostMethod(targetMap, getInstallEndpointSuffix()).then().body("response.status", equalTo(0));
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 6.5K bytes
    - Viewed (0)
Back to top