()
| 660 | } |
| 661 | |
| 662 | func (s *Service) getAllSubscriptions() (subscriptions map[proto.DatabaseID]int32, err error) { |
| 663 | subscriptions = map[proto.DatabaseID]int32{} |
| 664 | s.subscription.Range(func(_, rawWorker interface{}) bool { |
| 665 | worker := unpackWorker(rawWorker) |
| 666 | subscriptions[worker.dbID] = worker.getHead() |
| 667 | return true |
| 668 | }) |
| 669 | |
| 670 | return |
| 671 | } |
no test coverage detected