Struct LocalExportSink 

pub struct LocalExportSink { /* private fields */ }

Writes under root/<cell_id>/ using sanitized artifact name as filename.

Implementations

impl LocalExportSink

pub fn new( root: impl Into<PathBuf>, cell_id: impl Into<String>, ) -> Result<Self, CellosError>

pub async fn push_with_len( &self, name: &str, src: &Path, ) -> Result<u64, CellosError>

Bytes written (for observability).

Trait Implementations

impl ExportSink for LocalExportSink

fn target_kind(&self) -> Option<ExportReceiptTargetKind>

Best-effort hint for the target kind this sink writes to. Used for target-aware failure events when a push fails before a full receipt exists.

fn destination_hint(&self, name: &str) -> Option<String>

Best-effort destination hint for observability. Successful pushes should return the concrete destination in ExportReceipt.

fn push<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, name: &'life1 str, path: &'life2 str, _metadata: &'life3 ExportArtifactMetadata, ) -> Pin<Box<dyn Future<Output = Result<ExportReceipt, CellosError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Push an artifact and return the resulting receipt for observability.