Struct mz_orchestrator_process::ProcessOrchestrator

pub struct ProcessOrchestrator { /* private fields */ }

An orchestrator backed by processes on the local machine.

This orchestrator is for development only. Due to limitations in the Unix process API, it does not exactly conform to the documented semantics of Orchestrator.

Processes launched by this orchestrator must support a --pid-file-location command line flag which causes a PID file to be emitted at the specified path.

Implementations

impl ProcessOrchestrator

pub async fn new( __arg0: ProcessOrchestratorConfig ) -> Result<ProcessOrchestrator, Error>

Creates a new process orchestrator from the provided configuration.

Trait Implementations

impl Debug for ProcessOrchestrator

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

Formats the value using the given formatter.

impl Orchestrator for ProcessOrchestrator

fn namespace(&self, namespace: &str) -> Arc<dyn NamespacedOrchestrator>

Enter a namespace in the orchestrator.

impl SecretsController for ProcessOrchestrator

fn ensure<'life0, 'life1, 'async_trait>( &'life0 self, id: GlobalId, contents: &'life1 [u8] ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Creates or updates the specified secret with the specified binary contents.

fn delete<'life0, 'async_trait>( &'life0 self, id: GlobalId ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

Deletes the specified secret.

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

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

Lists known secrets. Unrecognized secret objects do not produce an error and are ignored.

fn reader(&self) -> Arc<dyn SecretsReader>

Returns a reader for the secrets managed by this controller.