(
&mut self,
current_st: DeploymentManagerState,
)
| 211 | } |
| 212 | |
| 213 | async fn run_exec_state( |
| 214 | &mut self, |
| 215 | current_st: DeploymentManagerState, |
| 216 | ) -> (DeploymentManagerState, Option<Duration>, DeploymentManagerRunOutcome) { |
| 217 | match current_st { |
| 218 | DeploymentManagerState::SeekingNewDeployment {} => self.seek_new_deployment().await, |
| 219 | DeploymentManagerState::ExecutingDeployment { deployment } => { |
| 220 | let (state, delay) = self.execute_deployment(deployment).await; |
| 221 | (state, delay, DeploymentManagerRunOutcome::Continue) |
| 222 | } |
| 223 | DeploymentManagerState::ExecutingDeploymentTask { |
| 224 | deployment, |
| 225 | task, |
| 226 | upstream_gtw: upstream, |
| 227 | } => { |
| 228 | let (state, delay) = self.execute_deployment_task(deployment, task, upstream).await; |
| 229 | (state, delay, DeploymentManagerRunOutcome::Continue) |
| 230 | } |
| 231 | DeploymentManagerState::ResumingDeploymentTask { deployment, task } => { |
| 232 | let (state, delay) = self.resuming_deployment_task(deployment, task).await; |
| 233 | (state, delay, DeploymentManagerRunOutcome::Continue) |
| 234 | } |
| 235 | } |
| 236 | } |
| 237 | |
| 238 | /// Engine has nothing to do, pool the gtw to get a new deployment to execute |
| 239 | async fn seek_new_deployment(&mut self) -> (DeploymentManagerState, Option<Duration>, DeploymentManagerRunOutcome) { |
no test coverage detected