org.apache.paimon.rest

Class ExponentialHttpRetryInterceptor

java.lang.Object

org.apache.paimon.rest.ExponentialHttpRetryInterceptor

All Implemented Interfaces:

okhttp3.Interceptor

public class ExponentialHttpRetryInterceptor
extends Object
implements okhttp3.Interceptor

Defines exponential HTTP request retry interceptor.

The following retrievable IOException

• InterruptedIOException
• UnknownHostException
• ConnectException
• NoRouteToHostException
• SSLException

The following retrievable HTTP status codes are defined:

• TOO_MANY_REQUESTS (429)
• BAD_GATEWAY (502)
• SERVICE_UNAVAILABLE (503)
• GATEWAY_TIMEOUT (504)

The following retrievable HTTP method which is idempotent are defined:

• GET
• HEAD
• PUT
• DELETE
• TRACE
• OPTIONS

Nested Class Summary

Nested classes/interfaces inherited from interface okhttp3.Interceptor

okhttp3.Interceptor.Chain, okhttp3.Interceptor.Companion

Field Summary

Fields inherited from interface okhttp3.Interceptor

Companion

Constructor Summary

Constructors

Constructor and Description
ExponentialHttpRetryInterceptor(int maxRetries)

Method Summary

Modifier and Type	Method and Description
long	getRetryIntervalInMilliseconds(okhttp3.Response response, int execCount)
okhttp3.Response	intercept(okhttp3.Interceptor.Chain chain)
boolean	needRetry(okhttp3.Response response, int execCount)
boolean	needRetry(String method, IOException e, int execCount)

Methods inherited from class java.lang.Object

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

Constructor Detail

ExponentialHttpRetryInterceptor

public ExponentialHttpRetryInterceptor(int maxRetries)

Method Detail

intercept

public okhttp3.Response intercept(okhttp3.Interceptor.Chain chain)
                           throws IOException

Specified by:

intercept in interface okhttp3.Interceptor

Throws:

IOException

needRetry

public boolean needRetry(okhttp3.Response response,
                         int execCount)

needRetry

public boolean needRetry(String method,
                         IOException e,
                         int execCount)
                  throws IOException

Throws:

IOException

getRetryIntervalInMilliseconds

public long getRetryIntervalInMilliseconds(okhttp3.Response response,
                                           int execCount)