Struct StreamSink 

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

Generic PackSink over any StreamStore: buffers one obj payload at a time in memory, then files it via the store’s verify-before-write put_object (so the store’s own integrity discipline re-checks the commit). Use FileSink for file://-rooted sinks to get O(1) memory per record.

Implementations

impl<'a> StreamSink<'a>

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

Wraps store as a pack sink.

Trait Implementations

impl PackSink for StreamSink<'_>

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).