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 . |
Modifier and Type | Method and Description |
---|---|
<T> org.reactivestreams.Publisher<T> |
execute(ReactiveElasticsearchOperations.ClientCallback<org.reactivestreams.Publisher<T>> callback)
Execute within a
ReactiveElasticsearchOperations.ClientCallback managing resources and translating errors. |
ElasticsearchConverter |
getElasticsearchConverter()
Get the
ElasticsearchConverter used. |
IndexCoordinates |
getIndexCoordinatesFor(Class<?> clazz) |
ElasticsearchPersistentEntity<?> |
getPersistentEntityFor(Class<?> clazz) |
bulkUpdate, bulkUpdate, delete, delete, deleteBy, deleteBy, deleteById, deleteById, deleteById, exists, exists, findById, findById, multiGet, save, save, save, save, saveAll, saveAll
<T> org.reactivestreams.Publisher<T> execute(ReactiveElasticsearchOperations.ClientCallback<org.reactivestreams.Publisher<T>> callback)
ReactiveElasticsearchOperations.ClientCallback
managing resources and translating errors.T
- callback
- must not be null.Publisher
emitting results.ElasticsearchConverter getElasticsearchConverter()
ElasticsearchConverter
used.@Nullable ElasticsearchPersistentEntity<?> getPersistentEntityFor(Class<?> clazz)
IndexCoordinates getIndexCoordinatesFor(Class<?> clazz)
clazz
- Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.