com.couchbase.client.java.repository

Interface AsyncRepository

All Known Implementing Classes:

CouchbaseAsyncRepository

@InterfaceAudience.Public
 @InterfaceStability.Experimental
public interface AsyncRepository

The async repository abstraction for entities on top of an AsyncBucket.

Since:

2.2.0

Author:

Michael Nitschinger

Method Summary

Modifier and Type	Method and Description
<T> Observable<Boolean>	exists(EntityDocument<T> document)
Observable<Boolean>	exists(String id)
<T> Observable<EntityDocument<T>>	get(String id, Class<T> entityClass)
<T> Observable<EntityDocument<T>>	getAndLock(String id, int lockTime, Class<T> entityClass)
<T> Observable<EntityDocument<T>>	getAndTouch(String id, int expiry, Class<T> entityClass)
<T> Observable<EntityDocument<T>>	getFromReplica(String id, ReplicaMode type, Class<T> entityClass)
<T> Observable<EntityDocument<T>>	insert(EntityDocument<T> document)
<T> Observable<EntityDocument<T>>	insert(EntityDocument<T> document, PersistTo persistTo)
<T> Observable<EntityDocument<T>>	insert(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
<T> Observable<EntityDocument<T>>	insert(EntityDocument<T> document, ReplicateTo replicateTo)
<T> Observable<EntityDocument<T>>	remove(EntityDocument<T> document)
<T> Observable<EntityDocument<T>>	remove(EntityDocument<T> document, PersistTo persistTo)
<T> Observable<EntityDocument<T>>	remove(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
<T> Observable<EntityDocument<T>>	remove(EntityDocument<T> document, ReplicateTo replicateTo)
<T> Observable<EntityDocument<T>>	remove(String id, Class<T> entityClass)
<T> Observable<EntityDocument<T>>	remove(String id, PersistTo persistTo, Class<T> entityClass)
<T> Observable<EntityDocument<T>>	remove(String id, PersistTo persistTo, ReplicateTo replicateTo, Class<T> entityClass)
<T> Observable<EntityDocument<T>>	remove(String id, ReplicateTo replicateTo, Class<T> entityClass)
<T> Observable<EntityDocument<T>>	replace(EntityDocument<T> document)
<T> Observable<EntityDocument<T>>	replace(EntityDocument<T> document, PersistTo persistTo)
<T> Observable<EntityDocument<T>>	replace(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
<T> Observable<EntityDocument<T>>	replace(EntityDocument<T> document, ReplicateTo replicateTo)
<T> Observable<EntityDocument<T>>	upsert(EntityDocument<T> document)
<T> Observable<EntityDocument<T>>	upsert(EntityDocument<T> document, PersistTo persistTo)
<T> Observable<EntityDocument<T>>	upsert(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
<T> Observable<EntityDocument<T>>	upsert(EntityDocument<T> document, ReplicateTo replicateTo)

Method Detail

get

<T> Observable<EntityDocument<T>> get(String id,
                                      Class<T> entityClass)

getFromReplica

<T> Observable<EntityDocument<T>> getFromReplica(String id,
                                                 ReplicaMode type,
                                                 Class<T> entityClass)

getAndLock

<T> Observable<EntityDocument<T>> getAndLock(String id,
                                             int lockTime,
                                             Class<T> entityClass)

getAndTouch

<T> Observable<EntityDocument<T>> getAndTouch(String id,
                                              int expiry,
                                              Class<T> entityClass)

exists

Observable<Boolean> exists(String id)

exists

<T> Observable<Boolean> exists(EntityDocument<T> document)

upsert

<T> Observable<EntityDocument<T>> upsert(EntityDocument<T> document)

upsert

<T> Observable<EntityDocument<T>> upsert(EntityDocument<T> document,
                                         PersistTo persistTo)

upsert

<T> Observable<EntityDocument<T>> upsert(EntityDocument<T> document,
                                         ReplicateTo replicateTo)

upsert

<T> Observable<EntityDocument<T>> upsert(EntityDocument<T> document,
                                         PersistTo persistTo,
                                         ReplicateTo replicateTo)

insert

<T> Observable<EntityDocument<T>> insert(EntityDocument<T> document)

insert

<T> Observable<EntityDocument<T>> insert(EntityDocument<T> document,
                                         PersistTo persistTo)

insert

<T> Observable<EntityDocument<T>> insert(EntityDocument<T> document,
                                         ReplicateTo replicateTo)

insert

<T> Observable<EntityDocument<T>> insert(EntityDocument<T> document,
                                         PersistTo persistTo,
                                         ReplicateTo replicateTo)

replace

<T> Observable<EntityDocument<T>> replace(EntityDocument<T> document)

replace

<T> Observable<EntityDocument<T>> replace(EntityDocument<T> document,
                                          PersistTo persistTo)

replace

<T> Observable<EntityDocument<T>> replace(EntityDocument<T> document,
                                          ReplicateTo replicateTo)

replace

<T> Observable<EntityDocument<T>> replace(EntityDocument<T> document,
                                          PersistTo persistTo,
                                          ReplicateTo replicateTo)

remove

<T> Observable<EntityDocument<T>> remove(EntityDocument<T> document)

remove

<T> Observable<EntityDocument<T>> remove(EntityDocument<T> document,
                                         PersistTo persistTo)

remove

<T> Observable<EntityDocument<T>> remove(EntityDocument<T> document,
                                         ReplicateTo replicateTo)

remove

<T> Observable<EntityDocument<T>> remove(EntityDocument<T> document,
                                         PersistTo persistTo,
                                         ReplicateTo replicateTo)

remove

<T> Observable<EntityDocument<T>> remove(String id,
                                         Class<T> entityClass)

remove

<T> Observable<EntityDocument<T>> remove(String id,
                                         PersistTo persistTo,
                                         Class<T> entityClass)

remove

<T> Observable<EntityDocument<T>> remove(String id,
                                         ReplicateTo replicateTo,
                                         Class<T> entityClass)

remove

<T> Observable<EntityDocument<T>> remove(String id,
                                         PersistTo persistTo,
                                         ReplicateTo replicateTo,
                                         Class<T> entityClass)