Struct BlobfsRamdisk

pub struct BlobfsRamdisk { /* private fields */ }

A ramdisk-backed blobfs instance

Implementations

impl BlobfsRamdisk

pub fn builder() -> BlobfsRamdiskBuilder

Creates a new BlobfsRamdiskBuilder with no pre-configured ramdisk.

pub async fn start() -> Result<Self, Error>

Starts a blobfs server backed by a freshly formatted ramdisk.

pub fn client(&self) -> Client

Returns a new connection to blobfs using the blobfs::Client wrapper type.

Panics

Panics on error

pub fn root_dir_handle(&self) -> Result<ClientEnd<DirectoryMarker>, Error>

Returns a new connection to blobfs’s root directory as a raw zircon channel.

pub fn root_dir_proxy(&self) -> Result<DirectoryProxy, Error>

Returns a new connection to blobfs’s root directory as a DirectoryProxy.

pub fn root_dir(&self) -> Result<Dir, Error>

Returns a new connection to blobfs’s root directory as a openat::Dir.

pub async fn into_builder(self) -> Result<BlobfsRamdiskBuilder, Error>

Signals blobfs to unmount and waits for it to exit cleanly, returning a new BlobfsRamdiskBuilder initialized with the ramdisk.

pub async fn unmount(self) -> Result<FormattedRamdisk, Error>

Signals blobfs to unmount and waits for it to exit cleanly, returning the backing Ramdisk.

pub async fn stop(self) -> Result<(), Error>

Signals blobfs to unmount and waits for it to exit cleanly, stopping the inner ramdisk.

pub fn list_blobs(&self) -> Result<BTreeSet<Hash>, Error>

Returns a sorted list of all blobs present in this blobfs instance.

pub async fn add_blob_from( &self, merkle: Hash, source: impl Read, ) -> Result<(), Error>

Writes the blob to blobfs.

pub async fn write_blob(&self, merkle: Hash, bytes: &[u8]) -> Result<(), Error>

Writes a blob with hash merkle and blob contents bytes to blobfs. bytes should be uncompressed. Ignores AlreadyExists errors.

pub fn svc_dir(&self) -> Result<Option<DirectoryProxy>, Error>

Returns a connection to blobfs’s exposed “svc” directory, or None if the implementation does not expose any services. More convenient than using blob_creator_proxy directly when forwarding the service to RealmBuilder components.

pub fn blob_creator_proxy(&self) -> Result<Option<BlobCreatorProxy>, Error>

Returns a new connection to blobfs’s fuchsia.fxfs/BlobCreator API, or None if the implementation does not support it.

pub fn blob_reader_proxy(&self) -> Result<Option<BlobReaderProxy>, Error>

Returns a new connection to blobfs’s fuchsia.fxfs/BlobReader API, or None if the implementation does not support it.