()
| 122 | } |
| 123 | |
| 124 | func (s *Router) KeepAlive() error { |
| 125 | s.mu.RLock() |
| 126 | defer s.mu.RUnlock() |
| 127 | if s.closed { |
| 128 | return ErrClosedRouter |
| 129 | } |
| 130 | s.pool.primary.KeepAlive() |
| 131 | s.pool.replica.KeepAlive() |
| 132 | return nil |
| 133 | } |
| 134 | |
| 135 | func (s *Router) isOnline() bool { |
| 136 | return s.online && !s.closed |