diff options
Diffstat (limited to 'internal/subscription/manager.go')
| -rw-r--r-- | internal/subscription/manager.go | 6 |
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 | ||
| 75 | func (m *Manager) Count() int { | ||
| 76 | m.mu.RLock() | ||
| 77 | defer m.mu.RUnlock() | ||
| 78 | return len(m.subscriptions) | ||
| 79 | } | ||
| 80 | |||
| 75 | func (m *Manager) MatchAndFan(event *pb.Event) { | 81 | func (m *Manager) MatchAndFan(event *pb.Event) { |
| 76 | m.mu.RLock() | 82 | m.mu.RLock() |
| 77 | defer m.mu.RUnlock() | 83 | defer m.mu.RUnlock() |
