Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for targetMap (0.04 sec)

  1. internal/bucket/replication/replication.go

    	if len(c.Rules) == 0 {
    		return errReplicationNoRule
    	}
    
    	// Validate all the rules in the replication config
    	targetMap := make(map[string]struct{})
    	priorityMap := make(map[string]struct{})
    	var legacyArn bool
    	for _, r := range c.Rules {
    		if _, ok := targetMap[r.Destination.Bucket]; !ok {
    			targetMap[r.Destination.Bucket] = struct{}{}
    		}
    		if err := r.Validate(bucket, sameTarget); err != nil {
    			return err
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  2. internal/config/lambda/event/targetlist.go

    	defer list.RUnlock()
    
    	keys := make([]ARN, 0, len(list.targets))
    	for k := range list.targets {
    		keys = append(keys, k.ToARN(region))
    	}
    
    	return keys
    }
    
    // TargetMap - returns available targets.
    func (list *TargetList) TargetMap() map[TargetID]Target {
    	list.RLock()
    	defer list.RUnlock()
    
    	ntargets := make(map[TargetID]Target, len(list.targets))
    	maps.Copy(ntargets, list.targets)
    	return ntargets
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
  3. cmd/event-notification.go

    // GetARNList - returns available ARNs.
    func (evnot *EventNotifier) GetARNList() []string {
    	arns := []string{}
    	if evnot == nil {
    		return arns
    	}
    	region := globalSite.Region()
    	for targetID := range evnot.targetList.TargetMap() {
    		// httpclient target is part of ListenNotification
    		// which doesn't need to be listed as part of the ARN list
    		// This list is only meant for external targets, filter
    		// this out pro-actively.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. internal/event/targetlist.go

    }
    
    func (list *TargetList) get(id TargetID) (Target, bool) {
    	list.RLock()
    	defer list.RUnlock()
    
    	target, ok := list.targets[id]
    	return target, ok
    }
    
    // TargetMap - returns available targets.
    func (list *TargetList) TargetMap() map[TargetID]Target {
    	list.RLock()
    	defer list.RUnlock()
    
    	ntargets := make(map[TargetID]Target, len(list.targets))
    	maps.Copy(ntargets, list.targets)
    	return ntargets
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  5. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 9.3K bytes
    - Viewed (0)
Back to top