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> rx.Observable<Boolean>	exists(EntityDocument<T> document)
rx.Observable<Boolean>	exists(String id)
<T> rx.Observable<EntityDocument<T>>	get(String id, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>	getAndLock(String id, int lockTime, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>	getAndTouch(String id, int expiry, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>	getFromReplica(String id, ReplicaMode type, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>	insert(EntityDocument<T> document)
<T> rx.Observable<EntityDocument<T>>	insert(EntityDocument<T> document, PersistTo persistTo)
<T> rx.Observable<EntityDocument<T>>	insert(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
<T> rx.Observable<EntityDocument<T>>	insert(EntityDocument<T> document, ReplicateTo replicateTo)
<T> rx.Observable<EntityDocument<T>>	remove(EntityDocument<T> document)
<T> rx.Observable<EntityDocument<T>>	remove(EntityDocument<T> document, PersistTo persistTo)
<T> rx.Observable<EntityDocument<T>>	remove(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
<T> rx.Observable<EntityDocument<T>>	remove(EntityDocument<T> document, ReplicateTo replicateTo)
<T> rx.Observable<EntityDocument<T>>	remove(String id, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>	remove(String id, PersistTo persistTo, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>	remove(String id, PersistTo persistTo, ReplicateTo replicateTo, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>	remove(String id, ReplicateTo replicateTo, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>	replace(EntityDocument<T> document)
<T> rx.Observable<EntityDocument<T>>	replace(EntityDocument<T> document, PersistTo persistTo)
<T> rx.Observable<EntityDocument<T>>	replace(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
<T> rx.Observable<EntityDocument<T>>	replace(EntityDocument<T> document, ReplicateTo replicateTo)
<T> rx.Observable<EntityDocument<T>>	upsert(EntityDocument<T> document)
<T> rx.Observable<EntityDocument<T>>	upsert(EntityDocument<T> document, PersistTo persistTo)
<T> rx.Observable<EntityDocument<T>>	upsert(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
<T> rx.Observable<EntityDocument<T>>	upsert(EntityDocument<T> document, ReplicateTo replicateTo)

Method Detail

get

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

getFromReplica

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

getAndLock

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

getAndTouch

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

exists

rx.Observable<Boolean> exists(String id)

exists

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

upsert

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

upsert

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

upsert

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

upsert

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

insert

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

insert

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

insert

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

insert

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

replace

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

replace

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

replace

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

replace

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

remove

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

remove

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

remove

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

remove

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

remove

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

remove

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

remove

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

remove

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