- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for targetIDSet (0.07 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)