Uses of Interface
com.couchbase.client.core.message.CouchbaseResponse
-
-
Uses of CouchbaseResponse in com.couchbase.client.core
Fields in com.couchbase.client.core with type parameters of type CouchbaseResponse Modifier and Type Field Description static com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>>
ResponseHandler. RESPONSE_TRANSLATOR
TranslatesCouchbaseRequest
s intoRequestEvent
s.static com.lmax.disruptor.EventTranslatorTwoArg<ResponseEvent,CouchbaseMessage,rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>>
ResponseHandler. RESPONSE_TRANSLATOR
TranslatesCouchbaseRequest
s intoRequestEvent
s.Methods in com.couchbase.client.core with type parameters of type CouchbaseResponse Modifier and Type Method Description <R extends CouchbaseResponse>
rx.Observable<R>ClusterFacade. send(CouchbaseRequest request)
Sends aCouchbaseRequest
into the cluster and eventually returns aCouchbaseResponse
.<R extends CouchbaseResponse>
rx.Observable<R>CouchbaseCore. send(CouchbaseRequest request)
Methods in com.couchbase.client.core that return types with arguments of type CouchbaseResponse Modifier and Type Method Description rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>
ResponseEvent. getObservable()
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>
ResponseEvent. getObservable()
Method parameters in com.couchbase.client.core with type arguments of type CouchbaseResponse Modifier and Type Method Description ResponseEvent
ResponseEvent. setObservable(rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
ResponseEvent
ResponseEvent. setObservable(rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
-
Uses of CouchbaseResponse in com.couchbase.client.core.endpoint
Methods in com.couchbase.client.core.endpoint that return CouchbaseResponse Modifier and Type Method Description protected abstract CouchbaseResponse
AbstractGenericHandler. decodeResponse(ChannelHandlerContext ctx, RESPONSE msg)
Decodes the incoming response and transforms it into aCouchbaseResponse
.Methods in com.couchbase.client.core.endpoint with parameters of type CouchbaseResponse Modifier and Type Method 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.Method parameters in com.couchbase.client.core.endpoint with type arguments of type CouchbaseResponse Modifier and Type Method 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. -
Uses of CouchbaseResponse in com.couchbase.client.core.endpoint.analytics
Classes in com.couchbase.client.core.endpoint.analytics that implement CouchbaseResponse Modifier and Type Class Description protected static class
AnalyticsHandler.KeepAliveResponse
protected static class
AnalyticsHandlerV2.KeepAliveResponse
Methods in com.couchbase.client.core.endpoint.analytics that return CouchbaseResponse Modifier and Type Method Description protected CouchbaseResponse
AnalyticsHandler. decodeResponse(ChannelHandlerContext ctx, HttpObject msg)
protected CouchbaseResponse
AnalyticsHandlerV2. decodeResponse(ChannelHandlerContext ctx, HttpObject msg)
-
Uses of CouchbaseResponse in com.couchbase.client.core.endpoint.config
Methods in com.couchbase.client.core.endpoint.config that return CouchbaseResponse Modifier and Type Method Description protected CouchbaseResponse
ConfigHandler. decodeResponse(ChannelHandlerContext ctx, HttpObject msg)
-
Uses of CouchbaseResponse in com.couchbase.client.core.endpoint.kv
Classes in com.couchbase.client.core.endpoint.kv that implement CouchbaseResponse Modifier and Type Class Description protected static class
KeyValueHandler.KeepAliveResponse
Methods in com.couchbase.client.core.endpoint.kv that return CouchbaseResponse Modifier and Type Method Description protected CouchbaseResponse
KeyValueHandler. decodeResponse(ChannelHandlerContext ctx, FullBinaryMemcacheResponse msg)
-
Uses of CouchbaseResponse in com.couchbase.client.core.endpoint.query
Classes in com.couchbase.client.core.endpoint.query that implement CouchbaseResponse Modifier and Type Class Description protected static class
QueryHandler.KeepAliveResponse
protected static class
QueryHandlerV2.KeepAliveResponse
Methods in com.couchbase.client.core.endpoint.query that return CouchbaseResponse Modifier and Type Method Description protected CouchbaseResponse
QueryHandler. decodeResponse(ChannelHandlerContext ctx, HttpObject msg)
protected CouchbaseResponse
QueryHandlerV2. decodeResponse(ChannelHandlerContext ctx, HttpObject msg)
-
Uses of CouchbaseResponse in com.couchbase.client.core.endpoint.search
Classes in com.couchbase.client.core.endpoint.search that implement CouchbaseResponse Modifier and Type Class Description protected static class
SearchHandler.KeepAliveResponse
Methods in com.couchbase.client.core.endpoint.search that return CouchbaseResponse Modifier and Type Method Description protected CouchbaseResponse
SearchHandler. decodeResponse(ChannelHandlerContext ctx, HttpObject msg)
-
Uses of CouchbaseResponse in com.couchbase.client.core.endpoint.view
Classes in com.couchbase.client.core.endpoint.view that implement CouchbaseResponse Modifier and Type Class Description protected static class
ViewHandler.KeepAliveResponse
Methods in com.couchbase.client.core.endpoint.view that return CouchbaseResponse Modifier and Type Method Description protected CouchbaseResponse
ViewHandler. decodeResponse(ChannelHandlerContext ctx, HttpObject msg)
-
Uses of CouchbaseResponse in com.couchbase.client.core.hooks
Methods in com.couchbase.client.core.hooks that return types with arguments of type CouchbaseResponse Modifier and Type Method 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.Method parameters in com.couchbase.client.core.hooks with type arguments of type CouchbaseResponse Modifier and Type Method 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. -
Uses of CouchbaseResponse in com.couchbase.client.core.message
Classes in com.couchbase.client.core.message that implement CouchbaseResponse Modifier and Type Class Description class
AbstractCouchbaseResponse
The default representation of aCouchbaseResponse
.Methods in com.couchbase.client.core.message that return types with arguments of type CouchbaseResponse Modifier and Type Method Description rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>
AbstractCouchbaseRequest. observable()
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>
AbstractCouchbaseRequest. observable()
rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>
CouchbaseRequest. observable()
Get the underlyingObservable
.rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse>
CouchbaseRequest. observable()
Get the underlyingObservable
.Methods in com.couchbase.client.core.message with parameters of type CouchbaseResponse Modifier and Type Method Description void
AbstractCouchbaseRequest. emit(CouchbaseResponse response)
void
CouchbaseRequest. emit(CouchbaseResponse response)
Emits theCouchbaseResponse
into the underlying state holder (like a subject) without completing it as per contract.void
AbstractCouchbaseRequest. succeed(CouchbaseResponse response)
void
CouchbaseRequest. succeed(CouchbaseResponse response)
Emits theCouchbaseResponse
into the underlying state holder (like a subject) and completes it as well per contract.Constructor parameters in com.couchbase.client.core.message with type arguments of type CouchbaseResponse Constructor Description AbstractCouchbaseRequest(String bucket, String username, String password, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Create a newAbstractCouchbaseRequest
.AbstractCouchbaseRequest(String bucket, String username, String password, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Create a newAbstractCouchbaseRequest
. -
Uses of CouchbaseResponse in com.couchbase.client.core.message.analytics
Classes in com.couchbase.client.core.message.analytics that implement CouchbaseResponse Modifier and Type Class Description class
GenericAnalyticsResponse
The base response for Analytics (SQL++) requests.class
PingResponse
class
RawAnalyticsResponse
The response to aRawAnalyticsRequest
, which only contains the raw JSON payload returned by the Analytics service, as aByteBuf
. -
Uses of CouchbaseResponse in com.couchbase.client.core.message.cluster
Classes in com.couchbase.client.core.message.cluster that implement CouchbaseResponse Modifier and Type Class Description class
CloseBucketResponse
class
DisconnectResponse
A response to aDisconnectRequest
.class
GetClusterConfigResponse
class
OpenBucketResponse
class
SeedNodesResponse
**Returns the status of aSeedNodesRequest
.** -
Uses of CouchbaseResponse in com.couchbase.client.core.message.config
Classes in com.couchbase.client.core.message.config that implement CouchbaseResponse Modifier and Type Class Description class
BucketConfigResponse
class
BucketsConfigResponse
class
BucketStreamingResponse
class
ClusterConfigResponse
class
FlushResponse
class
GetDesignDocumentsResponse
class
GetUsersResponse
class
InsertBucketResponse
class
RemoveBucketResponse
class
RemoveUserResponse
class
RestApiResponse
Response to aRestApiRequest
.class
UpdateBucketResponse
class
UpsertUserResponse
-
Uses of CouchbaseResponse in com.couchbase.client.core.message.internal
Classes in com.couchbase.client.core.message.internal that implement CouchbaseResponse Modifier and Type Class Description class
AddNodeResponse
class
AddServiceResponse
class
DiagnosticsResponse
class
GetConfigProviderResponse
Response to fetch the configuration provider from the core.class
RemoveNodeResponse
class
RemoveServiceResponse
-
Uses of CouchbaseResponse in com.couchbase.client.core.message.kv
Subinterfaces of CouchbaseResponse in com.couchbase.client.core.message.kv Modifier and Type Interface Description interface
BinaryResponse
Marker interface which signals a binary response.Classes in com.couchbase.client.core.message.kv that implement CouchbaseResponse Modifier and Type Class Description class
AbstractKeyValueResponse
class
AppendResponse
class
CounterResponse
class
FailoverObserveSeqnoResponse
Represents a observe seqno response.class
GetAllMutationTokensResponse
Represents response toGetAllMutationTokensRequest
.class
GetBucketConfigResponse
Represents a response with a bucket configuration.class
GetResponse
Represents a response to aGetRequest
.class
InsertResponse
Response to anInsertRequest
.class
NoFailoverObserveSeqnoResponse
Represents a observe seqno response.class
NoopResponse
class
ObserveResponse
.class
PrependResponse
.class
RemoveResponse
Represents a response to aRemoveRequest
.class
ReplaceResponse
class
StatResponse
class
TouchResponse
.class
UnlockResponse
class
UpsertResponse
Response to anUpsertRequest
.Constructor parameters in com.couchbase.client.core.message.kv with type arguments of type CouchbaseResponse Constructor Description AbstractKeyValueRequest(String key, String bucket, String username, String password, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a newAbstractKeyValueRequest
.AbstractKeyValueRequest(String key, String bucket, String username, String password, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a newAbstractKeyValueRequest
. -
Uses of CouchbaseResponse in com.couchbase.client.core.message.kv.subdoc.multi
Classes in com.couchbase.client.core.message.kv.subdoc.multi that implement CouchbaseResponse Modifier and Type Class Description class
MultiLookupResponse
The response for aBinarySubdocMultiLookupRequest
.class
MultiMutationResponse
The response for aBinarySubdocMultiMutationRequest
. -
Uses of CouchbaseResponse in com.couchbase.client.core.message.kv.subdoc.simple
Classes in com.couchbase.client.core.message.kv.subdoc.simple that implement CouchbaseResponse Modifier and Type Class Description class
SimpleSubdocResponse
A general-purpose response suitable for most "simple" sub-document operations (BinarySubdocRequest
andBinarySubdocMutationRequest
), as opposed to "multi-specification" sub-document operations.Constructor parameters in com.couchbase.client.core.message.kv.subdoc.simple with type arguments of type CouchbaseResponse Constructor Description AbstractSubdocMutationRequest(String key, String path, ByteBuf fragment, String bucket, int expiration, long cas, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a newAbstractSubdocMutationRequest
.AbstractSubdocMutationRequest(String key, String path, ByteBuf fragment, String bucket, int expiration, long cas, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable)
Creates a newAbstractSubdocMutationRequest
.AbstractSubdocRequest(String key, String path, String bucket, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable, ByteBuf... restOfContent)
Creates a newAbstractSubdocRequest
.AbstractSubdocRequest(String key, String path, String bucket, rx.subjects.Subject<CouchbaseResponse,CouchbaseResponse> observable, ByteBuf... restOfContent)
Creates a newAbstractSubdocRequest
. -
Uses of CouchbaseResponse in com.couchbase.client.core.message.query
Classes in com.couchbase.client.core.message.query that implement CouchbaseResponse Modifier and Type Class Description class
GenericQueryResponse
The base response for Query (N1QL) requests.class
PingResponse
class
RawQueryResponse
The response to aRawQueryRequest
, which only contains the raw JSON payload returned by the Query service, as aByteBuf
. -
Uses of CouchbaseResponse in com.couchbase.client.core.message.search
Classes in com.couchbase.client.core.message.search that implement CouchbaseResponse Modifier and Type Class Description class
GetSearchIndexResponse
Carries full text index definition as a payload.class
PingResponse
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. -
Uses of CouchbaseResponse in com.couchbase.client.core.message.view
Classes in com.couchbase.client.core.message.view that implement CouchbaseResponse Modifier and Type Class Description class
GetDesignDocumentResponse
class
PingResponse
class
RemoveDesignDocumentResponse
class
UpsertDesignDocumentResponse
class
ViewQueryResponse
-
Uses of CouchbaseResponse in com.couchbase.client.core.tracing
Methods in com.couchbase.client.core.tracing with parameters of type CouchbaseResponse Modifier and Type Method Description void
DefaultOrphanResponseReporter. report(CouchbaseResponse request)
Reports the givenCouchbaseRequest
as a orphan response.void
OrphanResponseReporter. report(CouchbaseResponse request)
-
Uses of CouchbaseResponse in com.couchbase.client.core.utils
Method parameters in com.couchbase.client.core.utils with type arguments of type CouchbaseResponse Modifier and Type Method 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).
-