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.IndicesClientCallback<T extends org.reactivestreams.Publisher<?>>
Callback interface to be used with
executeWithIndicesClient(IndicesClientCallback) for operating directly on
ReactiveElasticsearchClient.Indices . |
bulkUpdate, bulkUpdate, delete, delete, delete, delete, delete, delete, delete, exists, exists, exists, findById, findById, get, get, multiGet, multiGet, save, save, save, save, saveAll, saveAll, saveAll, saveAll, update
aggregate, aggregate, count, count, count, find, find, find, find, 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.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 informationCopyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.