Struct ModuleManagementEngine 

pub struct ModuleManagementEngine<S> { /* private fields */ }

Implementations

impl<S> ModuleManagementEngine<S>

where S: ModuleOperationStore,

pub fn new(store: S) -> Self

pub fn store(&self) -> &S

pub fn start( &self, request: StartModuleOperation<'_>, ) -> Result<ModuleOperation, ModuleManagementError>

pub fn submit_approval( &self, operation_id: &str, expected_revision: u64, plan: &ModuleChangePlan, policy: &ModuleEnvironmentPolicy, requester: &ManagementActor, approval: ModuleApproval, holder_id: &str, now: DateTime<Utc>, ) -> Result<ModuleOperation, ModuleManagementError>

pub fn advance( &self, request: AdvanceModuleOperation, ) -> Result<ModuleOperation, ModuleManagementError>

pub fn retry_blocked( &self, operation_id: &str, expected_revision: u64, next_state: ModuleOperationState, holder_id: &str, maximum_lease_seconds: u64, actor_id: &str, now: DateTime<Utc>, ) -> Result<ModuleOperation, ModuleManagementError>

pub fn begin_workspace_application( &self, operation_id: &str, expected_revision: u64, fencing_token: u64, actor_id: &str, plan: &ModuleChangePlan, backups: Vec<ModuleWorkspaceBackup>, evidence_references: Vec<ArtifactReference>, now: DateTime<Utc>, ) -> Result<ModuleOperation, ModuleManagementError>

pub fn record_effect_receipt( &self, operation_id: &str, expected_revision: u64, fencing_token: u64, actor_id: &str, receipt: ModuleEffectReceipt, now: DateTime<Utc>, ) -> Result<ModuleOperation, ModuleManagementError>

pub fn resume_after_crash( &self, operation_id: &str, expected_revision: u64, evidence: &ModuleResumeEvidence, holder_id: &str, maximum_lease_seconds: u64, actor_id: &str, now: DateTime<Utc>, ) -> Result<ModuleOperation, ModuleManagementError>

pub fn reconcile_with_succeeded_repair( &self, operation_id: &str, expected_revision: u64, repair_plan: &ModuleRepairPlan, repair_change_plan: &ModuleChangePlan, repair_operation_id: &str, actor_id: &str, evidence_references: Vec<ArtifactReference>, now: DateTime<Utc>, ) -> Result<ModuleOperation, ModuleManagementError>

pub fn acquire_lease( &self, application_id: &str, holder_id: &str, maximum_lease_seconds: u64, now: DateTime<Utc>, ) -> Result<ModuleOperationLease, ModuleManagementError>

pub fn release_lease( &self, holder_id: &str, fencing_token: u64, ) -> Result<(), ModuleManagementError>

Trait Implementations

impl<S: Debug> Debug for ModuleManagementEngine<S>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.