Struct Gcs 

pub struct Gcs<T: TokenProvider> { /* private fields */ }

A bucket as an ObjectStore.

Implementations

impl<T: TokenProvider> Gcs<T>

pub fn new(bucket: &str, tokens: T, cfg: GcsConfig) -> Result<Self>

A store for bucket, authenticated by tokens.

pub fn with_max_inflated(self, limit: u64) -> Self

Refuse to decode an encoded object past limit bytes (Error::TooLarge); the default is MAX_INFLATED_BYTES. The stored bytes stay bounded by GcsConfig::max_object_bytes.

pub fn tokens(&self) -> &T

The token provider.

Trait Implementations

impl<T: Debug + TokenProvider> Debug for Gcs<T>

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

Formats the value using the given formatter.

impl<T: TokenProvider> ObjectStore for Gcs<T>

type Get<'a> = impl Future<Output = Result<Option<Object>, Error>> + 'a where Self: 'a

Future of get.

type GetRange<'a> = impl Future<Output = Result<Bytes, Error>> + 'a where Self: 'a

Future of get_range.

type Head<'a> = impl Future<Output = Result<Option<Meta>, Error>> + 'a where Self: 'a

Future of head.

type Put<'a> = impl Future<Output = Result<u64, Error>> + 'a where Self: 'a

Future of put.

type List<'a> = impl Future<Output = Result<Vec<Meta>, Error>> + 'a where Self: 'a

Future of list.

type Delete<'a> = impl Future<Output = Result<(), Error>> + 'a where Self: 'a

Future of delete.

fn get<'a>(&'a self, key: &'a str) -> Self::Get<'a>

The whole object, or None if it does not exist.

fn get_range<'a>( &'a self, key: &'a str, range: Range<u64>, ) -> Self::GetRange<'a>

Bytes range of the object. A range running past the end is clipped; a range starting at or past the end is an empty body. A missing object is Error::NotFound.

fn head<'a>(&'a self, key: &'a str) -> Self::Head<'a>

Size and generation, without the body.

fn put<'a>(&'a self, key: &'a str, body: Bytes, cond: Cond) -> Self::Put<'a>

Write body under key if cond holds; returns the new generation.

fn list<'a>(&'a self, prefix: &'a str) -> Self::List<'a>

Every object whose key starts with prefix, sorted by key. An empty prefix lists everything; a non-empty prefix is validated like a key (a trailing / is allowed).

fn delete<'a>(&'a self, key: &'a str) -> Self::Delete<'a>

Remove the object. Deleting a missing key succeeds.

async fn put_encoded<'a>( &'a self, key: &'a str, body: Bytes, cond: Cond, encoding: ContentEncoding, ) -> Result<u64>

Like put, storing body compressed with encoding and recording the encoding, so get returns body again and get_range refuses with Error::EncodedRange. Conditions behave exactly as for put.

async fn stat<'a>(&'a self, key: &'a str) -> Result<Option<Stat>>

head plus the content encoding. The default reports none, which is exact for a store that cannot record one.

async fn list_stat<'a>(&'a self, prefix: &'a str) -> Result<Vec<Stat>>

list plus each object’s content encoding. The default reports none, which is exact for a store that cannot record one.