Uses of Class
com.couchbase.client.core.ResponseEvent
Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
=================================================
This documentation describes the domain model of the core package, covers important architecture and design
decisions and provides a solid introduction on the inner workings.
|
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 |
-
Uses of ResponseEvent in com.couchbase.client.core
Fields in com.couchbase.client.core with type parameters of type ResponseEvent Modifier and Type Field Description static com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>>
ResponseHandler. RESPONSE_TRANSLATOR
TranslatesCouchbaseRequest
s intoRequestEvent
s.Methods in com.couchbase.client.core that return ResponseEvent Modifier and Type Method 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)
Methods in com.couchbase.client.core that return types with arguments of type ResponseEvent Modifier and Type Method Description com.lmax.disruptor.RingBuffer<ResponseEvent>
CoreContext. responseRingBuffer()
Returns the response ring buffer.Methods in com.couchbase.client.core with parameters of type ResponseEvent Modifier and Type Method Description void
ResponseHandler. onEvent(ResponseEvent event, long sequence, boolean endOfBatch)
HandlesResponseEvent
s that come into the response RingBuffer.Constructor parameters in com.couchbase.client.core with type arguments of type ResponseEvent Constructor Description CoreContext(CoreEnvironment environment, com.lmax.disruptor.RingBuffer<ResponseEvent> responseRingBuffer)
Creates a newCoreContext
with no core id.CoreContext(CoreEnvironment environment, com.lmax.disruptor.RingBuffer<ResponseEvent> responseRingBuffer, long coreId)
Creates a newCoreContext
with no a core id. -
Uses of ResponseEvent in com.couchbase.client.core.endpoint
Methods in com.couchbase.client.core.endpoint that return types with arguments of type ResponseEvent Modifier and Type Method Description com.lmax.disruptor.RingBuffer<ResponseEvent>
AbstractEndpoint. responseBuffer()
TheRingBuffer
response buffer reference.Constructor parameters in com.couchbase.client.core.endpoint with type arguments of type ResponseEvent Constructor Description AbstractGenericHandler(AbstractEndpoint endpoint, com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
Creates a newAbstractGenericHandler
with the default queue.AbstractGenericHandler(AbstractEndpoint endpoint, com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer, Queue<REQUEST> queue, boolean isTransient, boolean pipeline)
Creates a newAbstractGenericHandler
with a custom queue. -
Uses of ResponseEvent in com.couchbase.client.core.endpoint.analytics
Constructor parameters in com.couchbase.client.core.endpoint.analytics with type arguments of type ResponseEvent Constructor Description AnalyticsHandler(AbstractEndpoint endpoint, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
Creates a newAnalyticsHandler
with the default queue for requests.AnalyticsHandlerV2(AbstractEndpoint endpoint, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
Creates a newAnalyticsHandlerV2
with the default queue for requests. -
Uses of ResponseEvent in com.couchbase.client.core.endpoint.config
Constructor parameters in com.couchbase.client.core.endpoint.config with type arguments of type ResponseEvent Constructor Description ConfigHandler(AbstractEndpoint endpoint, com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
Creates a newConfigHandler
with the default queue for requests. -
Uses of ResponseEvent in com.couchbase.client.core.endpoint.kv
Constructor parameters in com.couchbase.client.core.endpoint.kv with type arguments of type ResponseEvent Constructor Description KeyValueHandler(AbstractEndpoint endpoint, com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
Creates a newKeyValueHandler
with the default queue for requests. -
Uses of ResponseEvent in com.couchbase.client.core.endpoint.query
Constructor parameters in com.couchbase.client.core.endpoint.query with type arguments of type ResponseEvent Constructor Description QueryHandler(AbstractEndpoint endpoint, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
Creates a newQueryHandler
with the default queue for requests.QueryHandlerV2(AbstractEndpoint endpoint, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
Creates a newQueryHandlerV2
with the default queue for requests. -
Uses of ResponseEvent in com.couchbase.client.core.endpoint.search
Constructor parameters in com.couchbase.client.core.endpoint.search with type arguments of type ResponseEvent Constructor Description SearchHandler(AbstractEndpoint endpoint, com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
-
Uses of ResponseEvent in com.couchbase.client.core.endpoint.view
Constructor parameters in com.couchbase.client.core.endpoint.view with type arguments of type ResponseEvent Constructor Description ViewHandler(AbstractEndpoint endpoint, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer, boolean isTransient, boolean pipeline)
Creates a newViewHandler
with the default queue for requests. -
Uses of ResponseEvent in com.couchbase.client.core.node.locate
Method parameters in com.couchbase.client.core.node.locate with type arguments of type ResponseEvent Modifier and Type Method Description void
ConfigLocator. locateAndDispatch(CouchbaseRequest request, List<Node> nodes, ClusterConfig config, CoreEnvironment env, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
void
KeyValueLocator. locateAndDispatch(CouchbaseRequest request, List<Node> nodes, ClusterConfig cluster, 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
QueryLocator. locateAndDispatch(CouchbaseRequest request, List<Node> nodes, ClusterConfig config, CoreEnvironment env, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
void
ViewLocator. locateAndDispatch(CouchbaseRequest request, List<Node> nodes, ClusterConfig config, CoreEnvironment env, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
-
Uses of ResponseEvent in com.couchbase.client.core.retry
Method parameters in com.couchbase.client.core.retry with type arguments of type ResponseEvent Modifier and Type Method 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.