Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for NewTargetIDSet (0.14 sec)

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

    		expectedResult TargetIDSet
    	}{
    		{NewTargetIDSet(), NewTargetIDSet(), NewTargetIDSet()},
    		{NewTargetIDSet(), NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"1", "webhook"})},
    		{NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(), NewTargetIDSet(TargetID{"1", "webhook"})},
    		{NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"2", "amqp"}), NewTargetIDSet(TargetID{"1", "webhook"}, TargetID{"2", "amqp"})},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 07 16:12:41 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  2. internal/event/targetidset_test.go

    		expectedResult TargetIDSet
    	}{
    		{NewTargetIDSet(), NewTargetIDSet(), NewTargetIDSet()},
    		{NewTargetIDSet(), NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"1", "webhook"})},
    		{NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(), NewTargetIDSet(TargetID{"1", "webhook"})},
    		{NewTargetIDSet(TargetID{"1", "webhook"}), NewTargetIDSet(TargetID{"2", "amqp"}), NewTargetIDSet(TargetID{"1", "webhook"}, TargetID{"2", "amqp"})},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 3.9K bytes
    - Viewed (0)
  3. internal/config/lambda/event/targetidset.go

    func (set TargetIDSet) Difference(sset TargetIDSet) TargetIDSet {
    	nset := NewTargetIDSet()
    	for k := range set {
    		if _, ok := sset[k]; !ok {
    			nset.add(k)
    		}
    	}
    
    	return nset
    }
    
    // NewTargetIDSet - creates new TargetID set with given TargetIDs.
    func NewTargetIDSet(targetIDs ...TargetID) TargetIDSet {
    	set := make(TargetIDSet)
    	for _, targetID := range targetIDs {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  4. internal/event/targetidset.go

    func (set TargetIDSet) Difference(sset TargetIDSet) TargetIDSet {
    	nset := NewTargetIDSet()
    	for k := range set {
    		if _, ok := sset[k]; !ok {
    			nset.add(k)
    		}
    	}
    
    	return nset
    }
    
    // NewTargetIDSet - creates new TargetID set with given TargetIDs.
    func NewTargetIDSet(targetIDs ...TargetID) TargetIDSet {
    	set := make(TargetIDSet)
    	for _, targetID := range targetIDs {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  5. internal/event/rulesmap_test.go

    		expectedResult TargetIDSet
    	}{
    		{rulesMapCase1, ObjectCreatedPut, "2010/photo.jpg", NewTargetIDSet()},
    		{rulesMapCase2, ObjectCreatedPut, "2010/photo.jpg", NewTargetIDSet(TargetID{"1", "webhook"})},
    		{rulesMapCase3, ObjectCreatedPut, "2000/photo.png", NewTargetIDSet()},
    		{rulesMapCase4, ObjectCreatedPut, "2000/photo.png", NewTargetIDSet(TargetID{"2", "amqp"})},
    	}
    
    	for i, testCase := range testCases {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  6. internal/event/rules_test.go

    		rules          Rules
    		objectName     string
    		expectedResult TargetIDSet
    	}{
    		{rulesCase1, "photos.jpg", NewTargetIDSet()},
    		{rulesCase2, "photos.jpg", NewTargetIDSet(TargetID{"1", "webhook"})},
    		{rulesCase3, "2010/photos.jpg", NewTargetIDSet(TargetID{"1", "webhook"})},
    		{rulesCase4, "2000/photos.jpg", NewTargetIDSet()},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.rules.Match(testCase.objectName)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 8.8K bytes
    - Viewed (0)
  7. internal/event/rules.go

    	return pattern
    }
    
    // Rules - event rules
    type Rules map[string]TargetIDSet
    
    // Add - adds pattern and target ID.
    func (rules Rules) Add(pattern string, targetID TargetID) {
    	rules[pattern] = NewTargetIDSet(targetID).Union(rules[pattern])
    }
    
    // MatchSimple - returns true one of the matching object name in rules.
    func (rules Rules) MatchSimple(objectName string) bool {
    	for pattern := range 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)
  8. cmd/event-notification.go

    }
    
    // RemoveAllBucketTargets - closes and removes all notification targets.
    func (evnot *EventNotifier) RemoveAllBucketTargets() {
    	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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top