public interface ReactiveElasticsearchOperations extends ReactiveDocumentOperations, ReactiveSearchOperations
Implemented by ReactiveElasticsearchTemplate
. Not often used but a useful option for extensibility and
testability (as it can be easily mocked, stubbed, or be the target of a JDK proxy). Command execution using
ReactiveElasticsearchOperations
is deferred until a Subscriber
subscribes to the
Publisher
.
Modifier and Type | Interface and Description |
---|---|
static interface |
ReactiveElasticsearchOperations.ClientCallback<T extends org.reactivestreams.Publisher<?>>
Callback interface to be used with
execute(ClientCallback) for operating directly on
ReactiveElasticsearchClient . |
static interface |
ReactiveElasticsearchOperations.ClusterClientCallback<T extends org.reactivestreams.Publisher<?>>
Callback interface to be used with
executeWithClusterClient(ClusterClientCallback) for operating directly
on ReactiveElasticsearchClient.Cluster . |
static interface |
ReactiveElasticsearchOperations.IndicesClientCallback<T extends org.reactivestreams.Publisher<?>>
Callback interface to be used with
executeWithIndicesClient(IndicesClientCallback) for operating directly
on ReactiveElasticsearchClient.Indices . |
Modifier and Type | Method and Description |
---|---|
ReactiveClusterOperations |
cluster()
return a
ReactiveClusterOperations instance that uses the same client communication setup as this
ElasticsearchOperations instance. |
<T> org.reactivestreams.Publisher<T> |
execute(ReactiveElasticsearchOperations.ClientCallback<org.reactivestreams.Publisher<T>> callback)
Execute within a
ReactiveElasticsearchOperations.ClientCallback managing resources and translating errors. |
<T> org.reactivestreams.Publisher<T> |
executeWithClusterClient(ReactiveElasticsearchOperations.ClusterClientCallback<org.reactivestreams.Publisher<T>> callback)
Execute within a
ReactiveElasticsearchOperations.ClusterClientCallback managing resources and translating errors. |
<T> org.reactivestreams.Publisher<T> |
executeWithIndicesClient(ReactiveElasticsearchOperations.IndicesClientCallback<org.reactivestreams.Publisher<T>> callback)
Execute within a
ReactiveElasticsearchOperations.IndicesClientCallback managing resources and translating errors. |
ElasticsearchConverter |
getElasticsearchConverter()
Get the
ElasticsearchConverter used. |
IndexCoordinates |
getIndexCoordinatesFor(Class<?> clazz) |
ElasticsearchPersistentEntity<?> |
getPersistentEntityFor(Class<?> clazz) |
ReactiveIndexOperations |
indexOps(Class<?> clazz)
Creates a
ReactiveIndexOperations that is bound to the given class |
ReactiveIndexOperations |
indexOps(IndexCoordinates index)
Creates a
ReactiveIndexOperations that is bound to the given index |
ReactiveElasticsearchOperations |
withRouting(RoutingResolver routingResolver)
Returns a copy of this instance with the same configuration, but that uses a different
RoutingResolver to
obtain routing information. |
bulkUpdate, bulkUpdate, delete, delete, delete, delete, delete, delete, exists, exists, get, get, multiGet, multiGet, save, save, save, save, saveAll, saveAll, saveAll, saveAll, update, updateByQuery
aggregate, aggregate, count, count, count, search, search, search, search, searchForPage, searchForPage, searchForPage, searchForPage, suggest, suggest
<T> org.reactivestreams.Publisher<T> execute(ReactiveElasticsearchOperations.ClientCallback<org.reactivestreams.Publisher<T>> callback)
ReactiveElasticsearchOperations.ClientCallback
managing resources and translating errors.T
- the type the Publisher emitscallback
- must not be null.Publisher
emitting results.<T> org.reactivestreams.Publisher<T> executeWithIndicesClient(ReactiveElasticsearchOperations.IndicesClientCallback<org.reactivestreams.Publisher<T>> callback)
ReactiveElasticsearchOperations.IndicesClientCallback
managing resources and translating errors.T
- the type the Publisher emitscallback
- must not be null.Publisher
emitting results.<T> org.reactivestreams.Publisher<T> executeWithClusterClient(ReactiveElasticsearchOperations.ClusterClientCallback<org.reactivestreams.Publisher<T>> callback)
ReactiveElasticsearchOperations.ClusterClientCallback
managing resources and translating errors.T
- the type the Publisher emitscallback
- must not be null.Publisher
emitting results.ElasticsearchConverter getElasticsearchConverter()
ElasticsearchConverter
used.@Nullable ElasticsearchPersistentEntity<?> getPersistentEntityFor(Class<?> clazz)
IndexCoordinates getIndexCoordinatesFor(Class<?> clazz)
clazz
- ReactiveIndexOperations indexOps(IndexCoordinates index)
ReactiveIndexOperations
that is bound to the given indexindex
- IndexCoordinates specifying the indexReactiveIndexOperations indexOps(Class<?> clazz)
ReactiveIndexOperations
that is bound to the given classclazz
- the entity clazz specifiying the index informationReactiveClusterOperations cluster()
ReactiveClusterOperations
instance that uses the same client communication setup as this
ElasticsearchOperations instance.ReactiveElasticsearchOperations withRouting(RoutingResolver routingResolver)
RoutingResolver
to
obtain routing information.routingResolver
- the RoutingResolver
value, must not be null.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.