Struct GcsDocumentStorage 

pub struct GcsDocumentStorage { /* private fields */ }

DocumentStorage over one Google Cloud Storage bucket.

Implementations

impl GcsDocumentStorage

pub async fn connect(config: GcsConfig) -> Result<Self, StorageError>

Builds the client and obtains a first access token, so rejected credentials fail here rather than on the first document.

Errors

Returns StorageError::Configuration for an unusable configuration or credentials file, and StorageError::Unauthorized when the token endpoint rejects the credentials.

Trait Implementations

impl DocumentStorage for GcsDocumentStorage

fn put<'a>( &'a self, key: &'a DocumentKey, document: Document, ) -> StorageFuture<'a, DocumentMetadata>

Stores document under key, replacing whatever was there.

fn head<'a>( &'a self, key: &'a DocumentKey, ) -> StorageFuture<'a, DocumentMetadata>

Reads a document’s metadata without its body. Fails with StorageError::NotFound when nothing is stored under key.

fn get<'a>(&'a self, key: &'a DocumentKey) -> StorageFuture<'a, StoredDocument>

Reads a document, streaming its body. Fails with StorageError::NotFound when nothing is stored under key.

fn delete<'a>(&'a self, key: &'a DocumentKey) -> StorageFuture<'a, ()>

Deletes the document under key. Deleting a missing document succeeds.

fn list(&self, request: ListRequest) -> StorageFuture<'_, ListPage>

Lists documents whose keys start with the request’s prefix, one page at a time; pass the returned token back to fetch the next page.