Struct mz_orchestrator_process::ProcessOrchestrator

pub struct ProcessOrchestrator {
    pub(crate) image_dir: PathBuf,
    pub(crate) suppress_output: bool,
    pub(crate) namespaces: Mutex<BTreeMap<String, Arc<dyn NamespacedOrchestrator>>>,
    pub(crate) metadata_dir: PathBuf,
    pub(crate) secrets_dir: PathBuf,
    pub(crate) command_wrapper: Vec<String>,
    pub(crate) propagate_crashes: bool,
    pub(crate) tcp_proxy: Option<ProcessOrchestratorTcpProxyConfig>,
    pub(crate) scratch_directory: PathBuf,
    pub(crate) launch_spec: LaunchSpec,
}

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.

Fields

image_dir: PathBuf

suppress_output: bool

namespaces: Mutex<BTreeMap<String, Arc<dyn NamespacedOrchestrator>>>

metadata_dir: PathBuf

secrets_dir: PathBuf

command_wrapper: Vec<String>

propagate_crashes: bool

tcp_proxy: Option<ProcessOrchestratorTcpProxyConfig>

scratch_directory: PathBuf

launch_spec: LaunchSpec

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: CatalogItemId, 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: CatalogItemId, ) -> 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<CatalogItemId>, 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.