Class GrpcRetryer

java.lang.Object

io.temporal.internal.retryer.GrpcRetryer

public final class GrpcRetryer
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GrpcRetryer.GrpcRetryerOptions
static interface	GrpcRetryer.RetryableFunc<R,E extends Throwable>
static interface	GrpcRetryer.RetryableProc<E extends Throwable>

Constructor Summary

Constructors

Constructor	Description
GrpcRetryer(Supplier<GetSystemInfoResponse.Capabilities> serverCapabilities)

Method Summary

Modifier and Type	Method	Description
<T extends Throwable> void	retry(GrpcRetryer.RetryableProc<T> r, GrpcRetryer.GrpcRetryerOptions options)
<R, T extends Throwable> R	retryWithResult(GrpcRetryer.RetryableFunc<R,T> r, GrpcRetryer.GrpcRetryerOptions options)
<R> CompletableFuture<R>	retryWithResultAsync(ScheduledExecutorService asyncThrottlerExecutor, Supplier<CompletableFuture<R>> function, GrpcRetryer.GrpcRetryerOptions options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GrpcRetryer

public GrpcRetryer(Supplier<GetSystemInfoResponse.Capabilities> serverCapabilities)

Method Details

retry

public <T extends Throwable> void retry(GrpcRetryer.RetryableProc<T> r,
 GrpcRetryer.GrpcRetryerOptions options)
                                 throws T

Throws:

T

retryWithResult

public <R,
T extends Throwable> R retryWithResult(GrpcRetryer.RetryableFunc<R,T> r,
 GrpcRetryer.GrpcRetryerOptions options)
                                           throws T

Throws:

T

retryWithResultAsync

public <R> CompletableFuture<R> retryWithResultAsync(ScheduledExecutorService asyncThrottlerExecutor,
 Supplier<CompletableFuture<R>> function,
 GrpcRetryer.GrpcRetryerOptions options)