(host MockHost)
| 352 | } |
| 353 | |
| 354 | func (s *MockServer) Remove(host MockHost) { |
| 355 | if host.equal(s.local) { |
| 356 | return |
| 357 | } |
| 358 | s.mu.Lock() |
| 359 | s.peers = removeHost(s.peers, host) |
| 360 | s.mu.Unlock() |
| 361 | s.Event(&message.TopologyChangeEvent{ |
| 362 | ChangeType: primitive.TopologyChangeTypeRemovedNode, |
| 363 | Address: &primitive.Inet{ |
| 364 | Addr: net.ParseIP(host.IP), |
| 365 | Port: int32(host.Port), |
| 366 | }, |
| 367 | }) |
| 368 | } |
| 369 | |
| 370 | func (s *MockServer) Shutdown() { |
| 371 | s.cancel() |
nothing calls this directly
no test coverage detected