Package org.springframework.data.elasticsearch.client.elc

Class ElasticsearchClients

java.lang.Object

org.springframework.data.elasticsearch.client.elc.ElasticsearchClients

public final class ElasticsearchClients
extends Object

Utility class to create the different Elasticsearch clients

Since:

4.4

Author:

Peter-Josef Meisch

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ElasticsearchClients.ElasticsearchHttpClientConfigurationCallback	ClientConfiguration.ClientConfigurationCallback to configure the Elasticsearch RestClient's Http client with a HttpAsyncClientBuilder
static interface	ElasticsearchClients.ElasticsearchRestClientConfigurationCallback	ClientConfiguration.ClientConfigurationCallback to configure the RestClient client with a RestClientBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	IMPERATIVE_CLIENT
static final String	REACTIVE_CLIENT

Constructor Summary

Constructors

Constructor	Description
ElasticsearchClients()

Method Summary

Modifier and Type	Method	Description
static AutoCloseableElasticsearchClient	createImperative(co.elastic.clients.transport.ElasticsearchTransport transport)	Creates a new ElasticsearchClient that uses the given ElasticsearchTransport.
static co.elastic.clients.elasticsearch.ElasticsearchClient	createImperative(org.elasticsearch.client.RestClient restClient)	Creates a new imperative ElasticsearchClient
static co.elastic.clients.elasticsearch.ElasticsearchClient	createImperative(org.elasticsearch.client.RestClient restClient, co.elastic.clients.transport.TransportOptions transportOptions, co.elastic.clients.json.JsonpMapper jsonpMapper)	Creates a new imperative ElasticsearchClient
static co.elastic.clients.elasticsearch.ElasticsearchClient	createImperative(ClientConfiguration clientConfiguration)	Creates a new imperative ElasticsearchClient
static co.elastic.clients.elasticsearch.ElasticsearchClient	createImperative(ClientConfiguration clientConfiguration, co.elastic.clients.transport.TransportOptions transportOptions)	Creates a new imperative ElasticsearchClient
static ReactiveElasticsearchClient	createReactive(co.elastic.clients.transport.ElasticsearchTransport transport)	Creates a new ReactiveElasticsearchClient that uses the given ElasticsearchTransport.
static ReactiveElasticsearchClient	createReactive(org.elasticsearch.client.RestClient restClient)	Creates a new ReactiveElasticsearchClient.
static ReactiveElasticsearchClient	createReactive(org.elasticsearch.client.RestClient restClient, co.elastic.clients.transport.TransportOptions transportOptions, co.elastic.clients.json.JsonpMapper jsonpMapper)	Creates a new ReactiveElasticsearchClient.
static ReactiveElasticsearchClient	createReactive(ClientConfiguration clientConfiguration)	Creates a new ReactiveElasticsearchClient
static ReactiveElasticsearchClient	createReactive(ClientConfiguration clientConfiguration, co.elastic.clients.transport.TransportOptions transportOptions)	Creates a new ReactiveElasticsearchClient
static ReactiveElasticsearchClient	createReactive(ClientConfiguration clientConfiguration, co.elastic.clients.transport.TransportOptions transportOptions, co.elastic.clients.json.JsonpMapper jsonpMapper)	Creates a new ReactiveElasticsearchClient
static co.elastic.clients.transport.ElasticsearchTransport	getElasticsearchTransport(org.elasticsearch.client.RestClient restClient, String clientType, co.elastic.clients.transport.TransportOptions transportOptions, co.elastic.clients.json.JsonpMapper jsonpMapper)	Creates an ElasticsearchTransport that will use the given client that additionally is customized with a header to contain the clientType
static org.elasticsearch.client.RestClient	getRestClient(ClientConfiguration clientConfiguration)	Creates a low level RestClient for the given configuration.

Methods inherited from class java.lang.Object

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

Field Details

IMPERATIVE_CLIENT

public static final String IMPERATIVE_CLIENT

See Also:

• Constant Field Values

REACTIVE_CLIENT

public static final String REACTIVE_CLIENT

See Also:

• Constant Field Values

Constructor Details

ElasticsearchClients

public ElasticsearchClients()

Method Details

createReactive

public static ReactiveElasticsearchClient createReactive(ClientConfiguration clientConfiguration)

Creates a new ReactiveElasticsearchClient

Parameters:

clientConfiguration - configuration options, must not be null.

Returns:

the ReactiveElasticsearchClient

createReactive

public static ReactiveElasticsearchClient createReactive(ClientConfiguration clientConfiguration,
 @Nullable
 co.elastic.clients.transport.TransportOptions transportOptions)

Creates a new ReactiveElasticsearchClient

Parameters:

clientConfiguration - configuration options, must not be null.

transportOptions - options to be added to each request.

Returns:

the ReactiveElasticsearchClient

createReactive

public static ReactiveElasticsearchClient createReactive(ClientConfiguration clientConfiguration,
 @Nullable
 co.elastic.clients.transport.TransportOptions transportOptions,
 co.elastic.clients.json.JsonpMapper jsonpMapper)

Creates a new ReactiveElasticsearchClient

Parameters:

clientConfiguration - configuration options, must not be null.

transportOptions - options to be added to each request.

jsonpMapper - the JsonpMapper to use

Returns:

the ReactiveElasticsearchClient

createReactive

public static ReactiveElasticsearchClient createReactive(org.elasticsearch.client.RestClient restClient)

Creates a new ReactiveElasticsearchClient.

Parameters:

restClient - the underlying RestClient

Returns:

the ReactiveElasticsearchClient

createReactive

public static ReactiveElasticsearchClient createReactive(org.elasticsearch.client.RestClient restClient,
 @Nullable
 co.elastic.clients.transport.TransportOptions transportOptions,
 co.elastic.clients.json.JsonpMapper jsonpMapper)

Creates a new ReactiveElasticsearchClient.

Parameters:

restClient - the underlying RestClient

transportOptions - options to be added to each request.

Returns:

the ReactiveElasticsearchClient

createReactive

public static ReactiveElasticsearchClient createReactive(co.elastic.clients.transport.ElasticsearchTransport transport)

Creates a new ReactiveElasticsearchClient that uses the given ElasticsearchTransport.

Parameters:

transport - the transport to use

Returns:

the ElasticsearchClient

createImperative

public static co.elastic.clients.elasticsearch.ElasticsearchClient createImperative(ClientConfiguration clientConfiguration)

Creates a new imperative ElasticsearchClient

Parameters:

clientConfiguration - configuration options, must not be null.

Returns:

the ElasticsearchClient

createImperative

public static co.elastic.clients.elasticsearch.ElasticsearchClient createImperative(ClientConfiguration clientConfiguration,
 co.elastic.clients.transport.TransportOptions transportOptions)

Creates a new imperative ElasticsearchClient

Parameters:

clientConfiguration - configuration options, must not be null.

transportOptions - options to be added to each request.

Returns:

the ElasticsearchClient

createImperative

public static co.elastic.clients.elasticsearch.ElasticsearchClient createImperative(org.elasticsearch.client.RestClient restClient)

Creates a new imperative ElasticsearchClient

Parameters:

restClient - the RestClient to use

Returns:

the ElasticsearchClient

createImperative

public static co.elastic.clients.elasticsearch.ElasticsearchClient createImperative(org.elasticsearch.client.RestClient restClient,
 @Nullable
 co.elastic.clients.transport.TransportOptions transportOptions,
 co.elastic.clients.json.JsonpMapper jsonpMapper)

Creates a new imperative ElasticsearchClient

Parameters:

restClient - the RestClient to use

transportOptions - options to be added to each request.

jsonpMapper - the mapper for the transport to use

Returns:

the ElasticsearchClient

createImperative

public static AutoCloseableElasticsearchClient createImperative(co.elastic.clients.transport.ElasticsearchTransport transport)

Creates a new ElasticsearchClient that uses the given ElasticsearchTransport.

Parameters:

transport - the transport to use

Returns:

the ElasticsearchClient

getRestClient

public static org.elasticsearch.client.RestClient getRestClient(ClientConfiguration clientConfiguration)

Creates a low level RestClient for the given configuration.

Parameters:

clientConfiguration - must not be null

Returns:

the RestClient

getElasticsearchTransport

public static co.elastic.clients.transport.ElasticsearchTransport getElasticsearchTransport(org.elasticsearch.client.RestClient restClient,
 String clientType,
 @Nullable
 co.elastic.clients.transport.TransportOptions transportOptions,
 co.elastic.clients.json.JsonpMapper jsonpMapper)

Creates an ElasticsearchTransport that will use the given client that additionally is customized with a header to contain the clientType

Parameters:

restClient - the client to use

clientType - the client type to pass in each request as header

transportOptions - options for the transport

jsonpMapper - mapper for the transport

Returns:

ElasticsearchTransport