Skip to content

Commit

Permalink
Add default retry strategy
Browse files Browse the repository at this point in the history
  • Loading branch information
Ajay Kannan committed Jan 11, 2016
1 parent 5a23e57 commit 396a124
Show file tree
Hide file tree
Showing 4 changed files with 38 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
package com.google.gcloud.bigquery;

import com.google.common.collect.ImmutableSet;
import com.google.gcloud.RetryParams;
import com.google.gcloud.ServiceOptions;
import com.google.gcloud.spi.BigQueryRpc;
import com.google.gcloud.spi.BigQueryRpcFactory;
Expand Down Expand Up @@ -104,8 +105,17 @@ public boolean equals(Object obj) {
return baseEquals(other);
}

/**
* Returns a default {@code BigQueryOptions} instance with the retry strategy defined by
* {@link RetryParams#defaultInstance}. To disable retries, supply {@link RetryParams#noRetries}
* to the {@code BigQueryOptions} builder, like so:
* <pre> {@code
* BigQueryOptions options =
* BigQueryOptions.builder().retryParams(RetryParams.noRetries()).build();
* }
*/
public static BigQueryOptions defaultInstance() {
return builder().build();
return builder().retryParams(RetryParams.defaultInstance()).build();
}

public static Builder builder() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
import com.google.api.services.datastore.DatastoreV1.LookupResponse;
import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Iterables;
import com.google.gcloud.RetryParams;
import com.google.gcloud.ServiceOptions;
import com.google.gcloud.spi.DatastoreRpc;
import com.google.gcloud.spi.DatastoreRpc.DatastoreRpcException;
Expand Down Expand Up @@ -174,10 +175,16 @@ public String namespace() {
}

/**
* Returns a default {@code DatastoreOptions} instance.
* Returns a default {@code DatastoreOptions} instance with the retry strategy defined by
* {@link RetryParams#defaultInstance}. To disable retries, supply {@link RetryParams#noRetries}
* to the {@code DatastoreOptions} builder, like so:
* <pre> {@code
* DatastoreOptions options =
* DatastoreOptions.builder().retryParams(RetryParams.noRetries()).build();
* }
*/
public static DatastoreOptions defaultInstance() {
return builder().build();
return builder().retryParams(RetryParams.defaultInstance()).build();
}

private static String defaultNamespace() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
package com.google.gcloud.resourcemanager;

import com.google.common.collect.ImmutableSet;
import com.google.gcloud.RetryParams;
import com.google.gcloud.ServiceOptions;
import com.google.gcloud.spi.DefaultResourceManagerRpc;
import com.google.gcloud.spi.ResourceManagerRpc;
Expand All @@ -42,10 +43,16 @@ public ResourceManager create(ResourceManagerOptions options) {
}

/**
* Returns a default {@code ResourceManagerOptions} instance.
* Returns a default {@code ResourceManagerOptions} instance with the retry strategy defined
* by {@link RetryParams#defaultInstance}. To disable retries, supply
* {@link RetryParams#noRetries} to the {@code ResourceManagerOptions} builder, like so:
* <pre> {@code
* ResourceManagerOptions options =
* ResourceManagerOptions.builder().retryParams(RetryParams.noRetries()).build();
* }
*/
public static ResourceManagerOptions defaultInstance() {
return builder().build();
return builder().retryParams(RetryParams.defaultInstance()).build();
}

public static class DefaultResourceManagerRpcFactory implements ResourceManagerRpcFactory {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@

import com.google.common.base.MoreObjects;
import com.google.common.collect.ImmutableSet;
import com.google.gcloud.RetryParams;
import com.google.gcloud.ServiceOptions;
import com.google.gcloud.spi.DefaultStorageRpc;
import com.google.gcloud.spi.StorageRpc;
Expand Down Expand Up @@ -114,10 +115,16 @@ public String pathDelimiter() {
}

/**
* Returns a default {@code StorageOptions} instance.
* Returns a default {@code StorageOptions} instance with the retry strategy defined by
* {@link RetryParams#defaultInstance}. To disable retries, supply {@link RetryParams#noRetries}
* to the {@code StorageOptions} builder, like so:
* <pre> {@code
* StorageOptions options =
* StorageOptions.builder().retryParams(RetryParams.noRetries()).build();
* }
*/
public static StorageOptions defaultInstance() {
return builder().build();
return builder().retryParams(RetryParams.defaultInstance()).build();
}

@SuppressWarnings("unchecked")
Expand Down

0 comments on commit 396a124

Please sign in to comment.