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. |
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 |
---|---|
<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 . |
Modifier and Type | Method and Description |
---|---|
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> |
ResponseEvent.getObservable() |
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> |
ResponseEvent.getObservable() |
Modifier and Type | Method and Description |
---|---|
ResponseEvent |
ResponseEvent.setObservable(rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable) |
ResponseEvent |
ResponseEvent.setObservable(rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable) |
Modifier and Type | Method and Description |
---|---|
protected abstract CouchbaseResponse |
AbstractGenericHandler.decodeResponse(ChannelHandlerContext ctx,
RESPONSE msg)
Decodes the incoming response and transforms it into a
CouchbaseResponse . |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractGenericHandler.onKeepAliveResponse(ChannelHandlerContext ctx,
CouchbaseResponse keepAliveResponse)
Override to customize the behavior when a keep alive has been responded to.
|
protected void |
AbstractGenericHandler.publishResponse(CouchbaseResponse response,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Publishes a response with the attached observable.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractGenericHandler.publishResponse(CouchbaseResponse response,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Publishes a response with the attached observable.
|
protected void |
AbstractGenericHandler.publishResponse(CouchbaseResponse response,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Publishes a response with the attached observable.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
AnalyticsHandler.KeepAliveResponse |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
AnalyticsHandler.decodeResponse(ChannelHandlerContext ctx,
HttpObject msg) |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
ConfigHandler.decodeResponse(ChannelHandlerContext ctx,
HttpObject msg) |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
DCPHandler.decodeResponse(ChannelHandlerContext ctx,
FullBinaryMemcacheResponse msg) |
Modifier and Type | Class and Description |
---|---|
protected static class |
KeyValueHandler.KeepAliveResponse |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
KeyValueHandler.decodeResponse(ChannelHandlerContext ctx,
FullBinaryMemcacheResponse msg) |
Modifier and Type | Class and Description |
---|---|
protected static class |
QueryHandler.KeepAliveResponse |
protected static class |
QueryHandlerV2.KeepAliveResponse |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
QueryHandlerV2.decodeResponse(ChannelHandlerContext ctx,
HttpObject msg) |
protected CouchbaseResponse |
QueryHandler.decodeResponse(ChannelHandlerContext ctx,
HttpObject msg) |
Modifier and Type | Class and Description |
---|---|
protected static class |
SearchHandler.KeepAliveResponse |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
SearchHandler.decodeResponse(ChannelHandlerContext ctx,
HttpObject msg) |
Modifier and Type | Class and Description |
---|---|
protected static class |
ViewHandler.KeepAliveResponse |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
ViewHandler.decodeResponse(ChannelHandlerContext ctx,
HttpObject msg) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractCouchbaseResponse
The default representation of a
CouchbaseResponse . |
Modifier and Type | Method and Description |
---|---|
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> |
CouchbaseRequest.observable()
Get the underlying
Observable . |
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> |
CouchbaseRequest.observable()
Get the underlying
Observable . |
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> |
AbstractCouchbaseRequest.observable() |
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> |
AbstractCouchbaseRequest.observable() |
Constructor and Description |
---|
AbstractCouchbaseRequest(String bucket,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Create a new
AbstractCouchbaseRequest . |
AbstractCouchbaseRequest(String bucket,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Create a new
AbstractCouchbaseRequest . |
Modifier and Type | Class and Description |
---|---|
class |
GenericAnalyticsResponse
The base response for Analytics (SQL++) requests.
|
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 | Class and Description |
---|---|
class |
CloseBucketResponse |
class |
DisconnectResponse
A response to a
DisconnectRequest . |
class |
GetClusterConfigResponse |
class |
OpenBucketResponse |
class |
SeedNodesResponse
Returns the status of a
SeedNodesRequest . |
Modifier and Type | Class and Description |
---|---|
class |
BucketConfigResponse |
class |
BucketsConfigResponse |
class |
BucketStreamingResponse |
class |
ClusterConfigResponse |
class |
FlushResponse |
class |
GetDesignDocumentsResponse |
class |
InsertBucketResponse |
class |
RemoveBucketResponse |
class |
RestApiResponse
Response to a
RestApiRequest . |
class |
UpdateBucketResponse |
Modifier and Type | Interface and Description |
---|---|
interface |
DCPResponse
Common interface for all DCP responses.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDCPResponse
Default implementation of
DCPResponse . |
class |
GetFailoverLogResponse |
class |
GetLastCheckpointResponse |
class |
OpenConnectionResponse |
class |
StreamCloseResponse |
class |
StreamRequestResponse |
Constructor and Description |
---|
AbstractDCPMessage(int totalBodyLength,
short partition,
String key,
String bucket,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable) |
AbstractDCPMessage(int totalBodyLength,
short partition,
String key,
String bucket,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable) |
AbstractDCPRequest(String bucket,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable) |
AbstractDCPRequest(String bucket,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable) |
Modifier and Type | Class and Description |
---|---|
class |
AddNodeResponse |
class |
AddServiceResponse |
class |
GetConfigProviderResponse
Response to fetch the configuration provider from the core.
|
class |
RemoveNodeResponse |
class |
RemoveServiceResponse |
Modifier and Type | Interface and Description |
---|---|
interface |
BinaryResponse
Marker interface which signals a binary response.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractKeyValueResponse |
class |
AppendResponse |
class |
CounterResponse |
class |
FailoverObserveSeqnoResponse
Represents a observe seqno response.
|
class |
GetAllMutationTokensResponse
Represents response to
GetAllMutationTokensRequest . |
class |
GetBucketConfigResponse
Represents a response with a bucket configuration.
|
class |
GetResponse
Represents a response to a
GetRequest . |
class |
InsertResponse
Response to an
InsertRequest . |
class |
NoFailoverObserveSeqnoResponse
Represents a observe seqno response.
|
class |
ObserveResponse
.
|
class |
PrependResponse
.
|
class |
RemoveResponse
Represents a response to a
RemoveRequest . |
class |
ReplaceResponse |
class |
StatResponse |
class |
TouchResponse
.
|
class |
UnlockResponse |
class |
UpsertResponse
Response to an
UpsertRequest . |
Constructor and Description |
---|
AbstractKeyValueRequest(String key,
String bucket,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a new
AbstractKeyValueRequest . |
AbstractKeyValueRequest(String key,
String bucket,
String password,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a new
AbstractKeyValueRequest . |
Modifier and Type | Class and Description |
---|---|
class |
MultiLookupResponse
The response for a
BinarySubdocMultiLookupRequest . |
class |
MultiMutationResponse
The response for a
BinarySubdocMultiMutationRequest . |
Modifier and Type | Class and Description |
---|---|
class |
SimpleSubdocResponse
A general-purpose response suitable for most “simple” sub-document operations (
BinarySubdocRequest and BinarySubdocMutationRequest ), as opposed to “multi-specification” sub-document operations. |
Constructor and Description |
---|
AbstractSubdocMutationRequest(String key,
String path,
ByteBuf fragment,
String bucket,
int expiration,
long cas,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a new
AbstractSubdocMutationRequest . |
AbstractSubdocMutationRequest(String key,
String path,
ByteBuf fragment,
String bucket,
int expiration,
long cas,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a new
AbstractSubdocMutationRequest . |
AbstractSubdocRequest(String key,
String path,
String bucket,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable,
ByteBuf... restOfContent)
Creates a new
AbstractSubdocRequest . |
AbstractSubdocRequest(String key,
String path,
String bucket,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable,
ByteBuf... restOfContent)
Creates a new
AbstractSubdocRequest . |
Modifier and Type | Class and Description |
---|---|
class |
GenericQueryResponse
The base response for Query (N1QL) requests.
|
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 | Class and Description |
---|---|
class |
GetSearchIndexResponse
Carries full text index definition as a payload.
|
class |
RemoveSearchIndexResponse
Result of full text search index removing.
|
class |
SearchQueryResponse
Result of the full text search query.
|
class |
UpsertSearchIndexResponse
Contains result of the create/update action on full text search index.
|
Modifier and Type | Class and Description |
---|---|
class |
GetDesignDocumentResponse |
class |
RemoveDesignDocumentResponse |
class |
UpsertDesignDocumentResponse |
class |
ViewQueryResponse |
Modifier and Type | Method and Description |
---|---|
static void |
Observables.failSafe(rx.Scheduler scheduler,
boolean moveOut,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable,
Throwable err)
Helper method to fail a given observable while still making sure to move it onto the proper scheduler for handling if needed (similar to onNext).
|
static void |
Observables.failSafe(rx.Scheduler scheduler,
boolean moveOut,
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable,
Throwable err)
Helper method to fail a given observable while still making sure to move it onto the proper scheduler for handling if needed (similar to onNext).
|
Copyright © 2017 Couchbase, Inc.. All rights reserved.