com.couchbase.client.core.message.observe

Class Observe

java.lang.Object

com.couchbase.client.core.message.observe.Observe

@InterfaceStability.Uncommitted
 @InterfaceAudience.Private
public class Observe
extends Object

Utility class to handle observe calls and polling logic.

Since:

1.0.1

Author:

Michael Nitschinger

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Observe.PersistTo Defines the possible disk persistence constraints to observe.
static class	Observe.ReplicateTo Defines the possible replication constraints to observe.

Constructor Summary

Constructors

Constructor and Description
Observe()

Method Summary

Modifier and Type	Method and Description
static rx.Observable<Boolean>	call(ClusterFacade core, String bucket, String id, long cas, boolean remove, MutationToken token, Observe.PersistTo persistTo, Observe.ReplicateTo replicateTo, Delay delay, RetryStrategy retryStrategy)
static rx.Observable<Boolean>	call(ClusterFacade core, String bucket, String id, long cas, boolean remove, MutationToken token, Observe.PersistTo persistTo, Observe.ReplicateTo replicateTo, Delay delay, RetryStrategy retryStrategy, io.opentracing.Span parent)
static rx.Observable<Boolean>	call(ClusterFacade core, String bucket, String id, long cas, boolean remove, Observe.PersistTo persistTo, Observe.ReplicateTo replicateTo, Delay delay, RetryStrategy retryStrategy)
static rx.Observable<Boolean>	call(ClusterFacade core, String bucket, String id, long cas, boolean remove, Observe.PersistTo persistTo, Observe.ReplicateTo replicateTo, Delay delay, RetryStrategy retryStrategy, io.opentracing.Span parent)
static rx.Observable<Boolean>	call(ClusterFacade core, String bucket, String id, long cas, boolean remove, Observe.PersistTo persistTo, Observe.ReplicateTo replicateTo, RetryStrategy retryStrategy)
static rx.Observable<Boolean>	call(ClusterFacade core, String bucket, String id, long cas, boolean remove, Observe.PersistTo persistTo, Observe.ReplicateTo replicateTo, RetryStrategy retryStrategy, io.opentracing.Span parent)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Observe

public Observe()

Method Detail

call

public static rx.Observable<Boolean> call(ClusterFacade core,
                                          String bucket,
                                          String id,
                                          long cas,
                                          boolean remove,
                                          Observe.PersistTo persistTo,
                                          Observe.ReplicateTo replicateTo,
                                          RetryStrategy retryStrategy)

call

public static rx.Observable<Boolean> call(ClusterFacade core,
                                          String bucket,
                                          String id,
                                          long cas,
                                          boolean remove,
                                          Observe.PersistTo persistTo,
                                          Observe.ReplicateTo replicateTo,
                                          Delay delay,
                                          RetryStrategy retryStrategy)

call

public static rx.Observable<Boolean> call(ClusterFacade core,
                                          String bucket,
                                          String id,
                                          long cas,
                                          boolean remove,
                                          MutationToken token,
                                          Observe.PersistTo persistTo,
                                          Observe.ReplicateTo replicateTo,
                                          Delay delay,
                                          RetryStrategy retryStrategy)

call

public static rx.Observable<Boolean> call(ClusterFacade core,
                                          String bucket,
                                          String id,
                                          long cas,
                                          boolean remove,
                                          Observe.PersistTo persistTo,
                                          Observe.ReplicateTo replicateTo,
                                          RetryStrategy retryStrategy,
                                          io.opentracing.Span parent)

call

public static rx.Observable<Boolean> call(ClusterFacade core,
                                          String bucket,
                                          String id,
                                          long cas,
                                          boolean remove,
                                          Observe.PersistTo persistTo,
                                          Observe.ReplicateTo replicateTo,
                                          Delay delay,
                                          RetryStrategy retryStrategy,
                                          io.opentracing.Span parent)

call

public static rx.Observable<Boolean> call(ClusterFacade core,
                                          String bucket,
                                          String id,
                                          long cas,
                                          boolean remove,
                                          MutationToken token,
                                          Observe.PersistTo persistTo,
                                          Observe.ReplicateTo replicateTo,
                                          Delay delay,
                                          RetryStrategy retryStrategy,
                                          io.opentracing.Span parent)