pub struct ProcessOrchestratorConfig {
pub image_dir: PathBuf,
pub suppress_output: bool,
pub environment_id: String,
pub secrets_dir: PathBuf,
pub command_wrapper: Vec<String>,
pub propagate_crashes: bool,
pub tcp_proxy: Option<ProcessOrchestratorTcpProxyConfig>,
pub scratch_directory: PathBuf,
}
Expand description
Configures a ProcessOrchestrator
.
Fields§
§image_dir: PathBuf
The directory in which the orchestrator should look for executable images.
suppress_output: bool
Whether to supress output from spawned subprocesses.
environment_id: String
The ID of the environment under orchestration.
secrets_dir: PathBuf
The directory in which to store secrets.
command_wrapper: Vec<String>
A command to wrap the child command invocation
propagate_crashes: bool
Whether to crash this process if a child process crashes.
tcp_proxy: Option<ProcessOrchestratorTcpProxyConfig>
TCP proxy configuration.
When enabled, for each named port of each created service, the process orchestrator will bind a TCP listener that proxies incoming connections to the underlying Unix domain socket. Each bound TCP address will be emitted as a tracing event.
The primary use is live debugging the running child services via tools that do not support Unix domain sockets (e.g., Prometheus, web browsers).
scratch_directory: PathBuf
A scratch directory that orchestrated processes can use for ephemeral storage.
Trait Implementations§
source§impl Clone for ProcessOrchestratorConfig
impl Clone for ProcessOrchestratorConfig
source§fn clone(&self) -> ProcessOrchestratorConfig
fn clone(&self) -> ProcessOrchestratorConfig
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl Freeze for ProcessOrchestratorConfig
impl RefUnwindSafe for ProcessOrchestratorConfig
impl Send for ProcessOrchestratorConfig
impl Sync for ProcessOrchestratorConfig
impl Unpin for ProcessOrchestratorConfig
impl UnwindSafe for ProcessOrchestratorConfig
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
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
clone_to_uninit
)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>
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<T> ProgressEventTimestamp for T
impl<T> ProgressEventTimestamp 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>
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
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)
std::ops::AddAssign
, for types that do not implement AddAssign
.