Struct LocalManager

pub struct LocalManager {
    manager_ctx: Arc<ManagerContext>,
    procedure_store: Arc<ProcedureStore>,
    max_retry_times: usize,
    retry_delay: Duration,
    remove_outdated_meta_task: Mutex<Option<RepeatedTask<Error>>>,
    config: ManagerConfig,
}

A ProcedureManager that maintains procedure states locally.

Fields

manager_ctx: Arc<ManagerContext>

procedure_store: Arc<ProcedureStore>

max_retry_times: usize

retry_delay: Duration

remove_outdated_meta_task: Mutex<Option<RepeatedTask<Error>>>

GC task.

config: ManagerConfig

Implementations

impl LocalManager

pub fn new( config: ManagerConfig, state_store: Arc<dyn StateStore>, ) -> LocalManager

Create a new LocalManager with specific config.

pub fn build_remove_outdated_meta_task(&self) -> RepeatedTask<Error>

Build remove outedated meta task

fn submit_root( &self, procedure_id: ProcedureId, procedure_state: ProcedureState, step: u32, procedure: BoxedProcedure, ) -> Result<Watcher>

Submit a root procedure with given procedure_id.

fn submit_recovered_messages( &self, messages: HashMap<ProcedureId, ProcedureMessage>, init_state: InitProcedureState, )

async fn recover(&self) -> Result<()>

Recovers unfinished procedures and reruns them.

Trait Implementations

impl ProcedureManager for LocalManager

fn register_loader( &self, name: &str, loader: BoxedProcedureLoader, ) -> Result<()>

Registers loader for specific procedure type name.

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Starts the background GC task.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stops the background GC task.

fn submit<'life0, 'async_trait>( &'life0 self, procedure: ProcedureWithId, ) -> Pin<Box<dyn Future<Output = Result<Watcher>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Submits a procedure to execute.

fn procedure_state<'life0, 'async_trait>( &'life0 self, procedure_id: ProcedureId, ) -> Pin<Box<dyn Future<Output = Result<Option<ProcedureState>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Query the procedure state.

fn procedure_watcher(&self, procedure_id: ProcedureId) -> Option<Watcher>

Returns a Watcher to watch ProcedureState of specific procedure.

fn list_procedures<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ProcedureInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the details of the procedure.