Struct wascc_actor::objectstore::ObjectStoreHostBinding

pub struct ObjectStoreHostBinding { /* fields omitted */ }

An abstraction around a host runtime capability for a key-value store

Implementations

impl ObjectStoreHostBinding

pub fn create_container(&self, name: &str) -> Result<Container>

Creates a new container within the store

pub fn remove_container(&self, name: &str) -> Result<()>

Removes a container from the store. Whether or not this will fail if the container has items may be specific to a given provider implementation.

pub fn remove_object(&self, name: &str, container: &str) -> Result<()>

Removes an object from a container

pub fn list_objects(&self, container: &str) -> Result<BlobList>

Lists all objects within a container

pub fn get_blob_info(&self, container: &str, id: &str) -> Result<Option<Blob>>

Obtains binary object metadata, does not include the object bytes

pub fn start_upload(
    &self,
    blob: &Blob,
    chunk_size: u64,
    total_bytes: u64
) -> Result<Transfer>

Indicates that an upload is about to begin for an item. You should follow this call up with a for loop/iteration that sends successive chunks to the store. The chunk size specified in this call is a request or suggestion. It is up to the provider to determine the actual chunk size, which is returned in the resulting Transfer instance

pub fn upload_chunk(
    &self,
    transfer: &Transfer,
    offset: u64,
    bytes: &[u8]
) -> Result<()>

Uploads an individual chunk of a file to the blob store. This call must only ever come after signaling the start of a new upload with the start_upload function.

pub fn start_download(&self, blob: &Blob, chunk_size: u64) -> Result<Transfer>

Sends a request to the provider to begin a chunked download of a file. If this succeeds, your actor will begin receiving OP_RECEIVE_CHUNK messages from the provider.

Trait Implementations

impl Default for ObjectStoreHostBinding

fn default() -> Self

Returns the "default value" for a type.