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 Type	Method	Description
Mono<Void>	delete(T entity, @Nullable RefreshPolicy refreshPolicy)
Mono<Void>	deleteAll(Iterable<? extends T> entities, @Nullable RefreshPolicy refreshPolicy)
Mono<Void>	deleteAll(Publisher<? extends T> entityStream, @Nullable RefreshPolicy refreshPolicy)
Mono<Void>	deleteAll(@Nullable RefreshPolicy refreshPolicy)
Mono<Void>	deleteAllById(Iterable<? extends ID> ids, @Nullable RefreshPolicy refreshPolicy)
Mono<Void>	deleteById(ID id, @Nullable RefreshPolicy refreshPolicy)
Mono<Void>	deleteById(Publisher<ID> id, @Nullable RefreshPolicy refreshPolicy)
<S extends T> Mono<S>	save(S entity, @Nullable RefreshPolicy refreshPolicy)
<S extends T> Flux<S>	saveAll(Iterable<S> entities, @Nullable RefreshPolicy refreshPolicy)
<S extends T> Flux<S>	saveAll(Publisher<S> entityStream, @Nullable RefreshPolicy refreshPolicy)

Methods inherited from interface ReactiveCrudRepository

count, delete, deleteAll, deleteAll, deleteAll, deleteAllById, deleteById, deleteById, existsById, existsById, findAll, findAllById, findAllById, findById, findById, save, saveAll, saveAll

Methods inherited from interface ReactiveSortingRepository

findAll

Method Details

save

<S extends T> Mono<S> save(S entity,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

saveAll

<S extends T> Flux<S> saveAll(Iterable<S> entities,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

saveAll

<S extends T> Flux<S> saveAll(Publisher<S> entityStream,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

deleteById

Mono<Void> deleteById(ID id,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

deleteById

Mono<Void> deleteById(Publisher<ID> id,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

delete

Mono<Void> delete(T entity,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

deleteAllById

Mono<Void> deleteAllById(Iterable<? extends ID> ids,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

deleteAll

Mono<Void> deleteAll(Iterable<? extends T> entities,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

deleteAll

Mono<Void> deleteAll(Publisher<? extends T> entityStream,
 @Nullable RefreshPolicy refreshPolicy)

Since:

5.2

deleteAll

Mono<Void> deleteAll(@Nullable RefreshPolicy refreshPolicy)

Since:

5.2