summaryrefslogtreecommitdiffstats
path: root/internal/subscription
diff options
context:
space:
mode:
Diffstat (limited to 'internal/subscription')
-rw-r--r--internal/subscription/manager.go6
1 files changed, 6 insertions, 0 deletions
diff --git a/internal/subscription/manager.go b/internal/subscription/manager.go
index 6347018..3f6ac7f 100644
--- a/internal/subscription/manager.go
+++ b/internal/subscription/manager.go
@@ -72,6 +72,12 @@ func (m *Manager) Get(id string) (*Subscription, bool) {
72 return sub, ok 72 return sub, ok
73} 73}
74 74
75func (m *Manager) Count() int {
76 m.mu.RLock()
77 defer m.mu.RUnlock()
78 return len(m.subscriptions)
79}
80
75func (m *Manager) MatchAndFan(event *pb.Event) { 81func (m *Manager) MatchAndFan(event *pb.Event) {
76 m.mu.RLock() 82 m.mu.RLock()
77 defer m.mu.RUnlock() 83 defer m.mu.RUnlock()