Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
|
com.couchbase.client.core.env | |
com.couchbase.client.core.message | |
com.couchbase.client.core.message.analytics | |
com.couchbase.client.core.message.kv.subdoc.simple | |
com.couchbase.client.core.message.observe | |
com.couchbase.client.core.message.query | |
com.couchbase.client.core.utils |
Modifier and Type | Class and Description |
---|---|
class |
CoreContext
The
CoreContext contains required assets which are shared on a per-core basis. |
Modifier and Type | Method and Description |
---|---|
boolean |
CoreEnvironment.certAuthEnabled()
True if X.509 client certificate authentication is enabled.
|
SELF |
DefaultCoreEnvironment.Builder.certAuthEnabled(boolean certAuthEnabled)
Allows to enable X.509 client certificate authentication.
|
SELF |
DefaultCoreEnvironment.Builder.compressionMinRatio(double compressionMinRatio)
Allows to adjust the ratio over which the document is sent compressed over the wire - in percent.
|
SELF |
DefaultCoreEnvironment.Builder.compressionMinSize(int compressionMinSize)
Allows to adjust the minimum size of a document to be considered for compression - in bytes.
|
boolean |
CoreEnvironment.continuousKeepAliveEnabled()
If set to true, KeepAlives will be sent on a regular basis in the interval also if there is traffic on the socket, not only if its idle.
|
SELF |
DefaultCoreEnvironment.Builder.continuousKeepAliveEnabled(boolean continuousKeepAliveEnabled)
Allows to enable or disable the continous emitting of keepalive messages.
|
long |
CoreEnvironment.keepAliveErrorThreshold()
Specifies the number of times a KeepAlive message on a socket can fail before the connection is recycled.
|
SELF |
DefaultCoreEnvironment.Builder.keepAliveErrorThreshold(long keepAliveErrorThreshold)
Allows to customize the errors on keepalive messages threshold after which the connection will be recycled.
|
long |
CoreEnvironment.keepAliveTimeout()
Specifies the timeout of a keepalive operation on the socket in milliseconds.
|
SELF |
DefaultCoreEnvironment.Builder.keepAliveTimeout(long keepAliveTimeout)
Allows to customize the timeout used for keepalive operations.
|
NetworkResolution |
CoreEnvironment.networkResolution()
Allows to configure the network resolution, default being automatic.
|
SELF |
DefaultCoreEnvironment.Builder.networkResolution(NetworkResolution networkResolution)
Allows to tune the network resolution setting, pinning it to either internal or external instead of relying on the automatic mechanism.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CouchbaseRequest.isActive()
Checks if the request is unsubscribed on a timeout
|
void |
CouchbaseRequest.subscriber(rx.Subscriber subscriber)
Optionally add subscriber to check for the timeouts
|
Modifier and Type | Class and Description |
---|---|
class |
GenericAnalyticsRequest
For the lack of a better name, a analytics request against a analytics server.
|
class |
GenericAnalyticsResponse
The base response for Analytics (SQL++) requests.
|
class |
RawAnalyticsRequest
A
AnalyticsRequest that can also be prelocated , but expects a response with the uninterpreted JSON payload returned by the query service. |
class |
RawAnalyticsResponse
The response to a
RawAnalyticsRequest , which only contains the raw JSON payload returned by the Analytics service, as a ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
SubGetCountRequest
A sub-document get count operation.
|
Modifier and Type | Class and Description |
---|---|
class |
Observe
Utility class to handle observe calls and polling logic.
|
class |
ObserveViaCAS
Utility class to handle observe calls and polling logic.
|
class |
ObserveViaMutationToken
Document observe through mutation token information.
|
Modifier and Type | Class and Description |
---|---|
class |
RawQueryRequest
A
QueryRequest that can also be prelocated , but expects a response with the uninterpreted JSON payload returned by the query service. |
class |
RawQueryResponse
The response to a
RawQueryRequest , which only contains the raw JSON payload returned by the Query service, as a ByteBuf . |
Modifier and Type | Class and Description |
---|---|
class |
Blocking
Contains various utility methods related to blocking operations.
|
class |
DefaultObjectMapper
Provides global access to the services of a Jackson
ObjectMapper with default configuration. |
Copyright © 2018 Couchbase, Inc.. All rights reserved.