Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for targetIDSet (0.39 sec)

  1. internal/config/lambda/event/targetidset.go

    func (set TargetIDSet) add(targetID TargetID) {
    	set[targetID] = struct{}{}
    }
    
    // Union - returns union with given set as new set.
    func (set TargetIDSet) Union(sset TargetIDSet) TargetIDSet {
    	nset := set.Clone()
    
    	for k := range sset {
    		nset.add(k)
    	}
    
    	return nset
    }
    
    // Difference - returns difference with given set as new set.
    func (set TargetIDSet) Difference(sset TargetIDSet) TargetIDSet {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  2. internal/event/targetidset.go

    func (set TargetIDSet) Union(sset TargetIDSet) TargetIDSet {
    	nset := set.Clone()
    
    	for k := range sset {
    		nset.add(k)
    	}
    
    	return nset
    }
    
    // Difference - returns difference with given set as new set.
    func (set TargetIDSet) Difference(sset TargetIDSet) TargetIDSet {
    	nset := NewTargetIDSet()
    	for k := range set {
    		if _, ok := sset[k]; !ok {
    			nset.add(k)
    		}
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 1.8K bytes
    - Viewed (0)
  3. internal/event/targetlist.go

    func (list *TargetList) Send(event Event, targetIDset TargetIDSet, sync bool) {
    	if sync {
    		list.sendSync(event, targetIDset)
    	} else {
    		list.sendAsync(event, targetIDset)
    	}
    }
    
    func (list *TargetList) sendSync(event Event, targetIDset TargetIDSet) {
    	var wg sync.WaitGroup
    	for id := range targetIDset {
    		target, ok := list.get(id)
    		if !ok {
    			continue
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  4. internal/config/lambda/event/targetlist.go

    	Err error
    }
    
    // Remove - closes and removes targets by given target IDs.
    func (list *TargetList) Remove(targetIDSet TargetIDSet) {
    	list.Lock()
    	defer list.Unlock()
    
    	for id := range targetIDSet {
    		target, ok := list.targets[id]
    		if ok {
    			target.Close()
    			delete(list.targets, id)
    		}
    	}
    }
    
    // Targets - list all targets
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.3K bytes
    - Viewed (0)
Back to top