Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for targetIDSet (0.23 sec)

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

    package event
    
    // TargetIDSet - Set representation of TargetIDs.
    type TargetIDSet map[TargetID]struct{}
    
    // IsEmpty returns true if the set is empty.
    func (set TargetIDSet) IsEmpty() bool {
    	return len(set) != 0
    }
    
    // Clone - returns copy of this set.
    func (set TargetIDSet) Clone() TargetIDSet {
    	setCopy := NewTargetIDSet()
    	for k, v := range set {
    		setCopy[k] = v
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  2. internal/event/targetidset.go

    package event
    
    // TargetIDSet - Set representation of TargetIDs.
    type TargetIDSet map[TargetID]struct{}
    
    // IsEmpty returns true if the set is empty.
    func (set TargetIDSet) IsEmpty() bool {
    	return len(set) != 0
    }
    
    // Clone - returns copy of this set.
    func (set TargetIDSet) Clone() TargetIDSet {
    	setCopy := NewTargetIDSet()
    	for k, v := range set {
    		setCopy[k] = v
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.9K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. internal/event/rules.go

    			return true
    		}
    	}
    	return false
    }
    
    // Match - returns TargetIDSet matching object name in rules.
    func (rules Rules) Match(objectName string) TargetIDSet {
    	targetIDs := NewTargetIDSet()
    
    	for pattern, targetIDSet := range rules {
    		if wildcard.MatchSimple(pattern, objectName) {
    			targetIDs = targetIDs.Union(targetIDSet)
    		}
    	}
    
    	return targetIDs
    }
    
    // Clone - returns copy of this rules.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. internal/config/lambda/event/targetidset_test.go

    			t.Fatalf("test %v: result: expected: not equal, got: equal", i+1)
    		}
    	}
    }
    
    func TestTargetIDSetUnion(t *testing.T) {
    	testCases := []struct {
    		set            TargetIDSet
    		setToAdd       TargetIDSet
    		expectedResult TargetIDSet
    	}{
    		{NewTargetIDSet(), NewTargetIDSet(), NewTargetIDSet()},
    		{NewTargetIDSet(), NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"1", "webhook"})},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  6. internal/event/targetidset_test.go

    			t.Fatalf("test %v: result: expected: not equal, got: equal", i+1)
    		}
    	}
    }
    
    func TestTargetIDSetUnion(t *testing.T) {
    	testCases := []struct {
    		set            TargetIDSet
    		setToAdd       TargetIDSet
    		expectedResult TargetIDSet
    	}{
    		{NewTargetIDSet(), NewTargetIDSet(), NewTargetIDSet()},
    		{NewTargetIDSet(), NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"1", "webhook"})},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.9K bytes
    - Viewed (0)
  7. cmd/event-notification.go

    	evnot.Lock()
    	defer evnot.Unlock()
    
    	targetIDSet := event.NewTargetIDSet()
    	for k := range evnot.targetList.TargetMap() {
    		targetIDSet[k] = struct{}{}
    	}
    	evnot.targetList.Remove(targetIDSet)
    }
    
    // Send - sends the event to all registered notification targets
    func (evnot *EventNotifier) Send(args eventArgs) {
    	evnot.RLock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  8. internal/event/rulesmap.go

    func (rulesMap RulesMap) MatchSimple(eventName Name, objectName string) bool {
    	return rulesMap[eventName].MatchSimple(objectName)
    }
    
    // Match - returns TargetIDSet matching object name and event name in rules map.
    func (rulesMap RulesMap) Match(eventName Name, objectName string) TargetIDSet {
    	return rulesMap[eventName].Match(objectName)
    }
    
    // NewRulesMap - creates new rules map with given values.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.6K bytes
    - Viewed (0)
  9. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  10. internal/event/rulesmap_test.go

    	rulesMapCase4.add([]Name{ObjectCreatedAll}, "*", TargetID{"2", "amqp"})
    
    	testCases := []struct {
    		rulesMap       RulesMap
    		eventName      Name
    		objectName     string
    		expectedResult TargetIDSet
    	}{
    		{rulesMapCase1, ObjectCreatedPut, "2010/photo.jpg", NewTargetIDSet()},
    		{rulesMapCase2, ObjectCreatedPut, "2010/photo.jpg", NewTargetIDSet(TargetID{"1", "webhook"})},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
Back to top