Struct iroh_bytes::store::flat::Store

pub struct Store(/* private fields */);

Flat file database implementation.

This

Implementations

impl Store

pub fn load_blocking( complete_path: impl AsRef<Path>, partial_path: impl AsRef<Path>, meta_path: impl AsRef<Path>, rt: &Handle ) -> Result<Self>

Blocking load a database from disk.

pub async fn load( complete_path: impl AsRef<Path>, partial_path: impl AsRef<Path>, meta_path: impl AsRef<Path>, rt: &Handle ) -> Result<Self>

Load a database from disk.

Trait Implementations

impl Clone for Store

fn clone(&self) -> Store

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Store

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

Formats the value using the given formatter.

impl Map for Store

type Entry = Entry

The entry type. An entry is a cheaply cloneable handle that can be used to open readers for both the data and the outboard

type Outboard = PreOrderOutboard<MemOrFile>

The outboard type. This can be an in memory outboard or an outboard that retrieves the data asynchronously from a remote database.

type DataReader = MemOrFile

The reader type.

fn get(&self, hash: &Hash) -> Option<Self::Entry>

Get an entry for a hash.

fn contains(&self, hash: &Hash) -> EntryStatus

Find out if the data behind a hash is complete, partial, or not present.

impl MapEntry<Store> for Entry

fn hash(&self) -> Hash

The hash of the entry.

fn size(&self) -> u64

The size of the entry.

fn available_ranges(&self) -> BoxFuture<'_, Result<ChunkRanges>>

Compute the available ranges.

fn outboard(&self) -> BoxFuture<'_, Result<PreOrderOutboard<MemOrFile>>>

A future that resolves to a reader that can be used to read the outboard

fn data_reader(&self) -> BoxFuture<'_, Result<MemOrFile>>

A future that resolves to a reader that can be used to read the data

fn is_complete(&self) -> bool

Returns true if the entry is complete.

impl MapEntry<Store> for PartialEntry

fn hash(&self) -> Hash

The hash of the entry.

fn size(&self) -> u64

The size of the entry.

fn available_ranges(&self) -> BoxFuture<'_, Result<ChunkRanges>>

Compute the available ranges.

fn outboard(&self) -> BoxFuture<'_, Result<<Store as Map>::Outboard>>

A future that resolves to a reader that can be used to read the outboard

fn data_reader(&self) -> BoxFuture<'_, Result<<Store as Map>::DataReader>>

A future that resolves to a reader that can be used to read the data

fn is_complete(&self) -> bool

Returns true if the entry is complete.

impl PartialMap for Store

type OutboardMut = PreOrderOutboard<File>

The outboard type to write data to the partial entry.

type DataWriter = File

The writer type to write data to the partial entry.

type PartialEntry = PartialEntry

A partial entry. This is an entry that is writeable and possibly incomplete.

fn get_partial(&self, hash: &Hash) -> Option<Self::PartialEntry>

Get an existing partial entry.

fn get_or_create_partial( &self, hash: Hash, size: u64 ) -> Result<Self::PartialEntry>

Get an existing partial entry, or create a new one.

fn insert_complete( &self, entry: Self::PartialEntry ) -> BoxFuture<'_, Result<()>>

Upgrade a partial entry to a complete entry.

impl PartialMapEntry<Store> for PartialEntry

fn outboard_mut( &self ) -> BoxFuture<'_, Result<<Store as PartialMap>::OutboardMut>>

A future that resolves to an writeable outboard

fn data_writer( &self ) -> BoxFuture<'_, Result<<Store as PartialMap>::DataWriter>>

A future that resolves to a writer that can be used to write the data

impl ReadableStore for Store

fn blobs(&self) -> Box<dyn Iterator<Item = Hash> + Send + Sync + 'static>

list all blobs in the database. This should include collections, since collections are blobs and can be requested as blobs.

fn temp_tags( &self ) -> Box<dyn Iterator<Item = HashAndFormat> + Send + Sync + 'static>

Temp tags

fn tags( &self ) -> Box<dyn Iterator<Item = (Tag, HashAndFormat)> + Send + Sync + 'static>

list all tags (collections or other explicitly added things) in the database

fn validate(&self, _tx: Sender<ValidateProgress>) -> BoxFuture<'_, Result<()>>

Validate the database

fn partial_blobs( &self ) -> Box<dyn Iterator<Item = Hash> + Send + Sync + 'static>

list partial blobs in the database

fn export( &self, hash: Hash, target: PathBuf, mode: ExportMode, progress: impl Fn(u64) -> Result<()> + Send + Sync + 'static ) -> BoxFuture<'_, Result<()>>

This trait method extracts a file to a local path.

impl Store for Store

fn import_file( &self, path: PathBuf, mode: ImportMode, format: BlobFormat, progress: impl ProgressSender<Msg = ImportProgress> + IdGenerator ) -> BoxFuture<'_, Result<(TempTag, u64)>>

This trait method imports a file from a local path.

fn import_bytes( &self, data: Bytes, format: BlobFormat ) -> BoxFuture<'_, Result<TempTag>>

Import data from memory.

fn import_stream( &self, data: impl Stream<Item = Result<Bytes>> + Unpin + Send + 'static, format: BlobFormat, progress: impl ProgressSender<Msg = ImportProgress> + IdGenerator ) -> BoxFuture<'_, Result<(TempTag, u64)>>

Import data from a stream of bytes.

fn create_tag(&self, value: HashAndFormat) -> BoxFuture<'_, Result<Tag>>

Create a new tag

fn set_tag( &self, name: Tag, value: Option<HashAndFormat> ) -> BoxFuture<'_, Result<()>>

Set a tag

fn temp_tag(&self, tag: HashAndFormat) -> TempTag

Create a temporary pin for this store

fn clear_live(&self)

Clear the live set.

fn add_live(&self, elements: impl IntoIterator<Item = Hash>)

Add the given hashes to the live set.

fn is_live(&self, hash: &Hash) -> bool

True if the given hash is live.

fn delete(&self, hash: &Hash) -> BoxFuture<'_, Result<()>>

physically delete the given hash from the store.

fn import_reader( &self, data: impl AsyncRead + Send + Unpin + 'static, format: BlobFormat, progress: impl ProgressSender<Msg = ImportProgress> + IdGenerator ) -> BoxFuture<'_, Result<(TempTag, u64)>>

Import data from an async byte reader.

fn gc_mark<'a>( &'a self, extra_roots: impl IntoIterator<Item = Result<HashAndFormat>> + 'a ) -> LocalBoxStream<'a, GcMarkEvent>

Traverse all roots recursively and mark them as live.

fn gc_sweep(&self) -> LocalBoxStream<'_, GcSweepEvent>

Remove all blobs that are not marked as live.