public interface ReactiveDocumentOperations
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Void> |
bulkUpdate(List<UpdateQuery> queries,
BulkOptions bulkOptions,
IndexCoordinates index)
Bulk update all objects.
|
default reactor.core.publisher.Mono<Void> |
bulkUpdate(List<UpdateQuery> queries,
IndexCoordinates index)
Bulk update all objects.
|
reactor.core.publisher.Mono<String> |
delete(Object entity)
Delete the given entity extracting index and type from entity metadata.
|
reactor.core.publisher.Mono<String> |
delete(Object entity,
IndexCoordinates index)
Delete the given entity extracting index and type from entity metadata.
|
reactor.core.publisher.Mono<Long> |
deleteBy(Query query,
Class<?> entityType)
Delete the documents matching the given
Query extracting index and type from entity metadata. |
reactor.core.publisher.Mono<Long> |
deleteBy(Query query,
Class<?> entityType,
IndexCoordinates index)
Delete the documents matching the given
Query extracting index and type from entity metadata. |
reactor.core.publisher.Mono<String> |
deleteById(String id,
Class<?> entityType)
Delete the entity with given id extracting index and type from entity metadata.
|
reactor.core.publisher.Mono<String> |
deleteById(String id,
Class<?> entityType,
IndexCoordinates index)
Delete the entity with given id extracting index and type from entity metadata.
|
default reactor.core.publisher.Mono<String> |
deleteById(String id,
IndexCoordinates index)
Delete the entity with given id.
|
reactor.core.publisher.Mono<Boolean> |
exists(String id,
Class<?> entityType)
Check if an entity with given id exists.
|
reactor.core.publisher.Mono<Boolean> |
exists(String id,
Class<?> entityType,
IndexCoordinates index)
Check if an entity with given id exists.
|
<T> reactor.core.publisher.Mono<T> |
findById(String id,
Class<T> entityType)
Find the document with the given id mapped onto the given entityType.
|
<T> reactor.core.publisher.Mono<T> |
findById(String id,
Class<T> entityType,
IndexCoordinates index)
Fetch the entity with given id.
|
<T> reactor.core.publisher.Flux<T> |
multiGet(Query query,
Class<T> clazz,
IndexCoordinates index)
Execute a multiGet against elasticsearch for the given ids.
|
default <T> reactor.core.publisher.Mono<T> |
save(reactor.core.publisher.Mono<? extends T> entityPublisher)
Index the given entity, once available, extracting index and type from entity metadata.
|
default <T> reactor.core.publisher.Mono<T> |
save(reactor.core.publisher.Mono<? extends T> entityPublisher,
IndexCoordinates index)
Index the entity, once available, under the given type in the given index.
|
<T> reactor.core.publisher.Mono<T> |
save(T entity)
Index the given entity extracting index and type from entity metadata.
|
<T> reactor.core.publisher.Mono<T> |
save(T entity,
IndexCoordinates index)
Index the entity under the given type in the given index.
|
default <T> reactor.core.publisher.Flux<T> |
saveAll(Iterable<T> entities,
IndexCoordinates index)
Index entities under the given type in the given index.
|
<T> reactor.core.publisher.Flux<T> |
saveAll(reactor.core.publisher.Mono<? extends Collection<? extends T>> entities,
IndexCoordinates index)
Index entities under the given type in the given index.
|
default <T> reactor.core.publisher.Mono<T> save(reactor.core.publisher.Mono<? extends T> entityPublisher)
T
- entityPublisher
- must not be null.Mono
emitting the saved entity.<T> reactor.core.publisher.Mono<T> save(T entity)
T
- entity
- must not be null.Mono
emitting the saved entity.default <T> reactor.core.publisher.Mono<T> save(reactor.core.publisher.Mono<? extends T> entityPublisher, IndexCoordinates index)
T
- entityPublisher
- must not be null.index
- the target index, must not be nullMono
emitting the saved entity.<T> reactor.core.publisher.Mono<T> save(T entity, IndexCoordinates index)
T
- entity
- must not be null.index
- the target index, must not be nullMono
emitting the saved entity.default <T> reactor.core.publisher.Flux<T> saveAll(Iterable<T> entities, IndexCoordinates index)
T
- entities
- must not be null.index
- the target index, must not be nullFlux
emitting saved entities.<T> reactor.core.publisher.Flux<T> saveAll(reactor.core.publisher.Mono<? extends Collection<? extends T>> entities, IndexCoordinates index)
T
- entities
- must not be null.index
- the target index, must not be nullFlux
emitting saved entities.<T> reactor.core.publisher.Flux<T> multiGet(Query query, Class<T> clazz, IndexCoordinates index)
query
- the query defining the ids of the objects to getclazz
- the type of the object to be returnedindex
- the index(es) from which the objects are read.default reactor.core.publisher.Mono<Void> bulkUpdate(List<UpdateQuery> queries, IndexCoordinates index)
queries
- the queries to execute in bulkreactor.core.publisher.Mono<Void> bulkUpdate(List<UpdateQuery> queries, BulkOptions bulkOptions, IndexCoordinates index)
queries
- the queries to execute in bulkbulkOptions
- options to be added to the bulk request<T> reactor.core.publisher.Mono<T> findById(String id, Class<T> entityType)
T
- id
- the _id of the document to fetch.entityType
- the domain type used for mapping the document.Mono.empty()
if not found.<T> reactor.core.publisher.Mono<T> findById(String id, Class<T> entityType, IndexCoordinates index)
T
- id
- must not be null.index
- the target index, must not be nullMono
emitting the entity or signalling completion if none found.reactor.core.publisher.Mono<Boolean> exists(String id, Class<?> entityType)
id
- the _id of the document to look for.entityType
- the domain type used.Mono
emitting true if a matching document exists, false otherwise.reactor.core.publisher.Mono<Boolean> exists(String id, Class<?> entityType, IndexCoordinates index)
id
- the _id of the document to look for.index
- the target index, must not be nullMono
emitting true if a matching document exists, false otherwise.reactor.core.publisher.Mono<String> delete(Object entity)
entity
- must not be null.Mono
emitting the id of the removed document.reactor.core.publisher.Mono<String> delete(Object entity, IndexCoordinates index)
entity
- must not be null.index
- the target index, must not be nullMono
emitting the id of the removed document.default reactor.core.publisher.Mono<String> deleteById(String id, IndexCoordinates index)
id
- must not be null.index
- the target index, must not be nullMono
emitting the id of the removed document.reactor.core.publisher.Mono<String> deleteById(String id, Class<?> entityType)
id
- must not be null.entityType
- must not be null.Mono
emitting the id of the removed document.reactor.core.publisher.Mono<String> deleteById(String id, Class<?> entityType, IndexCoordinates index)
id
- must not be null.entityType
- must not be null.index
- the target index, must not be nullMono
emitting the id of the removed document.reactor.core.publisher.Mono<Long> deleteBy(Query query, Class<?> entityType)
Query
extracting index and type from entity metadata.query
- must not be null.entityType
- must not be null.Mono
emitting the number of the removed documents.reactor.core.publisher.Mono<Long> deleteBy(Query query, Class<?> entityType, IndexCoordinates index)
Query
extracting index and type from entity metadata.query
- must not be null.entityType
- must not be null.index
- the target index, must not be nullMono
emitting the number of the removed documents.Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.