Struct FailClosedExtraction 

pub struct FailClosedExtraction;

Every ChunkedBlob and every Blob of at least extract_min_bytes needs extraction, and there is none yet: the job ends ExtractionUnavailable.

Trait Implementations

impl Clone for FailClosedExtraction

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for FailClosedExtraction

impl Debug for FailClosedExtraction

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

Formats the value using the given formatter.

impl Default for FailClosedExtraction

fn default() -> Self

Returns the “default value” for a type.

impl SliceExtension for FailClosedExtraction

fn needs_extraction(&self, object: &Object, cfg: &IndexedConfig) -> bool

Whether object must be extracted into the object store before its pack is Verified.

fn extraction_enabled(&self) -> bool

Whether this existing extension supplies the internal upload callbacks.

fn begin_object<'a>( &'a self, _key: BlobKey, _plan: &'a PartPlan, _root: Hash, _cvs: &'a [Hash], _operation: Hash, _budget: &'a SliceBudget, ) -> BoxFuture<'a, Result<Option<Vec<u8>>, StoreError>>

Start a root-pinned private object session after all source CVs verify.

fn put_object_part<'a>( &'a self, _key: BlobKey, _session: &'a [u8], _plan: &'a PartPlan, _index: u32, _cv: Hash, _bytes: Vec<u8>, _budget: &'a SliceBudget, ) -> BoxFuture<'a, Result<Option<Vec<u8>>, StoreError>>

Verify and commit one bounded private part, returning its opaque receipt.

fn complete_object<'a>( &'a self, _key: BlobKey, _session: &'a [u8], _plan: &'a PartPlan, _parts: Vec<PartRef>, _root: Hash, _budget: &'a SliceBudget, ) -> BoxFuture<'a, Result<Option<CommitOutcome>, StoreError>>

Publish only the exact root-pinned parts selected by these receipts.

fn abort_object<'a>( &'a self, _key: BlobKey, _session: &'a [u8], _plan: &'a PartPlan, _budget: &'a SliceBudget, ) -> BoxFuture<'a, Result<(), StoreError>>

Abort the private session; the default extension has no session.