Skip to main content

encode_job_to_destination

Function encode_job_to_destination 

Source
pub fn encode_job_to_destination<J: EncodeJob, S: Source, D: Destination, R: OperationPolicy>(
    job: J,
    source: S,
    writer: D,
    resolver: R,
    options: Options,
    pulse: Option<&dyn Pulse>,
) -> Result<Completed, At<Failure>>
where J::Enc: Encoder,
Expand description

Execute a retained job’s declared row route against actual destination access.

Sequence: admit preparation workspace, plan without native startup, admit the route policy, revalidate the retained source/destination, reserve driver rows, construct once, begin with current color, compare the complete plan, then read/publish. A refusal or startup failure never retries another route. Strict unknown workspace/wait evidence refuses; byte timing alone never establishes either bound.

This is an adapter primitive for an already configured job. It does not select registry configurations or certify descriptive metadata treatment.