pub mod processkit
pub use processkit::CancellationToken
pub use processkit::Encoding
pub use processkit::StreamExt
pub mod processkit::testing
pub struct processkit::testing::Invocation
pub processkit::testing::Invocation::args: alloc::vec::Vec<std::ffi::os_str::OsString>
pub processkit::testing::Invocation::cwd: core::option::Option<std::path::PathBuf>
pub processkit::testing::Invocation::envs: alloc::vec::Vec<(std::ffi::os_str::OsString, core::option::Option<std::ffi::os_str::OsString>)>
pub processkit::testing::Invocation::has_stdin: bool
pub processkit::testing::Invocation::program: std::ffi::os_str::OsString
impl processkit::testing::Invocation
pub fn processkit::testing::Invocation::args_str(&self) -> alloc::vec::Vec<alloc::string::String>
pub fn processkit::testing::Invocation::has_flag(&self, impl core::convert::AsRef<std::ffi::os_str::OsStr>) -> bool
impl core::clone::Clone for processkit::testing::Invocation
pub fn processkit::testing::Invocation::clone(&self) -> processkit::testing::Invocation
impl core::cmp::Eq for processkit::testing::Invocation
impl core::cmp::PartialEq for processkit::testing::Invocation
pub fn processkit::testing::Invocation::eq(&self, &processkit::testing::Invocation) -> bool
impl core::fmt::Debug for processkit::testing::Invocation
pub fn processkit::testing::Invocation::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for processkit::testing::Invocation
impl core::marker::Freeze for processkit::testing::Invocation
impl core::marker::Send for processkit::testing::Invocation
impl core::marker::Sync for processkit::testing::Invocation
impl core::marker::Unpin for processkit::testing::Invocation
impl core::marker::UnsafeUnpin for processkit::testing::Invocation
impl core::panic::unwind_safe::RefUnwindSafe for processkit::testing::Invocation
impl core::panic::unwind_safe::UnwindSafe for processkit::testing::Invocation
pub struct processkit::testing::MockRunner
impl processkit::testing::MockRunner
pub fn processkit::testing::MockRunner::checkpoint(&mut self)
pub fn processkit::testing::MockRunner::new() -> Self
impl processkit::testing::MockRunner
pub fn processkit::testing::MockRunner::expect_output(&mut self) -> &mut processkit::runner::__mock_MockProcessRunner_ProcessRunner::__output::Expectation
pub fn processkit::testing::MockRunner::expect_output_bytes(&mut self) -> &mut processkit::runner::__mock_MockProcessRunner_ProcessRunner::__output_bytes::Expectation
pub fn processkit::testing::MockRunner::expect_start(&mut self) -> &mut processkit::runner::__mock_MockProcessRunner_ProcessRunner::__start::Expectation
impl core::default::Default for processkit::testing::MockRunner
pub fn processkit::testing::MockRunner::default() -> Self
impl core::fmt::Debug for processkit::testing::MockRunner
pub fn processkit::testing::MockRunner::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::result::Result<(), core::fmt::Error>
impl processkit::ProcessRunner for processkit::testing::MockRunner
pub fn processkit::testing::MockRunner::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::MockRunner::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::MockRunner::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl core::marker::Freeze for processkit::testing::MockRunner
impl core::marker::Send for processkit::testing::MockRunner
impl core::marker::Sync for processkit::testing::MockRunner
impl core::marker::Unpin for processkit::testing::MockRunner
impl core::marker::UnsafeUnpin for processkit::testing::MockRunner
impl core::panic::unwind_safe::RefUnwindSafe for processkit::testing::MockRunner
impl core::panic::unwind_safe::UnwindSafe for processkit::testing::MockRunner
pub struct processkit::testing::RecordReplayRunner<R: processkit::ProcessRunner>
impl processkit::testing::RecordReplayRunner<processkit::JobRunner>
pub fn processkit::testing::RecordReplayRunner<processkit::JobRunner>::replay(impl core::convert::AsRef<std::path::Path>) -> processkit::Result<Self>
impl<R: processkit::ProcessRunner> processkit::testing::RecordReplayRunner<R>
pub fn processkit::testing::RecordReplayRunner<R>::record(impl core::convert::Into<std::path::PathBuf>, R) -> Self
pub fn processkit::testing::RecordReplayRunner<R>::save(&self) -> processkit::Result<()>
impl<R: processkit::ProcessRunner> core::fmt::Debug for processkit::testing::RecordReplayRunner<R>
pub fn processkit::testing::RecordReplayRunner<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: processkit::ProcessRunner> core::ops::drop::Drop for processkit::testing::RecordReplayRunner<R>
pub fn processkit::testing::RecordReplayRunner<R>::drop(&mut self)
impl<R: processkit::ProcessRunner> processkit::ProcessRunner for processkit::testing::RecordReplayRunner<R>
pub fn processkit::testing::RecordReplayRunner<R>::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::RecordReplayRunner<R>::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::RecordReplayRunner<R>::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl<R> !core::marker::Freeze for processkit::testing::RecordReplayRunner<R>
impl<R> core::marker::Send for processkit::testing::RecordReplayRunner<R>
impl<R> core::marker::Sync for processkit::testing::RecordReplayRunner<R>
impl<R> core::marker::Unpin for processkit::testing::RecordReplayRunner<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for processkit::testing::RecordReplayRunner<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for processkit::testing::RecordReplayRunner<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for processkit::testing::RecordReplayRunner<R> where R: core::panic::unwind_safe::UnwindSafe
pub struct processkit::testing::RecordingRunner<R: processkit::ProcessRunner>
impl processkit::testing::RecordingRunner<processkit::testing::ScriptedRunner>
pub fn processkit::testing::RecordingRunner<processkit::testing::ScriptedRunner>::replying(processkit::testing::Reply) -> Self
impl<R: processkit::ProcessRunner> processkit::testing::RecordingRunner<R>
pub fn processkit::testing::RecordingRunner<R>::calls(&self) -> alloc::vec::Vec<processkit::testing::Invocation>
pub fn processkit::testing::RecordingRunner<R>::new(R) -> Self
pub fn processkit::testing::RecordingRunner<R>::only_call(&self) -> processkit::testing::Invocation
impl<R: processkit::ProcessRunner> core::fmt::Debug for processkit::testing::RecordingRunner<R>
pub fn processkit::testing::RecordingRunner<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: processkit::ProcessRunner> processkit::ProcessRunner for processkit::testing::RecordingRunner<R>
pub fn processkit::testing::RecordingRunner<R>::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::RecordingRunner<R>::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::RecordingRunner<R>::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl<R> !core::marker::Freeze for processkit::testing::RecordingRunner<R>
impl<R> core::marker::Send for processkit::testing::RecordingRunner<R>
impl<R> core::marker::Sync for processkit::testing::RecordingRunner<R>
impl<R> core::marker::Unpin for processkit::testing::RecordingRunner<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for processkit::testing::RecordingRunner<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for processkit::testing::RecordingRunner<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for processkit::testing::RecordingRunner<R> where R: core::panic::unwind_safe::UnwindSafe
pub struct processkit::testing::Reply
impl processkit::testing::Reply
pub fn processkit::testing::Reply::fail(i32, impl core::convert::Into<alloc::string::String>) -> Self
pub fn processkit::testing::Reply::lines<I, S>(I) -> Self where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::Into<alloc::string::String>
pub fn processkit::testing::Reply::ok(impl core::convert::Into<alloc::string::String>) -> Self
pub fn processkit::testing::Reply::pending() -> Self
pub fn processkit::testing::Reply::signalled(core::option::Option<i32>) -> Self
pub fn processkit::testing::Reply::timeout() -> Self
pub fn processkit::testing::Reply::with_line_delay(self, core::time::Duration) -> Self
pub fn processkit::testing::Reply::with_stdout(self, impl core::convert::Into<alloc::string::String>) -> Self
impl core::clone::Clone for processkit::testing::Reply
pub fn processkit::testing::Reply::clone(&self) -> processkit::testing::Reply
impl core::fmt::Debug for processkit::testing::Reply
pub fn processkit::testing::Reply::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for processkit::testing::Reply
impl core::marker::Send for processkit::testing::Reply
impl core::marker::Sync for processkit::testing::Reply
impl core::marker::Unpin for processkit::testing::Reply
impl core::marker::UnsafeUnpin for processkit::testing::Reply
impl core::panic::unwind_safe::RefUnwindSafe for processkit::testing::Reply
impl core::panic::unwind_safe::UnwindSafe for processkit::testing::Reply
pub struct processkit::testing::ScriptedRunner
impl processkit::testing::ScriptedRunner
pub fn processkit::testing::ScriptedRunner::fallback(self, processkit::testing::Reply) -> Self
pub fn processkit::testing::ScriptedRunner::new() -> Self
pub fn processkit::testing::ScriptedRunner::on<I, S>(self, I, processkit::testing::Reply) -> Self where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<std::ffi::os_str::OsStr>
pub fn processkit::testing::ScriptedRunner::on_sequence<I, S, R>(self, I, R) -> Self where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<std::ffi::os_str::OsStr>, R: core::iter::traits::collect::IntoIterator<Item = processkit::testing::Reply>
pub fn processkit::testing::ScriptedRunner::when<F>(self, F, processkit::testing::Reply) -> Self where F: core::ops::function::Fn(&processkit::Command) -> bool + core::marker::Send + core::marker::Sync + 'static
impl core::default::Default for processkit::testing::ScriptedRunner
pub fn processkit::testing::ScriptedRunner::default() -> processkit::testing::ScriptedRunner
impl core::fmt::Debug for processkit::testing::ScriptedRunner
pub fn processkit::testing::ScriptedRunner::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl processkit::ProcessRunner for processkit::testing::ScriptedRunner
pub fn processkit::testing::ScriptedRunner::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::ScriptedRunner::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::ScriptedRunner::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl core::marker::Freeze for processkit::testing::ScriptedRunner
impl core::marker::Send for processkit::testing::ScriptedRunner
impl core::marker::Sync for processkit::testing::ScriptedRunner
impl core::marker::Unpin for processkit::testing::ScriptedRunner
impl core::marker::UnsafeUnpin for processkit::testing::ScriptedRunner
impl !core::panic::unwind_safe::RefUnwindSafe for processkit::testing::ScriptedRunner
impl !core::panic::unwind_safe::UnwindSafe for processkit::testing::ScriptedRunner
pub macro processkit::cli_client!
#[non_exhaustive] pub enum processkit::Error
pub processkit::Error::Cancelled
pub processkit::Error::Cancelled::program: alloc::string::String
pub processkit::Error::CassetteMiss
pub processkit::Error::CassetteMiss::program: alloc::string::String
pub processkit::Error::Exit
pub processkit::Error::Exit::code: i32
pub processkit::Error::Exit::program: alloc::string::String
pub processkit::Error::Exit::stderr: alloc::string::String
pub processkit::Error::Exit::stdout: alloc::string::String
pub processkit::Error::Io(std::io::error::Error)
pub processkit::Error::NotFound
pub processkit::Error::NotFound::program: alloc::string::String
pub processkit::Error::NotFound::searched: core::option::Option<alloc::string::String>
pub processkit::Error::NotReady
pub processkit::Error::NotReady::program: alloc::string::String
pub processkit::Error::NotReady::timeout: core::time::Duration
pub processkit::Error::OutputTooLarge
pub processkit::Error::OutputTooLarge::byte_limit: core::option::Option<usize>
pub processkit::Error::OutputTooLarge::line_limit: core::option::Option<usize>
pub processkit::Error::OutputTooLarge::program: alloc::string::String
pub processkit::Error::OutputTooLarge::total_bytes: usize
pub processkit::Error::OutputTooLarge::total_lines: usize
pub processkit::Error::Parse
pub processkit::Error::Parse::message: alloc::string::String
pub processkit::Error::Parse::program: alloc::string::String
pub processkit::Error::ResourceLimit(alloc::string::String)
pub processkit::Error::Signalled
pub processkit::Error::Signalled::program: alloc::string::String
pub processkit::Error::Signalled::signal: core::option::Option<i32>
pub processkit::Error::Signalled::stderr: alloc::string::String
pub processkit::Error::Signalled::stdout: alloc::string::String
pub processkit::Error::Spawn
pub processkit::Error::Spawn::program: alloc::string::String
pub processkit::Error::Spawn::source: std::io::error::Error
pub processkit::Error::Stdin
pub processkit::Error::Stdin::program: alloc::string::String
pub processkit::Error::Stdin::source: std::io::error::Error
pub processkit::Error::Timeout
pub processkit::Error::Timeout::program: alloc::string::String
pub processkit::Error::Timeout::stderr: alloc::string::String
pub processkit::Error::Timeout::stdout: alloc::string::String
pub processkit::Error::Timeout::timeout: core::time::Duration
pub processkit::Error::Unsupported
pub processkit::Error::Unsupported::operation: alloc::string::String
impl processkit::Error
pub fn processkit::Error::diagnostic(&self) -> core::option::Option<&str>
pub fn processkit::Error::is_not_found(&self) -> bool
pub fn processkit::Error::is_permission_denied(&self) -> bool
pub fn processkit::Error::is_transient(&self) -> bool
impl core::error::Error for processkit::Error
pub fn processkit::Error::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for processkit::Error
pub fn processkit::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for processkit::Error
pub fn processkit::Error::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for processkit::Error
impl core::marker::Send for processkit::Error
impl core::marker::Sync for processkit::Error
impl core::marker::Unpin for processkit::Error
impl core::marker::UnsafeUnpin for processkit::Error
impl !core::panic::unwind_safe::RefUnwindSafe for processkit::Error
impl !core::panic::unwind_safe::UnwindSafe for processkit::Error
#[non_exhaustive] pub enum processkit::Mechanism
pub processkit::Mechanism::CgroupV2
pub processkit::Mechanism::JobObject
pub processkit::Mechanism::ProcessGroup
impl core::clone::Clone for processkit::Mechanism
pub fn processkit::Mechanism::clone(&self) -> processkit::Mechanism
impl core::cmp::Eq for processkit::Mechanism
impl core::cmp::PartialEq for processkit::Mechanism
pub fn processkit::Mechanism::eq(&self, &processkit::Mechanism) -> bool
impl core::fmt::Debug for processkit::Mechanism
pub fn processkit::Mechanism::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::Mechanism
impl core::marker::StructuralPartialEq for processkit::Mechanism
impl core::marker::Freeze for processkit::Mechanism
impl core::marker::Send for processkit::Mechanism
impl core::marker::Sync for processkit::Mechanism
impl core::marker::Unpin for processkit::Mechanism
impl core::marker::UnsafeUnpin for processkit::Mechanism
impl core::panic::unwind_safe::RefUnwindSafe for processkit::Mechanism
impl core::panic::unwind_safe::UnwindSafe for processkit::Mechanism
#[non_exhaustive] pub enum processkit::Outcome
pub processkit::Outcome::Exited(i32)
pub processkit::Outcome::Signalled(core::option::Option<i32>)
pub processkit::Outcome::TimedOut
impl core::clone::Clone for processkit::Outcome
pub fn processkit::Outcome::clone(&self) -> processkit::Outcome
impl core::cmp::Eq for processkit::Outcome
impl core::cmp::PartialEq for processkit::Outcome
pub fn processkit::Outcome::eq(&self, &processkit::Outcome) -> bool
impl core::fmt::Debug for processkit::Outcome
pub fn processkit::Outcome::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::Outcome
impl core::marker::StructuralPartialEq for processkit::Outcome
impl core::marker::Freeze for processkit::Outcome
impl core::marker::Send for processkit::Outcome
impl core::marker::Sync for processkit::Outcome
impl core::marker::Unpin for processkit::Outcome
impl core::marker::UnsafeUnpin for processkit::Outcome
impl core::panic::unwind_safe::RefUnwindSafe for processkit::Outcome
impl core::panic::unwind_safe::UnwindSafe for processkit::Outcome
#[non_exhaustive] pub enum processkit::OutputEvent
pub processkit::OutputEvent::Stderr(processkit::OutputLine)
pub processkit::OutputEvent::Stdout(processkit::OutputLine)
impl processkit::OutputEvent
pub fn processkit::OutputEvent::text(&self) -> core::option::Option<&str>
impl core::clone::Clone for processkit::OutputEvent
pub fn processkit::OutputEvent::clone(&self) -> processkit::OutputEvent
impl core::cmp::Eq for processkit::OutputEvent
impl core::cmp::PartialEq for processkit::OutputEvent
pub fn processkit::OutputEvent::eq(&self, &processkit::OutputEvent) -> bool
impl core::fmt::Debug for processkit::OutputEvent
pub fn processkit::OutputEvent::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for processkit::OutputEvent
impl core::marker::Freeze for processkit::OutputEvent
impl core::marker::Send for processkit::OutputEvent
impl core::marker::Sync for processkit::OutputEvent
impl core::marker::Unpin for processkit::OutputEvent
impl core::marker::UnsafeUnpin for processkit::OutputEvent
impl core::panic::unwind_safe::RefUnwindSafe for processkit::OutputEvent
impl core::panic::unwind_safe::UnwindSafe for processkit::OutputEvent
#[non_exhaustive] pub enum processkit::OverflowMode
pub processkit::OverflowMode::DropNewest
pub processkit::OverflowMode::DropOldest
pub processkit::OverflowMode::Error
impl core::clone::Clone for processkit::OverflowMode
pub fn processkit::OverflowMode::clone(&self) -> processkit::OverflowMode
impl core::cmp::Eq for processkit::OverflowMode
impl core::cmp::PartialEq for processkit::OverflowMode
pub fn processkit::OverflowMode::eq(&self, &processkit::OverflowMode) -> bool
impl core::fmt::Debug for processkit::OverflowMode
pub fn processkit::OverflowMode::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::OverflowMode
impl core::marker::StructuralPartialEq for processkit::OverflowMode
impl core::marker::Freeze for processkit::OverflowMode
impl core::marker::Send for processkit::OverflowMode
impl core::marker::Sync for processkit::OverflowMode
impl core::marker::Unpin for processkit::OverflowMode
impl core::marker::UnsafeUnpin for processkit::OverflowMode
impl core::panic::unwind_safe::RefUnwindSafe for processkit::OverflowMode
impl core::panic::unwind_safe::UnwindSafe for processkit::OverflowMode
#[non_exhaustive] pub enum processkit::RestartPolicy
pub processkit::RestartPolicy::Always
pub processkit::RestartPolicy::Never
pub processkit::RestartPolicy::OnCrash
impl core::clone::Clone for processkit::RestartPolicy
pub fn processkit::RestartPolicy::clone(&self) -> processkit::RestartPolicy
impl core::cmp::Eq for processkit::RestartPolicy
impl core::cmp::PartialEq for processkit::RestartPolicy
pub fn processkit::RestartPolicy::eq(&self, &processkit::RestartPolicy) -> bool
impl core::fmt::Debug for processkit::RestartPolicy
pub fn processkit::RestartPolicy::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::RestartPolicy
impl core::marker::StructuralPartialEq for processkit::RestartPolicy
impl core::marker::Freeze for processkit::RestartPolicy
impl core::marker::Send for processkit::RestartPolicy
impl core::marker::Sync for processkit::RestartPolicy
impl core::marker::Unpin for processkit::RestartPolicy
impl core::marker::UnsafeUnpin for processkit::RestartPolicy
impl core::panic::unwind_safe::RefUnwindSafe for processkit::RestartPolicy
impl core::panic::unwind_safe::UnwindSafe for processkit::RestartPolicy
#[non_exhaustive] pub enum processkit::Signal
pub processkit::Signal::Hup
pub processkit::Signal::Int
pub processkit::Signal::Kill
pub processkit::Signal::Other(i32)
pub processkit::Signal::Quit
pub processkit::Signal::Term
pub processkit::Signal::Usr1
pub processkit::Signal::Usr2
impl core::clone::Clone for processkit::Signal
pub fn processkit::Signal::clone(&self) -> processkit::Signal
impl core::cmp::Eq for processkit::Signal
impl core::cmp::PartialEq for processkit::Signal
pub fn processkit::Signal::eq(&self, &processkit::Signal) -> bool
impl core::fmt::Debug for processkit::Signal
pub fn processkit::Signal::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for processkit::Signal
pub fn processkit::Signal::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for processkit::Signal
impl core::marker::StructuralPartialEq for processkit::Signal
impl core::marker::Freeze for processkit::Signal
impl core::marker::Send for processkit::Signal
impl core::marker::Sync for processkit::Signal
impl core::marker::Unpin for processkit::Signal
impl core::marker::UnsafeUnpin for processkit::Signal
impl core::panic::unwind_safe::RefUnwindSafe for processkit::Signal
impl core::panic::unwind_safe::UnwindSafe for processkit::Signal
#[non_exhaustive] pub enum processkit::StdioMode
pub processkit::StdioMode::Inherit
pub processkit::StdioMode::Null
pub processkit::StdioMode::Piped
impl core::clone::Clone for processkit::StdioMode
pub fn processkit::StdioMode::clone(&self) -> processkit::StdioMode
impl core::cmp::Eq for processkit::StdioMode
impl core::cmp::PartialEq for processkit::StdioMode
pub fn processkit::StdioMode::eq(&self, &processkit::StdioMode) -> bool
impl core::default::Default for processkit::StdioMode
pub fn processkit::StdioMode::default() -> processkit::StdioMode
impl core::fmt::Debug for processkit::StdioMode
pub fn processkit::StdioMode::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::StdioMode
impl core::marker::StructuralPartialEq for processkit::StdioMode
impl core::marker::Freeze for processkit::StdioMode
impl core::marker::Send for processkit::StdioMode
impl core::marker::Sync for processkit::StdioMode
impl core::marker::Unpin for processkit::StdioMode
impl core::marker::UnsafeUnpin for processkit::StdioMode
impl core::panic::unwind_safe::RefUnwindSafe for processkit::StdioMode
impl core::panic::unwind_safe::UnwindSafe for processkit::StdioMode
#[non_exhaustive] pub enum processkit::StopReason
pub processkit::StopReason::PolicySatisfied
pub processkit::StopReason::Predicate
pub processkit::StopReason::RestartsExhausted
impl core::clone::Clone for processkit::StopReason
pub fn processkit::StopReason::clone(&self) -> processkit::StopReason
impl core::cmp::Eq for processkit::StopReason
impl core::cmp::PartialEq for processkit::StopReason
pub fn processkit::StopReason::eq(&self, &processkit::StopReason) -> bool
impl core::fmt::Debug for processkit::StopReason
pub fn processkit::StopReason::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::StopReason
impl core::marker::StructuralPartialEq for processkit::StopReason
impl core::marker::Freeze for processkit::StopReason
impl core::marker::Send for processkit::StopReason
impl core::marker::Sync for processkit::StopReason
impl core::marker::Unpin for processkit::StopReason
impl core::marker::UnsafeUnpin for processkit::StopReason
impl core::panic::unwind_safe::RefUnwindSafe for processkit::StopReason
impl core::panic::unwind_safe::UnwindSafe for processkit::StopReason
pub struct processkit::CliClient<R: processkit::ProcessRunner>
impl processkit::CliClient<processkit::JobRunner>
pub fn processkit::CliClient<processkit::JobRunner>::new(impl core::convert::AsRef<std::ffi::os_str::OsStr>) -> Self
impl<R: processkit::ProcessRunner> processkit::CliClient<R>
pub async fn processkit::CliClient<R>::checked(&self, impl processkit::IntoCommand<R>) -> processkit::Result<processkit::ProcessResult<alloc::string::String>>
pub fn processkit::CliClient<R>::command<I, S>(&self, I) -> processkit::Command where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<std::ffi::os_str::OsStr>
pub fn processkit::CliClient<R>::command_in<I, S>(&self, &std::path::Path, I) -> processkit::Command where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<std::ffi::os_str::OsStr>
pub fn processkit::CliClient<R>::default_cancel_on(self, tokio_util::sync::cancellation_token::CancellationToken) -> Self
pub fn processkit::CliClient<R>::default_env(self, impl core::convert::AsRef<std::ffi::os_str::OsStr>, impl core::convert::AsRef<std::ffi::os_str::OsStr>) -> Self
pub fn processkit::CliClient<R>::default_env_remove(self, impl core::convert::AsRef<std::ffi::os_str::OsStr>) -> Self
pub fn processkit::CliClient<R>::default_timeout(self, core::time::Duration) -> Self
pub async fn processkit::CliClient<R>::exit_code(&self, impl processkit::IntoCommand<R>) -> processkit::Result<i32>
pub async fn processkit::CliClient<R>::first_line<F>(&self, impl processkit::IntoCommand<R>, F) -> processkit::Result<core::option::Option<alloc::string::String>> where F: core::ops::function::Fn(&str) -> bool + core::marker::Send
pub async fn processkit::CliClient<R>::output(&self, impl processkit::IntoCommand<R>) -> processkit::Result<processkit::ProcessResult<alloc::string::String>>
pub async fn processkit::CliClient<R>::output_bytes(&self, impl processkit::IntoCommand<R>) -> processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>
pub async fn processkit::CliClient<R>::parse<T, F>(&self, impl processkit::IntoCommand<R>, F) -> processkit::Result<T> where T: core::marker::Send, F: core::ops::function::FnOnce(&str) -> T + core::marker::Send
pub async fn processkit::CliClient<R>::probe(&self, impl processkit::IntoCommand<R>) -> processkit::Result<bool>
pub async fn processkit::CliClient<R>::run(&self, impl processkit::IntoCommand<R>) -> processkit::Result<alloc::string::String>
pub async fn processkit::CliClient<R>::run_unit(&self, impl processkit::IntoCommand<R>) -> processkit::Result<()>
pub fn processkit::CliClient<R>::runner(&self) -> &R
pub fn processkit::CliClient<R>::timeout(&self) -> core::option::Option<core::time::Duration>
pub async fn processkit::CliClient<R>::try_parse<T, F>(&self, impl processkit::IntoCommand<R>, F) -> processkit::Result<T> where T: core::marker::Send, F: core::ops::function::FnOnce(&str) -> processkit::Result<T> + core::marker::Send
pub fn processkit::CliClient<R>::with_runner(impl core::convert::AsRef<std::ffi::os_str::OsStr>, R) -> Self
impl<R: processkit::ProcessRunner> core::fmt::Debug for processkit::CliClient<R>
pub fn processkit::CliClient<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R> core::marker::Freeze for processkit::CliClient<R> where R: core::marker::Freeze
impl<R> core::marker::Send for processkit::CliClient<R>
impl<R> core::marker::Sync for processkit::CliClient<R>
impl<R> core::marker::Unpin for processkit::CliClient<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for processkit::CliClient<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for processkit::CliClient<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for processkit::CliClient<R> where R: core::panic::unwind_safe::UnwindSafe
pub struct processkit::Command
impl processkit::Command
pub fn processkit::Command::arg(self, impl core::convert::AsRef<std::ffi::os_str::OsStr>) -> Self
pub fn processkit::Command::args<I, S>(self, I) -> Self where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<std::ffi::os_str::OsStr>
pub fn processkit::Command::arguments(&self) -> &[std::ffi::os_str::OsString]
pub fn processkit::Command::cancel_on(self, tokio_util::sync::cancellation_token::CancellationToken) -> Self
pub async fn processkit::Command::checked(&self) -> processkit::Result<processkit::ProcessResult<alloc::string::String>>
pub fn processkit::Command::command_line(&self) -> alloc::string::String
pub fn processkit::Command::configured_timeout(&self) -> core::option::Option<core::time::Duration>
pub fn processkit::Command::create_no_window(self) -> Self
pub fn processkit::Command::current_dir(self, impl core::convert::AsRef<std::path::Path>) -> Self
pub fn processkit::Command::encoding(self, &'static encoding_rs::Encoding) -> Self
pub fn processkit::Command::env(self, impl core::convert::AsRef<std::ffi::os_str::OsStr>, impl core::convert::AsRef<std::ffi::os_str::OsStr>) -> Self
pub fn processkit::Command::env_clear(self) -> Self
pub fn processkit::Command::env_overrides(&self) -> &[(std::ffi::os_str::OsString, core::option::Option<std::ffi::os_str::OsString>)]
pub fn processkit::Command::env_remove(self, impl core::convert::AsRef<std::ffi::os_str::OsStr>) -> Self
pub fn processkit::Command::envs<I, K, V>(self, I) -> Self where I: core::iter::traits::collect::IntoIterator<Item = (K, V)>, K: core::convert::AsRef<std::ffi::os_str::OsStr>, V: core::convert::AsRef<std::ffi::os_str::OsStr>
pub async fn processkit::Command::exit_code(&self) -> processkit::Result<i32>
pub async fn processkit::Command::first_line<F>(&self, F) -> processkit::Result<core::option::Option<alloc::string::String>> where F: core::ops::function::Fn(&str) -> bool + core::marker::Send
pub fn processkit::Command::gid(self, u32) -> Self
pub fn processkit::Command::groups(self, impl core::convert::AsRef<[u32]>) -> Self
pub fn processkit::Command::inherit_env<I, S>(self, I) -> Self where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<std::ffi::os_str::OsStr>
pub fn processkit::Command::keep_stdin_open(self) -> Self
pub fn processkit::Command::kill_on_parent_death(self) -> Self
pub fn processkit::Command::new(impl core::convert::AsRef<std::ffi::os_str::OsStr>) -> Self
pub fn processkit::Command::ok_codes(self, impl core::iter::traits::collect::IntoIterator<Item = i32>) -> Self
pub fn processkit::Command::on_stderr_line<F>(self, F) -> Self where F: core::ops::function::Fn(&str) + core::marker::Send + core::marker::Sync + 'static
pub fn processkit::Command::on_stdout_line<F>(self, F) -> Self where F: core::ops::function::Fn(&str) + core::marker::Send + core::marker::Sync + 'static
pub fn processkit::Command::output_buffer(self, processkit::OutputBufferPolicy) -> Self
pub async fn processkit::Command::output_bytes(&self) -> processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>
pub async fn processkit::Command::output_string(&self) -> processkit::Result<processkit::ProcessResult<alloc::string::String>>
pub async fn processkit::Command::parse<T, F>(&self, F) -> processkit::Result<T> where T: core::marker::Send, F: core::ops::function::FnOnce(&str) -> T + core::marker::Send
pub fn processkit::Command::pipe(self, processkit::Command) -> processkit::Pipeline
pub async fn processkit::Command::probe(&self) -> processkit::Result<bool>
pub fn processkit::Command::program(&self) -> &std::ffi::os_str::OsStr
pub fn processkit::Command::retry(self, u32, core::time::Duration, impl core::ops::function::Fn(&processkit::Error) -> bool + core::marker::Send + core::marker::Sync + 'static) -> Self
pub async fn processkit::Command::run(&self) -> processkit::Result<alloc::string::String>
pub async fn processkit::Command::run_unit(&self) -> processkit::Result<()>
pub fn processkit::Command::setsid(self) -> Self
pub async fn processkit::Command::start(&self) -> processkit::Result<processkit::RunningProcess>
pub fn processkit::Command::stderr(self, processkit::StdioMode) -> Self
pub fn processkit::Command::stderr_encoding(self, &'static encoding_rs::Encoding) -> Self
pub fn processkit::Command::stderr_tee<W>(self, W) -> Self where W: tokio::io::async_write::AsyncWrite + core::marker::Send + core::marker::Unpin + 'static
pub fn processkit::Command::stdin(self, processkit::Stdin) -> Self
pub fn processkit::Command::stdin_source(&self) -> core::option::Option<&processkit::Stdin>
pub fn processkit::Command::stdout(self, processkit::StdioMode) -> Self
pub fn processkit::Command::stdout_encoding(self, &'static encoding_rs::Encoding) -> Self
pub fn processkit::Command::stdout_tee<W>(self, W) -> Self where W: tokio::io::async_write::AsyncWrite + core::marker::Send + core::marker::Unpin + 'static
pub fn processkit::Command::timeout(self, core::time::Duration) -> Self
pub fn processkit::Command::timeout_grace(self, core::time::Duration) -> Self
pub fn processkit::Command::timeout_signal(self, processkit::Signal) -> Self
pub async fn processkit::Command::try_parse<T, F>(&self, F) -> processkit::Result<T> where T: core::marker::Send, F: core::ops::function::FnOnce(&str) -> processkit::Result<T> + core::marker::Send
pub fn processkit::Command::uid(self, u32) -> Self
pub fn processkit::Command::unchecked_in_pipe(self) -> Self
pub fn processkit::Command::working_dir(&self) -> core::option::Option<&std::path::Path>
impl core::clone::Clone for processkit::Command
pub fn processkit::Command::clone(&self) -> processkit::Command
impl core::fmt::Debug for processkit::Command
pub fn processkit::Command::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::ops::bit::BitOr for processkit::Command
pub type processkit::Command::Output = processkit::Pipeline
pub fn processkit::Command::bitor(self, processkit::Command) -> processkit::Pipeline
impl core::ops::bit::BitOr<processkit::Command> for processkit::Pipeline
pub type processkit::Pipeline::Output = processkit::Pipeline
pub fn processkit::Pipeline::bitor(self, processkit::Command) -> processkit::Pipeline
impl<R: processkit::ProcessRunner> processkit::IntoCommand<R> for processkit::Command
impl core::marker::Freeze for processkit::Command
impl core::marker::Send for processkit::Command
impl core::marker::Sync for processkit::Command
impl core::marker::Unpin for processkit::Command
impl core::marker::UnsafeUnpin for processkit::Command
impl !core::panic::unwind_safe::RefUnwindSafe for processkit::Command
impl !core::panic::unwind_safe::UnwindSafe for processkit::Command
#[non_exhaustive] pub struct processkit::Finished
pub processkit::Finished::outcome: processkit::Outcome
pub processkit::Finished::stderr: alloc::string::String
impl core::clone::Clone for processkit::Finished
pub fn processkit::Finished::clone(&self) -> processkit::Finished
impl core::cmp::Eq for processkit::Finished
impl core::cmp::PartialEq for processkit::Finished
pub fn processkit::Finished::eq(&self, &processkit::Finished) -> bool
impl core::fmt::Debug for processkit::Finished
pub fn processkit::Finished::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for processkit::Finished
impl core::marker::Freeze for processkit::Finished
impl core::marker::Send for processkit::Finished
impl core::marker::Sync for processkit::Finished
impl core::marker::Unpin for processkit::Finished
impl core::marker::UnsafeUnpin for processkit::Finished
impl core::panic::unwind_safe::RefUnwindSafe for processkit::Finished
impl core::panic::unwind_safe::UnwindSafe for processkit::Finished
pub struct processkit::JobRunner
impl processkit::JobRunner
pub fn processkit::JobRunner::new() -> Self
pub async fn processkit::JobRunner::start(&self, &processkit::Command) -> processkit::Result<processkit::RunningProcess>
impl core::clone::Clone for processkit::JobRunner
pub fn processkit::JobRunner::clone(&self) -> processkit::JobRunner
impl core::default::Default for processkit::JobRunner
pub fn processkit::JobRunner::default() -> processkit::JobRunner
impl core::fmt::Debug for processkit::JobRunner
pub fn processkit::JobRunner::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl processkit::ProcessRunner for processkit::JobRunner
pub fn processkit::JobRunner::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::JobRunner::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::JobRunner::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl core::marker::Freeze for processkit::JobRunner
impl core::marker::Send for processkit::JobRunner
impl core::marker::Sync for processkit::JobRunner
impl core::marker::Unpin for processkit::JobRunner
impl core::marker::UnsafeUnpin for processkit::JobRunner
impl core::panic::unwind_safe::RefUnwindSafe for processkit::JobRunner
impl core::panic::unwind_safe::UnwindSafe for processkit::JobRunner
#[non_exhaustive] pub struct processkit::OutputBufferPolicy
pub processkit::OutputBufferPolicy::max_bytes: core::option::Option<usize>
pub processkit::OutputBufferPolicy::max_lines: core::option::Option<usize>
pub processkit::OutputBufferPolicy::overflow: processkit::OverflowMode
impl processkit::OutputBufferPolicy
pub fn processkit::OutputBufferPolicy::bounded(usize) -> Self
pub fn processkit::OutputBufferPolicy::fail_loud(usize) -> Self
pub fn processkit::OutputBufferPolicy::unbounded() -> Self
pub fn processkit::OutputBufferPolicy::with_max_bytes(self, usize) -> Self
pub fn processkit::OutputBufferPolicy::with_overflow(self, processkit::OverflowMode) -> Self
impl core::clone::Clone for processkit::OutputBufferPolicy
pub fn processkit::OutputBufferPolicy::clone(&self) -> processkit::OutputBufferPolicy
impl core::cmp::Eq for processkit::OutputBufferPolicy
impl core::cmp::PartialEq for processkit::OutputBufferPolicy
pub fn processkit::OutputBufferPolicy::eq(&self, &processkit::OutputBufferPolicy) -> bool
impl core::default::Default for processkit::OutputBufferPolicy
pub fn processkit::OutputBufferPolicy::default() -> Self
impl core::fmt::Debug for processkit::OutputBufferPolicy
pub fn processkit::OutputBufferPolicy::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::OutputBufferPolicy
impl core::marker::StructuralPartialEq for processkit::OutputBufferPolicy
impl core::marker::Freeze for processkit::OutputBufferPolicy
impl core::marker::Send for processkit::OutputBufferPolicy
impl core::marker::Sync for processkit::OutputBufferPolicy
impl core::marker::Unpin for processkit::OutputBufferPolicy
impl core::marker::UnsafeUnpin for processkit::OutputBufferPolicy
impl core::panic::unwind_safe::RefUnwindSafe for processkit::OutputBufferPolicy
impl core::panic::unwind_safe::UnwindSafe for processkit::OutputBufferPolicy
pub struct processkit::OutputEvents
impl core::fmt::Debug for processkit::OutputEvents
pub fn processkit::OutputEvents::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl futures_core::stream::Stream for processkit::OutputEvents
pub type processkit::OutputEvents::Item = processkit::OutputEvent
pub fn processkit::OutputEvents::poll_next(core::pin::Pin<&mut Self>, &mut core::task::wake::Context<'_>) -> core::task::poll::Poll<core::option::Option<processkit::OutputEvent>>
impl core::marker::Freeze for processkit::OutputEvents
impl core::marker::Send for processkit::OutputEvents
impl !core::marker::Sync for processkit::OutputEvents
impl core::marker::Unpin for processkit::OutputEvents
impl core::marker::UnsafeUnpin for processkit::OutputEvents
impl !core::panic::unwind_safe::RefUnwindSafe for processkit::OutputEvents
impl !core::panic::unwind_safe::UnwindSafe for processkit::OutputEvents
#[non_exhaustive] pub struct processkit::OutputLine
pub processkit::OutputLine::text: alloc::string::String
impl core::clone::Clone for processkit::OutputLine
pub fn processkit::OutputLine::clone(&self) -> processkit::OutputLine
impl core::cmp::Eq for processkit::OutputLine
impl core::cmp::PartialEq for processkit::OutputLine
pub fn processkit::OutputLine::eq(&self, &processkit::OutputLine) -> bool
impl core::fmt::Debug for processkit::OutputLine
pub fn processkit::OutputLine::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for processkit::OutputLine
impl core::marker::Freeze for processkit::OutputLine
impl core::marker::Send for processkit::OutputLine
impl core::marker::Sync for processkit::OutputLine
impl core::marker::Unpin for processkit::OutputLine
impl core::marker::UnsafeUnpin for processkit::OutputLine
impl core::panic::unwind_safe::RefUnwindSafe for processkit::OutputLine
impl core::panic::unwind_safe::UnwindSafe for processkit::OutputLine
pub struct processkit::Pipeline
impl processkit::Pipeline
pub fn processkit::Pipeline::cancel_on(self, tokio_util::sync::cancellation_token::CancellationToken) -> Self
pub async fn processkit::Pipeline::checked(&self) -> processkit::Result<processkit::ProcessResult<alloc::string::String>>
pub async fn processkit::Pipeline::exit_code(&self) -> processkit::Result<i32>
pub async fn processkit::Pipeline::output_bytes(&self) -> processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>
pub async fn processkit::Pipeline::output_string(&self) -> processkit::Result<processkit::ProcessResult<alloc::string::String>>
pub async fn processkit::Pipeline::parse<T, F>(&self, F) -> processkit::Result<T> where F: core::ops::function::FnOnce(&str) -> T
pub fn processkit::Pipeline::pipe(self, processkit::Command) -> Self
pub async fn processkit::Pipeline::probe(&self) -> processkit::Result<bool>
pub async fn processkit::Pipeline::run(&self) -> processkit::Result<alloc::string::String>
pub async fn processkit::Pipeline::run_unit(&self) -> processkit::Result<()>
pub fn processkit::Pipeline::timeout(self, core::time::Duration) -> Self
pub async fn processkit::Pipeline::try_parse<T, F>(&self, F) -> processkit::Result<T> where F: core::ops::function::FnOnce(&str) -> processkit::Result<T>
impl core::clone::Clone for processkit::Pipeline
pub fn processkit::Pipeline::clone(&self) -> processkit::Pipeline
impl core::fmt::Debug for processkit::Pipeline
pub fn processkit::Pipeline::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::ops::bit::BitOr<processkit::Command> for processkit::Pipeline
pub type processkit::Pipeline::Output = processkit::Pipeline
pub fn processkit::Pipeline::bitor(self, processkit::Command) -> processkit::Pipeline
impl core::marker::Freeze for processkit::Pipeline
impl core::marker::Send for processkit::Pipeline
impl core::marker::Sync for processkit::Pipeline
impl core::marker::Unpin for processkit::Pipeline
impl core::marker::UnsafeUnpin for processkit::Pipeline
impl !core::panic::unwind_safe::RefUnwindSafe for processkit::Pipeline
impl !core::panic::unwind_safe::UnwindSafe for processkit::Pipeline
pub struct processkit::ProcessGroup
impl processkit::ProcessGroup
pub fn processkit::ProcessGroup::adopt(&self, &tokio::process::Child) -> processkit::Result<()>
pub fn processkit::ProcessGroup::mechanism(&self) -> processkit::Mechanism
pub fn processkit::ProcessGroup::members(&self) -> processkit::Result<alloc::vec::Vec<u32>>
pub fn processkit::ProcessGroup::new() -> processkit::Result<Self>
pub fn processkit::ProcessGroup::resume(&self) -> processkit::Result<()>
pub fn processkit::ProcessGroup::sample_stats(&self, core::time::Duration) -> processkit::StatsSampler<'_>
pub async fn processkit::ProcessGroup::shutdown(self) -> processkit::Result<()>
pub fn processkit::ProcessGroup::signal(&self, processkit::Signal) -> processkit::Result<()>
pub fn processkit::ProcessGroup::spawn(&self, tokio::process::Command) -> processkit::Result<tokio::process::Child>
pub fn processkit::ProcessGroup::stats(&self) -> processkit::Result<processkit::ProcessGroupStats>
pub fn processkit::ProcessGroup::suspend(&self) -> processkit::Result<()>
pub fn processkit::ProcessGroup::terminate_all(&self) -> processkit::Result<()>
pub fn processkit::ProcessGroup::with_options(processkit::ProcessGroupOptions) -> processkit::Result<Self>
impl processkit::ProcessGroup
pub async fn processkit::ProcessGroup::start(&self, &processkit::Command) -> processkit::Result<processkit::RunningProcess>
impl core::fmt::Debug for processkit::ProcessGroup
pub fn processkit::ProcessGroup::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl processkit::ProcessRunner for processkit::ProcessGroup
pub fn processkit::ProcessGroup::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessGroup::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessGroup::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl !core::marker::Freeze for processkit::ProcessGroup
impl core::marker::Send for processkit::ProcessGroup
impl core::marker::Sync for processkit::ProcessGroup
impl core::marker::Unpin for processkit::ProcessGroup
impl core::marker::UnsafeUnpin for processkit::ProcessGroup
impl core::panic::unwind_safe::RefUnwindSafe for processkit::ProcessGroup
impl core::panic::unwind_safe::UnwindSafe for processkit::ProcessGroup
#[non_exhaustive] pub struct processkit::ProcessGroupOptions
pub processkit::ProcessGroupOptions::escalate_to_kill: bool
pub processkit::ProcessGroupOptions::limits: processkit::ResourceLimits
pub processkit::ProcessGroupOptions::shutdown_timeout: core::time::Duration
impl processkit::ProcessGroupOptions
pub fn processkit::ProcessGroupOptions::cpu_quota(self, f64) -> Self
pub fn processkit::ProcessGroupOptions::max_processes(self, u32) -> Self
pub fn processkit::ProcessGroupOptions::memory_max(self, u64) -> Self
impl processkit::ProcessGroupOptions
pub fn processkit::ProcessGroupOptions::escalate_to_kill(self, bool) -> Self
pub fn processkit::ProcessGroupOptions::shutdown_timeout(self, core::time::Duration) -> Self
impl core::clone::Clone for processkit::ProcessGroupOptions
pub fn processkit::ProcessGroupOptions::clone(&self) -> processkit::ProcessGroupOptions
impl core::default::Default for processkit::ProcessGroupOptions
pub fn processkit::ProcessGroupOptions::default() -> Self
impl core::fmt::Debug for processkit::ProcessGroupOptions
pub fn processkit::ProcessGroupOptions::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for processkit::ProcessGroupOptions
impl core::marker::Send for processkit::ProcessGroupOptions
impl core::marker::Sync for processkit::ProcessGroupOptions
impl core::marker::Unpin for processkit::ProcessGroupOptions
impl core::marker::UnsafeUnpin for processkit::ProcessGroupOptions
impl core::panic::unwind_safe::RefUnwindSafe for processkit::ProcessGroupOptions
impl core::panic::unwind_safe::UnwindSafe for processkit::ProcessGroupOptions
#[non_exhaustive] pub struct processkit::ProcessGroupStats
pub processkit::ProcessGroupStats::active_process_count: usize
pub processkit::ProcessGroupStats::peak_memory_bytes: core::option::Option<u64>
pub processkit::ProcessGroupStats::total_cpu_time: core::option::Option<core::time::Duration>
impl core::clone::Clone for processkit::ProcessGroupStats
pub fn processkit::ProcessGroupStats::clone(&self) -> processkit::ProcessGroupStats
impl core::cmp::Eq for processkit::ProcessGroupStats
impl core::cmp::PartialEq for processkit::ProcessGroupStats
pub fn processkit::ProcessGroupStats::eq(&self, &processkit::ProcessGroupStats) -> bool
impl core::fmt::Debug for processkit::ProcessGroupStats
pub fn processkit::ProcessGroupStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::ProcessGroupStats
impl core::marker::StructuralPartialEq for processkit::ProcessGroupStats
impl core::marker::Freeze for processkit::ProcessGroupStats
impl core::marker::Send for processkit::ProcessGroupStats
impl core::marker::Sync for processkit::ProcessGroupStats
impl core::marker::Unpin for processkit::ProcessGroupStats
impl core::marker::UnsafeUnpin for processkit::ProcessGroupStats
impl core::panic::unwind_safe::RefUnwindSafe for processkit::ProcessGroupStats
impl core::panic::unwind_safe::UnwindSafe for processkit::ProcessGroupStats
pub struct processkit::ProcessResult<T>
impl processkit::ProcessResult<alloc::string::String>
pub fn processkit::ProcessResult<alloc::string::String>::combined(&self) -> alloc::string::String
pub fn processkit::ProcessResult<alloc::string::String>::diagnostic(&self) -> &str
impl<T> processkit::ProcessResult<T>
pub fn processkit::ProcessResult<T>::code(&self) -> core::option::Option<i32>
pub fn processkit::ProcessResult<T>::duration(&self) -> core::time::Duration
pub fn processkit::ProcessResult<T>::ensure_success(self) -> core::result::Result<Self, processkit::Error> where T: StdoutText
pub fn processkit::ProcessResult<T>::into_stdout(self) -> T
pub fn processkit::ProcessResult<T>::is_success(&self) -> bool
pub fn processkit::ProcessResult<T>::outcome(&self) -> processkit::Outcome
pub fn processkit::ProcessResult<T>::program(&self) -> &str
pub fn processkit::ProcessResult<T>::stderr(&self) -> &str
pub fn processkit::ProcessResult<T>::stdout(&self) -> &T
pub fn processkit::ProcessResult<T>::timed_out(&self) -> bool
pub fn processkit::ProcessResult<T>::truncated(&self) -> bool
impl<T: core::clone::Clone> core::clone::Clone for processkit::ProcessResult<T>
pub fn processkit::ProcessResult<T>::clone(&self) -> processkit::ProcessResult<T>
impl<T: core::cmp::Eq> core::cmp::Eq for processkit::ProcessResult<T>
impl<T: core::cmp::PartialEq> core::cmp::PartialEq for processkit::ProcessResult<T>
pub fn processkit::ProcessResult<T>::eq(&self, &Self) -> bool
impl<T: core::fmt::Debug> core::fmt::Debug for processkit::ProcessResult<T>
pub fn processkit::ProcessResult<T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<T> core::marker::Freeze for processkit::ProcessResult<T> where T: core::marker::Freeze
impl<T> core::marker::Send for processkit::ProcessResult<T> where T: core::marker::Send
impl<T> core::marker::Sync for processkit::ProcessResult<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for processkit::ProcessResult<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for processkit::ProcessResult<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for processkit::ProcessResult<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for processkit::ProcessResult<T> where T: core::panic::unwind_safe::UnwindSafe
pub struct processkit::ProcessStdin
impl processkit::ProcessStdin
pub async fn processkit::ProcessStdin::finish(self) -> std::io::error::Result<()>
pub async fn processkit::ProcessStdin::flush(&mut self) -> std::io::error::Result<()>
pub async fn processkit::ProcessStdin::write(&mut self, &[u8]) -> std::io::error::Result<()>
pub async fn processkit::ProcessStdin::write_line(&mut self, &str) -> std::io::error::Result<()>
impl core::fmt::Debug for processkit::ProcessStdin
pub fn processkit::ProcessStdin::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for processkit::ProcessStdin
impl core::marker::Send for processkit::ProcessStdin
impl core::marker::Sync for processkit::ProcessStdin
impl core::marker::Unpin for processkit::ProcessStdin
impl core::marker::UnsafeUnpin for processkit::ProcessStdin
impl core::panic::unwind_safe::RefUnwindSafe for processkit::ProcessStdin
impl core::panic::unwind_safe::UnwindSafe for processkit::ProcessStdin
#[non_exhaustive] pub struct processkit::ResourceLimits
pub processkit::ResourceLimits::cpu_quota: core::option::Option<f64>
pub processkit::ResourceLimits::max_processes: core::option::Option<u32>
pub processkit::ResourceLimits::memory_max: core::option::Option<u64>
impl core::clone::Clone for processkit::ResourceLimits
pub fn processkit::ResourceLimits::clone(&self) -> processkit::ResourceLimits
impl core::cmp::PartialEq for processkit::ResourceLimits
pub fn processkit::ResourceLimits::eq(&self, &processkit::ResourceLimits) -> bool
impl core::default::Default for processkit::ResourceLimits
pub fn processkit::ResourceLimits::default() -> processkit::ResourceLimits
impl core::fmt::Debug for processkit::ResourceLimits
pub fn processkit::ResourceLimits::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::ResourceLimits
impl core::marker::StructuralPartialEq for processkit::ResourceLimits
impl core::marker::Freeze for processkit::ResourceLimits
impl core::marker::Send for processkit::ResourceLimits
impl core::marker::Sync for processkit::ResourceLimits
impl core::marker::Unpin for processkit::ResourceLimits
impl core::marker::UnsafeUnpin for processkit::ResourceLimits
impl core::panic::unwind_safe::RefUnwindSafe for processkit::ResourceLimits
impl core::panic::unwind_safe::UnwindSafe for processkit::ResourceLimits
#[non_exhaustive] pub struct processkit::RunProfile
pub processkit::RunProfile::cpu_time: core::option::Option<core::time::Duration>
pub processkit::RunProfile::duration: core::time::Duration
pub processkit::RunProfile::exit_code: core::option::Option<i32>
pub processkit::RunProfile::peak_memory_bytes: core::option::Option<u64>
pub processkit::RunProfile::samples: usize
impl processkit::RunProfile
pub fn processkit::RunProfile::avg_cpu(&self) -> core::option::Option<f64>
impl core::clone::Clone for processkit::RunProfile
pub fn processkit::RunProfile::clone(&self) -> processkit::RunProfile
impl core::cmp::Eq for processkit::RunProfile
impl core::cmp::PartialEq for processkit::RunProfile
pub fn processkit::RunProfile::eq(&self, &processkit::RunProfile) -> bool
impl core::fmt::Debug for processkit::RunProfile
pub fn processkit::RunProfile::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for processkit::RunProfile
impl core::marker::StructuralPartialEq for processkit::RunProfile
impl core::marker::Freeze for processkit::RunProfile
impl core::marker::Send for processkit::RunProfile
impl core::marker::Sync for processkit::RunProfile
impl core::marker::Unpin for processkit::RunProfile
impl core::marker::UnsafeUnpin for processkit::RunProfile
impl core::panic::unwind_safe::RefUnwindSafe for processkit::RunProfile
impl core::panic::unwind_safe::UnwindSafe for processkit::RunProfile
pub struct processkit::RunningProcess
impl processkit::RunningProcess
pub fn processkit::RunningProcess::cpu_time(&self) -> core::option::Option<core::time::Duration>
pub fn processkit::RunningProcess::elapsed(&self) -> core::time::Duration
pub fn processkit::RunningProcess::kills_tree_on_drop(&self) -> bool
pub async fn processkit::RunningProcess::output_bytes(self) -> processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>
pub async fn processkit::RunningProcess::output_string(self) -> processkit::Result<processkit::ProcessResult<alloc::string::String>>
pub fn processkit::RunningProcess::peak_memory_bytes(&self) -> core::option::Option<u64>
pub fn processkit::RunningProcess::pid(&self) -> core::option::Option<u32>
pub async fn processkit::RunningProcess::profile(self, core::time::Duration) -> processkit::Result<processkit::RunProfile>
pub async fn processkit::RunningProcess::shutdown(self, core::time::Duration) -> processkit::Result<processkit::Outcome>
pub fn processkit::RunningProcess::start_kill(&mut self) -> processkit::Result<()>
pub fn processkit::RunningProcess::start_time(&self) -> std::time::SystemTime
pub fn processkit::RunningProcess::stderr_line_count(&self) -> usize
pub fn processkit::RunningProcess::stdout_line_count(&self) -> usize
pub fn processkit::RunningProcess::take_stdin(&mut self) -> core::option::Option<processkit::ProcessStdin>
pub async fn processkit::RunningProcess::wait(self) -> processkit::Result<processkit::Outcome>
impl processkit::RunningProcess
pub async fn processkit::RunningProcess::finish(self) -> processkit::Result<processkit::Finished>
pub fn processkit::RunningProcess::output_events(&mut self) -> processkit::Result<processkit::OutputEvents>
pub fn processkit::RunningProcess::stdout_lines(&mut self) -> processkit::Result<processkit::StdoutLines>
impl processkit::RunningProcess
pub async fn processkit::RunningProcess::wait_for<F, Fut>(&mut self, F, core::time::Duration) -> processkit::Result<()> where F: core::ops::function::FnMut() -> Fut, Fut: core::future::future::Future<Output = bool>
pub async fn processkit::RunningProcess::wait_for_line(&mut self, impl core::ops::function::Fn(&str) -> bool, core::time::Duration) -> processkit::Result<alloc::string::String>
pub async fn processkit::RunningProcess::wait_for_port(&mut self, core::net::socket_addr::SocketAddr, core::time::Duration) -> processkit::Result<()>
impl core::fmt::Debug for processkit::RunningProcess
pub fn processkit::RunningProcess::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::ops::drop::Drop for processkit::RunningProcess
pub fn processkit::RunningProcess::drop(&mut self)
impl core::marker::Freeze for processkit::RunningProcess
impl core::marker::Send for processkit::RunningProcess
impl core::marker::Sync for processkit::RunningProcess
impl core::marker::Unpin for processkit::RunningProcess
impl core::marker::UnsafeUnpin for processkit::RunningProcess
impl !core::panic::unwind_safe::RefUnwindSafe for processkit::RunningProcess
impl !core::panic::unwind_safe::UnwindSafe for processkit::RunningProcess
pub struct processkit::StatsSampler<'a>
impl core::fmt::Debug for processkit::StatsSampler<'_>
pub fn processkit::StatsSampler<'_>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl futures_core::stream::Stream for processkit::StatsSampler<'_>
pub type processkit::StatsSampler<'_>::Item = processkit::ProcessGroupStats
pub fn processkit::StatsSampler<'_>::poll_next(core::pin::Pin<&mut Self>, &mut core::task::wake::Context<'_>) -> core::task::poll::Poll<core::option::Option<Self::Item>>
impl<'a> core::marker::Freeze for processkit::StatsSampler<'a>
impl<'a> core::marker::Send for processkit::StatsSampler<'a>
impl<'a> core::marker::Sync for processkit::StatsSampler<'a>
impl<'a> core::marker::Unpin for processkit::StatsSampler<'a>
impl<'a> core::marker::UnsafeUnpin for processkit::StatsSampler<'a>
impl<'a> !core::panic::unwind_safe::RefUnwindSafe for processkit::StatsSampler<'a>
impl<'a> !core::panic::unwind_safe::UnwindSafe for processkit::StatsSampler<'a>
pub struct processkit::Stdin(_)
impl processkit::Stdin
pub fn processkit::Stdin::empty() -> Self
pub fn processkit::Stdin::from_bytes(impl core::convert::Into<alloc::vec::Vec<u8>>) -> Self
pub fn processkit::Stdin::from_file(impl core::convert::AsRef<std::path::Path>) -> Self
pub fn processkit::Stdin::from_iter_lines<I, S>(I) -> Self where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<str>
pub fn processkit::Stdin::from_lines<S>(S) -> Self where S: futures_core::stream::Stream<Item = alloc::string::String> + core::marker::Send + 'static
pub fn processkit::Stdin::from_reader<R>(R) -> Self where R: tokio::io::async_read::AsyncRead + core::marker::Send + 'static
pub fn processkit::Stdin::from_string(impl core::convert::Into<alloc::string::String>) -> Self
impl core::clone::Clone for processkit::Stdin
pub fn processkit::Stdin::clone(&self) -> processkit::Stdin
impl core::fmt::Debug for processkit::Stdin
pub fn processkit::Stdin::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for processkit::Stdin
impl core::marker::Send for processkit::Stdin
impl core::marker::Sync for processkit::Stdin
impl core::marker::Unpin for processkit::Stdin
impl core::marker::UnsafeUnpin for processkit::Stdin
impl !core::panic::unwind_safe::RefUnwindSafe for processkit::Stdin
impl !core::panic::unwind_safe::UnwindSafe for processkit::Stdin
pub struct processkit::StdoutLines
impl core::fmt::Debug for processkit::StdoutLines
pub fn processkit::StdoutLines::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl futures_core::stream::Stream for processkit::StdoutLines
pub type processkit::StdoutLines::Item = alloc::string::String
pub fn processkit::StdoutLines::poll_next(core::pin::Pin<&mut Self>, &mut core::task::wake::Context<'_>) -> core::task::poll::Poll<core::option::Option<alloc::string::String>>
impl core::marker::Freeze for processkit::StdoutLines
impl core::marker::Send for processkit::StdoutLines
impl !core::marker::Sync for processkit::StdoutLines
impl core::marker::Unpin for processkit::StdoutLines
impl core::marker::UnsafeUnpin for processkit::StdoutLines
impl !core::panic::unwind_safe::RefUnwindSafe for processkit::StdoutLines
impl !core::panic::unwind_safe::UnwindSafe for processkit::StdoutLines
#[non_exhaustive] pub struct processkit::SupervisionOutcome
pub processkit::SupervisionOutcome::final_result: processkit::ProcessResult<alloc::string::String>
pub processkit::SupervisionOutcome::restarts: u32
pub processkit::SupervisionOutcome::stopped: processkit::StopReason
pub processkit::SupervisionOutcome::storm_pauses: u32
impl core::fmt::Debug for processkit::SupervisionOutcome
pub fn processkit::SupervisionOutcome::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for processkit::SupervisionOutcome
impl core::marker::Send for processkit::SupervisionOutcome
impl core::marker::Sync for processkit::SupervisionOutcome
impl core::marker::Unpin for processkit::SupervisionOutcome
impl core::marker::UnsafeUnpin for processkit::SupervisionOutcome
impl core::panic::unwind_safe::RefUnwindSafe for processkit::SupervisionOutcome
impl core::panic::unwind_safe::UnwindSafe for processkit::SupervisionOutcome
pub struct processkit::Supervisor<R: processkit::ProcessRunner>
impl processkit::Supervisor<processkit::JobRunner>
pub fn processkit::Supervisor<processkit::JobRunner>::new(processkit::Command) -> Self
impl<R: processkit::ProcessRunner> processkit::Supervisor<R>
pub fn processkit::Supervisor<R>::backoff(self, core::time::Duration, f64) -> Self
pub fn processkit::Supervisor<R>::capture(self, processkit::OutputBufferPolicy) -> Self
pub fn processkit::Supervisor<R>::failure_decay(self, core::time::Duration) -> Self
pub fn processkit::Supervisor<R>::failure_threshold(self, f64) -> Self
pub fn processkit::Supervisor<R>::jitter(self, bool) -> Self
pub fn processkit::Supervisor<R>::max_backoff(self, core::time::Duration) -> Self
pub fn processkit::Supervisor<R>::max_restarts(self, u32) -> Self
pub fn processkit::Supervisor<R>::restart(self, processkit::RestartPolicy) -> Self
pub async fn processkit::Supervisor<R>::run(self) -> processkit::Result<processkit::SupervisionOutcome>
pub fn processkit::Supervisor<R>::stop_when(self, impl core::ops::function::Fn(&processkit::ProcessResult<alloc::string::String>) -> bool + core::marker::Send + core::marker::Sync + 'static) -> Self
pub fn processkit::Supervisor<R>::storm_pause(self, core::time::Duration) -> Self
pub fn processkit::Supervisor<R>::with_runner<R2: processkit::ProcessRunner>(self, R2) -> processkit::Supervisor<R2>
impl<R: processkit::ProcessRunner> core::fmt::Debug for processkit::Supervisor<R>
pub fn processkit::Supervisor<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R> core::marker::Freeze for processkit::Supervisor<R> where R: core::marker::Freeze
impl<R> core::marker::Send for processkit::Supervisor<R>
impl<R> core::marker::Sync for processkit::Supervisor<R>
impl<R> core::marker::Unpin for processkit::Supervisor<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for processkit::Supervisor<R> where R: core::marker::UnsafeUnpin
impl<R> !core::panic::unwind_safe::RefUnwindSafe for processkit::Supervisor<R>
impl<R> !core::panic::unwind_safe::UnwindSafe for processkit::Supervisor<R>
pub trait processkit::IntoCommand<R: processkit::ProcessRunner>: processkit::client::sealed::Sealed
impl<R: processkit::ProcessRunner, S: core::convert::AsRef<std::ffi::os_str::OsStr>, const N: usize> processkit::IntoCommand<R> for [S; N]
impl<R: processkit::ProcessRunner, S: core::convert::AsRef<std::ffi::os_str::OsStr>> processkit::IntoCommand<R> for &[S]
impl<R: processkit::ProcessRunner, S: core::convert::AsRef<std::ffi::os_str::OsStr>> processkit::IntoCommand<R> for alloc::vec::Vec<S>
impl<R: processkit::ProcessRunner> processkit::IntoCommand<R> for processkit::Command
pub trait processkit::ProcessRunner: core::marker::Send + core::marker::Sync
pub fn processkit::ProcessRunner::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunner::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunner::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl processkit::ProcessRunner for processkit::JobRunner
pub fn processkit::JobRunner::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::JobRunner::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::JobRunner::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl processkit::ProcessRunner for processkit::ProcessGroup
pub fn processkit::ProcessGroup::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessGroup::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessGroup::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl processkit::ProcessRunner for processkit::testing::MockRunner
pub fn processkit::testing::MockRunner::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::MockRunner::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::MockRunner::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl processkit::ProcessRunner for processkit::testing::ScriptedRunner
pub fn processkit::testing::ScriptedRunner::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::ScriptedRunner::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::ScriptedRunner::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl<R: processkit::ProcessRunner + ?core::marker::Sized> processkit::ProcessRunner for &R
pub fn &R::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn &R::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn &R::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl<R: processkit::ProcessRunner> processkit::ProcessRunner for processkit::testing::RecordReplayRunner<R>
pub fn processkit::testing::RecordReplayRunner<R>::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::RecordReplayRunner<R>::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::RecordReplayRunner<R>::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl<R: processkit::ProcessRunner> processkit::ProcessRunner for processkit::testing::RecordingRunner<R>
pub fn processkit::testing::RecordingRunner<R>::output<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::RecordingRunner<R>::output_bytes<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::testing::RecordingRunner<R>::start<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::RunningProcess>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub trait processkit::ProcessRunnerExt: processkit::ProcessRunner
pub fn processkit::ProcessRunnerExt::checked<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunnerExt::exit_code<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<i32>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunnerExt::first_line<'life0, 'life1, 'async_trait, F>(&'life0 self, &'life1 processkit::Command, F) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<core::option::Option<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where F: core::ops::function::Fn(&str) -> bool + core::marker::Send + 'async_trait, Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunnerExt::parse<'life0, 'life1, 'async_trait, T, F>(&'life0 self, &'life1 processkit::Command, F) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<T>> + core::marker::Send + 'async_trait)>> where T: core::marker::Send + 'async_trait, F: core::ops::function::FnOnce(&str) -> T + core::marker::Send + 'async_trait, Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunnerExt::probe<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<bool>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunnerExt::run<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<alloc::string::String>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunnerExt::run_unit<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<()>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn processkit::ProcessRunnerExt::try_parse<'life0, 'life1, 'async_trait, T, F>(&'life0 self, &'life1 processkit::Command, F) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<T>> + core::marker::Send + 'async_trait)>> where T: core::marker::Send + 'async_trait, F: core::ops::function::FnOnce(&str) -> processkit::Result<T> + core::marker::Send + 'async_trait, Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
impl<T: processkit::ProcessRunner + ?core::marker::Sized> processkit::ProcessRunnerExt for T
pub fn T::checked<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<processkit::ProcessResult<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn T::exit_code<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<i32>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn T::first_line<'life0, 'life1, 'async_trait, F>(&'life0 self, &'life1 processkit::Command, F) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<core::option::Option<alloc::string::String>>> + core::marker::Send + 'async_trait)>> where F: core::ops::function::Fn(&str) -> bool + core::marker::Send + 'async_trait, Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn T::parse<'life0, 'life1, 'async_trait, T, F>(&'life0 self, &'life1 processkit::Command, F) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<T>> + core::marker::Send + 'async_trait)>> where T: core::marker::Send + 'async_trait, F: core::ops::function::FnOnce(&str) -> T + core::marker::Send + 'async_trait, Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn T::probe<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<bool>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn T::run<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<alloc::string::String>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn T::run_unit<'life0, 'life1, 'async_trait>(&'life0 self, &'life1 processkit::Command) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<()>> + core::marker::Send + 'async_trait)>> where Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub fn T::try_parse<'life0, 'life1, 'async_trait, T, F>(&'life0 self, &'life1 processkit::Command, F) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = processkit::Result<T>> + core::marker::Send + 'async_trait)>> where T: core::marker::Send + 'async_trait, F: core::ops::function::FnOnce(&str) -> processkit::Result<T> + core::marker::Send + 'async_trait, Self: core::marker::Sync + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait
pub async fn processkit::output<I, S>(impl core::convert::AsRef<std::ffi::os_str::OsStr>, I) -> processkit::Result<processkit::ProcessResult<alloc::string::String>> where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<std::ffi::os_str::OsStr>
pub async fn processkit::output_all<R, I>(I, usize, &R) -> alloc::vec::Vec<processkit::Result<processkit::ProcessResult<alloc::string::String>>> where R: processkit::ProcessRunner + ?core::marker::Sized, I: core::iter::traits::collect::IntoIterator<Item = processkit::Command>
pub async fn processkit::output_all_bytes<R, I>(I, usize, &R) -> alloc::vec::Vec<processkit::Result<processkit::ProcessResult<alloc::vec::Vec<u8>>>> where R: processkit::ProcessRunner + ?core::marker::Sized, I: core::iter::traits::collect::IntoIterator<Item = processkit::Command>
pub async fn processkit::run<I, S>(impl core::convert::AsRef<std::ffi::os_str::OsStr>, I) -> processkit::Result<alloc::string::String> where I: core::iter::traits::collect::IntoIterator<Item = S>, S: core::convert::AsRef<std::ffi::os_str::OsStr>
pub async fn processkit::wait_all(&mut [&mut processkit::RunningProcess]) -> processkit::Result<alloc::vec::Vec<processkit::Outcome>>
pub async fn processkit::wait_any(&mut [&mut processkit::RunningProcess]) -> processkit::Result<(usize, processkit::Outcome)>
pub type processkit::Result<T> = core::result::Result<T, processkit::Error>