Struct ProcessSource 

pub struct ProcessSource {
    pub identity: ProcessIdentity,
    pub args: Vec<String>,
    pub env: BTreeMap<String, String>,
    pub current_dir: Option<PathBuf>,
    pub props: Option<Value>,
}

Fields

identity: ProcessIdentity

args: Vec<String>

env: BTreeMap<String, String>

current_dir: Option<PathBuf>

props: Option<Value>

Trait Implementations

impl Clone for ProcessSource

fn clone(&self) -> ProcessSource

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ProcessSource

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for ProcessSource

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Lifecycle for ProcessSource

type Key = ProcessIdentity

type State = ProcessState

type Context = ()

type Output = Sender<StreamItem>

type Error = SpawnError

fn key(&self) -> ProcessIdentity

fn enter( self, _ctx: &mut (), output: &mut Self::Output, ) -> Result<Self::State, Self::Error>

fn reconcile_self( self, state: &mut Self::State, _ctx: &mut (), output: &mut Self::Output, ) -> Result<(), Self::Error>

fn exit( state: Self::State, _ctx: &mut (), _output: &mut Self::Output, ) -> Result<(), Self::Error>

fn display_name(&self) -> String

Human-readable label for logs and traces. Defaults to empty; override when you want lifecycle events to identify themselves by something other than key.

fn enhance_lifecycle_context(&self, _ctx: &mut LifecycleContext)

fn enhance_lifecycle_state_context( _state: &Self::State, _ctx: &mut LifecycleContext, )

fn lifecycle_context(&self) -> LifecycleContext

fn lifecycle_state_context(state: &Self::State) -> LifecycleContext

fn wrap_enter( self, ctx: &mut Self::Context, output: &mut Self::Output, ) -> Result<Self::State, Self::Error>

where Self: Sized,

fn wrap_reconcile( self, state: &mut Self::State, ctx: &mut Self::Context, output: &mut Self::Output, ) -> Result<(), Self::Error>

where Self: Sized,

fn wrap_exit( state: Self::State, ctx: &mut Self::Context, output: &mut Self::Output, ) -> Result<(), Self::Error>