Struct LeanWorkerImportPlanConfig 

pub struct LeanWorkerImportPlanConfig { /* private fields */ }

Capability and session requirements used to plan worker batches.

Implementations

impl LeanWorkerImportPlanConfig

pub fn new( project_root: impl Into<PathBuf>, package: impl Into<String>, lib_name: impl Into<String>, ) -> Self

Create planner configuration for a Lake capability target.

pub fn source_roots( self, roots: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Restrict discovery to these source roots.

pub fn base_imports( self, imports: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Add imports required by every planned session batch.

pub fn validate_metadata( self, export: impl Into<String>, request: Value, ) -> Self

Validate metadata before a worker batch is used.

pub fn expect_metadata( self, export: impl Into<String>, request: Value, expected: LeanWorkerCapabilityMetadata, ) -> Self

Require exact generic capability metadata before a worker batch is used.

pub fn restart_policy(self, policy: LeanWorkerRestartPolicy) -> Self

Use a worker restart policy for builders derived from planned batches.

Trait Implementations

impl Clone for LeanWorkerImportPlanConfig

fn clone(&self) -> LeanWorkerImportPlanConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LeanWorkerImportPlanConfig

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

Formats the value using the given formatter.

impl PartialEq for LeanWorkerImportPlanConfig

fn eq(&self, other: &LeanWorkerImportPlanConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for LeanWorkerImportPlanConfig

impl StructuralPartialEq for LeanWorkerImportPlanConfig