1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

#![deny(rust_2018_idioms, unreachable_pub, missing_docs)]
#![forbid(unsafe_code)]

//! # cloud-storage-lite
//!
//! A simple, flexible Google Cloud Storage client (GCS).
//!
//! This library isn't as featureful as, say the [cloud-storage](https://crates.io/crates/cloud-storage) crate, but it's also more usable if you:
//! * are using a secret keeper like [Vault](https://www.vaultproject.io)
//! * generally work with a single bucket (using a bucket-scoped client)
//! * would like to use multiple clients or tokio runtimes in one program
//! * want canonicalized errors (404 gets one and only one error variant)
//!
//! ## Example
//!
//! ```no_run
//! use cloud_storage_lite::{
//!  self as gcs,
//!  client::BucketClient,
//!  token_provider::{self, oauth::{self, OAuthTokenProvider, ServiceAccount}},
//! };
//! use futures::TryStreamExt;
//!
//! #[tokio::main]
//! async fn main() -> Result<(), Box<dyn std::error::Error + 'static>> {
//!   let token_provider = token_provider::RenewingTokenProvider::new(
//!     OAuthTokenProvider::new(
//!       ServiceAccount::read_from_canonical_env()?,
//!       oauth::SCOPE_STORAGE_FULL_CONTROL,
//!     )?
//!   );
//!   let client = gcs::Client::new(token_provider).into_bucket_client("my-bucket".into());
//!
//!   client
//!     .create_object(
//!       "key",
//!       futures::stream::once(
//!         futures::future::ok::<_, std::convert::Infallible>(b"value".to_vec())
//!       )
//!     )
//!     .await?;
//!
//!   let object = client.get_object("key").await?;
//!
//!   let value_bytes = client
//!     .download_object(&object.name)
//!     .await?
//!     .map_ok(|chunk| chunk.to_vec())
//!     .try_concat()
//!     .await?;
//!
//!   println!("the value is: {}", String::from_utf8(value_bytes)?);
//!   Ok(())
//! }
//! ```

pub mod api;
pub mod client;
pub mod errors;
pub mod token_provider;

pub use client::Client;
pub use errors::Error;
pub use token_provider::TokenProvider;