Interface ReactiveElasticsearchRepository<T,ID>
- All Superinterfaces:
ReactiveCrudRepository<T,
,ID> ReactiveSortingRepository<T,
,ID> Repository<T,
ID>
- All Known Implementing Classes:
SimpleReactiveElasticsearchRepository
@NoRepositoryBean
public interface ReactiveElasticsearchRepository<T,ID>
extends ReactiveSortingRepository<T,ID>, ReactiveCrudRepository<T,ID>
Elasticsearch specific
Repository
interface with reactive support.- Since:
- 3.2
- Author:
- Christoph Strobl
-
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<Void>
delete
(T entity, RefreshPolicy refreshPolicy) reactor.core.publisher.Mono<Void>
deleteAll
(Iterable<? extends T> entities, RefreshPolicy refreshPolicy) reactor.core.publisher.Mono<Void>
deleteAll
(org.reactivestreams.Publisher<? extends T> entityStream, RefreshPolicy refreshPolicy) reactor.core.publisher.Mono<Void>
deleteAll
(RefreshPolicy refreshPolicy) reactor.core.publisher.Mono<Void>
deleteAllById
(Iterable<? extends ID> ids, RefreshPolicy refreshPolicy) reactor.core.publisher.Mono<Void>
deleteById
(ID id, RefreshPolicy refreshPolicy) reactor.core.publisher.Mono<Void>
deleteById
(org.reactivestreams.Publisher<ID> id, RefreshPolicy refreshPolicy) <S extends T>
reactor.core.publisher.Mono<S>save
(S entity, RefreshPolicy refreshPolicy) <S extends T>
reactor.core.publisher.Flux<S>saveAll
(Iterable<S> entities, RefreshPolicy refreshPolicy) <S extends T>
reactor.core.publisher.Flux<S>saveAll
(org.reactivestreams.Publisher<S> entityStream, RefreshPolicy refreshPolicy) Methods inherited from interface org.springframework.data.repository.reactive.ReactiveCrudRepository
count, delete, deleteAll, deleteAll, deleteAll, deleteAllById, deleteById, deleteById, existsById, existsById, findAll, findAllById, findAllById, findById, findById, save, saveAll, saveAll
Methods inherited from interface org.springframework.data.repository.reactive.ReactiveSortingRepository
findAll
-
Method Details
-
save
- Since:
- 5.2
-
saveAll
<S extends T> reactor.core.publisher.Flux<S> saveAll(Iterable<S> entities, @Nullable RefreshPolicy refreshPolicy) - Since:
- 5.2
-
saveAll
<S extends T> reactor.core.publisher.Flux<S> saveAll(org.reactivestreams.Publisher<S> entityStream, @Nullable RefreshPolicy refreshPolicy) - Since:
- 5.2
-
deleteById
- Since:
- 5.2
-
deleteById
reactor.core.publisher.Mono<Void> deleteById(org.reactivestreams.Publisher<ID> id, @Nullable RefreshPolicy refreshPolicy) - Since:
- 5.2
-
delete
- Since:
- 5.2
-
deleteAllById
reactor.core.publisher.Mono<Void> deleteAllById(Iterable<? extends ID> ids, @Nullable RefreshPolicy refreshPolicy) - Since:
- 5.2
-
deleteAll
reactor.core.publisher.Mono<Void> deleteAll(Iterable<? extends T> entities, @Nullable RefreshPolicy refreshPolicy) - Since:
- 5.2
-
deleteAll
reactor.core.publisher.Mono<Void> deleteAll(org.reactivestreams.Publisher<? extends T> entityStream, @Nullable RefreshPolicy refreshPolicy) - Since:
- 5.2
-
deleteAll
- Since:
- 5.2
-