Modifier and Type | Method and Description |
---|---|
CouchbaseRequest |
RequestEvent.getRequest() |
Modifier and Type | Method and Description |
---|---|
protected void |
RequestHandler.checkFeaturesForRequest(CouchbaseRequest request,
BucketConfig config)
Checks, for a sub-set of
CouchbaseRequest , if the current environment has the necessary feature activated. |
protected Locator |
RequestHandler.locator(CouchbaseRequest request)
Helper method to detect the correct locator for the given request type.
|
<R extends CouchbaseResponse> |
CouchbaseCore.send(CouchbaseRequest request) |
<R extends CouchbaseResponse> |
ClusterFacade.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the cluster and eventually returns a CouchbaseResponse . |
RequestEvent |
RequestEvent.setRequest(CouchbaseRequest request)
Set the new request as a payload for this event.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractGenericHandler<RESPONSE,ENCODED,REQUEST extends CouchbaseRequest>
Generic handler which acts as the common base type for all implementing handlers.
|
Modifier and Type | Method and Description |
---|---|
protected CouchbaseRequest |
AbstractGenericHandler.createKeepAliveRequest()
Override to return a non-null request to be fired in the pipeline in case a keep alive is triggered.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractGenericHandler.onKeepAliveFired(ChannelHandlerContext ctx,
CouchbaseRequest keepAliveRequest)
Override to customize the behavior when a keep alive has been triggered and a keep alive request sent.
|
void |
Endpoint.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the endpoint and eventually returns a CouchbaseResponse . |
void |
AbstractEndpoint.send(CouchbaseRequest request) |
Modifier and Type | Class and Description |
---|---|
protected static class |
AnalyticsHandler.KeepAliveRequest |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseRequest |
AnalyticsHandler.createKeepAliveRequest() |
Constructor and Description |
---|
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
Modifier and Type | Class and Description |
---|---|
protected static class |
KeyValueHandler.KeepAliveRequest |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseRequest |
KeyValueHandler.createKeepAliveRequest() |
Constructor and Description |
---|
KeepAliveResponse(ResponseStatus status,
short serverStatusCode,
CouchbaseRequest request) |
Modifier and Type | Class and Description |
---|---|
protected static class |
QueryHandler.KeepAliveRequest |
protected static class |
QueryHandlerV2.KeepAliveRequest |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseRequest |
QueryHandlerV2.createKeepAliveRequest() |
protected CouchbaseRequest |
QueryHandler.createKeepAliveRequest() |
Constructor and Description |
---|
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
Modifier and Type | Field and Description |
---|---|
protected CouchbaseRequest |
YasjlQueryResponseParser.currentRequest
Represents the current request
|
Modifier and Type | Class and Description |
---|---|
protected static class |
SearchHandler.KeepAliveRequest |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseRequest |
SearchHandler.createKeepAliveRequest() |
Constructor and Description |
---|
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
Modifier and Type | Class and Description |
---|---|
protected static class |
ViewHandler.KeepAliveRequest |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseRequest |
ViewHandler.createKeepAliveRequest() |
Constructor and Description |
---|
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
Modifier and Type | Interface and Description |
---|---|
interface |
PrelocatedRequest
A
CouchbaseRequest that can be targeted at a specific node through the corresponding InetAddress , shortcutting the dispatch usually performed by a Locator .. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCouchbaseRequest
Default implementation for a
CouchbaseRequest , should be extended by child messages. |
Modifier and Type | Method and Description |
---|---|
CouchbaseRequest |
CouchbaseResponse.request()
Potentially has the associated request attached.
|
CouchbaseRequest |
AbstractCouchbaseResponse.request()
Stub method implementation which needs to be overriden by all responses that support cloning.
|
Constructor and Description |
---|
AbstractCouchbaseResponse(ResponseStatus status,
CouchbaseRequest request)
Sets the required properties for the response.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AnalyticsRequest
Marker interface for all requests against the Analytics Service
|
Modifier and Type | Class and Description |
---|---|
class |
GenericAnalyticsRequest
For the lack of a better name, a analytics request against a analytics server.
|
class |
RawAnalyticsRequest
A
AnalyticsRequest that can also be prelocated , but expects a response with the uninterpreted JSON payload returned by the query service. |
Constructor and Description |
---|
GenericAnalyticsResponse(rx.Observable<ByteBuf> errors,
rx.Observable<ByteBuf> rows,
rx.Observable<ByteBuf> signature,
rx.Observable<String> queryStatus,
rx.Observable<ByteBuf> info,
CouchbaseRequest request,
ResponseStatus status,
String requestId,
String clientRequestId) |
RawAnalyticsResponse(ResponseStatus status,
CouchbaseRequest request,
ByteBuf jsonResponse,
int httpStatusCode,
String httpStatusMsg) |
Modifier and Type | Interface and Description |
---|---|
interface |
ClusterRequest |
Modifier and Type | Class and Description |
---|---|
class |
CloseBucketRequest |
class |
DisconnectRequest
Disconnects all open buckets.
|
class |
GetClusterConfigRequest |
class |
OpenBucketRequest |
class |
SeedNodesRequest
Set up the bootstrap nodes for a
ClusterFacade . |
Modifier and Type | Interface and Description |
---|---|
interface |
ConfigRequest
Common marker interface for all
ConfigRequest s. |
Modifier and Type | Class and Description |
---|---|
class |
BucketConfigRequest |
class |
BucketsConfigRequest |
class |
BucketStreamingRequest |
class |
ClusterConfigRequest |
class |
FlushRequest
Sends a flush command to the cluster.
|
class |
GetDesignDocumentsRequest |
class |
InsertBucketRequest |
class |
RemoveBucketRequest |
class |
RestApiRequest
A generic HTTP request to perform on the cluster REST API port (8091).
|
class |
UpdateBucketRequest |
Constructor and Description |
---|
BucketStreamingResponse(rx.Observable<String> configs,
String host,
ResponseStatus status,
CouchbaseRequest request) |
GetDesignDocumentsResponse(String content,
ResponseStatus status,
CouchbaseRequest request) |
Modifier and Type | Interface and Description |
---|---|
interface |
DCPRequest
Common interface for all DCP requests.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDCPMessage
Default implementation of
DCPRequest . |
class |
AbstractDCPRequest
Default implementation of
DCPRequest . |
class |
ExpirationMessage
A message representing event that removes or expires a document.
|
class |
GetFailoverLogRequest
Get the current failover logs for partition.
|
class |
GetLastCheckpointRequest
Returns the last checkpoint for a particular VBucket.
|
class |
MutationMessage
A message representing event that creates or updates a document.
|
class |
OpenConnectionRequest |
class |
RemoveMessage
A message representing event that removes or expires a document.
|
class |
SnapshotMarkerMessage
Snapshot marker.
|
class |
StreamCloseRequest |
class |
StreamEndMessage |
class |
StreamRequestRequest
Stream request.
|
Constructor and Description |
---|
AbstractDCPResponse(ResponseStatus status,
CouchbaseRequest request)
Creates
AbstractDCPResponse . |
GetFailoverLogResponse(ResponseStatus status,
List<FailoverLogEntry> failoverLog,
CouchbaseRequest request)
Creates
GetFailoverLogResponse . |
GetLastCheckpointResponse(ResponseStatus status,
long sequenceNumber,
CouchbaseRequest request)
Creates
GetLastCheckpointResponse . |
StreamCloseResponse(ResponseStatus status,
CouchbaseRequest request)
Sets the required properties for the response.
|
StreamRequestResponse(ResponseStatus status,
List<FailoverLogEntry> failoverLog,
long rollbackToSequenceNumber,
CouchbaseRequest request)
Sets the required properties for the response.
|
Modifier and Type | Interface and Description |
---|---|
interface |
InternalRequest
Marker interface for all internal
CouchbaseRequest s that are potentially treated differently and with priority. |
Modifier and Type | Class and Description |
---|---|
class |
AddNodeRequest |
class |
AddServiceRequest |
class |
GetConfigProviderRequest
Request to fetch the configuration provider from the core.
|
class |
RemoveNodeRequest |
class |
RemoveServiceRequest |
class |
SignalConfigReload |
class |
SignalFlush |
Modifier and Type | Interface and Description |
---|---|
interface |
BinaryRequest
Common marker interface for all
BinaryRequest s. |
interface |
BinaryStoreRequest |
Modifier and Type | Class and Description |
---|---|
class |
AbstractKeyValueRequest
Default implementation of a
BinaryRequest . |
class |
AppendRequest |
class |
CounterRequest
Request to handle increment/decrement of a counter.
|
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 |
GetBucketConfigRequest
Request which fetches a bucket configuration through carrier publication.
|
class |
GetRequest
Fetch a document from the cluster and return it if found.
|
class |
InsertRequest
Insert a document.
|
class |
ObserveRequest |
class |
ObserveSeqnoRequest
Observe through sequence numbers instead of cas.
|
class |
PrependRequest |
class |
RemoveRequest |
class |
ReplaceRequest |
class |
ReplicaGetRequest
Fetch a document from one or more and/or active nodes replicas.
|
class |
StatRequest |
class |
TouchRequest |
class |
UnlockRequest |
class |
UpsertRequest
Insert or update a document.
|
Constructor and Description |
---|
AbstractKeyValueResponse(ResponseStatus status,
short serverStatusCode,
String bucket,
ByteBuf content,
CouchbaseRequest request) |
AppendResponse(ResponseStatus status,
short serverStatusCode,
long cas,
String bucket,
ByteBuf content,
MutationToken mutationToken,
CouchbaseRequest request) |
CounterResponse(ResponseStatus status,
short serverStatusCode,
String bucket,
long value,
long cas,
MutationToken mutationToken,
CouchbaseRequest request) |
FailoverObserveSeqnoResponse(boolean master,
short vbucketID,
long vbucketUUID,
long lastPersistedSeqNo,
long currentSeqNo,
long oldVbucketUUID,
long lastSeqNoReceived,
ResponseStatus status,
short serverStatusCode,
String bucket,
CouchbaseRequest request) |
GetAllMutationTokensResponse(MutationToken[] mutationTokens,
ResponseStatus status,
short serverStatusCode,
String bucket,
CouchbaseRequest request) |
GetResponse(ResponseStatus status,
short serverStatusCode,
long cas,
int flags,
String bucket,
ByteBuf content,
CouchbaseRequest request) |
InsertResponse(ResponseStatus status,
short serverStatusCode,
long cas,
String bucket,
ByteBuf content,
MutationToken mutationToken,
CouchbaseRequest request) |
NoFailoverObserveSeqnoResponse(boolean master,
short vbucketID,
long vbucketUUID,
long lastPersistedSeqNo,
long currentSeqNo,
ResponseStatus status,
short serverStatusCode,
String bucket,
CouchbaseRequest request) |
ObserveResponse(ResponseStatus status,
short serverStatusCode,
byte obs,
boolean master,
long cas,
String bucket,
CouchbaseRequest request) |
PrependResponse(ResponseStatus status,
short serverStatusCode,
long cas,
String bucket,
ByteBuf content,
MutationToken mutationToken,
CouchbaseRequest request) |
RemoveResponse(ResponseStatus status,
short serverStatusCode,
long cas,
String bucket,
ByteBuf content,
MutationToken mutationToken,
CouchbaseRequest request) |
ReplaceResponse(ResponseStatus status,
short serverStatusCode,
long cas,
String bucket,
ByteBuf content,
MutationToken mutationToken,
CouchbaseRequest request) |
StatResponse(ResponseStatus status,
short serverStatusCode,
String hostname,
String key,
String value,
String bucket,
CouchbaseRequest request) |
TouchResponse(ResponseStatus status,
short serverStatusCode,
String bucket,
ByteBuf content,
CouchbaseRequest request) |
UnlockResponse(ResponseStatus status,
short serverStatusCode,
String bucket,
ByteBuf content,
CouchbaseRequest request) |
UpsertResponse(ResponseStatus status,
short serverStatusCode,
long cas,
String bucket,
ByteBuf content,
MutationToken mutationToken,
CouchbaseRequest request) |
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 |
SubMultiLookupRequest
Concrete implementation of a
BinarySubdocMultiLookupRequest . |
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 |
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 dictionnary upsert operation.
|
class |
SubExistRequest
A sub-document exist operation.
|
class |
SubGetRequest
A sub-document get operation.
|
class |
SubReplaceRequest
A sub-document replace operation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
QueryRequest |
Modifier and Type | Class and Description |
---|---|
class |
GenericQueryRequest
For the lack of a better name, a query request against a query server.
|
class |
RawQueryRequest
A
QueryRequest that can also be prelocated , but expects a response with the uninterpreted JSON payload returned by the query service. |
Constructor and Description |
---|
GenericQueryResponse(rx.Observable<ByteBuf> errors,
rx.Observable<ByteBuf> rows,
rx.Observable<ByteBuf> signature,
rx.Observable<String> queryStatus,
rx.Observable<ByteBuf> info,
CouchbaseRequest request,
ResponseStatus status,
String requestId,
String clientRequestId) |
RawQueryResponse(ResponseStatus status,
CouchbaseRequest request,
ByteBuf jsonResponse,
int httpStatusCode,
String httpStatusMsg) |
Modifier and Type | Interface and Description |
---|---|
interface |
SearchRequest
Common marker interface for all
SearchRequest s. |
Modifier and Type | Class and Description |
---|---|
class |
GetSearchIndexRequest
Retrieves full text index definition.
|
class |
RemoveSearchIndexRequest
Removes full text search index.
|
class |
SearchQueryRequest
Runs query against search index.
|
class |
UpsertSearchIndexRequest
Inserts or updates full text search index definition.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ViewRequest |
Modifier and Type | Class and Description |
---|---|
class |
GetDesignDocumentRequest |
class |
RemoveDesignDocumentRequest |
class |
UpsertDesignDocumentRequest |
class |
ViewQueryRequest |
Constructor and Description |
---|
GetDesignDocumentResponse(String name,
boolean development,
ByteBuf content,
ResponseStatus status,
CouchbaseRequest request) |
RemoveDesignDocumentResponse(ResponseStatus status,
ByteBuf content,
CouchbaseRequest request) |
UpsertDesignDocumentResponse(ResponseStatus status,
ByteBuf content,
CouchbaseRequest request) |
ViewQueryResponse(rx.Observable<ByteBuf> rows,
rx.Observable<ByteBuf> info,
rx.Observable<String> error,
int responseCode,
String responsePhrase,
ResponseStatus status,
CouchbaseRequest request) |
Modifier and Type | Method and Description |
---|---|
Service |
ServiceRegistry.locate(CouchbaseRequest request) |
Service |
DefaultServiceRegistry.locate(CouchbaseRequest request) |
void |
Node.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the node and eventually returns a CouchbaseResponse . |
void |
CouchbaseNode.send(CouchbaseRequest request) |
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.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.
|
boolean |
RetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment environment)
Decides whether the given
CouchbaseRequest should be retried or cancelled. |
boolean |
FailFastRetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment env) |
boolean |
BestEffortRetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment env) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractPoolingService.dispatch(CouchbaseRequest request) |
protected void |
AbstractOnDemandService.dispatch(CouchbaseRequest request) |
protected void |
AbstractLazyService.dispatch(CouchbaseRequest request) |
protected abstract void |
AbstractDynamicService.dispatch(CouchbaseRequest request) |
void |
Service.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the service and eventually returns a CouchbaseResponse . |
void |
PooledService.send(CouchbaseRequest request) |
void |
AbstractDynamicService.send(CouchbaseRequest request) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
SelectionStrategy.select(CouchbaseRequest request,
List<Endpoint> endpoints)
Selects an
Endpoint for the given CouchbaseRequest . |
Endpoint |
RoundRobinSelectionStrategy.select(CouchbaseRequest request,
List<Endpoint> endpoints)
Selects an
Endpoint for the given CouchbaseRequest . |
Endpoint |
RandomSelectionStrategy.select(CouchbaseRequest request,
List<Endpoint> endpoints) |
Endpoint |
PartitionSelectionStrategy.select(CouchbaseRequest request,
List<Endpoint> endpoints) |
Copyright © 2017 Couchbase, Inc.. All rights reserved.