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> |
ClusterFacade.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the cluster and eventually returns a CouchbaseResponse . |
<R extends CouchbaseResponse> |
CouchbaseCore.send(CouchbaseRequest request) |
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.completeRequestSpan(CouchbaseRequest request)
Helper method to complete the request span, called from child instances.
|
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 |
AbstractEndpoint.send(CouchbaseRequest request) |
void |
Endpoint.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the endpoint and eventually returns a CouchbaseResponse . |
Modifier and Type | Class and Description |
---|---|
protected static class |
AnalyticsHandler.KeepAliveRequest |
protected static class |
AnalyticsHandlerV2.KeepAliveRequest |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseRequest |
AnalyticsHandler.createKeepAliveRequest() |
protected CouchbaseRequest |
AnalyticsHandlerV2.createKeepAliveRequest() |
Constructor and Description |
---|
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
Modifier and Type | Method and Description |
---|---|
void |
YasjlAnalyticsResponseParser.initialize(ByteBuf responseContent,
ResponseStatus responseStatus,
CouchbaseRequest request)
Initialize this parser for a response parsing cycle.
|
void |
YasjlAnalyticsDeferredResponseParser.initialize(ByteBuf responseContent,
ResponseStatus responseStatus,
CouchbaseRequest request)
Initialize this parser for a response parsing cycle.
|
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 |
QueryHandler.createKeepAliveRequest() |
protected CouchbaseRequest |
QueryHandlerV2.createKeepAliveRequest() |
Constructor and Description |
---|
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
KeepAliveResponse(ResponseStatus status,
CouchbaseRequest request) |
Modifier and Type | Method and Description |
---|---|
void |
YasjlQueryResponseParser.initialize(ByteBuf responseContent,
ResponseStatus responseStatus,
CouchbaseRequest request)
Initialize this parser for a response parsing cycle.
|
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 | 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 |
---|---|
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 | Interface and Description |
---|---|
interface |
PrelocatedRequest
A
CouchbaseRequest that can be targeted at a specific node through the corresponding
hostname, 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 |
AbstractCouchbaseResponse.request()
Stub method implementation which needs to be overridden by all responses that support cloning.
|
CouchbaseRequest |
CouchbaseResponse.request()
Potentially has the associated request attached.
|
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 |
AnalyticsQueryResultRequest
Deferred analytics query result request
|
class |
AnalyticsQueryStatusRequest
Deferred analytics query status request
|
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,
String handle,
CouchbaseRequest request,
ResponseStatus status,
String requestId,
String clientRequestId) |
PingResponse(ResponseStatus status,
CouchbaseRequest request) |
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 .**
For stability reasons, it is advised to always provide more than one seed node (but not necessarily all nodes from
the cluster) so that the cluster can correctly bootstrap the bucket, even if one of the hosts in the list is
currently not available. |
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 |
GetUsersRequest
Get a user or list of users.
|
class |
InsertBucketRequest |
class |
RemoveBucketRequest |
class |
RemoveUserRequest |
class |
RestApiRequest
A generic HTTP request to perform on the cluster REST API port (8091).
|
class |
UpdateBucketRequest |
class |
UpsertUserRequest |
Constructor and Description |
---|
BucketStreamingResponse(rx.Observable<String> configs,
String host,
ResponseStatus status,
CouchbaseRequest request) |
GetDesignDocumentsResponse(String content,
ResponseStatus status,
CouchbaseRequest request) |
GetUsersResponse(String content,
ResponseStatus status,
CouchbaseRequest request) |
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 |
DiagnosticsRequest |
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 |
NoopRequest |
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) |
NoopResponse(ResponseStatus status,
short serverStatusCode,
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 dictionary upsert operation.
|
class |
SubExistRequest
A sub-document exist operation.
|
class |
SubGetCountRequest
A sub-document get count 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,
rx.Observable<ByteBuf> profileInfo,
CouchbaseRequest request,
ResponseStatus status,
String requestId,
String clientRequestId) |
PingResponse(ResponseStatus status,
CouchbaseRequest request) |
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 |
PingRequest |
class |
RemoveSearchIndexRequest
Removes full text search index.
|
class |
SearchQueryRequest
Runs query against search index.
|
class |
UpsertSearchIndexRequest
Inserts or updates full text search index definition.
|
Constructor and Description |
---|
PingResponse(ResponseStatus status,
CouchbaseRequest request) |
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) |
PingResponse(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 |
CouchbaseNode.send(CouchbaseRequest request) |
void |
Node.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the node and eventually returns a CouchbaseResponse . |
Modifier and Type | Method and Description |
---|---|
void |
KeyValueLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig cluster,
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) |
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 |
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 |
FailFastRetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment env) |
boolean |
BestEffortRetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment env) |
boolean |
RetryStrategy.shouldRetry(CouchbaseRequest request,
CoreEnvironment environment)
Decides whether the given
CouchbaseRequest should be retried or cancelled. |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractDynamicService.dispatch(CouchbaseRequest request) |
protected void |
AbstractLazyService.dispatch(CouchbaseRequest request) |
protected void |
AbstractOnDemandService.dispatch(CouchbaseRequest request) |
protected void |
AbstractPoolingService.dispatch(CouchbaseRequest request) |
void |
AbstractDynamicService.send(CouchbaseRequest request) |
void |
Service.send(CouchbaseRequest request)
Sends a
CouchbaseRequest into the service and eventually returns a CouchbaseResponse . |
void |
PooledService.send(CouchbaseRequest request) |
Modifier and Type | Method and Description |
---|---|
Endpoint |
PartitionSelectionStrategy.select(CouchbaseRequest request,
List<Endpoint> endpoints) |
Endpoint |
SelectionStrategy.select(CouchbaseRequest request,
List<Endpoint> endpoints)
Selects an
Endpoint for the given CouchbaseRequest . |
Endpoint |
RandomSelectionStrategy.select(CouchbaseRequest request,
List<Endpoint> endpoints) |
Endpoint |
RoundRobinSelectionStrategy.select(CouchbaseRequest request,
List<Endpoint> endpoints)
Selects an
Endpoint for the given CouchbaseRequest . |
Modifier and Type | Method and Description |
---|---|
CouchbaseRequest |
ThresholdLogSpan.request() |
Modifier and Type | Method and Description |
---|---|
void |
RingBufferMonitor.addRequest(CouchbaseRequest request) |
void |
RingBufferMonitor.removeRequest(CouchbaseRequest request) |
void |
ThresholdLogSpan.request(CouchbaseRequest request) |
Copyright © 2021 Couchbase, Inc.. All rights reserved.