Modifier and Type | Method and Description |
---|---|
ResponseStatusDetails |
CouchbaseException.details() |
RingBufferDiagnostics |
BackpressureException.diagostics()
Returns a
RingBufferDiagnostics which, if non-null, gives a granular breakdown of the contents of the ringbuffer at the time of this exception |
<R extends CouchbaseResponse> |
ClusterFacade.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the cluster and eventually returns a CouchbaseResponse . |
Modifier and Type | Class and Description |
---|---|
class |
InterfaceAudience
Defines the intended audience for each entity.
|
class |
InterfaceStability
Defines the stability annotations for each public or private class.
|
Modifier and Type | Interface and Description |
---|---|
interface |
WaitStrategyFactory
Factory to create a new
WaitStrategy when called. |
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.
|
long |
DefaultCoreEnvironment.configPollFloorInterval() |
long |
CoreEnvironment.configPollFloorInterval()
Returns the minimum polling interval allowed.
|
SELF |
DefaultCoreEnvironment.Builder.configPollFloorInterval(long configPollFloorInterval)
Allows to set the minimum config polling interval.
|
long |
DefaultCoreEnvironment.configPollInterval() |
long |
CoreEnvironment.configPollInterval()
Returns the proactive polling interval for cluster configurations.
|
SELF |
DefaultCoreEnvironment.Builder.configPollInterval(long configPollInterval)
Allows to set the configuration poll interval which polls the server cluster configuration proactively.
|
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.
|
CouchbaseCoreSendHook |
CoreEnvironment.couchbaseCoreSendHook()
Returns the
CouchbaseCoreSendHook if set, null otherwise. |
SELF |
DefaultCoreEnvironment.Builder.couchbaseCoreSendHook(CouchbaseCoreSendHook hook)
Allows to configure a custom core send hook, see the javadocs for it for more details.
|
SELF |
DefaultCoreEnvironment.Builder.forceSaslPlain(boolean forceSaslPlain)
Allows to forcre the KeyValue SASL authentication method to PLAIN which is used to allow authentication against LDAP-based users.
|
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.
|
SELF |
DefaultCoreEnvironment.Builder.orphanResponseReporter(OrphanResponseReporter orphanResponseReporter) |
SELF |
DefaultCoreEnvironment.Builder.orphanResponseReportingEnabled(boolean orphanResponseReportingEnabled) |
WaitStrategyFactory |
CoreEnvironment.requestBufferWaitStrategy()
Waiting strategy used by request
EventProcessor s to wait for data from RingBuffer |
SELF |
DefaultCoreEnvironment.Builder.requestBufferWaitStrategy(WaitStrategyFactory waitStrategy)
Sets a custom waiting strategy for requests.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CouchbaseCoreSendHook
This hook allows to intercept and modify the
CouchbaseRequest in the path of the CouchbaseCore.send(CouchbaseRequest) method. |
Modifier and Type | Method and Description |
---|---|
Tuple2<CouchbaseRequest,rx.Observable<CouchbaseResponse>> |
CouchbaseCoreSendHook.beforeSend(CouchbaseRequest originalRequest,
rx.Observable<CouchbaseResponse> originalResponse)
Allows to hook in before the send method on core, make sure to return either the original tuple or the modified ones from the originals.
|
Modifier and Type | Method and Description |
---|---|
ResponseStatusDetails |
CouchbaseResponse.statusDetails()
If set, provides more detailed information into the response status than the always available
ResponseStatus enum. |
void |
CouchbaseResponse.statusDetails(ResponseStatusDetails statusDetails)
Set the status details if not set previously.
|
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 |
DiagnosticsReport
Aggregates the health of all
Endpoint s. |
class |
EndpointHealth
Aggregates the health of one specific
Endpoint . |
class |
PingReport
Contains a report for all the internal service health states.
|
class |
PingServiceHealth
Represents health for a specific service on ping.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BinarySubdocMultiLookupRequest
A
BinarySubdocRequest that describes multiple lookup operations on a single document. |
interface |
BinarySubdocMultiMutationRequest
A
BinarySubdocRequest that describes multiple mutations on a single document. |
interface |
BinarySubdocMutationRequest
A
BinarySubdocRequest that describes a mutation operation. |
interface |
BinarySubdocRequest
A type of
BinaryRequest that deals with getting or mutating parts of a JSON document, aka a Sub-Document. |
Modifier and Type | Class and Description |
---|---|
class |
Lookup
Enumeration of possible mutations inside a sub-document
LookupCommand . |
class |
LookupCommand
A single lookup description inside a TODO.
|
class |
LookupCommandBuilder
Builder for
LookupCommand |
class |
MultiLookupResponse
The response for a
BinarySubdocMultiLookupRequest . |
class |
MultiMutationResponse
The response for a
BinarySubdocMultiMutationRequest . |
class |
MultiResult<OPERATION>
The result corresponding to an individual
LookupCommand or MutationCommand . |
class |
Mutation
Enumeration of possible mutations inside a sub-document
MutationCommand . |
class |
MutationCommand
A single mutation description inside a
BinarySubdocMultiMutationRequest . |
class |
MutationCommandBuilder
Builder for
MutationCommand . |
class |
SubMultiLookupDocOptionsBuilder
Document options for
SubMultiLookupRequest |
class |
SubMultiLookupRequest
Concrete implementation of a
BinarySubdocMultiLookupRequest . |
class |
SubMultiMutationDocOptionsBuilder
Document options for
SubMultiMutationRequest |
class |
SubMultiMutationRequest
Concrete implementation of a
BinarySubdocMultiMutationRequest . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSubdocMutationRequest
Base class for all
BinarySubdocMutationRequest . |
class |
AbstractSubdocRequest
Base class for all
BinarySubdocRequest . |
class |
SimpleSubdocResponse
A general-purpose response suitable for most “simple” sub-document operations (
BinarySubdocRequest and BinarySubdocMutationRequest ), as opposed to “multi-specification” sub-document operations. |
class |
SubArrayRequest
A request covering all sub-document array operations (see
SubArrayRequest.ArrayOperation ). |
class |
SubCounterRequest
A sub-document counter operation.
|
class |
SubDeleteRequest
A sub-document delete operation.
|
class |
SubDictAddRequest
A sub-document dictionary add operation.
|
class |
SubDictUpsertRequest
A sub-document dictionary upsert operation.
|
class |
SubExistRequest
A sub-document exist operation.
|
class |
SubGetCountRequest
A sub-document get count operation.
|
class |
SubGetRequest
A sub-document get operation.
|
class |
SubReplaceRequest
A sub-document replace operation.
|
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 |
RingBufferDiagnostics
Provides a granular breakdown of the queries in the ringbuffer
|
Modifier and Type | Method and Description |
---|---|
int |
RingBufferDiagnostics.countNonService()
Returns the count of all requests not associated with a particular service
|
Map<ServiceType,Integer> |
RingBufferDiagnostics.counts()
Returns a map of the type of each request, along with the current count of each in the ringbuffer
|
int |
RingBufferDiagnostics.totalCount()
Returns the count of all requests in the ringbuffer
|
Constructor and Description |
---|
RingBufferDiagnostics(Map<ServiceType,Integer> counts,
int countNonService) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultObjectMapper
Provides global access to the services of a Jackson
ObjectMapper with default configuration. |
Copyright © 2018 Couchbase, Inc.. All rights reserved.