[−][src]Trait wascc_actor::ObjectStore

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

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

    fn remove_object(&self, id: &str, container: &str) -> Result<()>;

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

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

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

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

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

Required methods

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

Creates a new container

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

Removes a container

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

Removes an object from a container

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

Lists objects in a container

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

Gets information for a single object

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

Starts an upload to the object store

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

Uploads one chunk of a blob (max size determined by blob store capability provider)

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

Requests a download of a blob, actor will begin receiving OP_RECEIVE_CHUNK messages

Loading content...

Implementors

impl ObjectStore for DefaultObjectStore[src]

Loading content...