Struct StorePromotionExecutor 

pub struct StorePromotionExecutor<S, D> { /* private fields */ }

Canonical zero-copy-capable executor between two configured object stores.

The executor binds opaque plan locations to exact store handles. It reads through the source’s authenticated object contract and moves the returned Bytes directly into idempotent destination admission. It never discovers objects, chooses infrastructure, or retains a second body.

Implementations

impl<S, D> StorePromotionExecutor<S, D>

pub fn new( source_location_id: StorageLocationId, source: S, destination_location_id: StorageLocationId, destination: D, ) -> Result<Self, StorePromotionExecutorError>

Binds two distinct opaque locations to their exact store handles.

Errors

Rejects a self-copy configuration before either store can be accessed.

pub const fn source(&self) -> &S

Returns the exact configured source handle.

pub const fn destination(&self) -> &D

Returns the exact configured destination handle.

Trait Implementations

impl<S: AsyncObjectStore, D: AsyncObjectStore> PromotionExecutor for StorePromotionExecutor<S, D>

async fn promote( &self, plan: &PromotionPlan, budget: WorkBudget, cancellation: &CancellationToken, ) -> ObjectResult<()>

Copies, authenticates, and durably admits the exact object at the plan’s destination, retaining the operation identity for idempotent retry.