Return a list of all data-bearing servers. This includes any server that might be selected for an operation.
(self)
| 690 | await _async_cond_wait(self._condition, wait_time) |
| 691 | |
| 692 | def data_bearing_servers(self) -> list[ServerDescription]: |
| 693 | """Return a list of all data-bearing servers. |
| 694 | |
| 695 | This includes any server that might be selected for an operation. |
| 696 | """ |
| 697 | if self._description.topology_type == TOPOLOGY_TYPE.Single: |
| 698 | return self._description.known_servers |
| 699 | return self._description.readable_servers |
| 700 | |
| 701 | async def update_pool(self) -> None: |
| 702 | # Remove any stale sockets and add new sockets if pool is too small. |