public class DefaultReactiveElasticsearchClient extends Object implements ReactiveElasticsearchClient, ReactiveElasticsearchClient.Indices
WebClient
based ReactiveElasticsearchClient
that connects to an Elasticsearch cluster using HTTP.ClientConfiguration
,
ReactiveRestClients
ReactiveElasticsearchClient.Indices, ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback<T>, ReactiveElasticsearchClient.Status
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 . |
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)
|
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<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> |
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.action.admin.indices.mapping.get.GetMappingsResponse> |
getMapping(HttpHeaders headers,
org.elasticsearch.action.admin.indices.mapping.get.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.index.get.GetResult> |
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> |
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. |
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. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregate, aggregate, bulk, bulk, count, count, delete, delete, deleteBy, deleteBy, exists, exists, get, get, index, index, info, multiGet, multiGet, ping, scroll, search, search, searchForResponse, suggest, suggest, update, update
closeIndex, closeIndex, createIndex, createIndex, deleteIndex, deleteIndex, deleteTemplate, deleteTemplate, existsIndex, existsIndex, existsTemplate, existsTemplate, flushIndex, flushIndex, getAliases, getAliases, getMapping, getMapping, getSettings, getSettings, getTemplate, getTemplate, openIndex, openIndex, putMapping, putMapping, putTemplate, putTemplate, refreshIndex, refreshIndex, updateAliases, updateAliases, updateMapping, updateMapping, updateMapping
public DefaultReactiveElasticsearchClient(HostProvider hostProvider)
DefaultReactiveElasticsearchClient
using the given HostProvider
to obtain server
connections.hostProvider
- must not be null.public DefaultReactiveElasticsearchClient(HostProvider hostProvider, RequestCreator requestCreator)
DefaultReactiveElasticsearchClient
using the given HostProvider
to obtain server
connections and the given RequestCreator
.hostProvider
- must not be null.requestCreator
- must not be null.public static ReactiveElasticsearchClient create(HttpHeaders headers, String... hosts)
DefaultReactiveElasticsearchClient
aware of the given nodes in the cluster. HttpHeaders
correctly.headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.hosts
- must not be null nor empty!DefaultReactiveElasticsearchClient
.public static ReactiveElasticsearchClient create(ClientConfiguration clientConfiguration)
DefaultReactiveElasticsearchClient
given ClientConfiguration
. HttpHeaders
correctly.clientConfiguration
- Client configuration. Must not be null.DefaultReactiveElasticsearchClient
.public static ReactiveElasticsearchClient create(ClientConfiguration clientConfiguration, RequestCreator requestCreator)
DefaultReactiveElasticsearchClient
given ClientConfiguration
and
RequestCreator
. HttpHeaders
correctly.clientConfiguration
- Client configuration. Must not be null.requestCreator
- Request creator. Must not be null.DefaultReactiveElasticsearchClient
.public void setHeadersSupplier(Supplier<HttpHeaders> headersSupplier)
public reactor.core.publisher.Mono<Boolean> ping(HttpHeaders headers)
ReactiveElasticsearchClient
ping
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.Mono
emitting the result of the ping attempt.public reactor.core.publisher.Mono<org.elasticsearch.action.main.MainResponse> info(HttpHeaders headers)
ReactiveElasticsearchClient
info
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.Mono
emitting the result of the info request.public reactor.core.publisher.Mono<org.elasticsearch.index.get.GetResult> get(HttpHeaders headers, org.elasticsearch.action.get.GetRequest getRequest)
ReactiveElasticsearchClient
GetRequest
against the get API to retrieve a document by id.get
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.getRequest
- must not be null.Mono
emitting the result
.public reactor.core.publisher.Flux<org.elasticsearch.index.get.GetResult> multiGet(HttpHeaders headers, org.elasticsearch.action.get.MultiGetRequest multiGetRequest)
ReactiveElasticsearchClient
MultiGetRequest
against the multi-get API to retrieve multiple documents by
id.multiGet
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.multiGetRequest
- must not be null.Flux
emitting the result
.public reactor.core.publisher.Mono<Boolean> exists(HttpHeaders headers, org.elasticsearch.action.get.GetRequest getRequest)
ReactiveElasticsearchClient
exists
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.getRequest
- must not be null.Mono
emitting true if it exists, false otherwise.public reactor.core.publisher.Mono<org.elasticsearch.action.index.IndexResponse> index(HttpHeaders headers, org.elasticsearch.action.index.IndexRequest indexRequest)
ReactiveElasticsearchClient
IndexRequest
against the index API to index a document.index
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.indexRequest
- must not be null.Mono
emitting the IndexResponse
.public ReactiveElasticsearchClient.Indices indices()
ReactiveElasticsearchClient
indices
in interface ReactiveElasticsearchClient
public reactor.core.publisher.Mono<org.elasticsearch.action.update.UpdateResponse> update(HttpHeaders headers, org.elasticsearch.action.update.UpdateRequest updateRequest)
ReactiveElasticsearchClient
UpdateRequest
against the update API to alter a document.update
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.updateRequest
- must not be null.Mono
emitting the UpdateResponse
.public reactor.core.publisher.Mono<org.elasticsearch.action.delete.DeleteResponse> delete(HttpHeaders headers, org.elasticsearch.action.delete.DeleteRequest deleteRequest)
ReactiveElasticsearchClient
DeleteRequest
against the delete API to remove a document.delete
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.deleteRequest
- must not be null.Mono
emitting the DeleteResponse
.public reactor.core.publisher.Mono<Long> count(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
ReactiveElasticsearchClient
SearchRequest
against the search API.count
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.searchRequest
- must not be null.Mono
emitting the count result.public reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit> search(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
ReactiveElasticsearchClient
SearchRequest
against the search API.search
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.searchRequest
- must not be null.Flux
emitting hits
one by one.public reactor.core.publisher.Mono<org.elasticsearch.action.search.SearchResponse> searchForResponse(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
ReactiveElasticsearchClient
SearchRequest
against the search API returning the whole response in one Mono.searchForResponse
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.searchRequest
- must not be null.Mono
emitting the whole SearchResponse
.public reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> suggest(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
ReactiveElasticsearchClient
SearchRequest
against the search API.suggest
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.searchRequest
- must not be null.Flux
emitting suggestions
one by one.public reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation> aggregate(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
ReactiveElasticsearchClient
SearchRequest
with aggregations against the search API.aggregate
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.searchRequest
- must not be null.Flux
emitting Aggregation
one by one.public reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit> scroll(HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
ReactiveElasticsearchClient
SearchRequest
against the search scroll API. scrollIds
returned by the server and provides them when
requesting more results via _search/scroll
. All bound server resources are freed on completion.scroll
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.searchRequest
- must not be null.Flux
emitting hits
one by one.public reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse> deleteBy(HttpHeaders headers, org.elasticsearch.index.reindex.DeleteByQueryRequest deleteRequest)
ReactiveElasticsearchClient
DeleteByQueryRequest
against the delete by query API.deleteBy
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.deleteRequest
- must not be null.Mono
emitting operation response.public reactor.core.publisher.Mono<org.elasticsearch.action.bulk.BulkResponse> bulk(HttpHeaders headers, org.elasticsearch.action.bulk.BulkRequest bulkRequest)
ReactiveElasticsearchClient
BulkRequest
against the bulk API.bulk
in interface ReactiveElasticsearchClient
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.bulkRequest
- must not be null.Mono
emitting operation response.public <T> reactor.core.publisher.Mono<T> execute(ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback<T> callback)
ReactiveElasticsearchClient
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.execute
in interface ReactiveElasticsearchClient
T
- the type emitted by the returned Mono.callback
- the callback
wielding the actual command to run.Mono
emitting the ClientResponse
once subscribed.public reactor.core.publisher.Mono<ReactiveElasticsearchClient.Status> status()
ReactiveElasticsearchClient
ReactiveElasticsearchClient.Status
. status
in interface ReactiveElasticsearchClient
ReactiveElasticsearchClient.Status
information.public reactor.core.publisher.Mono<Boolean> createIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest)
ReactiveElasticsearchClient.Indices
CreateIndexRequest
against the indices API.createIndex
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.createIndexRequest
- must not be null.Mono
signalling successful operation completion or an error
if
eg. the index already exist.public reactor.core.publisher.Mono<Void> closeIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest)
ReactiveElasticsearchClient.Indices
CloseIndexRequest
against the indices API.closeIndex
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.closeIndexRequest
- must not be null.Mono
signalling operation completion or an error
if eg. the index
does not exist.public reactor.core.publisher.Mono<Boolean> existsIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.get.GetIndexRequest request)
ReactiveElasticsearchClient.Indices
GetIndexRequest
against the indices API.existsIndex
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.request
- must not be null.Mono
emitting true if the index exists, false otherwise.public reactor.core.publisher.Mono<Boolean> deleteIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest request)
ReactiveElasticsearchClient.Indices
DeleteIndexRequest
against the indices API.deleteIndex
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.request
- must not be null.Mono
signalling operation completion or an error
if eg. the index
does not exist.public reactor.core.publisher.Mono<Void> flushIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest)
ReactiveElasticsearchClient.Indices
RefreshRequest
against the indices API.flushIndex
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.flushRequest
- must not be null.Mono
signalling operation completion or an error
if eg. the index
does not exist.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)
ReactiveElasticsearchClient.Indices
GetMappingsRequest
against the indices API.getMapping
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.getMappingsRequest
- must not be null.Mono
signalling operation completion or an error
if eg. the index
does not exist.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)
ReactiveElasticsearchClient.Indices
GetSettingsRequest
against the indices API.getSettings
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.getSettingsRequest
- must not be null.Mono
signalling operation completion or an error
if eg. the index
does not exist.public reactor.core.publisher.Mono<Boolean> putMapping(HttpHeaders headers, org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest)
ReactiveElasticsearchClient.Indices
PutMappingRequest
against the indices API.putMapping
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.putMappingRequest
- must not be null.Mono
signalling operation completion or an error
if eg. the index
does not exist.public reactor.core.publisher.Mono<Void> openIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.open.OpenIndexRequest request)
ReactiveElasticsearchClient.Indices
OpenIndexRequest
against the indices API.openIndex
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.request
- must not be null.Mono
signalling operation completion or an error
if eg. the index
does not exist.public reactor.core.publisher.Mono<Void> refreshIndex(HttpHeaders headers, org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest)
ReactiveElasticsearchClient.Indices
RefreshRequest
against the indices API.refreshIndex
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.refreshRequest
- must not be null.Mono
signalling operation completion or an error
if eg. the index
does not exist.public reactor.core.publisher.Mono<Boolean> updateAliases(HttpHeaders headers, org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequest indicesAliasesRequest)
ReactiveElasticsearchClient.Indices
IndicesAliasesRequest
against the indices API.updateAliases
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.indicesAliasesRequest
- must not be nullMono
signalling operation completion.public reactor.core.publisher.Mono<org.elasticsearch.client.GetAliasesResponse> getAliases(HttpHeaders headers, org.elasticsearch.action.admin.indices.alias.get.GetAliasesRequest getAliasesRequest)
ReactiveElasticsearchClient.Indices
GetAliasesRequest
against the indices API.getAliases
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.getAliasesRequest
- must not be nullMono
signalling operation completion.public reactor.core.publisher.Mono<Boolean> putTemplate(HttpHeaders headers, org.elasticsearch.client.indices.PutIndexTemplateRequest putIndexTemplateRequest)
ReactiveElasticsearchClient.Indices
PutIndexTemplateRequest
against the indices API.putTemplate
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.putIndexTemplateRequest
- must not be nullMono
signalling operation completion.public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexTemplatesResponse> getTemplate(HttpHeaders headers, org.elasticsearch.client.indices.GetIndexTemplatesRequest getIndexTemplatesRequest)
ReactiveElasticsearchClient.Indices
GetIndexTemplatesRequest
against the indices API.getTemplate
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.getIndexTemplatesRequest
- must not be nullMono
with the GetIndexTemplatesResponse.public reactor.core.publisher.Mono<Boolean> existsTemplate(HttpHeaders headers, org.elasticsearch.client.indices.IndexTemplatesExistRequest indexTemplatesExistRequest)
ReactiveElasticsearchClient.Indices
IndexTemplatesExistRequest
against the indices API.existsTemplate
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.indexTemplatesExistRequest
- must not be nullMono
emitting true if the template exists, false otherwise.public reactor.core.publisher.Mono<Boolean> deleteTemplate(HttpHeaders headers, org.elasticsearch.action.admin.indices.template.delete.DeleteIndexTemplateRequest deleteIndexTemplateRequest)
ReactiveElasticsearchClient.Indices
DeleteIndexTemplateRequest
against the indices API.deleteTemplate
in interface ReactiveElasticsearchClient.Indices
headers
- Use HttpHeaders
to provide eg. authentication data. Must not be null.deleteIndexTemplateRequest
- must not be nullMono
emitting true if the template exists, false otherwise.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.