Получить список всех зарегистрированных сервисов Возвращает: list[ServerEndpoint]: Список зарегистрированных конечных точек Исключения: CloudPubError: Если получение списка не удалось
(&self)
| 790 | /// Исключения: |
| 791 | /// CloudPubError: Если получение списка не удалось |
| 792 | fn ls(&self) -> PyResult<Vec<ServerEndpoint>> { |
| 793 | let endpoints = self |
| 794 | .runtime |
| 795 | .block_on(async { |
| 796 | let mut conn = self.connection.write(); |
| 797 | conn.ls().await |
| 798 | }) |
| 799 | .map_err(|e| CloudPubError::new_err(format!("Получение списка не удалось: {}", e)))?; |
| 800 | |
| 801 | // Преобразование конечных точек в объекты Python ServerEndpoint |
| 802 | let py_endpoints: Vec<ServerEndpoint> = endpoints |
| 803 | .into_iter() |
| 804 | .map(|ep| ServerEndpoint { |
| 805 | url: ep.as_url(), |
| 806 | guid: ep.guid, |
| 807 | status: ep.status, |
| 808 | remote_proto: format!("{:?}", ep.remote_proto).to_lowercase(), |
| 809 | remote_addr: ep.remote_addr, |
| 810 | remote_port: ep.remote_port, |
| 811 | error: ep.error, |
| 812 | }) |
| 813 | .collect(); |
| 814 | |
| 815 | Ok(py_endpoints) |
| 816 | } |
| 817 | |
| 818 | /// Очистить (удалить) все зарегистрированные сервисы |
| 819 | /// |