com.arakelian.elastic.utils

Class ElasticClientUtils

java.lang.Object

com.arakelian.elastic.utils.ElasticClientUtils

public class ElasticClientUtils
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ElasticClientUtils.RetryIoException Determines if an IOException is suitable for retry.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_TIMEOUT

Method Summary

Modifier and Type	Method and Description
static void	configure(com.fasterxml.jackson.databind.ObjectMapper mapper, VersionComponents version)
static void	configureIndexSerialization(com.fasterxml.jackson.databind.ObjectMapper mapper)
static ElasticClient	createElasticClient(java.lang.String elasticUrl, okhttp3.OkHttpClient client, com.fasterxml.jackson.databind.ObjectMapper objectMapper, VersionComponents version)
static <T> com.github.rholder.retry.Retryer<T>	createElasticRetryer()
static boolean	retryIfResponse(int status) Returns true if call to Elastic should be retried.
static boolean	retryIfResponse(retrofit2.Response<?> response) Returns true if call to Elastic should be retried.
static About	waitForElasticReady(ElasticClient elasticClient, long timeout, java.util.concurrent.TimeUnit unit)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_TIMEOUT

public static final java.lang.String DEFAULT_TIMEOUT

See Also:

Constant Field Values

Method Detail

configure

public static void configure(com.fasterxml.jackson.databind.ObjectMapper mapper,
                             VersionComponents version)

configureIndexSerialization

public static void configureIndexSerialization(com.fasterxml.jackson.databind.ObjectMapper mapper)

createElasticClient

public static ElasticClient createElasticClient(java.lang.String elasticUrl,
                                                okhttp3.OkHttpClient client,
                                                com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                                VersionComponents version)

createElasticRetryer

public static <T> com.github.rholder.retry.Retryer<T> createElasticRetryer()

retryIfResponse

public static boolean retryIfResponse(int status)

Returns true if call to Elastic should be retried.

• HTTP 1xx are informational, and retry will have no benefit.
• HTTP 2xx are success, and retry makes no sense.
• HTTP 3xx are redirect message, and should be handled by Retrofit/OkHttp3 client.
• HTTP 4xx are bad client requests, except for status 429 (TOO_MANY_REQUESTS).
• HTTP 5xx are server errors, and retry is worthwhile

Parameters:

status - status code from HTTP response

Returns:

true if call to Elastic should be retried

retryIfResponse

public static boolean retryIfResponse(retrofit2.Response<?> response)

Returns true if call to Elastic should be retried.

Parameters:

response - response from last call to Elastic

Returns:

true if call to Elastic should be retried.

waitForElasticReady

public static About waitForElasticReady(ElasticClient elasticClient,
                                        long timeout,
                                        java.util.concurrent.TimeUnit unit)