(self)
| 272 | } |
| 273 | |
| 274 | async fn get_node_statuses(self) -> Result<GetNodeStatusesResponse> { |
| 275 | let kv_store = self.state.kv_store(); |
| 276 | let statuses = kv_store.load_all_node_statuses(); |
| 277 | |
| 278 | let entries = statuses |
| 279 | .into_iter() |
| 280 | .map(|(node_id, status)| { |
| 281 | let status_str = match status { |
| 282 | NodeStatus::Up => "up", |
| 283 | NodeStatus::Down => "down", |
| 284 | }; |
| 285 | NodeStatusEntry { |
| 286 | node_id, |
| 287 | status: status_str.to_string(), |
| 288 | } |
| 289 | }) |
| 290 | .collect(); |
| 291 | |
| 292 | Ok(GetNodeStatusesResponse { statuses: entries }) |
| 293 | } |
| 294 | |
| 295 | // ==================== DNS Credential Management ==================== |
| 296 |
nothing calls this directly
no test coverage detected