Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
|
com.couchbase.client.core.endpoint | |
com.couchbase.client.core.endpoint.analytics | |
com.couchbase.client.core.endpoint.config | |
com.couchbase.client.core.endpoint.kv | |
com.couchbase.client.core.endpoint.query | |
com.couchbase.client.core.endpoint.search | |
com.couchbase.client.core.endpoint.view | |
com.couchbase.client.core.node.locate | |
com.couchbase.client.core.retry |
Modifier and Type | Field and Description |
---|---|
static com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>> |
ResponseHandler.RESPONSE_TRANSLATOR
Translates
CouchbaseRequest s into RequestEvent s. |
Modifier and Type | Method and Description |
---|---|
ResponseEvent |
ResponseEventFactory.newInstance() |
ResponseEvent |
ResponseEvent.setMessage(CouchbaseMessage message)
Set the new response as a payload for this event.
|
ResponseEvent |
ResponseEvent.setObservable(rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable) |
Modifier and Type | Method and Description |
---|---|
com.lmax.disruptor.RingBuffer<ResponseEvent> |
CoreContext.responseRingBuffer()
Returns the response ring buffer.
|
Modifier and Type | Method and Description |
---|---|
void |
ResponseHandler.onEvent(ResponseEvent event,
long sequence,
boolean endOfBatch)
Handles
ResponseEvent s that come into the response RingBuffer. |
Constructor and Description |
---|
CoreContext(CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseRingBuffer)
Creates a new
CoreContext with no core id. |
CoreContext(CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseRingBuffer,
long coreId)
Creates a new
CoreContext with no a core id. |
Modifier and Type | Method and Description |
---|---|
com.lmax.disruptor.RingBuffer<ResponseEvent> |
AbstractEndpoint.responseBuffer()
The
RingBuffer response buffer reference. |
Constructor and Description |
---|
AbstractGenericHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline)
Creates a new
AbstractGenericHandler with the default queue. |
AbstractGenericHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
Queue<REQUEST> queue,
boolean isTransient,
boolean pipeline)
Creates a new
AbstractGenericHandler with a custom queue. |
Constructor and Description |
---|
AnalyticsHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline)
Creates a new
AnalyticsHandler with the default queue for requests. |
Constructor and Description |
---|
ConfigHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline)
Creates a new
ConfigHandler with the default queue for requests. |
Constructor and Description |
---|
KeyValueHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline)
Creates a new
KeyValueHandler with the default queue for requests. |
Constructor and Description |
---|
QueryHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline)
Creates a new
QueryHandler with the default queue for requests. |
QueryHandlerV2(AbstractEndpoint endpoint,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline)
Creates a new
QueryHandlerV2 with the default queue for requests. |
Constructor and Description |
---|
SearchHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline) |
Constructor and Description |
---|
ViewHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient,
boolean pipeline)
Creates a new
ViewHandler with the default queue for requests. |
Modifier and Type | Method and Description |
---|---|
void |
ViewLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
QueryLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
Locator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Given with the environment and node information, the implementation locates the right set of nodes and dispatches the request into them.
|
void |
KeyValueLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig cluster,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
ConfigLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Modifier and Type | Method and Description |
---|---|
static void |
RetryHelper.retry(CouchbaseRequest request,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer)
Always retry the request and send it into the response buffer.
|
static void |
RetryHelper.retryOrCancel(CoreEnvironment environment,
CouchbaseRequest request,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer)
Either retry or cancel a request, based on the strategy used.
|
Copyright © 2018 Couchbase, Inc.. All rights reserved.