(
&self,
server_name: &str,
level: impl Into<String>,
message: impl Into<String>,
)
| 99 | } |
| 100 | |
| 101 | async fn log_event( |
| 102 | &self, |
| 103 | server_name: &str, |
| 104 | level: impl Into<String>, |
| 105 | message: impl Into<String>, |
| 106 | ) { |
| 107 | let entry = McpServerLogEntry { |
| 108 | timestamp: Utc::now().to_rfc3339(), |
| 109 | level: level.into(), |
| 110 | message: message.into(), |
| 111 | }; |
| 112 | self.logs |
| 113 | .write() |
| 114 | .await |
| 115 | .entry(server_name.to_string()) |
| 116 | .or_default() |
| 117 | .push(entry); |
| 118 | } |
| 119 | |
| 120 | pub async fn has_server(&self, server_name: &str) -> bool { |
| 121 | self.servers.read().await.contains_key(server_name) |
no outgoing calls
no test coverage detected