Class Mutate
- java.lang.Object
-
- com.couchbase.client.java.bucket.api.Mutate
-
@Private @Uncommitted public class Mutate extends Object
Contains the logic to execute and handle mutation requests.- Since:
- 2.6.0
- Author:
- Michael Nitschinger
-
-
Constructor Summary
Constructors Constructor Description Mutate()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <D extends Document<?>>
rx.Observable<D>append(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
static rx.Observable<JsonLongDocument>
counter(String id, long delta, long initial, int expiry, CouchbaseEnvironment env, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
static <D extends Document<?>>
rx.Observable<D>insert(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
static <D extends Document<?>>
rx.Observable<D>prepend(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
static <D extends Document<?>>
rx.Observable<D>remove(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
static <D extends Document<?>>
rx.Observable<D>replace(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
static rx.Observable<Boolean>
touch(String id, int expiry, CouchbaseEnvironment env, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit)
static rx.Observable<Boolean>
unlock(String id, long cas, CouchbaseEnvironment env, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit)
static <D extends Document<?>>
rx.Observable<D>upsert(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
-
-
-
Method Detail
-
insert
public static <D extends Document<?>> rx.Observable<D> insert(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
-
upsert
public static <D extends Document<?>> rx.Observable<D> upsert(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
-
replace
public static <D extends Document<?>> rx.Observable<D> replace(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
-
remove
public static <D extends Document<?>> rx.Observable<D> remove(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
-
unlock
public static rx.Observable<Boolean> unlock(String id, long cas, CouchbaseEnvironment env, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit)
-
touch
public static rx.Observable<Boolean> touch(String id, int expiry, CouchbaseEnvironment env, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit)
-
counter
public static rx.Observable<JsonLongDocument> counter(String id, long delta, long initial, int expiry, CouchbaseEnvironment env, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
-
append
public static <D extends Document<?>> rx.Observable<D> append(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
-
prepend
public static <D extends Document<?>> rx.Observable<D> prepend(D document, CouchbaseEnvironment env, Transcoder<Document<Object>,Object> transcoder, ClusterFacade core, String bucket, long timeout, TimeUnit timeUnit, io.opentracing.Span parent)
-
-