Struct ipc_orchestrator::Orchestrator

pub struct Orchestrator<LF: TryFuture> {
    pub processes: HashMap<String, Process>,
    // some fields omitted
}

Orchestrator which is in progress of starting up

Fields

processes: HashMap<String, Process>

Methods

impl<LF: TryFuture> Orchestrator<LF>

pub fn from_handlers(logger: fn(_: ChildStdout, _: String) -> LF) -> Self

Create orchestrator with provided log handler

Log handler is a function: fn(ChildStdout, String) -> impl TryFuture Provided future should process ChildStdout until eof, returning with anyhow::Result<()>

impl<LF> Orchestrator<LF> where
    LF: Future<Output = Result<()>>, 

pub fn start(&mut self, name: &str, cmd: &mut Command) -> Result<()>

Start provided command with communication channel As opinionated executor for all the processes Orchestrator provides following setup:

1. Start IpcOneShotServer and provide server name to process via commandline argument --orchestrator-ch
2. cmd.kill_on_drop(true) - process will exit if orchestrator's handle is dropped
3. cmd.stdout(Stdio::piped()) - stdout will be logged as info!(target: &name, ...)

pub async fn connect(
    self
) -> Result<ConnectedOrchestrator<Fuse<TryJoinAll<LF>>>>

Connect to processes IPC channels Resulting ConnectedOrchestrator can be used to further setup handlers over processes bridges

impl<LF: TryFuture> Orchestrator<LF>

pub fn ipc(self, ipc: bool) -> Self

Setup IPC channel Will pass IpcOneShotServer name via --orchestrator-ch

pub fn rust_backtrace(self, backtrace: bool) -> Self

Start child process with RUST_BACKTRACE=1 env option