Home
last modified time | relevance | path

Searched refs:timedAlgorithm (Results 1 – 5 of 5) sorted by relevance

/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/retrying/
DRetryAlgorithmTest.java47 TimedRetryAlgorithm timedAlgorithm = mock(TimedRetryAlgorithm.class); in testCreateFirstAttempt() local
49 new RetryAlgorithm<>(mock(ResultRetryAlgorithm.class), timedAlgorithm); in testCreateFirstAttempt()
52 verify(timedAlgorithm).createFirstAttempt(); in testCreateFirstAttempt()
57 TimedRetryAlgorithm timedAlgorithm = mock(TimedRetryAlgorithm.class); in testCreateFirstAttemptWithUnusedContext() local
59 new RetryAlgorithm<>(mock(ResultRetryAlgorithm.class), timedAlgorithm); in testCreateFirstAttemptWithUnusedContext()
63 verify(timedAlgorithm).createFirstAttempt(); in testCreateFirstAttemptWithUnusedContext()
68 TimedRetryAlgorithmWithContext timedAlgorithm = mock(TimedRetryAlgorithmWithContext.class); in testCreateFirstAttemptWithContext() local
70 new RetryAlgorithm<>(mock(ResultRetryAlgorithmWithContext.class), timedAlgorithm); in testCreateFirstAttemptWithContext()
74 verify(timedAlgorithm).createFirstAttempt(context); in testCreateFirstAttemptWithContext()
79 TimedRetryAlgorithmWithContext timedAlgorithm = mock(TimedRetryAlgorithmWithContext.class); in testCreateFirstAttemptWithNullContext() local
[all …]
/external/sdk-platform-java/gax-java/gax/src/test/java/com/google/api/gax/rpc/
DStreamingRetryAlgorithmTest.java81 ExponentialRetryAlgorithm timedAlgorithm = in testFirstAttemptUsesDefaultSettings() local
85 new StreamingRetryAlgorithm<>(resultAlgorithm, timedAlgorithm); in testFirstAttemptUsesDefaultSettings()
97 ExponentialRetryAlgorithm timedAlgorithm = in testFirstAttemptUsesContextSettings() local
101 new StreamingRetryAlgorithm<>(resultAlgorithm, timedAlgorithm); in testFirstAttemptUsesContextSettings()
115 ExponentialRetryAlgorithm timedAlgorithm = in testNextAttemptReturnsNullWhenShouldNotRetry() local
119 new StreamingRetryAlgorithm<>(resultAlgorithm, timedAlgorithm); in testNextAttemptReturnsNullWhenShouldNotRetry()
144 ExponentialRetryAlgorithm timedAlgorithm = in testNextAttemptReturnsResultAlgorithmSettingsWhenShouldRetry() local
148 new StreamingRetryAlgorithm<>(resultAlgorithm, timedAlgorithm); in testNextAttemptReturnsResultAlgorithmSettingsWhenShouldRetry()
166 ExponentialRetryAlgorithm timedAlgorithm = in testNextAttemptResetsTimedSettings() local
169 new StreamingRetryAlgorithm<>(resultAlgorithm, timedAlgorithm); in testNextAttemptResetsTimedSettings()
[all …]
/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/retrying/
DRetryAlgorithm.java47 private final TimedRetryAlgorithm timedAlgorithm; field in RetryAlgorithm
68 ResultRetryAlgorithm<ResponseT> resultAlgorithm, TimedRetryAlgorithm timedAlgorithm) { in RetryAlgorithm() argument
70 this.timedAlgorithm = checkNotNull(timedAlgorithm); in RetryAlgorithm()
85 TimedRetryAlgorithmWithContext timedAlgorithm) { in RetryAlgorithm() argument
87 this.timedAlgorithm = null; in RetryAlgorithm()
89 this.timedAlgorithmWithContext = checkNotNull(timedAlgorithm); in RetryAlgorithm()
265 return timedAlgorithmWithContext != null ? timedAlgorithmWithContext : timedAlgorithm; in getTimedAlgorithm()
DStreamingRetryAlgorithm.java58 ResultRetryAlgorithm<ResponseT> resultAlgorithm, TimedRetryAlgorithm timedAlgorithm) { in StreamingRetryAlgorithm() argument
59 super(resultAlgorithm, timedAlgorithm); in StreamingRetryAlgorithm()
68 TimedRetryAlgorithmWithContext timedAlgorithm) { in StreamingRetryAlgorithm() argument
69 super(resultAlgorithm, timedAlgorithm); in StreamingRetryAlgorithm()
/external/sdk-platform-java/java-core/google-cloud-core/src/main/java/com/google/cloud/
DRetryHelper.java69 TimedRetryAlgorithm timedAlgorithm, in run() argument
72 RetryAlgorithm<V> retryAlgorithm = new RetryAlgorithm<>(resultAlgorithm, timedAlgorithm); in run()