cloud_storage/
sync.rs

1//! Synchronous clients for Google Cloud Storage endpoints.
2
3mod bucket;
4mod bucket_access_control;
5mod default_object_access_control;
6mod hmac_key;
7mod object;
8mod object_access_control;
9
10mod helpers; // for internal use only
11
12pub use bucket::BucketClient;
13pub use bucket_access_control::BucketAccessControlClient;
14pub use default_object_access_control::DefaultObjectAccessControlClient;
15pub use hmac_key::HmacKeyClient;
16pub use object::ObjectClient;
17pub use object_access_control::ObjectAccessControlClient;
18
19/// The primary synchronous entrypoint to perform operations with Google Cloud Storage.
20#[derive(Debug)]
21pub struct Client {
22    runtime: tokio::runtime::Runtime,
23    client: crate::client::Client,
24}
25
26impl Client {
27    /// Constructs a client with the default token provider, where it attemps to obtain the
28    /// credentials from the following locations:
29    ///
30    /// 1. Checks for the environment variable `SERVICE_ACCOUNT`, and if it exists, reads the file
31    /// at the path specified there as a credentials json file.
32    /// 2. It attemps to do the same with the `GOOGLE_APPLICATION_CREDENTIALS` var.
33    /// 3. It reads the `SERVICE_ACCOUNT_JSON` environment variable directly as json and uses that
34    /// 4.It attemps to do the same with the `GOOGLE_APPLICATION_CREDENTIALS_JSON` var.
35    pub fn new() -> crate::Result<Self> {
36        Ok(Self {
37            runtime: crate::runtime()?,
38            client: crate::Client::default(),
39        })
40    }
41
42    /// Initializer with a provided refreshable token
43    pub fn with_cache(token_cache: impl crate::TokenCache + Send + 'static) -> crate::Result<Self> {
44        Ok(Self {
45            runtime: crate::runtime()?,
46            client: crate::Client::with_cache(token_cache),
47        })
48    }
49
50    /// Synchronous operations on [`Bucket`](crate::bucket::Bucket)s.
51    pub fn bucket(&self) -> BucketClient {
52        BucketClient(self)
53    }
54
55    /// Synchronous operations on [`BucketAccessControl`](crate::bucket_access_control::BucketAccessControl)s.
56    pub fn bucket_access_control(&self) -> BucketAccessControlClient {
57        BucketAccessControlClient(self)
58    }
59
60    /// Synchronous operations on [`DefaultObjectAccessControl`](crate::default_object_access_control::DefaultObjectAccessControl)s.
61    pub fn default_object_access_control(&self) -> DefaultObjectAccessControlClient {
62        DefaultObjectAccessControlClient(self)
63    }
64
65    /// Synchronous operations on [`HmacKey`](crate::hmac_key::HmacKey)s.
66    pub fn hmac_key(&self) -> HmacKeyClient {
67        HmacKeyClient(self)
68    }
69
70    /// Synchronous operations on [`Object`](crate::object::Object)s.
71    pub fn object(&self) -> ObjectClient {
72        ObjectClient(self)
73    }
74
75    /// Synchronous operations on [`ObjectAccessControl`](crate::object_access_control::ObjectAccessControl)s.
76    pub fn object_access_control(&self) -> ObjectAccessControlClient {
77        ObjectAccessControlClient(self)
78    }
79}
cloud_storage/sync.rs

cloud_storage/
sync.rs
