Modifier and Type | Field and Description |
---|---|
static com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,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(Subject<CouchbaseResponse,CouchbaseResponse> observable) |
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 |
---|
RequestHandler(CoreEnvironment environment,
Observable<ClusterConfig> configObservable,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
RequestHandler . |
Modifier and Type | Method and Description |
---|---|
com.lmax.disruptor.RingBuffer<ResponseEvent> |
AbstractEndpoint.responseBuffer()
The
RingBuffer response buffer reference. |
Constructor and Description |
---|
AbstractEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient)
Create a new
AbstractEndpoint . |
AbstractGenericHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
AbstractGenericHandler with the default queue. |
AbstractGenericHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
Queue<REQUEST> queue,
boolean isTransient)
Creates a new
AbstractGenericHandler with a custom queue. |
Constructor and Description |
---|
ConfigEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
ConfigHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
ConfigHandler with the default queue for requests. |
Constructor and Description |
---|
DCPEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
DCPHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
DCPHandler with the default queue for requests. |
DCPHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
Queue<DCPRequest> queue,
boolean isTransient)
Creates a new
DCPHandler with a custom queue for requests (suitable for tests). |
Constructor and Description |
---|
KeyValueEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
KeyValueEndpoint . |
KeyValueHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
KeyValueHandler with the default queue for requests. |
Constructor and Description |
---|
QueryEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
QueryHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
QueryHandler with the default queue for requests. |
Constructor and Description |
---|
SearchEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
SearchHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer,
boolean isTransient) |
Constructor and Description |
---|
ViewEndpoint(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
ViewEndpoint . |
ViewHandler(AbstractEndpoint endpoint,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
boolean isTransient)
Creates a new
ViewHandler with the default queue for requests. |
Constructor and Description |
---|
CouchbaseNode(InetAddress hostname,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
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 |
DCPLocator.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.retryOrCancel(CoreEnvironment environment,
CouchbaseRequest request,
com.lmax.disruptor.EventSink<ResponseEvent> responseBuffer)
Either retry or cancel a request, based on the strategy used.
|
Modifier and Type | Method and Description |
---|---|
Endpoint |
Service.EndpointFactory.create(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
Endpoint . |
static Service |
ServiceFactory.create(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
ServiceType type,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Constructor and Description |
---|
AbstractDynamicService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
int minEndpoints,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
Service.EndpointFactory endpointFactory) |
AbstractLazyService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
Service.EndpointFactory endpointFactory) |
AbstractOnDemandService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
Service.EndpointFactory endpointFactory) |
AbstractPoolingService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
int minEndpoints,
int maxEndpoints,
SelectionStrategy strategy,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer,
Service.EndpointFactory endpointFactory) |
ConfigService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
DCPService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
KeyValueService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Creates a new
KeyValueService . |
QueryService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Creates a new
ViewService . |
SearchService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Creates a new
ViewService . |
ViewService(String hostname,
String bucket,
String password,
int port,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Creates a new
ViewService . |
Copyright © 2016 Couchbase, Inc.. All rights reserved.