Package io.vrap.rmf.base.client.http

Class RetryPolicyBuilder

java.lang.Object

io.vrap.rmf.base.client.http.RetryPolicyBuilder

public class RetryPolicyBuilder
extends Object

Constructor Summary

Constructors

Constructor	Description
RetryPolicyBuilder()
RetryPolicyBuilder(int maxRetries, long initialDelay, long maxDelay, List<Integer> statusCodes, List<Class<? extends Throwable>> failures, FailsafeRetryPolicyBuilderOptions fn)

Method Summary

Modifier and Type	Method	Description
dev.failsafe.RetryPolicy<ApiHttpResponse<byte[]>>	build()
static dev.failsafe.Bulkhead<ApiHttpResponse<byte[]>>	bulkhead(int maxConcurrency)
static dev.failsafe.Bulkhead<ApiHttpResponse<byte[]>>	bulkhead(int maxConcurrency, FailsafeConcurrencyBuilderOptions fn)
static dev.failsafe.Bulkhead<ApiHttpResponse<byte[]>>	bulkhead(int maxConcurrency, Duration maxWaitTime)
static dev.failsafe.Bulkhead<ApiHttpResponse<byte[]>>	bulkhead(int maxConcurrency, Duration maxWaitTime, FailsafeConcurrencyBuilderOptions fn)
RetryPolicyBuilder	failures(List<Class<? extends Throwable>> failures)
static FailsafeRetryPolicyBuilderOptions	handleFailures(List<Class<? extends Throwable>> failures)
static FailsafeRetryPolicyBuilderOptions	handleStatusCodes(List<Integer> statusCodes)
RetryPolicyBuilder	initialDelay(long initialDelay)
RetryPolicyBuilder	maxDelay(long maxDelay)
RetryPolicyBuilder	maxRetries(int maxRetries)
static RetryPolicyBuilder	of()
RetryPolicyBuilder	options(FailsafeRetryPolicyBuilderOptions options)
static dev.failsafe.RetryPolicy<ApiHttpResponse<byte[]>>	retry(int maxRetries, long delay, long maxDelay, FailsafeRetryPolicyBuilderOptions fn)
RetryPolicyBuilder	statusCodes(List<Integer> statusCodes)
static dev.failsafe.Timeout<ApiHttpResponse<byte[]>>	timeout(Duration duration)
static dev.failsafe.Timeout<ApiHttpResponse<byte[]>>	timeout(Duration duration, FailsafeTimeoutBuilderOptions fn)

Methods inherited from class java.lang.Object

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

Constructor Details

RetryPolicyBuilder

public RetryPolicyBuilder()

RetryPolicyBuilder

public RetryPolicyBuilder(int maxRetries,
 long initialDelay,
 long maxDelay,
 List<Integer> statusCodes,
 List<Class<? extends Throwable>> failures,
 FailsafeRetryPolicyBuilderOptions fn)

Method Details

maxRetries

public RetryPolicyBuilder maxRetries(int maxRetries)

initialDelay

public RetryPolicyBuilder initialDelay(long initialDelay)

maxDelay

public RetryPolicyBuilder maxDelay(long maxDelay)

statusCodes

public RetryPolicyBuilder statusCodes(List<Integer> statusCodes)

failures

public RetryPolicyBuilder failures(List<Class<? extends Throwable>> failures)

options

public RetryPolicyBuilder options(FailsafeRetryPolicyBuilderOptions options)

build

public dev.failsafe.RetryPolicy<ApiHttpResponse<byte[]>> build()

of

public static RetryPolicyBuilder of()

retry

public static dev.failsafe.RetryPolicy<ApiHttpResponse<byte[]>> retry(int maxRetries,
 long delay,
 long maxDelay,
 FailsafeRetryPolicyBuilderOptions fn)

timeout

public static dev.failsafe.Timeout<ApiHttpResponse<byte[]>> timeout(Duration duration)

timeout

public static dev.failsafe.Timeout<ApiHttpResponse<byte[]>> timeout(Duration duration,
 FailsafeTimeoutBuilderOptions fn)

bulkhead

public static dev.failsafe.Bulkhead<ApiHttpResponse<byte[]>> bulkhead(int maxConcurrency)

bulkhead

public static dev.failsafe.Bulkhead<ApiHttpResponse<byte[]>> bulkhead(int maxConcurrency,
 Duration maxWaitTime)

bulkhead

public static dev.failsafe.Bulkhead<ApiHttpResponse<byte[]>> bulkhead(int maxConcurrency,
 FailsafeConcurrencyBuilderOptions fn)

bulkhead

public static dev.failsafe.Bulkhead<ApiHttpResponse<byte[]>> bulkhead(int maxConcurrency,
 Duration maxWaitTime,
 FailsafeConcurrencyBuilderOptions fn)

handleFailures

public static FailsafeRetryPolicyBuilderOptions handleFailures(List<Class<? extends Throwable>> failures)

handleStatusCodes

public static FailsafeRetryPolicyBuilderOptions handleStatusCodes(List<Integer> statusCodes)