Package | Description |
---|---|
com.couchbase.client.core.env | |
com.couchbase.client.core.message | |
com.couchbase.client.core.message.observe | |
com.couchbase.client.core.time |
Modifier and Type | Field and Description |
---|---|
static Delay |
DefaultCoreEnvironment.OBSERVE_INTERVAL_DELAY |
static Delay |
DefaultCoreEnvironment.RECONNECT_DELAY |
static Delay |
DefaultCoreEnvironment.RETRY_DELAY |
Modifier and Type | Method and Description |
---|---|
Delay |
DefaultCoreEnvironment.observeIntervalDelay() |
Delay |
CoreEnvironment.observeIntervalDelay()
|
Delay |
DefaultCoreEnvironment.reconnectDelay() |
Delay |
CoreEnvironment.reconnectDelay()
Returns the
Delay for node reconnects. |
Delay |
DefaultCoreEnvironment.retryDelay() |
Delay |
CoreEnvironment.retryDelay()
Returns the
Delay for request retries. |
Modifier and Type | Method and Description |
---|---|
DefaultCoreEnvironment.Builder |
DefaultCoreEnvironment.Builder.observeIntervalDelay(Delay observeIntervalDelay)
|
DefaultCoreEnvironment.Builder |
DefaultCoreEnvironment.Builder.reconnectDelay(Delay reconnectDelay)
Sets the
Delay for node reconnects (default value is a delay growing exponentially between 32ms and 4096ms). |
DefaultCoreEnvironment.Builder |
DefaultCoreEnvironment.Builder.retryDelay(Delay retryDelay)
Sets the
Delay for retries of requests (default value is a delay growing exponentially between 100us and 100ms). |
Modifier and Type | Method and Description |
---|---|
Delay |
CouchbaseRequest.retryDelay()
Returns the retry delay config
|
Delay |
AbstractCouchbaseRequest.retryDelay() |
Modifier and Type | Method and Description |
---|---|
void |
CouchbaseRequest.retryDelay(Delay delay)
Sets the retry delay config
|
void |
AbstractCouchbaseRequest.retryDelay(Delay retryDelay) |
Modifier and Type | Method and Description |
---|---|
static rx.Observable<Boolean> |
Observe.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> |
ObserveViaCAS.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> |
Observe.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> |
ObserveViaMutationToken.call(ClusterFacade core,
String bucket,
String id,
MutationToken token,
Observe.PersistTo persistTo,
Observe.ReplicateTo replicateTo,
Delay delay,
RetryStrategy retryStrategy) |
Modifier and Type | Class and Description |
---|---|
class |
ExponentialDelay
Delay which increases exponentially on every attempt.
|
class |
FixedDelay
Delay which is fixed for every attempt.
|
class |
LinearDelay
Delay which increases linearly for every attempt.
|
Modifier and Type | Method and Description |
---|---|
static Delay |
Delay.exponential(TimeUnit unit)
Creates a new
ExponentialDelay with default boundaries and factor (1, 2, 4, 8, 16, 32…). |
static Delay |
Delay.exponential(TimeUnit unit,
long upper)
Creates a new
ExponentialDelay with custom upper boundary and default factor (eg. |
static Delay |
Delay.exponential(TimeUnit unit,
long upper,
long lower)
Creates a new
ExponentialDelay with custom boundaries and default factor (eg. |
static Delay |
Delay.exponential(TimeUnit unit,
long upper,
long lower,
long growBy)
Creates a new
ExponentialDelay with custom boundaries and factor (eg. |
static Delay |
Delay.exponential(TimeUnit unit,
long upper,
long lower,
long growBy,
int powersOf)
Creates a new
ExponentialDelay on a base different from powers of two, with custom boundaries and factor (eg. |
static Delay |
Delay.fixed(long delay,
TimeUnit unit)
Creates a new
FixedDelay . |
static Delay |
Delay.linear(TimeUnit unit)
Creates a new
LinearDelay with no bounds and default factor. |
static Delay |
Delay.linear(TimeUnit unit,
long upper)
Creates a new
LinearDelay with a custom upper boundary and the default factor. |
static Delay |
Delay.linear(TimeUnit unit,
long upper,
long lower)
Creates a new
LinearDelay with a custom boundaries and the default factor. |
static Delay |
Delay.linear(TimeUnit unit,
long upper,
long lower,
long growBy)
Creates a new
LinearDelay with a custom boundaries and factor. |
Copyright © 2017 Couchbase, Inc.. All rights reserved.