(
state: &Arc<ServerState>,
sandbox: &str,
service: &str,
)
| 195 | } |
| 196 | |
| 197 | async fn get_service_endpoint( |
| 198 | state: &Arc<ServerState>, |
| 199 | sandbox: &str, |
| 200 | service: &str, |
| 201 | ) -> Result<Option<ServiceEndpoint>, Status> { |
| 202 | let key = service_routing::endpoint_key(sandbox, service); |
| 203 | state |
| 204 | .store |
| 205 | .get_message_by_name::<ServiceEndpoint>(&key) |
| 206 | .await |
| 207 | .map_err(|e| Status::internal(format!("fetch endpoint failed: {e}"))) |
| 208 | } |
| 209 | |
| 210 | fn service_endpoint_response( |
| 211 | state: &Arc<ServerState>, |
no test coverage detected