Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
|
com.couchbase.client.core.env | |
com.couchbase.client.core.hooks | |
com.couchbase.client.core.message | |
com.couchbase.client.core.message.internal | |
com.couchbase.client.core.message.kv | |
com.couchbase.client.core.tracing |
Modifier and Type | Method and Description |
---|---|
ResponseStatusDetails |
CouchbaseException.details() |
void |
CouchbaseException.details(ResponseStatusDetails responseStatusDetails) |
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 |
Modifier and Type | Interface and Description |
---|---|
interface |
WaitStrategyFactory
Factory to create a new
WaitStrategy when called. |
Modifier and Type | Method and Description |
---|---|
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.
|
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 |
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 | Class and Description |
---|---|
class |
GetAllMutationTokensRequest
Get the current high sequence numbers one could initialize streams for all partitions that are located on the server, or use in
ObserveViaMutationToken . |
class |
GetAllMutationTokensResponse
Represents response to
GetAllMutationTokensRequest . |
Modifier and Type | Class and Description |
---|---|
class |
RingBufferDiagnostics
Provides a granular breakdown of the queries in the ringbuffer
|
class |
RingBufferMonitor
Stores diagnostics on the main ringbuffer to provide additional context to BackpressureExceptions.
|
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) |
Copyright © 2018 Couchbase, Inc.. All rights reserved.