Struct ChildProcessPool 

pub struct ChildProcessPool {
    pub assets_for_source_mapping: ResolvedVc<AssetsForSourceMapping>,
    pub assets_root: FileSystemPath,
    pub project_dir: FileSystemPath,
    /* private fields */
}

A pool of Node.js workers operating on [entrypoint] with specific [cwd] and env.

The pool will spawn processes when needed and reuses old ones. It will never spawn more then a certain number of concurrent processes. This is specified with the concurrency argument in the constructor.

The worker will not use the env of the parent process by default. All env vars need to be provided to make the execution as pure as possible.

Fields

assets_for_source_mapping: ResolvedVc<AssetsForSourceMapping>

assets_root: FileSystemPath

project_dir: FileSystemPath

Implementations

impl ChildProcessPool

pub fn cell(self) -> Vc<Self>

Places a value in a cell of the current task.

Cell is selected based on the value type and call order of cell.

pub fn resolved_cell(self) -> ResolvedVc<Self>

Places a value in a cell of the current task. Returns a ResolvedVc.

Cell is selected based on the value type and call order of cell.

impl ChildProcessPool

pub fn create( cwd: PathBuf, entrypoint: PathBuf, env: FxHashMap<RcStr, RcStr>, assets_for_source_mapping: ResolvedVc<AssetsForSourceMapping>, assets_root: FileSystemPath, project_dir: FileSystemPath, concurrency: usize, debug: bool, ) -> EvaluatePool

• debug: Whether to automatically enable Node’s --inspect-brk when spawning it. Note: automatically overrides concurrency to 1.

impl ChildProcessPool

pub fn scale_down()

pub fn scale_zero()

Trait Implementations

impl EvaluateOperation for ChildProcessPool

fn stats(&self) -> PoolStatsSnapshot

Returns a snapshot of the pool’s internal statistics.

fn pre_warm(&self)

Eagerly spawn a Node.js process so it’s ready when the first operation() is called. The process goes into the idle queue. If a node request comes in while this is still initializing, it waits on the bootup semaphore and will resume when the process is ready.

fn operation<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Operation>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl ShrinkToFit for ChildProcessPool

fn shrink_to_fit(&mut self)

impl TraceRawVcs for ChildProcessPool

fn trace_raw_vcs(&self, __context__: &mut TraceRawVcsContext)

fn get_raw_vcs(&self) -> Vec<RawVc>

impl ValueDebug for ChildProcessPool

fn dbg(self: Vc<Self>) -> Vc<ValueDebugString>

fn dbg_depth(self: Vc<Self>, depth: usize) -> Vc<ValueDebugString>

Like dbg, but with a depth limit.

impl ValueDebugFormat for ChildProcessPool

fn value_debug_format<'a>(&'a self, depth: usize) -> ValueDebugFormatString<'a>

impl VcValueType for ChildProcessPool

type Read = VcDefaultRead<ChildProcessPool>

How to read the value.

type CellMode = VcCellNewMode<ChildProcessPool>

How to update cells of this value type.

fn get_value_type_id() -> ValueTypeId

Returns the type id of the value type.

fn has_serialization() -> bool

impl NonLocalValue for ChildProcessPool

impl Upcast<Box<dyn ValueDebug>> for ChildProcessPool

impl UpcastStrict<Box<dyn ValueDebug>> for ChildProcessPool