pub struct ExecutionPlan { /* private fields */ }Implementations§
Source§impl ExecutionPlan
impl ExecutionPlan
pub fn build<P: RuntimePolicy>( request: PlanBuildRequest<'_, P>, ) -> Result<Self, VNextError>
pub fn payload(&self) -> &ExecutionPlanPayload
pub fn completion_checkpoint( &self, value_id: &ProgramValueId, ) -> Result<&RetainedCompletionValue, VNextError>
Sourcepub fn completion_checkpoint_readback_for_work(
&self,
value_id: &ProgramValueId,
participant_index: u32,
work: &ResourceWorkShape,
) -> Result<CompletionReadbackRequest, VNextError>
pub fn completion_checkpoint_readback_for_work( &self, value_id: &ProgramValueId, participant_index: u32, work: &ResourceWorkShape, ) -> Result<CompletionReadbackRequest, VNextError>
Builds an exact readback for one participant’s immediate work shape. The immutable resource demand, rather than a model-shape heuristic, determines the dynamic byte extent.
pub fn plan_hash(&self) -> &PlanHash
Source§impl ExecutionPlan
impl ExecutionPlan
pub fn to_json(&self) -> Result<Vec<u8>, VNextError>
pub fn decode_untrusted( bytes: &[u8], ) -> Result<UnvalidatedExecutionPlan, VNextError>
pub fn from_json_validated<P: RuntimePolicy>( bytes: &[u8], family: &PreparedModelFamily, capabilities: &CapabilityCatalog, policy: &P, node_resolutions: Vec<PlanNodeResolution>, ) -> Result<Self, VNextError>
pub fn from_json_validated_with_completion_retention<P: RuntimePolicy>( bytes: &[u8], family: &PreparedModelFamily, capabilities: &CapabilityCatalog, policy: &P, node_resolutions: Vec<PlanNodeResolution>, completion_retention: CompletionRetentionSpec, ) -> Result<Self, VNextError>
pub fn from_json_validated_with_execution_weights<P: RuntimePolicy>( bytes: &[u8], family: &PreparedModelFamily, capabilities: &CapabilityCatalog, policy: &P, node_resolutions: Vec<PlanNodeResolution>, completion_retention: CompletionRetentionSpec, execution_weights: TrustedExecutionWeightPlan, ) -> Result<Self, VNextError>
pub fn validate_against<P: RuntimePolicy>( &self, family: &PreparedModelFamily, capabilities: &CapabilityCatalog, policy: &P, node_resolutions: &[PlanNodeResolution], ) -> Result<(), VNextError>
pub fn validate_against_with_completion_retention<P: RuntimePolicy>( &self, family: &PreparedModelFamily, capabilities: &CapabilityCatalog, policy: &P, node_resolutions: &[PlanNodeResolution], completion_retention: CompletionRetentionSpec, ) -> Result<(), VNextError>
Source§impl ExecutionPlan
impl ExecutionPlan
pub fn sequence_checkpoint_capability(&self) -> SequenceCheckpointCapability<'_>
Sourcepub fn checkpoint_byte_plan(
&self,
boundary: u64,
) -> Result<SequenceCheckpointBytePlan, VNextError>
pub fn checkpoint_byte_plan( &self, boundary: u64, ) -> Result<SequenceCheckpointBytePlan, VNextError>
Pure, checked allocation/copy-range planning. N is not a proof that a source has actually completed that boundary; transfer requires its own completed-frame authority and checks the source’s actual backing.
Source§impl ExecutionPlan
impl ExecutionPlan
Sourcepub fn determinism_witness_plan(
&self,
) -> Result<ExecutionDeterminismWitnessPlan, VNextError>
pub fn determinism_witness_plan( &self, ) -> Result<ExecutionDeterminismWitnessPlan, VNextError>
Derives the complete same-runtime proof denominator from the trusted plan. Hardware runners consume this contract rather than maintaining a second provider/output/state inventory.
Sourcepub fn determinism_witness_plan_for_nodes(
&self,
node_ids: &[NodeId],
) -> Result<ExecutionDeterminismWitnessPlan, VNextError>
pub fn determinism_witness_plan_for_nodes( &self, node_ids: &[NodeId], ) -> Result<ExecutionDeterminismWitnessPlan, VNextError>
Derives the proof denominator for one canonical plan-ordered node subset. Inputs produced outside this subset become explicit restore inputs, which permits a hardware runner to probe real resolved-plan nodes without constructing a second synthetic plan.
Source§impl ExecutionPlan
impl ExecutionPlan
Sourcepub fn provision_static<R>(
&self,
runtime: Arc<R>,
request_id: RequestIdentity,
) -> Result<ProvisionedPlanResources<R>, VNextError>where
R: DeviceRuntime,
pub fn provision_static<R>(
&self,
runtime: Arc<R>,
request_id: RequestIdentity,
) -> Result<ProvisionedPlanResources<R>, VNextError>where
R: DeviceRuntime,
Provisions only plan-lifetime buffers. Dynamic sequence admission is a separate logical authority and is never implied by this result.
Trait Implementations§
Source§impl Clone for ExecutionPlan
impl Clone for ExecutionPlan
Source§fn clone(&self) -> ExecutionPlan
fn clone(&self) -> ExecutionPlan
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more