org.springframework.data.elasticsearch.client.reactive

Class DefaultReactiveElasticsearchClient

java.lang.Object

org.springframework.data.elasticsearch.client.reactive.DefaultReactiveElasticsearchClient

All Implemented Interfaces:

ReactiveElasticsearchClient, ReactiveElasticsearchClient.Indices

public class DefaultReactiveElasticsearchClient
extends Object
implements ReactiveElasticsearchClient, ReactiveElasticsearchClient.Indices

A WebClient based ReactiveElasticsearchClient that connects to an Elasticsearch cluster using HTTP.

Since:

3.2

Author:

Christoph Strobl, Mark Paluch, Peter-Josef Meisch, Huw Ayling-Miller, Henrique Amaral, Roman Puchkovskiy, Russell Parry, Thomas Geese, Brian Clozel, Farid Faoudi, George Popides

See Also:

ClientConfiguration, ReactiveRestClients

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.elasticsearch.client.reactive.ReactiveElasticsearchClient

ReactiveElasticsearchClient.Indices, ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback<T>, ReactiveElasticsearchClient.Status

Constructor Summary

Constructors

Constructor and Description
DefaultReactiveElasticsearchClient(HostProvider<?> hostProvider) Create a new DefaultReactiveElasticsearchClient using the given HostProvider to obtain server connections.
DefaultReactiveElasticsearchClient(HostProvider<?> hostProvider, RequestCreator requestCreator) Create a new DefaultReactiveElasticsearchClient using the given HostProvider to obtain server connections and the given RequestCreator.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation>	aggregate(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest) Execute the given SearchRequest with aggregations against the search API.
reactor.core.publisher.Mono<org.elasticsearch.action.bulk.BulkResponse>	bulk(HttpHeaders headers, org.elasticsearch.action.bulk.BulkRequest bulkRequest) Execute a BulkRequest against the bulk API.
reactor.core.publisher.Mono<Void>	closeIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest) Execute the given CloseIndexRequest against the indices API.
reactor.core.publisher.Mono<Long>	count(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest) Execute a SearchRequest against the search API.
static ReactiveElasticsearchClient	create(ClientConfiguration clientConfiguration) Create a new DefaultReactiveElasticsearchClient given ClientConfiguration.
static ReactiveElasticsearchClient	create(ClientConfiguration clientConfiguration, RequestCreator requestCreator) Create a new DefaultReactiveElasticsearchClient given ClientConfiguration and RequestCreator.
static ReactiveElasticsearchClient	create(HttpHeaders headers, String... hosts) Create a new DefaultReactiveElasticsearchClient aware of the given nodes in the cluster.
reactor.core.publisher.Mono<Boolean>	createIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest) Execute the given CreateIndexRequest against the indices API.
reactor.core.publisher.Mono<Boolean>	createIndex(HttpHeaders headers, org.elasticsearch.client.indices.CreateIndexRequest createIndexRequest) Execute the given CreateIndexRequest against the indices API.
reactor.core.publisher.Mono<org.elasticsearch.action.delete.DeleteResponse>	delete(HttpHeaders headers, org.elasticsearch.action.delete.DeleteRequest deleteRequest) Execute the given DeleteRequest against the delete API to remove a document.
reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse>	deleteBy(HttpHeaders headers, org.elasticsearch.index.reindex.DeleteByQueryRequest deleteRequest) Execute a DeleteByQueryRequest against the delete by query API.
reactor.core.publisher.Mono<Boolean>	deleteIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest request) Execute the given DeleteIndexRequest against the indices API.
reactor.core.publisher.Mono<Boolean>	deleteTemplate(HttpHeaders headers, org.elasticsearch.action.admin.indices.template.delete.DeleteIndexTemplateRequest deleteIndexTemplateRequest) Execute the given DeleteIndexTemplateRequest against the indices API.
<T> reactor.core.publisher.Mono<T>	execute(ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback<T> callback) Compose the actual command/s to run against Elasticsearch using the underlying connection.
reactor.core.publisher.Mono<Boolean>	exists(HttpHeaders headers, org.elasticsearch.action.get.GetRequest getRequest) Checks for the existence of a document.
reactor.core.publisher.Mono<Boolean>	existsIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.get.GetIndexRequest request) Execute the given GetIndexRequest against the indices API.
reactor.core.publisher.Mono<Boolean>	existsIndex(HttpHeaders headers, org.elasticsearch.client.indices.GetIndexRequest request) Execute the given GetIndexRequest against the indices API.
reactor.core.publisher.Mono<Boolean>	existsTemplate(HttpHeaders headers, org.elasticsearch.client.indices.IndexTemplatesExistRequest indexTemplatesExistRequest) Execute the given IndexTemplatesExistRequest against the indices API.
reactor.core.publisher.Mono<Void>	flushIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest) Execute the given RefreshRequest against the indices API.
reactor.core.publisher.Mono<org.elasticsearch.index.get.GetResult>	get(HttpHeaders headers, org.elasticsearch.action.get.GetRequest getRequest) Execute the given GetRequest against the get API to retrieve a document by id.
reactor.core.publisher.Mono<org.elasticsearch.client.GetAliasesResponse>	getAliases(HttpHeaders headers, org.elasticsearch.action.admin.indices.alias.get.GetAliasesRequest getAliasesRequest) Execute the given GetAliasesRequest against the indices API.
reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetFieldMappingsResponse>	getFieldMapping(HttpHeaders headers, org.elasticsearch.client.indices.GetFieldMappingsRequest getFieldMappingsRequest) Execute the given GetFieldMappingsRequest against the indices API.
reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexResponse>	getIndex(HttpHeaders headers, org.elasticsearch.client.indices.GetIndexRequest getIndexRequest) Execute the given GetIndexRequest against the indices API.
reactor.core.publisher.Mono<org.elasticsearch.action.admin.indices.mapping.get.GetMappingsResponse>	getMapping(HttpHeaders headers, org.elasticsearch.action.admin.indices.mapping.get.GetMappingsRequest getMappingsRequest) Deprecated.
reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetMappingsResponse>	getMapping(HttpHeaders headers, org.elasticsearch.client.indices.GetMappingsRequest getMappingsRequest) Execute the given GetMappingsRequest against the indices API.
reactor.core.publisher.Mono<org.elasticsearch.action.admin.indices.settings.get.GetSettingsResponse>	getSettings(HttpHeaders headers, org.elasticsearch.action.admin.indices.settings.get.GetSettingsRequest getSettingsRequest) Execute the given GetSettingsRequest against the indices API.
reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexTemplatesResponse>	getTemplate(HttpHeaders headers, org.elasticsearch.client.indices.GetIndexTemplatesRequest getIndexTemplatesRequest) Execute the given GetIndexTemplatesRequest against the indices API.
reactor.core.publisher.Mono<org.elasticsearch.action.index.IndexResponse>	index(HttpHeaders headers, org.elasticsearch.action.index.IndexRequest indexRequest) Execute the given IndexRequest against the index API to index a document.
ReactiveElasticsearchClient.Indices	indices() Gain access to index related commands.
reactor.core.publisher.Mono<org.elasticsearch.action.main.MainResponse>	info(HttpHeaders headers) Get the cluster info otherwise provided when sending an HTTP request to port 9200.
reactor.core.publisher.Flux<org.elasticsearch.action.get.MultiGetItemResponse>	multiGet(HttpHeaders headers, org.elasticsearch.action.get.MultiGetRequest multiGetRequest) Execute the given MultiGetRequest against the multi-get API to retrieve multiple documents by id.
reactor.core.publisher.Mono<Void>	openIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.open.OpenIndexRequest request) Execute the given OpenIndexRequest against the indices API.
reactor.core.publisher.Mono<Boolean>	ping(HttpHeaders headers) Pings the remote Elasticsearch cluster and emits true if the ping succeeded, false otherwise.
reactor.core.publisher.Mono<Boolean>	putMapping(HttpHeaders headers, org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest) Execute the given PutMappingRequest against the indices API.
reactor.core.publisher.Mono<Boolean>	putMapping(HttpHeaders headers, org.elasticsearch.client.indices.PutMappingRequest putMappingRequest) Execute the given PutMappingRequest against the indices API.
reactor.core.publisher.Mono<Boolean>	putTemplate(HttpHeaders headers, org.elasticsearch.client.indices.PutIndexTemplateRequest putIndexTemplateRequest) Execute the given PutIndexTemplateRequest against the indices API.
reactor.core.publisher.Mono<Void>	refreshIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest) Execute the given RefreshRequest against the indices API.
reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit>	scroll(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest) Execute the given SearchRequest against the search scroll API.
reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit>	search(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest) Execute the given SearchRequest against the search API.
reactor.core.publisher.Mono<org.elasticsearch.action.search.SearchResponse>	searchForResponse(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest) Execute the given SearchRequest against the search API returning the whole response in one Mono.
reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit>	searchTemplate(HttpHeaders headers, org.elasticsearch.script.mustache.SearchTemplateRequest searchTemplateRequest) Executes a SearchTemplateRequest against the search template API.
void	setHeadersSupplier(Supplier<HttpHeaders> headersSupplier)
reactor.core.publisher.Mono<ReactiveElasticsearchClient.Status>	status() Get the current client ReactiveElasticsearchClient.Status.
reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest>	suggest(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest) Execute the given SearchRequest against the search API.
reactor.core.publisher.Mono<org.elasticsearch.action.update.UpdateResponse>	update(HttpHeaders headers, org.elasticsearch.action.update.UpdateRequest updateRequest) Execute the given UpdateRequest against the update API to alter a document.
reactor.core.publisher.Mono<Boolean>	updateAliases(HttpHeaders headers, org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequest indicesAliasesRequest) Execute the given IndicesAliasesRequest against the indices API.
reactor.core.publisher.Mono<ByQueryResponse>	updateBy(HttpHeaders headers, org.elasticsearch.index.reindex.UpdateByQueryRequest updateRequest) Execute a UpdateByQueryRequest against the update by query API.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.data.elasticsearch.client.reactive.ReactiveElasticsearchClient

aggregate, aggregate, bulk, bulk, count, count, delete, delete, deleteBy, deleteBy, exists, exists, get, get, index, index, info, multiGet, multiGet, ping, scroll, search, search, searchForResponse, searchTemplate, searchTemplate, suggest, suggest, update, update, updateBy, updateBy

Methods inherited from interface org.springframework.data.elasticsearch.client.reactive.ReactiveElasticsearchClient.Indices

closeIndex, closeIndex, createIndex, createIndex, createIndex, deleteIndex, deleteIndex, deleteTemplate, deleteTemplate, existsIndex, existsIndex, existsIndex, existsTemplate, existsTemplate, flushIndex, flushIndex, getAliases, getAliases, getFieldMapping, getFieldMapping, getIndex, getIndex, getMapping, getMapping, getMapping, getSettings, getSettings, getTemplate, getTemplate, openIndex, openIndex, putMapping, putMapping, putMapping, putTemplate, putTemplate, refreshIndex, refreshIndex, updateAliases, updateAliases, updateMapping, updateMapping, updateMapping

Constructor Detail

DefaultReactiveElasticsearchClient

public DefaultReactiveElasticsearchClient(HostProvider<?> hostProvider)

Create a new DefaultReactiveElasticsearchClient using the given HostProvider to obtain server connections.

Parameters:

hostProvider - must not be null.

DefaultReactiveElasticsearchClient

public DefaultReactiveElasticsearchClient(HostProvider<?> hostProvider,
                                          RequestCreator requestCreator)

Create a new DefaultReactiveElasticsearchClient using the given HostProvider to obtain server connections and the given RequestCreator.

Parameters:

hostProvider - must not be null.

requestCreator - must not be null.

Method Detail

create

public static ReactiveElasticsearchClient create(HttpHeaders headers,
                                                 String... hosts)

Create a new DefaultReactiveElasticsearchClient aware of the given nodes in the cluster.
NOTE If the cluster requires authentication be sure to provide the according HttpHeaders correctly.

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

hosts - must not be null nor empty!

Returns:

new instance of DefaultReactiveElasticsearchClient.

create

public static ReactiveElasticsearchClient create(ClientConfiguration clientConfiguration)

Create a new DefaultReactiveElasticsearchClient given ClientConfiguration.
NOTE If the cluster requires authentication be sure to provide the according HttpHeaders correctly.

Parameters:

clientConfiguration - Client configuration. Must not be null.

Returns:

new instance of DefaultReactiveElasticsearchClient.

create

public static ReactiveElasticsearchClient create(ClientConfiguration clientConfiguration,
                                                 RequestCreator requestCreator)

Create a new DefaultReactiveElasticsearchClient given ClientConfiguration and RequestCreator.
NOTE If the cluster requires authentication be sure to provide the according HttpHeaders correctly.

Parameters:

clientConfiguration - Client configuration. Must not be null.

requestCreator - Request creator. Must not be null.

Returns:

new instance of DefaultReactiveElasticsearchClient.

setHeadersSupplier

public void setHeadersSupplier(Supplier<HttpHeaders> headersSupplier)

ping

public reactor.core.publisher.Mono<Boolean> ping(HttpHeaders headers)

Description copied from interface: ReactiveElasticsearchClient

Pings the remote Elasticsearch cluster and emits true if the ping succeeded, false otherwise.

Specified by:

ping in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

Returns:

the Mono emitting the result of the ping attempt.

info

public reactor.core.publisher.Mono<org.elasticsearch.action.main.MainResponse> info(HttpHeaders headers)

Description copied from interface: ReactiveElasticsearchClient

Get the cluster info otherwise provided when sending an HTTP request to port 9200.

Specified by:

info in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

Returns:

the Mono emitting the result of the info request.

get

public reactor.core.publisher.Mono<org.elasticsearch.index.get.GetResult> get(HttpHeaders headers,
                                                                              org.elasticsearch.action.get.GetRequest getRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given GetRequest against the get API to retrieve a document by id.

Specified by:

get in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getRequest - must not be null.

Returns:

the Mono emitting the result.

See Also:

Get API on elastic.co

multiGet

public reactor.core.publisher.Flux<org.elasticsearch.action.get.MultiGetItemResponse> multiGet(HttpHeaders headers,
                                                                                               org.elasticsearch.action.get.MultiGetRequest multiGetRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given MultiGetRequest against the multi-get API to retrieve multiple documents by id.

Specified by:

multiGet in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

multiGetRequest - must not be null.

Returns:

the Flux emitting the result.

See Also:

Multi Get API on elastic.co

exists

public reactor.core.publisher.Mono<Boolean> exists(HttpHeaders headers,
                                                   org.elasticsearch.action.get.GetRequest getRequest)

Description copied from interface: ReactiveElasticsearchClient

Checks for the existence of a document. Emits true if it exists, false otherwise.

Specified by:

exists in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getRequest - must not be null.

Returns:

the Mono emitting true if it exists, false otherwise.

index

public reactor.core.publisher.Mono<org.elasticsearch.action.index.IndexResponse> index(HttpHeaders headers,
                                                                                       org.elasticsearch.action.index.IndexRequest indexRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given IndexRequest against the index API to index a document.

Specified by:

index in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

indexRequest - must not be null.

Returns:

the Mono emitting the IndexResponse.

See Also:

Index API on elastic.co

indices

public ReactiveElasticsearchClient.Indices indices()

Description copied from interface: ReactiveElasticsearchClient

Gain access to index related commands.

Specified by:

indices in interface ReactiveElasticsearchClient

Returns:

access to index related commands.

update

public reactor.core.publisher.Mono<org.elasticsearch.action.update.UpdateResponse> update(HttpHeaders headers,
                                                                                          org.elasticsearch.action.update.UpdateRequest updateRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given UpdateRequest against the update API to alter a document.

Specified by:

update in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

updateRequest - must not be null.

Returns:

the Mono emitting the UpdateResponse.

See Also:

Update API on elastic.co

delete

public reactor.core.publisher.Mono<org.elasticsearch.action.delete.DeleteResponse> delete(HttpHeaders headers,
                                                                                          org.elasticsearch.action.delete.DeleteRequest deleteRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given DeleteRequest against the delete API to remove a document.

Specified by:

delete in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

deleteRequest - must not be null.

Returns:

the Mono emitting the DeleteResponse.

See Also:

Delete API on elastic.co

count

public reactor.core.publisher.Mono<Long> count(HttpHeaders headers,
                                               org.elasticsearch.action.search.SearchRequest searchRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute a SearchRequest against the search API.

Specified by:

count in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

searchRequest - must not be null.

Returns:

the Mono emitting the count result.

See Also:

Count API on elastic.co

searchTemplate

public reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit> searchTemplate(HttpHeaders headers,
                                                                                      org.elasticsearch.script.mustache.SearchTemplateRequest searchTemplateRequest)

Description copied from interface: ReactiveElasticsearchClient

Executes a SearchTemplateRequest against the search template API.

Specified by:

searchTemplate in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

searchTemplateRequest - must not be null.

Returns:

the Flux emitting hits one by one.

See Also:

Search Template API on elastic.co

search

public reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit> search(HttpHeaders headers,
                                                                              org.elasticsearch.action.search.SearchRequest searchRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given SearchRequest against the search API.

Specified by:

search in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

searchRequest - must not be null.

Returns:

the Flux emitting hits one by one.

See Also:

Search API on elastic.co

searchForResponse

public reactor.core.publisher.Mono<org.elasticsearch.action.search.SearchResponse> searchForResponse(HttpHeaders headers,
                                                                                                     org.elasticsearch.action.search.SearchRequest searchRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given SearchRequest against the search API returning the whole response in one Mono.

Specified by:

searchForResponse in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

searchRequest - must not be null.

Returns:

the Mono emitting the whole SearchResponse.

See Also:

Search API on elastic.co

suggest

public reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> suggest(HttpHeaders headers,
                                                                                     org.elasticsearch.action.search.SearchRequest searchRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given SearchRequest against the search API.

Specified by:

suggest in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

searchRequest - must not be null.

Returns:

the Flux emitting suggestions one by one.

aggregate

public reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation> aggregate(HttpHeaders headers,
                                                                                                org.elasticsearch.action.search.SearchRequest searchRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given SearchRequest with aggregations against the search API.

Specified by:

aggregate in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

searchRequest - must not be null.

Returns:

the Flux emitting Aggregation one by one.

See Also:

Search API on elastic.co

scroll

public reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit> scroll(HttpHeaders headers,
                                                                              org.elasticsearch.action.search.SearchRequest searchRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute the given SearchRequest against the search scroll API.
Scroll keeps track of scrollIds returned by the server and provides them when requesting more results via _search/scroll. All bound server resources are freed on completion.

Specified by:

scroll in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

searchRequest - must not be null.

Returns:

the Flux emitting hits one by one.

See Also:

Search Scroll API on elastic.co

deleteBy

public reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse> deleteBy(HttpHeaders headers,
                                                                                                  org.elasticsearch.index.reindex.DeleteByQueryRequest deleteRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute a DeleteByQueryRequest against the delete by query API.

Specified by:

deleteBy in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

deleteRequest - must not be null.

Returns:

a Mono emitting operation response.

See Also:

Delete By Query API on elastic.co

updateBy

public reactor.core.publisher.Mono<ByQueryResponse> updateBy(HttpHeaders headers,
                                                             org.elasticsearch.index.reindex.UpdateByQueryRequest updateRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute a UpdateByQueryRequest against the update by query API.

Specified by:

updateBy in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

updateRequest - must not be null.

Returns:

a Mono emitting operation response.

See Also:

Update By * Query API on elastic.co

bulk

public reactor.core.publisher.Mono<org.elasticsearch.action.bulk.BulkResponse> bulk(HttpHeaders headers,
                                                                                    org.elasticsearch.action.bulk.BulkRequest bulkRequest)

Description copied from interface: ReactiveElasticsearchClient

Execute a BulkRequest against the bulk API.

Specified by:

bulk in interface ReactiveElasticsearchClient

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

bulkRequest - must not be null.

Returns:

a Mono emitting operation response.

See Also:

Bulk API on elastic.co

execute

public <T> reactor.core.publisher.Mono<T> execute(ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback<T> callback)

Description copied from interface: ReactiveElasticsearchClient

Compose the actual command/s to run against Elasticsearch using the underlying connection. Execute selects an active server from the available ones and retries operations that fail with a ConnectException on another node if the previously selected one becomes unavailable.

Specified by:

execute in interface ReactiveElasticsearchClient

Type Parameters:

T - the type emitted by the returned Mono.

Parameters:

callback - the callback wielding the actual command to run.

Returns:

the Mono emitting the ClientResponse once subscribed.

status

public reactor.core.publisher.Mono<ReactiveElasticsearchClient.Status> status()

Description copied from interface: ReactiveElasticsearchClient

Get the current client ReactiveElasticsearchClient.Status.
NOTE the actual implementation might choose to actively check the current cluster state by pinging known nodes.

Specified by:

status in interface ReactiveElasticsearchClient

Returns:

the actual ReactiveElasticsearchClient.Status information.

createIndex

public reactor.core.publisher.Mono<Boolean> createIndex(HttpHeaders headers,
                                                        org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given CreateIndexRequest against the indices API.

Specified by:

createIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

createIndexRequest - must not be null.

Returns:

a Mono signalling successful operation completion or an error if eg. the index already exist.

See Also:

Indices Create API on elastic.co

createIndex

public reactor.core.publisher.Mono<Boolean> createIndex(HttpHeaders headers,
                                                        org.elasticsearch.client.indices.CreateIndexRequest createIndexRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given CreateIndexRequest against the indices API.

Specified by:

createIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

createIndexRequest - must not be null.

Returns:

a Mono signalling successful operation completion or an error if eg. the index already exist.

See Also:

Indices Create API on elastic.co

closeIndex

public reactor.core.publisher.Mono<Void> closeIndex(HttpHeaders headers,
                                                    org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given CloseIndexRequest against the indices API.

Specified by:

closeIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

closeIndexRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices CLose API on elastic.co

existsIndex

public reactor.core.publisher.Mono<Boolean> existsIndex(HttpHeaders headers,
                                                        org.elasticsearch.action.admin.indices.get.GetIndexRequest request)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetIndexRequest against the indices API.

Specified by:

existsIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

request - must not be null.

Returns:

the Mono emitting true if the index exists, false otherwise.

See Also:

Indices Exists API on elastic.co

existsIndex

public reactor.core.publisher.Mono<Boolean> existsIndex(HttpHeaders headers,
                                                        org.elasticsearch.client.indices.GetIndexRequest request)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetIndexRequest against the indices API.

Specified by:

existsIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

request - must not be null.

Returns:

the Mono emitting true if the index exists, false otherwise.

See Also:

Indices Exists API on elastic.co

deleteIndex

public reactor.core.publisher.Mono<Boolean> deleteIndex(HttpHeaders headers,
                                                        org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest request)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given DeleteIndexRequest against the indices API.

Specified by:

deleteIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

request - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Delete API on elastic.co

flushIndex

public reactor.core.publisher.Mono<Void> flushIndex(HttpHeaders headers,
                                                    org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given RefreshRequest against the indices API.

Specified by:

flushIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

flushRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Flush API on elastic.co

getMapping

@Deprecated
public reactor.core.publisher.Mono<org.elasticsearch.action.admin.indices.mapping.get.GetMappingsResponse> getMapping(HttpHeaders headers,
                                                                                                                                  org.elasticsearch.action.admin.indices.mapping.get.GetMappingsRequest getMappingsRequest)

Deprecated.

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetMappingsRequest against the indices API.

Specified by:

getMapping in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getMappingsRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Flush API on elastic.co

getMapping

public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetMappingsResponse> getMapping(HttpHeaders headers,
                                                                                                    org.elasticsearch.client.indices.GetMappingsRequest getMappingsRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetMappingsRequest against the indices API.

Specified by:

getMapping in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getMappingsRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Get mapping API on elastic.co

getFieldMapping

public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetFieldMappingsResponse> getFieldMapping(HttpHeaders headers,
                                                                                                              org.elasticsearch.client.indices.GetFieldMappingsRequest getFieldMappingsRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetFieldMappingsRequest against the indices API.

Specified by:

getFieldMapping in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getFieldMappingsRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Flush API on elastic.co

getSettings

public reactor.core.publisher.Mono<org.elasticsearch.action.admin.indices.settings.get.GetSettingsResponse> getSettings(HttpHeaders headers,
                                                                                                                        org.elasticsearch.action.admin.indices.settings.get.GetSettingsRequest getSettingsRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetSettingsRequest against the indices API.

Specified by:

getSettings in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getSettingsRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Flush API on elastic.co

putMapping

public reactor.core.publisher.Mono<Boolean> putMapping(HttpHeaders headers,
                                                       org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given PutMappingRequest against the indices API.

Specified by:

putMapping in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

putMappingRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Put Mapping API on elastic.co

putMapping

public reactor.core.publisher.Mono<Boolean> putMapping(HttpHeaders headers,
                                                       org.elasticsearch.client.indices.PutMappingRequest putMappingRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given PutMappingRequest against the indices API.

Specified by:

putMapping in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

putMappingRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Put Mapping API on elastic.co

openIndex

public reactor.core.publisher.Mono<Void> openIndex(HttpHeaders headers,
                                                   org.elasticsearch.action.admin.indices.open.OpenIndexRequest request)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given OpenIndexRequest against the indices API.

Specified by:

openIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

request - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Open API on elastic.co

refreshIndex

public reactor.core.publisher.Mono<Void> refreshIndex(HttpHeaders headers,
                                                      org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given RefreshRequest against the indices API.

Specified by:

refreshIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

refreshRequest - must not be null.

Returns:

a Mono signalling operation completion or an error if eg. the index does not exist.

See Also:

Indices Refresh API on elastic.co

updateAliases

public reactor.core.publisher.Mono<Boolean> updateAliases(HttpHeaders headers,
                                                          org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequest indicesAliasesRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given IndicesAliasesRequest against the indices API.

Specified by:

updateAliases in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

indicesAliasesRequest - must not be null

Returns:

a Mono signalling operation completion.

getAliases

public reactor.core.publisher.Mono<org.elasticsearch.client.GetAliasesResponse> getAliases(HttpHeaders headers,
                                                                                           org.elasticsearch.action.admin.indices.alias.get.GetAliasesRequest getAliasesRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetAliasesRequest against the indices API.

Specified by:

getAliases in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getAliasesRequest - must not be null

Returns:

a Mono signalling operation completion.

putTemplate

public reactor.core.publisher.Mono<Boolean> putTemplate(HttpHeaders headers,
                                                        org.elasticsearch.client.indices.PutIndexTemplateRequest putIndexTemplateRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given PutIndexTemplateRequest against the indices API.

Specified by:

putTemplate in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

putIndexTemplateRequest - must not be null

Returns:

a Mono signalling operation completion.

getTemplate

public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexTemplatesResponse> getTemplate(HttpHeaders headers,
                                                                                                           org.elasticsearch.client.indices.GetIndexTemplatesRequest getIndexTemplatesRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetIndexTemplatesRequest against the indices API.

Specified by:

getTemplate in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getIndexTemplatesRequest - must not be null

Returns:

a Mono with the GetIndexTemplatesResponse.

existsTemplate

public reactor.core.publisher.Mono<Boolean> existsTemplate(HttpHeaders headers,
                                                           org.elasticsearch.client.indices.IndexTemplatesExistRequest indexTemplatesExistRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given IndexTemplatesExistRequest against the indices API.

Specified by:

existsTemplate in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

indexTemplatesExistRequest - must not be null

Returns:

the Mono emitting true if the template exists, false otherwise.

deleteTemplate

public reactor.core.publisher.Mono<Boolean> deleteTemplate(HttpHeaders headers,
                                                           org.elasticsearch.action.admin.indices.template.delete.DeleteIndexTemplateRequest deleteIndexTemplateRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given DeleteIndexTemplateRequest against the indices API.

Specified by:

deleteTemplate in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

deleteIndexTemplateRequest - must not be null

Returns:

the Mono emitting true if the template exists, false otherwise.

getIndex

public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexResponse> getIndex(HttpHeaders headers,
                                                                                               org.elasticsearch.client.indices.GetIndexRequest getIndexRequest)

Description copied from interface: ReactiveElasticsearchClient.Indices

Execute the given GetIndexRequest against the indices API.

Specified by:

getIndex in interface ReactiveElasticsearchClient.Indices

Parameters:

headers - Use HttpHeaders to provide eg. authentication data. Must not be null.

getIndexRequest - must not be null

Returns:

the Mono emitting the response