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. |
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 |
---|---|
<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 |
---|---|
Subject<CouchbaseResponse,CouchbaseResponse> |
ResponseEvent.getObservable() |
Subject<CouchbaseResponse,CouchbaseResponse> |
ResponseEvent.getObservable() |
Modifier and Type | Method and Description |
---|---|
ResponseEvent |
ResponseEvent.setObservable(Subject<CouchbaseResponse,CouchbaseResponse> observable) |
ResponseEvent |
ResponseEvent.setObservable(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,
Subject<CouchbaseResponse,CouchbaseResponse> observable)
Publishes a response with the attached observable.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractGenericHandler.publishResponse(CouchbaseResponse response,
Subject<CouchbaseResponse,CouchbaseResponse> observable)
Publishes a response with the attached observable.
|
protected void |
AbstractGenericHandler.publishResponse(CouchbaseResponse response,
Subject<CouchbaseResponse,CouchbaseResponse> observable)
Publishes a response with the attached observable.
|
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 |
Modifier and Type | Method and Description |
---|---|
protected CouchbaseResponse |
QueryHandler.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 |
---|---|
Subject<CouchbaseResponse,CouchbaseResponse> |
CouchbaseRequest.observable()
Get the underlying
Observable . |
Subject<CouchbaseResponse,CouchbaseResponse> |
CouchbaseRequest.observable()
Get the underlying
Observable . |
Subject<CouchbaseResponse,CouchbaseResponse> |
AbstractCouchbaseRequest.observable() |
Subject<CouchbaseResponse,CouchbaseResponse> |
AbstractCouchbaseRequest.observable() |
Constructor and Description |
---|
AbstractCouchbaseRequest(String bucket,
String password,
Subject<CouchbaseResponse,CouchbaseResponse> observable)
Create a new
AbstractCouchbaseRequest . |
AbstractCouchbaseRequest(String bucket,
String password,
Subject<CouchbaseResponse,CouchbaseResponse> observable)
Create a new
AbstractCouchbaseRequest . |
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 |
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 |
OpenConnectionResponse |
class |
StreamRequestResponse |
Constructor and Description |
---|
AbstractDCPRequest(String bucket,
String password,
Subject<CouchbaseResponse,CouchbaseResponse> observable) |
AbstractDCPRequest(String bucket,
String password,
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 |
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,
Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a new
AbstractKeyValueRequest . |
AbstractKeyValueRequest(String key,
String bucket,
String password,
Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a new
AbstractKeyValueRequest . |
Modifier and Type | Class and Description |
---|---|
class |
GenericQueryResponse
The base response for Query (N1QL) requests.
|
Modifier and Type | Class and Description |
---|---|
class |
GetDesignDocumentResponse |
class |
RemoveDesignDocumentResponse |
class |
UpsertDesignDocumentResponse |
class |
ViewQueryResponse |
Copyright © 2015 Couchbase, Inc.. All rights reserved.