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 |
---|---|
CouchbaseMessage |
ResponseEvent.getMessage()
Get the response from the payload.
|
Modifier and Type | Method and Description |
---|---|
ResponseEvent |
ResponseEvent.setMessage(CouchbaseMessage message)
Set the new response as a payload for this event.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
AnalyticsHandler.KeepAliveRequest |
protected static class |
AnalyticsHandler.KeepAliveResponse |
Modifier and Type | Class and Description |
---|---|
protected static class |
KeyValueHandler.KeepAliveRequest |
protected static class |
KeyValueHandler.KeepAliveResponse |
Modifier and Type | Class and Description |
---|---|
protected static class |
QueryHandler.KeepAliveRequest |
protected static class |
QueryHandler.KeepAliveResponse |
protected static class |
QueryHandlerV2.KeepAliveRequest |
protected static class |
QueryHandlerV2.KeepAliveResponse |
Modifier and Type | Class and Description |
---|---|
protected static class |
SearchHandler.KeepAliveRequest |
protected static class |
SearchHandler.KeepAliveResponse |
Modifier and Type | Class and Description |
---|---|
protected static class |
ViewHandler.KeepAliveRequest |
protected static class |
ViewHandler.KeepAliveResponse |
Modifier and Type | Interface and Description |
---|---|
interface |
CouchbaseRequest
High-Level marker interface for all
CouchbaseRequest s. |
interface |
CouchbaseResponse |
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. |
class |
AbstractCouchbaseResponse
The default representation of a
CouchbaseResponse . |
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 |
GenericAnalyticsResponse
The base response for Analytics (SQL++) requests.
|
class |
RawAnalyticsRequest
A
AnalyticsRequest that can also be prelocated , but expects a response with the uninterpreted JSON payload returned by the query service. |
class |
RawAnalyticsResponse
The response to a
RawAnalyticsRequest , which only contains the raw JSON payload returned by the Analytics service, as a ByteBuf . |
Modifier and Type | Interface and Description |
---|---|
interface |
ClusterRequest |
Modifier and Type | Class and Description |
---|---|
class |
CloseBucketRequest |
class |
CloseBucketResponse |
class |
DisconnectRequest
Disconnects all open buckets.
|
class |
DisconnectResponse
A response to a
DisconnectRequest . |
class |
GetClusterConfigRequest |
class |
GetClusterConfigResponse |
class |
OpenBucketRequest |
class |
OpenBucketResponse |
class |
SeedNodesRequest
Set up the bootstrap nodes for a
ClusterFacade . |
class |
SeedNodesResponse
Returns the status of a
SeedNodesRequest . |
Modifier and Type | Interface and Description |
---|---|
interface |
ConfigRequest
Common marker interface for all
ConfigRequest s. |
Modifier and Type | Class and Description |
---|---|
class |
BucketConfigRequest |
class |
BucketConfigResponse |
class |
BucketsConfigRequest |
class |
BucketsConfigResponse |
class |
BucketStreamingRequest |
class |
BucketStreamingResponse |
class |
ClusterConfigRequest |
class |
ClusterConfigResponse |
class |
FlushRequest
Sends a flush command to the cluster.
|
class |
FlushResponse |
class |
GetDesignDocumentsRequest |
class |
GetDesignDocumentsResponse |
class |
InsertBucketRequest |
class |
InsertBucketResponse |
class |
RemoveBucketRequest |
class |
RemoveBucketResponse |
class |
RestApiRequest
A generic HTTP request to perform on the cluster REST API port (8091).
|
class |
RestApiResponse
Response to a
RestApiRequest . |
class |
UpdateBucketRequest |
class |
UpdateBucketResponse |
Modifier and Type | Interface and Description |
---|---|
interface |
DCPRequest
Common interface for all DCP requests.
|
interface |
DCPResponse
Common interface for all DCP responses.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDCPMessage
Default implementation of
DCPRequest . |
class |
AbstractDCPRequest
Default implementation of
DCPRequest . |
class |
AbstractDCPResponse
Default implementation of
DCPResponse . |
class |
ExpirationMessage
A message representing event that removes or expires a document.
|
class |
GetFailoverLogRequest
Get the current failover logs for partition.
|
class |
GetFailoverLogResponse |
class |
GetLastCheckpointRequest
Returns the last checkpoint for a particular VBucket.
|
class |
GetLastCheckpointResponse |
class |
MutationMessage
A message representing event that creates or updates a document.
|
class |
OpenConnectionRequest |
class |
OpenConnectionResponse |
class |
RemoveMessage
A message representing event that removes or expires a document.
|
class |
SnapshotMarkerMessage
Snapshot marker.
|
class |
StreamCloseRequest |
class |
StreamCloseResponse |
class |
StreamEndMessage |
class |
StreamRequestRequest
Stream request.
|
class |
StreamRequestResponse |
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 |
AddNodeResponse |
class |
AddServiceRequest |
class |
AddServiceResponse |
class |
GetConfigProviderRequest
Request to fetch the configuration provider from the core.
|
class |
GetConfigProviderResponse
Response to fetch the configuration provider from the core.
|
class |
RemoveNodeRequest |
class |
RemoveNodeResponse |
class |
RemoveServiceRequest |
class |
RemoveServiceResponse |
class |
SignalConfigReload |
class |
SignalFlush |
Modifier and Type | Interface and Description |
---|---|
interface |
BinaryRequest
Common marker interface for all
BinaryRequest s. |
interface |
BinaryResponse
Marker interface which signals a binary response.
|
interface |
BinaryStoreRequest |
Modifier and Type | Class and Description |
---|---|
class |
AbstractKeyValueRequest
Default implementation of a
BinaryRequest . |
class |
AbstractKeyValueResponse |
class |
AppendRequest |
class |
AppendResponse |
class |
CounterRequest
Request to handle increment/decrement of a counter.
|
class |
CounterResponse |
class |
FailoverObserveSeqnoResponse
Represents a observe seqno response.
|
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 |
GetAllMutationTokensResponse
Represents response to
GetAllMutationTokensRequest . |
class |
GetBucketConfigRequest
Request which fetches a bucket configuration through carrier publication.
|
class |
GetBucketConfigResponse
Represents a response with a bucket configuration.
|
class |
GetRequest
Fetch a document from the cluster and return it if found.
|
class |
GetResponse
Represents a response to a
GetRequest . |
class |
InsertRequest
Insert a document.
|
class |
InsertResponse
Response to an
InsertRequest . |
class |
NoFailoverObserveSeqnoResponse
Represents a observe seqno response.
|
class |
ObserveRequest |
class |
ObserveResponse
.
|
class |
ObserveSeqnoRequest
Observe through sequence numbers instead of cas.
|
class |
PrependRequest |
class |
PrependResponse
.
|
class |
RemoveRequest |
class |
RemoveResponse
Represents a response to a
RemoveRequest . |
class |
ReplaceRequest |
class |
ReplaceResponse |
class |
ReplicaGetRequest
Fetch a document from one or more and/or active nodes replicas.
|
class |
StatRequest |
class |
StatResponse |
class |
TouchRequest |
class |
TouchResponse
.
|
class |
UnlockRequest |
class |
UnlockResponse |
class |
UpsertRequest
Insert or update a document.
|
class |
UpsertResponse
Response to an
UpsertRequest . |
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 |
MultiLookupResponse
The response for a
BinarySubdocMultiLookupRequest . |
class |
MultiMutationResponse
The response for a
BinarySubdocMultiMutationRequest . |
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 |
SimpleSubdocResponse
A general-purpose response suitable for most “simple” sub-document operations (
BinarySubdocRequest and BinarySubdocMutationRequest ), as opposed to “multi-specification” sub-document operations. |
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 |
GenericQueryResponse
The base response for Query (N1QL) requests.
|
class |
RawQueryRequest
A
QueryRequest that can also be prelocated , but expects a response with the uninterpreted JSON payload returned by the query service. |
class |
RawQueryResponse
The response to a
RawQueryRequest , which only contains the raw JSON payload returned by the Query service, as a ByteBuf . |
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 |
GetSearchIndexResponse
Carries full text index definition as a payload.
|
class |
RemoveSearchIndexRequest
Removes full text search index.
|
class |
RemoveSearchIndexResponse
Result of full text search index removing.
|
class |
SearchQueryRequest
Runs query against search index.
|
class |
SearchQueryResponse
Result of the full text search query.
|
class |
UpsertSearchIndexRequest
Inserts or updates full text search index definition.
|
class |
UpsertSearchIndexResponse
Contains result of the create/update action on full text search index.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ViewRequest |
Modifier and Type | Class and Description |
---|---|
class |
GetDesignDocumentRequest |
class |
GetDesignDocumentResponse |
class |
RemoveDesignDocumentRequest |
class |
RemoveDesignDocumentResponse |
class |
UpsertDesignDocumentRequest |
class |
UpsertDesignDocumentResponse |
class |
ViewQueryRequest |
class |
ViewQueryResponse |
Copyright © 2017 Couchbase, Inc.. All rights reserved.