Class CouchbaseAsyncRepository
- java.lang.Object
-
- com.couchbase.client.java.repository.CouchbaseAsyncRepository
-
- All Implemented Interfaces:
AsyncRepository
@Public @Experimental public class CouchbaseAsyncRepository extends Object implements AsyncRepository
-
-
Constructor Summary
Constructors Constructor Description CouchbaseAsyncRepository(AsyncBucket bucket)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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, PersistTo persistTo, ReplicateTo replicateTo, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>
remove(String id, PersistTo persistTo, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>
remove(String id, ReplicateTo replicateTo, Class<T> entityClass)
<T> rx.Observable<EntityDocument<T>>
remove(String id, 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)
-
-
-
Constructor Detail
-
CouchbaseAsyncRepository
public CouchbaseAsyncRepository(AsyncBucket bucket)
-
-
Method Detail
-
get
public <T> rx.Observable<EntityDocument<T>> get(String id, Class<T> entityClass)
- Specified by:
get
in interfaceAsyncRepository
-
getFromReplica
public <T> rx.Observable<EntityDocument<T>> getFromReplica(String id, ReplicaMode type, Class<T> entityClass)
- Specified by:
getFromReplica
in interfaceAsyncRepository
-
getAndLock
public <T> rx.Observable<EntityDocument<T>> getAndLock(String id, int lockTime, Class<T> entityClass)
- Specified by:
getAndLock
in interfaceAsyncRepository
-
getAndTouch
public <T> rx.Observable<EntityDocument<T>> getAndTouch(String id, int expiry, Class<T> entityClass)
- Specified by:
getAndTouch
in interfaceAsyncRepository
-
upsert
public <T> rx.Observable<EntityDocument<T>> upsert(EntityDocument<T> document)
- Specified by:
upsert
in interfaceAsyncRepository
-
upsert
public <T> rx.Observable<EntityDocument<T>> upsert(EntityDocument<T> document, PersistTo persistTo)
- Specified by:
upsert
in interfaceAsyncRepository
-
upsert
public <T> rx.Observable<EntityDocument<T>> upsert(EntityDocument<T> document, ReplicateTo replicateTo)
- Specified by:
upsert
in interfaceAsyncRepository
-
upsert
public <T> rx.Observable<EntityDocument<T>> upsert(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
- Specified by:
upsert
in interfaceAsyncRepository
-
insert
public <T> rx.Observable<EntityDocument<T>> insert(EntityDocument<T> document)
- Specified by:
insert
in interfaceAsyncRepository
-
insert
public <T> rx.Observable<EntityDocument<T>> insert(EntityDocument<T> document, PersistTo persistTo)
- Specified by:
insert
in interfaceAsyncRepository
-
insert
public <T> rx.Observable<EntityDocument<T>> insert(EntityDocument<T> document, ReplicateTo replicateTo)
- Specified by:
insert
in interfaceAsyncRepository
-
insert
public <T> rx.Observable<EntityDocument<T>> insert(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
- Specified by:
insert
in interfaceAsyncRepository
-
replace
public <T> rx.Observable<EntityDocument<T>> replace(EntityDocument<T> document)
- Specified by:
replace
in interfaceAsyncRepository
-
replace
public <T> rx.Observable<EntityDocument<T>> replace(EntityDocument<T> document, PersistTo persistTo)
- Specified by:
replace
in interfaceAsyncRepository
-
replace
public <T> rx.Observable<EntityDocument<T>> replace(EntityDocument<T> document, ReplicateTo replicateTo)
- Specified by:
replace
in interfaceAsyncRepository
-
replace
public <T> rx.Observable<EntityDocument<T>> replace(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
- Specified by:
replace
in interfaceAsyncRepository
-
exists
public rx.Observable<Boolean> exists(String id)
- Specified by:
exists
in interfaceAsyncRepository
-
exists
public <T> rx.Observable<Boolean> exists(EntityDocument<T> document)
- Specified by:
exists
in interfaceAsyncRepository
-
remove
public <T> rx.Observable<EntityDocument<T>> remove(EntityDocument<T> document)
- Specified by:
remove
in interfaceAsyncRepository
-
remove
public <T> rx.Observable<EntityDocument<T>> remove(EntityDocument<T> document, PersistTo persistTo)
- Specified by:
remove
in interfaceAsyncRepository
-
remove
public <T> rx.Observable<EntityDocument<T>> remove(EntityDocument<T> document, ReplicateTo replicateTo)
- Specified by:
remove
in interfaceAsyncRepository
-
remove
public <T> rx.Observable<EntityDocument<T>> remove(EntityDocument<T> document, PersistTo persistTo, ReplicateTo replicateTo)
- Specified by:
remove
in interfaceAsyncRepository
-
remove
public <T> rx.Observable<EntityDocument<T>> remove(String id, Class<T> entityClass)
- Specified by:
remove
in interfaceAsyncRepository
-
remove
public <T> rx.Observable<EntityDocument<T>> remove(String id, PersistTo persistTo, Class<T> entityClass)
- Specified by:
remove
in interfaceAsyncRepository
-
remove
public <T> rx.Observable<EntityDocument<T>> remove(String id, ReplicateTo replicateTo, Class<T> entityClass)
- Specified by:
remove
in interfaceAsyncRepository
-
remove
public <T> rx.Observable<EntityDocument<T>> remove(String id, PersistTo persistTo, ReplicateTo replicateTo, Class<T> entityClass)
- Specified by:
remove
in interfaceAsyncRepository
-
-