Struct GoogleCloudStorageBuilder 

pub struct GoogleCloudStorageBuilder { /* private fields */ }

Available on crate feature gcp-base only.

Configure a connection to Google Cloud Storage.

If no credentials are explicitly provided, they will be sourced from the environment as documented here.

Example

let gcs = GoogleCloudStorageBuilder::from_env().with_bucket_name(BUCKET_NAME).build();

Implementations

impl GoogleCloudStorageBuilder

pub fn new() -> Self

Create a new GoogleCloudStorageBuilder with default values.

pub fn from_env() -> Self

Create an instance of GoogleCloudStorageBuilder with values pre-populated from environment variables.

Variables extracted from environment:

• GOOGLE_SERVICE_ACCOUNT: location of service account file
• GOOGLE_SERVICE_ACCOUNT_PATH: (alias) location of service account file
• SERVICE_ACCOUNT: (alias) location of service account file
• GOOGLE_SERVICE_ACCOUNT_KEY: JSON serialized service account key
• GOOGLE_BUCKET: bucket name
• GOOGLE_BUCKET_NAME: (alias) bucket name

Example

use object_store::gcp::GoogleCloudStorageBuilder;

let gcs = GoogleCloudStorageBuilder::from_env()
    .with_bucket_name("foo")
    .build();

pub fn with_url(self, url: impl Into<String>) -> Self

Parse available connection info form a well-known storage URL.

The supported url schemes are:

• gs://<bucket>/<path>

Note: Settings derived from the URL will override any others set on this builder

Example

use object_store::gcp::GoogleCloudStorageBuilder;

let gcs = GoogleCloudStorageBuilder::from_env()
    .with_url("gs://bucket/path")
    .build();

pub fn with_config(self, key: GoogleConfigKey, value: impl Into<String>) -> Self

Set an option on the builder via a key - value pair.

pub fn get_config_value(&self, key: &GoogleConfigKey) -> Option<String>

Get config value via a GoogleConfigKey.

Example

use object_store::gcp::{GoogleCloudStorageBuilder, GoogleConfigKey};

let builder = GoogleCloudStorageBuilder::from_env()
    .with_service_account_key("foo");
let service_account_key = builder.get_config_value(&GoogleConfigKey::ServiceAccountKey).unwrap_or_default();
assert_eq!("foo", &service_account_key);

pub fn with_bucket_name(self, bucket_name: impl Into<String>) -> Self

Set the bucket name (required)

pub fn with_base_url(self, base_url: &str) -> Self

Sets the base URL for communicating with GCS.

If not explicitly set, it will be:

1. Derived from the service account credentials, if provided
2. Otherwise, uses the default GCS endpoint

Example

use object_store::gcp::GoogleCloudStorageBuilder;

let gcs = GoogleCloudStorageBuilder::from_env()
    .with_base_url("https://localhost:4443")
    .build();

pub fn with_service_account_path( self, service_account_path: impl Into<String>, ) -> Self

Set the path to the service account file.

This or GoogleCloudStorageBuilder::with_service_account_key must be set.

Example "/tmp/gcs.json".

Example contents of gcs.json:

{
   "gcs_base_url": "https://localhost:4443",
   "disable_oauth": true,
   "client_email": "",
   "private_key": ""
}

pub fn with_service_account_key( self, service_account: impl Into<String>, ) -> Self

Set the service account key. The service account must be in the JSON format.

This or GoogleCloudStorageBuilder::with_service_account_path must be set.

pub fn with_application_credentials( self, application_credentials_path: impl Into<String>, ) -> Self

Set the path to the application credentials file.

https://cloud.google.com/docs/authentication/provide-credentials-adc

pub fn with_bearer_token(self, bearer_token: impl Into<String>) -> Self

Set an explicit OAuth bearer token.

This is treated as a static token and will not be refreshed automatically.

pub fn with_skip_signature(self, skip_signature: bool) -> Self

If enabled, GoogleCloudStorage will not fetch credentials and will not sign requests.

This can be useful when interacting with public GCS buckets that deny authorized requests.

pub fn with_credentials(self, credentials: GcpCredentialProvider) -> Self

Set the credential provider overriding any other options

pub fn with_signing_credentials( self, credentials: GcpSigningCredentialProvider, ) -> Self

Set the signing credential provider overriding any other options

pub fn with_crypto_provider(self, provider: Arc<dyn CryptoProvider>) -> Self

The CryptoProvider to use

pub fn with_retry(self, retry_config: RetryConfig) -> Self

Set the retry configuration

pub fn with_proxy_url(self, proxy_url: impl Into<String>) -> Self

Set the proxy_url to be used by the underlying client

pub fn with_proxy_ca_certificate( self, proxy_ca_certificate: impl Into<String>, ) -> Self

Set a trusted proxy CA certificate

pub fn with_proxy_excludes(self, proxy_excludes: impl Into<String>) -> Self

Set a list of hosts to exclude from proxy connections

pub fn with_client_options(self, options: ClientOptions) -> Self

Sets the client options, overriding any already set

pub fn with_http_connector<C: HttpConnector>(self, connector: C) -> Self

The HttpConnector to use

On non-WASM32 platforms uses reqwest by default, on WASM32 platforms must be provided

pub fn build(self) -> Result<GoogleCloudStorage>

Configure a connection to Google Cloud Storage, returning a new GoogleCloudStorage and consuming self

Trait Implementations

impl Clone for GoogleCloudStorageBuilder

fn clone(&self) -> GoogleCloudStorageBuilder

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GoogleCloudStorageBuilder

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

Formats the value using the given formatter.

impl Default for GoogleCloudStorageBuilder

fn default() -> Self

Returns the “default value” for a type.