Struct ContentUploadRunner 

pub struct ContentUploadRunner { /* private fields */ }

Runtime-neutral driver for resumable immutable-snapshot uploads.

The runner does not spawn tasks, sleep, choose retry delays, allocate operation identities, or own product transport. One invocation advances a durable record until it completes, reaches an unknown remote outcome, is fenced, or returns the first backend/store/contract failure.

Implementations

impl ContentUploadRunner

pub fn new(chunk_size: usize) -> Result<Self>

Creates a runner with a non-zero in-memory chunk size.

Errors

Returns an error when validation fails or an underlying backend, store, or platform operation fails.

pub const fn chunk_size(&self) -> usize

Returns the maximum immutable byte count submitted in one backend chunk.

pub async fn submit( &self, intent: ContentUploadIntent, execution_generation: SessionGeneration, store: &dyn ContentUploadStore, backend: &dyn CloudContentUploadBackend, source: &dyn LocalContentSnapshotReader, ) -> ContentUploadRunResult<ContentUploadRunOutcome>

Persists a caller-owned upload intent, then advances its durable record.

Errors

Returns an error when validation fails or an underlying backend, store, or platform operation fails.

pub async fn resume( &self, operation_id: &OperationId, execution_generation: SessionGeneration, store: &dyn ContentUploadStore, backend: &dyn CloudContentUploadBackend, source: &dyn LocalContentSnapshotReader, ) -> ContentUploadRunResult<ContentUploadRunOutcome>

Advances one already-persisted upload using the active executor generation.

Errors

Returns an error when validation fails or an underlying backend, store, or platform operation fails.

Trait Implementations

impl Clone for ContentUploadRunner

fn clone(&self) -> ContentUploadRunner

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ContentUploadRunner

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

Formats the value using the given formatter.

impl Copy for ContentUploadRunner