Skip to content

Commit 8c99c5e

Browse files
mziccardmziccard
committed
---
yaml --- r: 1925 b: refs/heads/pubsub-alpha c: 67bfcdd h: refs/heads/master i: 1923: 42983bb
1 parent fe68556 commit 8c99c5e

27 files changed

Lines changed: 256 additions & 798 deletions

File tree

‎[refs]‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ refs/heads/master: 689bbb466df4b2d5d2483d6edb8ac5c7c7f7c6fa
33
refs/heads/travis: e21ee7b88a5edc3f3d8c71f90c3fc32abf7e8dd6
44
refs/heads/gh-pages: 4e0561bb4504bf647db669a14417b2b2c87ba45d
55
refs/heads/bigquery: 762fa5830e6c398c0396177e3e7fd243bd62cfc3
6-
refs/heads/pubsub-alpha: 99795026fd9e542dc9b2e33351381676beab3ee6
6+
refs/heads/pubsub-alpha: 67bfcdd00e1c475eb74f222d1ea59ef7b0b3e130
77
refs/heads/resource-manager: ebf4adc5ee835cd2086c4ac5b4e78d01a5a005a7
88
refs/heads/update-datastore: 482954f2c5055231e5b3122ea91d2ba00ce8187c
99
refs/tags/0.0.9: 22f1839238f66c39e67ed4dfdcd273b1ae2e8444

‎branches/pubsub-alpha/README.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,7 @@ import com.google.gcloud.datastore.Entity;
121121
import com.google.gcloud.datastore.Key;
122122
import com.google.gcloud.datastore.KeyFactory;
123123
124-
Datastore datastore = DatastoreOptions.defaultInstance().service();
124+
Datastore datastore = DatastoreOptions.getDefaultInstance().service();
125125
KeyFactory keyFactory = datastore.newKeyFactory().kind(KIND);
126126
Key key = keyFactory.newKey(keyName);
127127
Entity entity = datastore.get(key);

‎branches/pubsub-alpha/gcloud-java-core/src/main/java/com/google/gcloud/ExceptionHandler.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -231,11 +231,11 @@ void verifyCaller(Callable<?> callable) {
231231
}
232232
}
233233

234-
public Set<Class<? extends Exception>> retriableExceptions() {
234+
public Set<Class<? extends Exception>> getRetriableExceptions() {
235235
return retriableExceptions;
236236
}
237237

238-
public Set<Class<? extends Exception>> nonRetriableExceptions() {
238+
public Set<Class<? extends Exception>> getNonRetriableExceptions() {
239239
return nonRetriableExceptions;
240240
}
241241

@@ -262,7 +262,7 @@ boolean shouldRetry(Exception ex) {
262262
/**
263263
* Returns an instance which retry any checked exception and abort on any runtime exception.
264264
*/
265-
public static ExceptionHandler defaultInstance() {
265+
public static ExceptionHandler getDefaultInstance() {
266266
return DEFAULT_INSTANCE;
267267
}
268268

‎branches/pubsub-alpha/gcloud-java-core/src/main/java/com/google/gcloud/RetryHelper.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -194,9 +194,9 @@ private V doRetry() throws RetryHelperException {
194194
}
195195
exception = e;
196196
}
197-
if (attemptNumber >= params.retryMaxAttempts()
198-
|| attemptNumber >= params.retryMinAttempts()
199-
&& stopwatch.elapsed(MILLISECONDS) >= params.totalRetryPeriodMillis()) {
197+
if (attemptNumber >= params.getRetryMaxAttempts()
198+
|| attemptNumber >= params.getRetryMinAttempts()
199+
&& stopwatch.elapsed(MILLISECONDS) >= params.getTotalRetryPeriodMillis()) {
200200
throw new RetriesExhaustedException(this + ": Too many failures, giving up", exception);
201201
}
202202
long sleepDurationMillis = getSleepDuration(params, attemptNumber);
@@ -215,9 +215,9 @@ private V doRetry() throws RetryHelperException {
215215

216216
@VisibleForTesting
217217
static long getSleepDuration(RetryParams retryParams, int attemptsSoFar) {
218-
long initialDelay = retryParams.initialRetryDelayMillis();
219-
double backoffFactor = retryParams.retryDelayBackoffFactor();
220-
long maxDelay = retryParams.maxRetryDelayMillis();
218+
long initialDelay = retryParams.getInitialRetryDelayMillis();
219+
double backoffFactor = retryParams.getRetryDelayBackoffFactor();
220+
long maxDelay = retryParams.getMaxRetryDelayMillis();
221221
long retryDelay = getExponentialValue(initialDelay, backoffFactor, maxDelay, attemptsSoFar);
222222
return (long) ((random() / 2.0 + .75) * retryDelay);
223223
}
@@ -228,8 +228,8 @@ private static long getExponentialValue(long initialDelay, double backoffFactor,
228228
}
229229

230230
public static <V> V runWithRetries(Callable<V> callable) throws RetryHelperException {
231-
return runWithRetries(callable, RetryParams.defaultInstance(),
232-
ExceptionHandler.defaultInstance());
231+
return runWithRetries(callable, RetryParams.getDefaultInstance(),
232+
ExceptionHandler.getDefaultInstance());
233233
}
234234

235235
public static <V> V runWithRetries(Callable<V> callable, RetryParams params,

‎branches/pubsub-alpha/gcloud-java-core/src/main/java/com/google/gcloud/RetryParams.java‎

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,8 @@
3838
* {@code RetryParams}, first create a {@link RetryParams.Builder}. The builder is mutable and each
3939
* of the parameters can be set (any unset parameters will fallback to the defaults). The
4040
* {@code Builder} can be then used to create an immutable {@code RetryParams} object. For default
41-
* {@code RetryParams} use {@link #defaultInstance}. Default settings are subject to change release
42-
* to release. If you require specific settings, explicitly create an instance of
41+
* {@code RetryParams} use {@link #getDefaultInstance}. Default settings are subject to change
42+
* release to release. If you require specific settings, explicitly create an instance of
4343
* {@code RetryParams} with all the required settings.
4444
*
4545
* @see RetryHelper
@@ -91,12 +91,12 @@ private Builder() {
9191
retryDelayBackoffFactor = DEFAULT_RETRY_DELAY_BACKOFF_FACTOR;
9292
totalRetryPeriodMillis = DEFAULT_TOTAL_RETRY_PERIOD_MILLIS;
9393
} else {
94-
retryMinAttempts = retryParams.retryMinAttempts();
95-
retryMaxAttempts = retryParams.retryMaxAttempts();
96-
initialRetryDelayMillis = retryParams.initialRetryDelayMillis();
97-
maxRetryDelayMillis = retryParams.maxRetryDelayMillis();
98-
retryDelayBackoffFactor = retryParams.retryDelayBackoffFactor();
99-
totalRetryPeriodMillis = retryParams.totalRetryPeriodMillis();
94+
retryMinAttempts = retryParams.getRetryMinAttempts();
95+
retryMaxAttempts = retryParams.getRetryMaxAttempts();
96+
initialRetryDelayMillis = retryParams.getInitialRetryDelayMillis();
97+
maxRetryDelayMillis = retryParams.getMaxRetryDelayMillis();
98+
retryDelayBackoffFactor = retryParams.getRetryDelayBackoffFactor();
99+
totalRetryPeriodMillis = retryParams.getTotalRetryPeriodMillis();
100100
}
101101
}
102102

@@ -201,7 +201,7 @@ private RetryParams(Builder builder) {
201201
/**
202202
* Returns an instance with the default parameters.
203203
*/
204-
public static RetryParams defaultInstance() {
204+
public static RetryParams getDefaultInstance() {
205205
return DEFAULT_INSTANCE;
206206
}
207207

@@ -216,45 +216,45 @@ public static RetryParams noRetries() {
216216
/**
217217
* Returns the retryMinAttempts. Default value is {@value #DEFAULT_RETRY_MIN_ATTEMPTS}.
218218
*/
219-
public int retryMinAttempts() {
219+
public int getRetryMinAttempts() {
220220
return retryMinAttempts;
221221
}
222222

223223
/**
224224
* Returns the retryMaxAttempts. Default value is {@value #DEFAULT_RETRY_MAX_ATTEMPTS}.
225225
*/
226-
public int retryMaxAttempts() {
226+
public int getRetryMaxAttempts() {
227227
return retryMaxAttempts;
228228
}
229229

230230
/**
231231
* Returns the initialRetryDelayMillis. Default value is
232232
* {@value #DEFAULT_INITIAL_RETRY_DELAY_MILLIS}.
233233
*/
234-
public long initialRetryDelayMillis() {
234+
public long getInitialRetryDelayMillis() {
235235
return initialRetryDelayMillis;
236236
}
237237

238238
/**
239239
* Returns the maxRetryDelayMillis. Default values is {@value #DEFAULT_MAX_RETRY_DELAY_MILLIS}.
240240
*/
241-
public long maxRetryDelayMillis() {
241+
public long getMaxRetryDelayMillis() {
242242
return maxRetryDelayMillis;
243243
}
244244

245245
/**
246246
* Returns the maxRetryDelayBackoffFactor. Default values is
247247
* {@value #DEFAULT_RETRY_DELAY_BACKOFF_FACTOR}.
248248
*/
249-
public double retryDelayBackoffFactor() {
249+
public double getRetryDelayBackoffFactor() {
250250
return retryDelayBackoffFactor;
251251
}
252252

253253
/**
254254
* Returns the totalRetryPeriodMillis. Default value is
255255
* {@value #DEFAULT_TOTAL_RETRY_PERIOD_MILLIS}.
256256
*/
257-
public long totalRetryPeriodMillis() {
257+
public long getTotalRetryPeriodMillis() {
258258
return totalRetryPeriodMillis;
259259
}
260260

‎branches/pubsub-alpha/gcloud-java-core/src/test/java/com/google/gcloud/ExceptionHandlerTest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public Object call() throws Error {
8282
}
8383

8484
// using default exception handler (retry upon any non-runtime exceptions)
85-
ExceptionHandler handler = ExceptionHandler.defaultInstance();
85+
ExceptionHandler handler = ExceptionHandler.getDefaultInstance();
8686
assertValidCallable(new A(), handler);
8787
assertValidCallable(new B(), handler);
8888
assertValidCallable(new C(), handler);

‎branches/pubsub-alpha/gcloud-java-core/src/test/java/com/google/gcloud/RetryHelperTest.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -118,13 +118,13 @@ public void testTriesAtLeastMinTimes() {
118118
@Override public Integer call() throws IOException {
119119
timesCalled++;
120120
assertEquals(timesCalled, RetryHelper.getContext().getAttemptNumber());
121-
assertEquals(10, RetryHelper.getContext().getRetryParams().retryMaxAttempts());
121+
assertEquals(10, RetryHelper.getContext().getRetryParams().getRetryMaxAttempts());
122122
if (timesCalled <= timesToFail) {
123123
throw new IOException();
124124
}
125125
return timesCalled;
126126
}
127-
}, params, ExceptionHandler.defaultInstance());
127+
}, params, ExceptionHandler.getDefaultInstance());
128128
assertEquals(timesToFail + 1, attempted);
129129
assertNull(RetryHelper.getContext());
130130
}

‎branches/pubsub-alpha/gcloud-java-core/src/test/java/com/google/gcloud/RetryParamsTest.java‎

Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -41,15 +41,15 @@ public class RetryParamsTest {
4141

4242
@Test
4343
public void testDefaults() {
44-
RetryParams params1 = RetryParams.defaultInstance();
44+
RetryParams params1 = RetryParams.getDefaultInstance();
4545
RetryParams params2 = RetryParams.builder().build();
4646
for (RetryParams params : Arrays.asList(params1, params2)) {
47-
assertEquals(DEFAULT_INITIAL_RETRY_DELAY_MILLIS, params.initialRetryDelayMillis());
48-
assertEquals(DEFAULT_MAX_RETRY_DELAY_MILLIS, params.maxRetryDelayMillis());
49-
assertEquals(DEFAULT_RETRY_DELAY_BACKOFF_FACTOR, params.retryDelayBackoffFactor(), 0);
50-
assertEquals(DEFAULT_RETRY_MAX_ATTEMPTS, params.retryMaxAttempts());
51-
assertEquals(DEFAULT_RETRY_MIN_ATTEMPTS, params.retryMinAttempts());
52-
assertEquals(DEFAULT_TOTAL_RETRY_PERIOD_MILLIS, params.totalRetryPeriodMillis());
47+
assertEquals(DEFAULT_INITIAL_RETRY_DELAY_MILLIS, params.getInitialRetryDelayMillis());
48+
assertEquals(DEFAULT_MAX_RETRY_DELAY_MILLIS, params.getMaxRetryDelayMillis());
49+
assertEquals(DEFAULT_RETRY_DELAY_BACKOFF_FACTOR, params.getRetryDelayBackoffFactor(), 0);
50+
assertEquals(DEFAULT_RETRY_MAX_ATTEMPTS, params.getRetryMaxAttempts());
51+
assertEquals(DEFAULT_RETRY_MIN_ATTEMPTS, params.getRetryMinAttempts());
52+
assertEquals(DEFAULT_TOTAL_RETRY_PERIOD_MILLIS, params.getTotalRetryPeriodMillis());
5353
}
5454
}
5555

@@ -65,12 +65,12 @@ public void testSetAndCopy() {
6565
RetryParams params1 = builder.build();
6666
RetryParams params2 = new RetryParams.Builder(params1).build();
6767
for (RetryParams params : Arrays.asList(params1, params2)) {
68-
assertEquals(101, params.initialRetryDelayMillis());
69-
assertEquals(102, params.maxRetryDelayMillis());
70-
assertEquals(103, params.retryDelayBackoffFactor(), 0);
71-
assertEquals(107, params.retryMinAttempts());
72-
assertEquals(108, params.retryMaxAttempts());
73-
assertEquals(109, params.totalRetryPeriodMillis());
68+
assertEquals(101, params.getInitialRetryDelayMillis());
69+
assertEquals(102, params.getMaxRetryDelayMillis());
70+
assertEquals(103, params.getRetryDelayBackoffFactor(), 0);
71+
assertEquals(107, params.getRetryMinAttempts());
72+
assertEquals(108, params.getRetryMaxAttempts());
73+
assertEquals(109, params.getTotalRetryPeriodMillis());
7474
}
7575
}
7676

@@ -79,19 +79,19 @@ public void testBadSettings() {
7979
RetryParams.Builder builder = RetryParams.builder();
8080
builder.initialRetryDelayMillis(-1);
8181
builder = assertFailure(builder);
82-
builder.maxRetryDelayMillis(RetryParams.defaultInstance().initialRetryDelayMillis() - 1);
82+
builder.maxRetryDelayMillis(RetryParams.getDefaultInstance().getInitialRetryDelayMillis() - 1);
8383
builder = assertFailure(builder);
8484
builder.retryDelayBackoffFactor(-1);
8585
builder = assertFailure(builder);
8686
builder.retryMinAttempts(-1);
8787
builder = assertFailure(builder);
88-
builder.retryMaxAttempts(RetryParams.defaultInstance().retryMinAttempts() - 1);
88+
builder.retryMaxAttempts(RetryParams.getDefaultInstance().getRetryMinAttempts() - 1);
8989
builder = assertFailure(builder);
9090
builder.totalRetryPeriodMillis(-1);
9191
builder = assertFailure(builder);
9292
// verify that it is OK for min and max to be equal
93-
builder.retryMaxAttempts(RetryParams.defaultInstance().retryMinAttempts());
94-
builder.maxRetryDelayMillis(RetryParams.defaultInstance().initialRetryDelayMillis());
93+
builder.retryMaxAttempts(RetryParams.getDefaultInstance().getRetryMinAttempts());
94+
builder.maxRetryDelayMillis(RetryParams.getDefaultInstance().getInitialRetryDelayMillis());
9595
builder.build();
9696
}
9797

‎branches/pubsub-alpha/gcloud-java-datastore/README.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ import com.google.gcloud.datastore.Entity;
6666
import com.google.gcloud.datastore.Key;
6767
import com.google.gcloud.datastore.KeyFactory;
6868

69-
Datastore datastore = DatastoreOptions.defaultInstance().service();
69+
Datastore datastore = DatastoreOptions.getDefaultInstance().service();
7070
KeyFactory keyFactory = datastore.newKeyFactory().kind(KIND);
7171
Key key = keyFactory.newKey(keyName);
7272
Entity entity = datastore.get(key);

‎branches/pubsub-alpha/gcloud-java-datastore/src/main/java/com/google/gcloud/datastore/DatastoreOptions.java‎

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -171,13 +171,6 @@ public String namespace() {
171171
return namespace;
172172
}
173173

174-
/**
175-
* Returns a default {@code DatastoreOptions} instance.
176-
*/
177-
public static DatastoreOptions defaultInstance() {
178-
return builder().build();
179-
}
180-
181174
private static String defaultNamespace() {
182175
try {
183176
Class<?> clazz = Class.forName("com.google.appengine.api.NamespaceManager");

0 commit comments

Comments
 (0)