Struct GcsBlob 

pub struct GcsBlob {
    metrics: S3BlobMetrics,
    knobs: Arc<dyn BlobKnobs>,
    storage_client: Storage,
    storage_control_client: StorageControl,
    bucket: String,
    prefix: String,
}

Implementation of Blob backed by GCS

Fields

metrics: S3BlobMetrics

knobs: Arc<dyn BlobKnobs>

storage_client: Storage

storage_control_client: StorageControl

bucket: String

prefix: String

Implementations

impl GcsBlob

pub async fn open(config: GcsBlobConfig) -> Result<Self, ExternalError>

Opens the given location for non-exclusive read-write access.

fn get_path(&self, key: &str) -> String

fn formatted_bucket_path(&self) -> String

Returns the bucket path formatted for gRPC API calls. The gRPC API requires bucket names in the format projects/_/buckets/{bucket}.

async fn with_timeout<T>( &self, op: &str, fut: impl Future<Output = Result<T, ExternalError>>, ) -> Result<T, ExternalError>

Fails op if it takes longer than the operation timeout, read anew on each call.

NOTE: The SDK has no per-attempt timeout for read_object and write_object (google-cloud-storage 1.20.0 leaves it as a TODO in perform_upload/unbuffered.rs), nor a way to set connect or read timeouts, so this is the only bound on a stalled data transfer.

fn error(&self, op: &str, e: Error) -> ExternalError

Converts an SDK error from the call op and counts it.

async fn get_inner( &self, key: &str, ) -> Result<Option<SegmentedBytes>, ExternalError>

async fn list_keys_and_metadata_inner( &self, key_prefix: &str, f: &mut (dyn FnMut(BlobMetadata<'_>) + Send + Sync), ) -> Result<(), ExternalError>

async fn set_inner(&self, key: &str, value: Bytes) -> Result<(), ExternalError>

async fn delete_inner(&self, key: &str) -> Result<Option<usize>, ExternalError>

async fn restore_inner(&self, key: &str) -> Result<(), ExternalError>

Trait Implementations

impl Blob for GcsBlob

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<SegmentedBytes>, ExternalError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Returns a reference to the value corresponding to the key.

fn list_keys_and_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key_prefix: &'life1 str, f: &'life2 mut (dyn FnMut(BlobMetadata<'_>) + Send + Sync), ) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

List all of the keys in the map with metadata about the entry.

fn set<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, value: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Inserts a key-value pair into the map.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<usize>, ExternalError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove a key from the map.

fn restore<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), ExternalError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Restores a previously-deleted key to the map, if possible.

impl Debug for GcsBlob

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

Formats the value using the given formatter.