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,
}
Expand description
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§
source§impl ProcessOrchestrator
impl ProcessOrchestrator
sourcepub async fn new(
__arg0: ProcessOrchestratorConfig,
) -> Result<ProcessOrchestrator, Error>
pub async fn new( __arg0: ProcessOrchestratorConfig, ) -> Result<ProcessOrchestrator, Error>
Creates a new process orchestrator from the provided configuration.
Trait Implementations§
source§impl Debug for ProcessOrchestrator
impl Debug for ProcessOrchestrator
source§impl Orchestrator for ProcessOrchestrator
impl Orchestrator for ProcessOrchestrator
source§impl SecretsController for ProcessOrchestrator
impl SecretsController for ProcessOrchestrator
source§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,
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.
source§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,
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.
source§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,
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.
source§fn reader(&self) -> Arc<dyn SecretsReader>
fn reader(&self) -> Arc<dyn SecretsReader>
Returns a reader for the secrets managed by this controller.
Auto Trait Implementations§
impl !Freeze for ProcessOrchestrator
impl RefUnwindSafe for ProcessOrchestrator
impl Send for ProcessOrchestrator
impl Sync for ProcessOrchestrator
impl Unpin for ProcessOrchestrator
impl UnwindSafe for ProcessOrchestrator
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
source§impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
impl<T, U> OverrideFrom<Option<&T>> for Uwhere
U: OverrideFrom<T>,
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.