Struct CarStore 

pub struct CarStore<S: AsyncRead + AsyncSeek> { /* private fields */ }

An indexed reader/writer for CAR files.

Implementations

impl<R: AsyncRead + AsyncSeek + Unpin> CarStore<R>

pub async fn open(storage: R) -> Result<Self, Error>

Open a pre-existing CAR file.

pub fn roots(&self) -> impl Iterator<Item = Cid>

impl<S: AsyncRead + AsyncWrite + AsyncSeek + Send + Unpin> CarStore<S>

pub async fn create(storage: S) -> Result<Self, Error>

pub async fn create_with_roots( storage: S, roots: impl IntoIterator<Item = Cid>, ) -> Result<Self, Error>

Trait Implementations

impl<R: AsyncRead + AsyncSeek + Send + Unpin> AsyncBlockStoreRead for CarStore<R>

async fn read_block_into( &mut self, cid: Cid, contents: &mut Vec<u8>, ) -> Result<(), Error>

Read a single block from the block store into the provided buffer.

fn read_block( &mut self, cid: Cid, ) -> impl Future<Output = Result<Vec<u8>, Error>> + Send

Read a single block from the block store.

impl<R: AsyncRead + AsyncWrite + AsyncSeek + Send + Unpin> AsyncBlockStoreWrite for CarStore<R>

async fn write_block( &mut self, codec: u64, hash: u64, contents: &[u8], ) -> Result<Cid, Error>

Write a single block into the block store. This will return the block’s computed hash.

impl<S: Debug + AsyncRead + AsyncSeek> Debug for CarStore<S>

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

Formats the value using the given formatter.