org.springframework.data.elasticsearch.client.elc

Class ReactiveElasticsearchClient

java.lang.Object

co.elastic.clients.ApiClient<co.elastic.clients.transport.ElasticsearchTransport,ReactiveElasticsearchClient>

org.springframework.data.elasticsearch.client.elc.ReactiveElasticsearchClient

All Implemented Interfaces:

AutoCloseable

public class ReactiveElasticsearchClient
extends co.elastic.clients.ApiClient<co.elastic.clients.transport.ElasticsearchTransport,ReactiveElasticsearchClient>
implements AutoCloseable

Reactive version of ElasticsearchClient.

Since:

4.4

Author:

Peter-Josef Meisch

Field Summary

Fields inherited from class co.elastic.clients.ApiClient

transport, transportOptions

Constructor Summary

Constructors

Constructor and Description
ReactiveElasticsearchClient(co.elastic.clients.transport.ElasticsearchTransport transport)
ReactiveElasticsearchClient(co.elastic.clients.transport.ElasticsearchTransport transport, co.elastic.clients.transport.TransportOptions transportOptions)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.BulkResponse>	bulk(co.elastic.clients.elasticsearch.core.BulkRequest request)
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.BulkResponse>	bulk(Function<co.elastic.clients.elasticsearch.core.BulkRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.BulkRequest>> fn)
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClearScrollResponse>	clearScroll(co.elastic.clients.elasticsearch.core.ClearScrollRequest request)
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClearScrollResponse>	clearScroll(Function<co.elastic.clients.elasticsearch.core.ClearScrollRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ClearScrollRequest>> fn)
void	close()
ReactiveElasticsearchClusterClient	cluster()
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteResponse>	delete(co.elastic.clients.elasticsearch.core.DeleteRequest request)
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteResponse>	delete(Function<co.elastic.clients.elasticsearch.core.DeleteRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteRequest>> fn)
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteByQueryResponse>	deleteByQuery(co.elastic.clients.elasticsearch.core.DeleteByQueryRequest request)
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteByQueryResponse>	deleteByQuery(Function<co.elastic.clients.elasticsearch.core.DeleteByQueryRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteByQueryRequest>> fn)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetResponse<T>>	get(Function<co.elastic.clients.elasticsearch.core.GetRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.GetRequest>> fn, Class<T> tClass)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetResponse<T>>	get(co.elastic.clients.elasticsearch.core.GetRequest request, Class<T> tClass)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.IndexResponse>	index(Function<co.elastic.clients.elasticsearch.core.IndexRequest.Builder<T>,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.IndexRequest<T>>> fn)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.IndexResponse>	index(co.elastic.clients.elasticsearch.core.IndexRequest<T> request)
ReactiveElasticsearchIndicesClient	indices()
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.InfoResponse>	info()
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.MgetResponse<T>>	mget(Function<co.elastic.clients.elasticsearch.core.MgetRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.MgetRequest>> fn, Class<T> clazz)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.MgetResponse<T>>	mget(co.elastic.clients.elasticsearch.core.MgetRequest request, Class<T> clazz)
reactor.core.publisher.Mono<co.elastic.clients.transport.endpoints.BooleanResponse>	ping()
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ReindexResponse>	reindex(Function<co.elastic.clients.elasticsearch.core.ReindexRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ReindexRequest>> fn)
reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ReindexResponse>	reindex(co.elastic.clients.elasticsearch.core.ReindexRequest request)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ScrollResponse<T>>	scroll(Function<co.elastic.clients.elasticsearch.core.ScrollRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ScrollRequest>> fn, Class<T> tDocumentClass)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ScrollResponse<T>>	scroll(co.elastic.clients.elasticsearch.core.ScrollRequest request, Class<T> tDocumentClass)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.search.ResponseBody<T>>	search(Function<co.elastic.clients.elasticsearch.core.SearchRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.SearchRequest>> fn, Class<T> tDocumentClass)
<T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.search.ResponseBody<T>>	search(co.elastic.clients.elasticsearch.core.SearchRequest request, Class<T> tDocumentClass)
<T,P> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.UpdateResponse<T>>	update(Function<co.elastic.clients.elasticsearch.core.UpdateRequest.Builder<T,P>,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.UpdateRequest<T,P>>> fn, Class<T> clazz)
<T,P> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.UpdateResponse<T>>	update(co.elastic.clients.elasticsearch.core.UpdateRequest<T,P> request, Class<T> clazz)
ReactiveElasticsearchClient	withTransportOptions(co.elastic.clients.transport.TransportOptions transportOptions)

Methods inherited from class co.elastic.clients.ApiClient

_jsonpMapper, _transport, _transportOptions, getDeserializer, withTransportOptions

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactiveElasticsearchClient

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

ReactiveElasticsearchClient

public ReactiveElasticsearchClient(co.elastic.clients.transport.ElasticsearchTransport transport,
                                   @Nullable
                                   co.elastic.clients.transport.TransportOptions transportOptions)

Method Detail

withTransportOptions

public ReactiveElasticsearchClient withTransportOptions(@Nullable
                                                        co.elastic.clients.transport.TransportOptions transportOptions)

Specified by:

withTransportOptions in class co.elastic.clients.ApiClient<co.elastic.clients.transport.ElasticsearchTransport,ReactiveElasticsearchClient>

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

cluster

public ReactiveElasticsearchClusterClient cluster()

indices

public ReactiveElasticsearchIndicesClient indices()

info

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.InfoResponse> info()

ping

public reactor.core.publisher.Mono<co.elastic.clients.transport.endpoints.BooleanResponse> ping()

index

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.IndexResponse> index(co.elastic.clients.elasticsearch.core.IndexRequest<T> request)

index

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.IndexResponse> index(Function<co.elastic.clients.elasticsearch.core.IndexRequest.Builder<T>,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.IndexRequest<T>>> fn)

bulk

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.BulkResponse> bulk(co.elastic.clients.elasticsearch.core.BulkRequest request)

bulk

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.BulkResponse> bulk(Function<co.elastic.clients.elasticsearch.core.BulkRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.BulkRequest>> fn)

get

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetResponse<T>> get(co.elastic.clients.elasticsearch.core.GetRequest request,
                                                                                                 Class<T> tClass)

update

public <T,P> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.UpdateResponse<T>> update(co.elastic.clients.elasticsearch.core.UpdateRequest<T,P> request,
                                                                                                         Class<T> clazz)

update

public <T,P> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.UpdateResponse<T>> update(Function<co.elastic.clients.elasticsearch.core.UpdateRequest.Builder<T,P>,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.UpdateRequest<T,P>>> fn,
                                                                                                         Class<T> clazz)

get

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetResponse<T>> get(Function<co.elastic.clients.elasticsearch.core.GetRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.GetRequest>> fn,
                                                                                                 Class<T> tClass)

mget

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.MgetResponse<T>> mget(co.elastic.clients.elasticsearch.core.MgetRequest request,
                                                                                                   Class<T> clazz)

mget

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.MgetResponse<T>> mget(Function<co.elastic.clients.elasticsearch.core.MgetRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.MgetRequest>> fn,
                                                                                                   Class<T> clazz)

reindex

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ReindexResponse> reindex(co.elastic.clients.elasticsearch.core.ReindexRequest request)

reindex

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ReindexResponse> reindex(Function<co.elastic.clients.elasticsearch.core.ReindexRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ReindexRequest>> fn)

delete

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteResponse> delete(co.elastic.clients.elasticsearch.core.DeleteRequest request)

delete

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteResponse> delete(Function<co.elastic.clients.elasticsearch.core.DeleteRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteRequest>> fn)

deleteByQuery

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteByQueryResponse> deleteByQuery(co.elastic.clients.elasticsearch.core.DeleteByQueryRequest request)

deleteByQuery

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteByQueryResponse> deleteByQuery(Function<co.elastic.clients.elasticsearch.core.DeleteByQueryRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteByQueryRequest>> fn)

search

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.search.ResponseBody<T>> search(co.elastic.clients.elasticsearch.core.SearchRequest request,
                                                                                                            Class<T> tDocumentClass)

search

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.search.ResponseBody<T>> search(Function<co.elastic.clients.elasticsearch.core.SearchRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.SearchRequest>> fn,
                                                                                                            Class<T> tDocumentClass)

scroll

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ScrollResponse<T>> scroll(co.elastic.clients.elasticsearch.core.ScrollRequest request,
                                                                                                       Class<T> tDocumentClass)

scroll

public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ScrollResponse<T>> scroll(Function<co.elastic.clients.elasticsearch.core.ScrollRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ScrollRequest>> fn,
                                                                                                       Class<T> tDocumentClass)

clearScroll

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClearScrollResponse> clearScroll(co.elastic.clients.elasticsearch.core.ClearScrollRequest request)

clearScroll

public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClearScrollResponse> clearScroll(Function<co.elastic.clients.elasticsearch.core.ClearScrollRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ClearScrollRequest>> fn)