- 2.59.0 (latest)
- 2.58.1
- 2.57.0
- 2.56.0
- 2.55.0
- 2.54.0
- 2.53.3
- 2.52.3
- 2.50.0
- 2.49.0
- 2.48.2
- 2.47.0
- 2.46.0
- 2.45.0
- 2.44.1
- 2.43.2
- 2.42.0
- 2.41.0
- 2.40.1
- 2.39.0
- 2.38.0
- 2.37.0
- 2.36.1
- 2.34.0
- 2.33.0
- 2.32.1
- 2.30.1
- 2.29.1
- 2.28.0
- 2.27.1
- 2.24.0
- 2.23.0
- 2.22.6
- 2.21.0
- 2.20.2
- 2.19.0
- 2.18.0
- 2.17.2
- 2.16.0
- 2.15.1
- 2.14.0
- 2.13.1
- 2.12.0
- 2.11.3
- 2.10.0
- 2.9.3
- 2.8.1
- 2.7.1
- 2.6.1
- 2.5.1
- 2.4.5
- 2.3.0
- 2.2.3
- 2.1.10
public class RemoteStorageHelperUtility to create a remote storage configuration for testing. Storage options can be obtained via
the #getOptions() ()} method. Returned options have custom StorageOptions#getRetrySettings(): RetrySettings#getMaxAttempts() is 10, RetrySettings#getMaxRetryDelay() is 30000, RetrySettings#getTotalTimeout() is
120000 and RetrySettings#getInitialRetryDelay() is 250. HttpTransportOptions#getConnectTimeout() and HttpTransportOptions#getReadTimeout() are
both set to 60000.
Static Methods
cleanBuckets(Storage storage, long olderThan, long timeoutMs)
public static void cleanBuckets(Storage storage, long olderThan, long timeoutMs)| Parameters | |
|---|---|
| Name | Description |
storage |
Storage |
olderThan |
long |
timeoutMs |
long |
create()
public static RemoteStorageHelper create()Creates a RemoteStorageHelper object using default project id and authentication
credentials.
| Returns | |
|---|---|
| Type | Description |
RemoteStorageHelper |
|
| Exceptions | |
|---|---|
| Type | Description |
RemoteStorageHelper.StorageHelperException |
|
create(String projectId, InputStream keyStream)
public static RemoteStorageHelper create(String projectId, InputStream keyStream)Creates a RemoteStorageHelper object for the given project id and JSON key input
stream.
| Parameters | |
|---|---|
| Name | Description |
projectId |
Stringid of the project to be used for running the tests |
keyStream |
InputStreaminput stream for a JSON key |
| Returns | |
|---|---|
| Type | Description |
RemoteStorageHelper |
A |
| Exceptions | |
|---|---|
| Type | Description |
RemoteStorageHelper.StorageHelperException |
if |
forceDelete(Storage storage, String bucket)
public static void forceDelete(Storage storage, String bucket)Deletes a bucket, even if non-empty. This method blocks until the deletion completes or fails.
| Parameters | |
|---|---|
| Name | Description |
storage |
Storagethe storage service to be used to issue requests |
bucket |
Stringthe bucket to be deleted |
forceDelete(Storage storage, String bucket, long timeout, TimeUnit unit)
public static Boolean forceDelete(Storage storage, String bucket, long timeout, TimeUnit unit)Deletes a bucket, even if non-empty. Objects in the bucket are listed and deleted until bucket
deletion succeeds or timeout expires. To allow for the timeout, this method uses a
separate thread to send the delete requests. Use #forceDelete(Storage storage, String
bucket) if spawning an additional thread is undesirable, such as in the App Engine production
runtime.
| Parameters | |
|---|---|
| Name | Description |
storage |
Storagethe storage service to be used to issue requests |
bucket |
Stringthe bucket to be deleted |
timeout |
longthe maximum time to wait |
unit |
TimeUnitthe time unit of the timeout argument |
| Returns | |
|---|---|
| Type | Description |
Boolean |
true if deletion succeeded, false if timeout expired |
| Exceptions | |
|---|---|
| Type | Description |
InterruptedException |
if the thread deleting the bucket is interrupted while waiting |
ExecutionException |
if the thread deleting the bucket is interrupted while waiting |
forceDelete(Storage storage, String bucket, long timeout, TimeUnit unit, String userProject)
public static Boolean forceDelete(Storage storage, String bucket, long timeout, TimeUnit unit, String userProject)Deletes a bucket, even if non-empty. Objects in the bucket are listed and deleted until bucket
deletion succeeds or timeout expires. To allow for the timeout, this method uses a
separate thread to send the delete requests. Use #forceDelete(Storage storage, String
bucket) if spawning an additional thread is undesirable, such as in the App Engine production
runtime.
| Parameters | |
|---|---|
| Name | Description |
storage |
Storagethe storage service to be used to issue requests |
bucket |
Stringthe bucket to be deleted |
timeout |
longthe maximum time to wait |
unit |
TimeUnitthe time unit of the timeout argument |
userProject |
Stringthe project to bill for requester-pays buckets (or "") |
| Returns | |
|---|---|
| Type | Description |
Boolean |
true if deletion succeeded, false if timeout expired |
| Exceptions | |
|---|---|
| Type | Description |
InterruptedException |
if the thread deleting the bucket is interrupted while waiting |
ExecutionException |
if the thread deleting the bucket is interrupted while waiting |
generateBucketName()
public static String generateBucketName()Returns a bucket name generated using a random UUID.
| Returns | |
|---|---|
| Type | Description |
String |
|
Methods
getOptions()
public StorageOptions getOptions()Returns a StorageOptions object to be used for testing.
| Returns | |
|---|---|
| Type | Description |
StorageOptions |
|