Struct FileSink 

pub struct FileSink<'a> { /* private fields */ }

File-backed PackSink over a FileStore: obj payloads stream through a fixed-size buffer straight into a unique temp sibling of the final object path, then an atomic rename commits on hash match — O(1) memory per record regardless of object size.

This mirrors file_store.rs’s private temp_sibling/persist discipline (temp file in the SAME directory so the rename is an atomic, same-filesystem move; a partially-written object is never visible at its content-address; a failed record removes its temp file).

Implementations

impl<'a> FileSink<'a>

pub fn new(store: &'a FileStore) -> Self

Wraps store as a streaming, file-backed pack sink.

Trait Implementations

impl Drop for FileSink<'_>

fn drop(&mut self)

Last-resort cleanup: never leave a stray temp file in .objects/ even if the reader bails between stage and commit/abort.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl PackSink for FileSink<'_>

fn has_object(&mut self, checksum: &str) -> Result<bool, StoreError>

Returns true when the sink already holds checksum (the record’s bytes will then be verified-and-discarded rather than re-written).

fn stage_object( &mut self, checksum: &str, _len: u64, payload: &mut dyn Read, ) -> Result<(), StoreError>

Stages the payload for checksum by reading payload to EOF (the reader has already limited it to exactly len bytes). Must not make the object observable at its final address yet. On error the sink must clean up after itself or tolerate the follow-up abort_object call.

fn commit_object(&mut self, checksum: &str) -> Result<(), StoreError>

Commits the staged payload at its (reader-verified) content-address.

fn abort_object(&mut self, _checksum: &str)

Discards any staged payload for checksum, leaving no trace (best effort; must tolerate nothing being staged).

fn put_manifest( &mut self, id: &str, manifest: &Manifest, ) -> Result<(), StoreError>

Commits the manifest under id. Called only after the end trailer of a fully verified stream (manifest-last survives truncation).