(
&self,
sandbox_id: &str,
reason: &str,
message: String,
mut metadata: HashMap<String, String>,
)
| 1189 | } |
| 1190 | |
| 1191 | fn publish_docker_progress( |
| 1192 | &self, |
| 1193 | sandbox_id: &str, |
| 1194 | reason: &str, |
| 1195 | message: String, |
| 1196 | mut metadata: HashMap<String, String>, |
| 1197 | ) { |
| 1198 | attach_docker_progress_metadata(&mut metadata, reason, &message); |
| 1199 | self.publish_platform_event( |
| 1200 | sandbox_id.to_string(), |
| 1201 | DriverPlatformEvent { |
| 1202 | timestamp_ms: openshell_core::time::now_ms(), |
| 1203 | source: "docker".to_string(), |
| 1204 | r#type: "Normal".to_string(), |
| 1205 | reason: reason.to_string(), |
| 1206 | message, |
| 1207 | metadata, |
| 1208 | }, |
| 1209 | ); |
| 1210 | } |
| 1211 | |
| 1212 | async fn poll_loop(self) { |
| 1213 | let mut previous = match self.current_snapshot_map().await { |
no test coverage detected