org.springframework.data.aerospike.core

Interface ReactiveAerospikeOperations

All Known Implementing Classes:

ReactiveAerospikeTemplate

public interface ReactiveAerospikeOperations

Aerospike specific data access operations.

Author:

luke

Method Summary

Modifier and Type	Method and Description
<T> reactor.core.publisher.Mono<T>	add(T objectToAddTo, java.util.Map<java.lang.String,java.lang.Long> values)
<T> reactor.core.publisher.Mono<T>	add(T objectToAddTo, java.lang.String binName, long value)
<T> reactor.core.publisher.Flux<T>	aggregate(com.aerospike.client.query.Filter filter, java.lang.Class<T> outputType, java.lang.String module, java.lang.String function, java.util.List<com.aerospike.client.Value> arguments)
<T> reactor.core.publisher.Mono<T>	append(T objectToAppendTo, java.util.Map<java.lang.String,java.lang.String> values)
<T> reactor.core.publisher.Mono<T>	append(T objectToAppendTo, java.lang.String binName, java.lang.String value)
reactor.core.publisher.Mono<java.lang.Long>	count(java.lang.Class<?> type)
reactor.core.publisher.Mono<java.lang.Long>	count(java.lang.Class<?> type, java.lang.String setName)
reactor.core.publisher.Mono<java.lang.Long>	count(Query query, java.lang.Class<?> javaType)
<T> reactor.core.publisher.Mono<java.lang.Void>	createIndex(java.lang.Class<T> domainType, java.lang.String indexName, java.lang.String binName, com.aerospike.client.query.IndexType indexType) Creates index by specified name in Aerospike.
reactor.core.publisher.Mono<java.lang.Boolean>	delete(java.lang.Class<?> type)
reactor.core.publisher.Mono<java.lang.Boolean>	delete(java.lang.Object objectToDelete)
reactor.core.publisher.Mono<java.lang.Boolean>	delete(java.lang.Object id, java.lang.Class<?> type)
<T> reactor.core.publisher.Mono<java.lang.Void>	deleteIndex(java.lang.Class<T> domainType, java.lang.String indexName) Deletes index by specified name from Aerospike.
<T> reactor.core.publisher.Mono<T>	execute(java.util.function.Supplier<T> supplier) Execute operation against underlying store.
reactor.core.publisher.Mono<java.lang.Boolean>	exists(java.lang.Object id, java.lang.Class<?> type)
reactor.core.publisher.Mono<java.lang.Boolean>	exists(Query query, java.lang.Class<?> type)
<T> reactor.core.publisher.Flux<T>	find(Query query, java.lang.Class<T> type)
<T> reactor.core.publisher.Flux<T>	findAll(java.lang.Class<T> type)
<T> reactor.core.publisher.Flux<T>	findAll(org.springframework.data.domain.Sort sort, java.lang.Class<T> type)
<T> reactor.core.publisher.Mono<T>	findById(java.lang.Object id, java.lang.Class<T> type)
<T> reactor.core.publisher.Flux<T>	findByIds(java.lang.Iterable<?> IDs, java.lang.Class<T> type)
<T> reactor.core.publisher.Flux<T>	findInRange(long offset, long limit, org.springframework.data.domain.Sort sort, java.lang.Class<T> type)
ReactiveQueryEngine	getEngine()
org.springframework.data.mapping.context.MappingContext<?,?>	getMappingContext()
java.lang.String	getSetName(java.lang.Class<?> entityClass) The Set name used for the specified class by this template.
reactor.core.publisher.Mono<java.lang.Boolean>	indexExists(java.lang.String indexName) Checks whether index by specified name exists in Aerospike.
<T> reactor.core.publisher.Mono<T>	insert(T document) Insert operation using the WritePolicy.recordExisits policy of CREATE_ONLY
<T> reactor.core.publisher.Mono<T>	persist(T document, com.aerospike.client.policy.WritePolicy writePolicy) Persist document using specified WritePolicy
<T> reactor.core.publisher.Mono<T>	prepend(T objectToPrependTo, java.util.Map<java.lang.String,java.lang.String> values)
<T> reactor.core.publisher.Mono<T>	prepend(T objectToPrependTo, java.lang.String binName, java.lang.String value)
<T> reactor.core.publisher.Mono<T>	save(T document) Save operation.
<T> reactor.core.publisher.Mono<T>	update(T objectToUpdate) Update operation using the WritePolicy.recordExisits policy of UPDATE_ONLY

Method Detail

getSetName

java.lang.String getSetName(java.lang.Class<?> entityClass)

The Set name used for the specified class by this template.

Parameters:

entityClass - must not be null.

Returns:

insert

<T> reactor.core.publisher.Mono<T> insert(T document)

Insert operation using the WritePolicy.recordExisits policy of CREATE_ONLY

Parameters:

document -

getMappingContext

org.springframework.data.mapping.context.MappingContext<?,?> getMappingContext()

Returns:

mapping context in use.

save

<T> reactor.core.publisher.Mono<T> save(T document)

Save operation.

If document has version property - CAS algorithm is used for updating record. Version property is used for deciding whether to create new record or update existing. If version is set to zero - new record will be created, creation will fail is such record already exists. If version is greater than zero - existing record will be updated with RecordExistsAction.REPLACE_ONLY policy taking into consideration the version property of the document.

If document does not have version property - record is updated with RecordExistsAction.UPDATE policy. This means that when such record does not exist it will be created, otherwise updated.

Parameters:

document -

persist

<T> reactor.core.publisher.Mono<T> persist(T document,
                                           com.aerospike.client.policy.WritePolicy writePolicy)

Persist document using specified WritePolicy

Parameters:

document -

writePolicy -

update

<T> reactor.core.publisher.Mono<T> update(T objectToUpdate)

Update operation using the WritePolicy.recordExisits policy of UPDATE_ONLY

Parameters:

objectToUpdate -

delete

reactor.core.publisher.Mono<java.lang.Boolean> delete(java.lang.Class<?> type)

delete

reactor.core.publisher.Mono<java.lang.Boolean> delete(java.lang.Object id,
                                                      java.lang.Class<?> type)

delete

reactor.core.publisher.Mono<java.lang.Boolean> delete(java.lang.Object objectToDelete)

exists

reactor.core.publisher.Mono<java.lang.Boolean> exists(java.lang.Object id,
                                                      java.lang.Class<?> type)

exists

reactor.core.publisher.Mono<java.lang.Boolean> exists(Query query,
                                                      java.lang.Class<?> type)

find

<T> reactor.core.publisher.Flux<T> find(Query query,
                                        java.lang.Class<T> type)

findAll

<T> reactor.core.publisher.Flux<T> findAll(java.lang.Class<T> type)

findById

<T> reactor.core.publisher.Mono<T> findById(java.lang.Object id,
                                            java.lang.Class<T> type)

findByIds

<T> reactor.core.publisher.Flux<T> findByIds(java.lang.Iterable<?> IDs,
                                             java.lang.Class<T> type)

add

<T> reactor.core.publisher.Mono<T> add(T objectToAddTo,
                                       java.util.Map<java.lang.String,java.lang.Long> values)

add

<T> reactor.core.publisher.Mono<T> add(T objectToAddTo,
                                       java.lang.String binName,
                                       long value)

append

<T> reactor.core.publisher.Mono<T> append(T objectToAppendTo,
                                          java.util.Map<java.lang.String,java.lang.String> values)

append

<T> reactor.core.publisher.Mono<T> append(T objectToAppendTo,
                                          java.lang.String binName,
                                          java.lang.String value)

prepend

<T> reactor.core.publisher.Mono<T> prepend(T objectToPrependTo,
                                           java.util.Map<java.lang.String,java.lang.String> values)

prepend

<T> reactor.core.publisher.Mono<T> prepend(T objectToPrependTo,
                                           java.lang.String binName,
                                           java.lang.String value)

aggregate

<T> reactor.core.publisher.Flux<T> aggregate(com.aerospike.client.query.Filter filter,
                                             java.lang.Class<T> outputType,
                                             java.lang.String module,
                                             java.lang.String function,
                                             java.util.List<com.aerospike.client.Value> arguments)

count

reactor.core.publisher.Mono<java.lang.Long> count(Query query,
                                                  java.lang.Class<?> javaType)

Parameters:

query -

javaType -

Returns:

execute

<T> reactor.core.publisher.Mono<T> execute(java.util.function.Supplier<T> supplier)

Execute operation against underlying store.

Parameters:

supplier - must not be null.

Returns:

findAll

<T> reactor.core.publisher.Flux<T> findAll(org.springframework.data.domain.Sort sort,
                                           java.lang.Class<T> type)

Parameters:

sort -

type -

Returns:

findInRange

<T> reactor.core.publisher.Flux<T> findInRange(long offset,
                                               long limit,
                                               org.springframework.data.domain.Sort sort,
                                               java.lang.Class<T> type)

Parameters:

offset -

limit -

sort -

type -

Returns:

count

reactor.core.publisher.Mono<java.lang.Long> count(java.lang.Class<?> type,
                                                  java.lang.String setName)

Parameters:

type -

Returns:

createIndex

<T> reactor.core.publisher.Mono<java.lang.Void> createIndex(java.lang.Class<T> domainType,
                                                            java.lang.String indexName,
                                                            java.lang.String binName,
                                                            com.aerospike.client.query.IndexType indexType)

Creates index by specified name in Aerospike.

Parameters:

domainType -

indexName -

binName -

indexType -

deleteIndex

<T> reactor.core.publisher.Mono<java.lang.Void> deleteIndex(java.lang.Class<T> domainType,
                                                            java.lang.String indexName)

Deletes index by specified name from Aerospike.

Parameters:

domainType -

indexName -

indexExists

reactor.core.publisher.Mono<java.lang.Boolean> indexExists(java.lang.String indexName)

Checks whether index by specified name exists in Aerospike.

Parameters:

indexName -

Returns:

true if exists

count

reactor.core.publisher.Mono<java.lang.Long> count(java.lang.Class<?> type)

Parameters:

type -

Returns:

getEngine

ReactiveQueryEngine getEngine()