Uses of Interface
com.couchbase.client.core.message.CouchbaseRequest

Packages that use CouchbaseRequest

Package	Description
com.couchbase.client.core	Couchbase Core IO - Domain Model and Architecture ================================================= This documentation describes the domain model of the core package, covers important architecture and design decisions and provides a solid introduction on the inner workings.
com.couchbase.client.core.endpoint
com.couchbase.client.core.endpoint.analytics
com.couchbase.client.core.endpoint.analytics.parser
com.couchbase.client.core.endpoint.kv
com.couchbase.client.core.endpoint.query
com.couchbase.client.core.endpoint.query.parser
com.couchbase.client.core.endpoint.search
com.couchbase.client.core.endpoint.view
com.couchbase.client.core.hooks
com.couchbase.client.core.message
com.couchbase.client.core.message.analytics
com.couchbase.client.core.message.cluster
com.couchbase.client.core.message.config
com.couchbase.client.core.message.internal
com.couchbase.client.core.message.kv
com.couchbase.client.core.message.kv.subdoc
com.couchbase.client.core.message.kv.subdoc.multi
com.couchbase.client.core.message.kv.subdoc.simple
com.couchbase.client.core.message.query
com.couchbase.client.core.message.search
com.couchbase.client.core.message.view
com.couchbase.client.core.node
com.couchbase.client.core.node.locate
com.couchbase.client.core.retry
com.couchbase.client.core.service
com.couchbase.client.core.service.strategies
com.couchbase.client.core.tracing

Uses of CouchbaseRequest in com.couchbase.client.core

Methods in com.couchbase.client.core that return CouchbaseRequest

Modifier and Type	Method	Description
CouchbaseRequest	RequestEvent.getRequest()

Methods in com.couchbase.client.core with parameters of type CouchbaseRequest

Modifier and Type	Method	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> rx.Observable<R>	ClusterFacade.send(CouchbaseRequest request)	Sends a CouchbaseRequest into the cluster and eventually returns a CouchbaseResponse.
<R extends CouchbaseResponse> rx.Observable<R>	CouchbaseCore.send(CouchbaseRequest request)
RequestEvent	RequestEvent.setRequest(CouchbaseRequest request)	Set the new request as a payload for this event.

Uses of CouchbaseRequest in com.couchbase.client.core.endpoint

Classes in com.couchbase.client.core.endpoint with type parameters of type CouchbaseRequest

Modifier and Type	Class	Description
class	AbstractGenericHandler<RESPONSE,ENCODED,REQUEST extends CouchbaseRequest>	Generic handler which acts as the common base type for all implementing handlers.

Methods in com.couchbase.client.core.endpoint that return CouchbaseRequest

Modifier and Type	Method	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.

Methods in com.couchbase.client.core.endpoint with parameters of type CouchbaseRequest

Modifier and Type	Method	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.

Uses of CouchbaseRequest in com.couchbase.client.core.endpoint.analytics

Classes in com.couchbase.client.core.endpoint.analytics that implement CouchbaseRequest

Modifier and Type	Class	Description
protected static class	AnalyticsHandler.KeepAliveRequest
protected static class	AnalyticsHandlerV2.KeepAliveRequest

Methods in com.couchbase.client.core.endpoint.analytics that return CouchbaseRequest

Modifier and Type	Method	Description
protected CouchbaseRequest	AnalyticsHandler.createKeepAliveRequest()
protected CouchbaseRequest	AnalyticsHandlerV2.createKeepAliveRequest()

Constructors in com.couchbase.client.core.endpoint.analytics with parameters of type CouchbaseRequest

Constructor	Description
KeepAliveResponse(ResponseStatus status, CouchbaseRequest request)
KeepAliveResponse(ResponseStatus status, CouchbaseRequest request)

Uses of CouchbaseRequest in com.couchbase.client.core.endpoint.analytics.parser

Methods in com.couchbase.client.core.endpoint.analytics.parser with parameters of type CouchbaseRequest

Modifier and Type	Method	Description
void	YasjlAnalyticsDeferredResponseParser.initialize(ByteBuf responseContent, ResponseStatus responseStatus, CouchbaseRequest request)	Initialize this parser for a response parsing cycle.
void	YasjlAnalyticsResponseParser.initialize(ByteBuf responseContent, ResponseStatus responseStatus, CouchbaseRequest request)	Initialize this parser for a response parsing cycle.

Uses of CouchbaseRequest in com.couchbase.client.core.endpoint.kv

Classes in com.couchbase.client.core.endpoint.kv that implement CouchbaseRequest

Modifier and Type	Class	Description
protected static class	KeyValueHandler.KeepAliveRequest

Methods in com.couchbase.client.core.endpoint.kv that return CouchbaseRequest

Modifier and Type	Method	Description
protected CouchbaseRequest	KeyValueHandler.createKeepAliveRequest()

Constructors in com.couchbase.client.core.endpoint.kv with parameters of type CouchbaseRequest

Constructor	Description
KeepAliveResponse(ResponseStatus status, short serverStatusCode, CouchbaseRequest request)

Uses of CouchbaseRequest in com.couchbase.client.core.endpoint.query

Classes in com.couchbase.client.core.endpoint.query that implement CouchbaseRequest

Modifier and Type	Class	Description
protected static class	QueryHandler.KeepAliveRequest
protected static class	QueryHandlerV2.KeepAliveRequest

Methods in com.couchbase.client.core.endpoint.query that return CouchbaseRequest

Modifier and Type	Method	Description
protected CouchbaseRequest	QueryHandler.createKeepAliveRequest()
protected CouchbaseRequest	QueryHandlerV2.createKeepAliveRequest()

Constructors in com.couchbase.client.core.endpoint.query with parameters of type CouchbaseRequest

Constructor	Description
KeepAliveResponse(ResponseStatus status, CouchbaseRequest request)
KeepAliveResponse(ResponseStatus status, CouchbaseRequest request)

Uses of CouchbaseRequest in com.couchbase.client.core.endpoint.query.parser

Methods in com.couchbase.client.core.endpoint.query.parser with parameters of type CouchbaseRequest

Modifier and Type	Method	Description
void	YasjlQueryResponseParser.initialize(ByteBuf responseContent, ResponseStatus responseStatus, CouchbaseRequest request)	Initialize this parser for a response parsing cycle.

Uses of CouchbaseRequest in com.couchbase.client.core.endpoint.search

Classes in com.couchbase.client.core.endpoint.search that implement CouchbaseRequest

Modifier and Type	Class	Description
protected static class	SearchHandler.KeepAliveRequest

Methods in com.couchbase.client.core.endpoint.search that return CouchbaseRequest

Modifier and Type	Method	Description
protected CouchbaseRequest	SearchHandler.createKeepAliveRequest()

Constructors in com.couchbase.client.core.endpoint.search with parameters of type CouchbaseRequest

Constructor	Description
KeepAliveResponse(ResponseStatus status, CouchbaseRequest request)

Uses of CouchbaseRequest in com.couchbase.client.core.endpoint.view

Classes in com.couchbase.client.core.endpoint.view that implement CouchbaseRequest

Modifier and Type	Class	Description
protected static class	ViewHandler.KeepAliveRequest

Methods in com.couchbase.client.core.endpoint.view that return CouchbaseRequest

Modifier and Type	Method	Description
protected CouchbaseRequest	ViewHandler.createKeepAliveRequest()

Constructors in com.couchbase.client.core.endpoint.view with parameters of type CouchbaseRequest

Constructor	Description
KeepAliveResponse(ResponseStatus status, CouchbaseRequest request)

Uses of CouchbaseRequest in com.couchbase.client.core.hooks

Methods in com.couchbase.client.core.hooks that return types with arguments of type CouchbaseRequest

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.

Methods in com.couchbase.client.core.hooks with parameters of type CouchbaseRequest

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 CouchbaseRequest in com.couchbase.client.core.message

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message

Modifier and Type	Interface	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..

Classes in com.couchbase.client.core.message that implement CouchbaseRequest

Modifier and Type	Class	Description
class	AbstractCouchbaseRequest	Default implementation for a CouchbaseRequest, should be extended by child messages.

Methods in com.couchbase.client.core.message that return CouchbaseRequest

Modifier and Type	Method	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.

Constructors in com.couchbase.client.core.message with parameters of type CouchbaseRequest

Constructor	Description
AbstractCouchbaseResponse(ResponseStatus status, CouchbaseRequest request)	Sets the required properties for the response.

Uses of CouchbaseRequest in com.couchbase.client.core.message.analytics

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.analytics

Modifier and Type	Interface	Description
interface	AnalyticsRequest	Marker interface for all requests against the Analytics Service

Classes in com.couchbase.client.core.message.analytics that implement CouchbaseRequest

Modifier and Type	Class	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	PingRequest
class	RawAnalyticsRequest	A AnalyticsRequest that can also be prelocated, but expects a response with the uninterpreted JSON payload returned by the query service.

Constructors in com.couchbase.client.core.message.analytics with parameters of type CouchbaseRequest

Constructor	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)

Uses of CouchbaseRequest in com.couchbase.client.core.message.cluster

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.cluster

Modifier and Type	Interface	Description
interface	ClusterRequest

Classes in com.couchbase.client.core.message.cluster that implement CouchbaseRequest

Modifier and Type	Class	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.

Uses of CouchbaseRequest in com.couchbase.client.core.message.config

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.config

Modifier and Type	Interface	Description
interface	ConfigRequest	Common marker interface for all ConfigRequests.

Classes in com.couchbase.client.core.message.config that implement CouchbaseRequest

Modifier and Type	Class	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

Constructors in com.couchbase.client.core.message.config with parameters of type CouchbaseRequest

Constructor	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)

Uses of CouchbaseRequest in com.couchbase.client.core.message.internal

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.internal

Modifier and Type	Interface	Description
interface	InternalRequest	Marker interface for all internal CouchbaseRequests that are potentially treated differently and with priority.

Classes in com.couchbase.client.core.message.internal that implement CouchbaseRequest

Modifier and Type	Class	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

Uses of CouchbaseRequest in com.couchbase.client.core.message.kv

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.kv

Modifier and Type	Interface	Description
interface	BinaryRequest	Common marker interface for all BinaryRequests.
interface	BinaryStoreRequest

Classes in com.couchbase.client.core.message.kv that implement CouchbaseRequest

Modifier and Type	Class	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.

Constructors in com.couchbase.client.core.message.kv with parameters of type CouchbaseRequest

Constructor	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)

Uses of CouchbaseRequest in com.couchbase.client.core.message.kv.subdoc

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.kv.subdoc

Modifier and Type	Interface	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.

Uses of CouchbaseRequest in com.couchbase.client.core.message.kv.subdoc.multi

Classes in com.couchbase.client.core.message.kv.subdoc.multi that implement CouchbaseRequest

Modifier and Type	Class	Description
class	SubMultiLookupRequest	Concrete implementation of a BinarySubdocMultiLookupRequest.
class	SubMultiMutationRequest	Concrete implementation of a BinarySubdocMultiMutationRequest.

Uses of CouchbaseRequest in com.couchbase.client.core.message.kv.subdoc.simple

Classes in com.couchbase.client.core.message.kv.subdoc.simple that implement CouchbaseRequest

Modifier and Type	Class	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.

Uses of CouchbaseRequest in com.couchbase.client.core.message.query

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.query

Modifier and Type	Interface	Description
interface	QueryRequest

Classes in com.couchbase.client.core.message.query that implement CouchbaseRequest

Modifier and Type	Class	Description
class	GenericQueryRequest	For the lack of a better name, a query request against a query server.
class	PingRequest
class	RawQueryRequest	A QueryRequest that can also be prelocated, but expects a response with the uninterpreted JSON payload returned by the query service.

Constructors in com.couchbase.client.core.message.query with parameters of type CouchbaseRequest

Constructor	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)

Uses of CouchbaseRequest in com.couchbase.client.core.message.search

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.search

Modifier and Type	Interface	Description
interface	SearchRequest	Common marker interface for all SearchRequests.

Classes in com.couchbase.client.core.message.search that implement CouchbaseRequest

Modifier and Type	Class	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.

Constructors in com.couchbase.client.core.message.search with parameters of type CouchbaseRequest

Constructor	Description
PingResponse(ResponseStatus status, CouchbaseRequest request)

Uses of CouchbaseRequest in com.couchbase.client.core.message.view

Subinterfaces of CouchbaseRequest in com.couchbase.client.core.message.view

Modifier and Type	Interface	Description
interface	ViewRequest

Classes in com.couchbase.client.core.message.view that implement CouchbaseRequest

Modifier and Type	Class	Description
class	GetDesignDocumentRequest
class	PingRequest
class	RemoveDesignDocumentRequest
class	UpsertDesignDocumentRequest
class	ViewQueryRequest

Constructors in com.couchbase.client.core.message.view with parameters of type CouchbaseRequest

Constructor	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)

Uses of CouchbaseRequest in com.couchbase.client.core.node

Methods in com.couchbase.client.core.node with parameters of type CouchbaseRequest

Modifier and Type	Method	Description
Service	DefaultServiceRegistry.locate(CouchbaseRequest request)
Service	ServiceRegistry.locate(CouchbaseRequest request)
void	CouchbaseNode.send(CouchbaseRequest request)
void	Node.send(CouchbaseRequest request)	Sends a CouchbaseRequest into the node and eventually returns a CouchbaseResponse.

Uses of CouchbaseRequest in com.couchbase.client.core.node.locate

Methods in com.couchbase.client.core.node.locate with parameters of type CouchbaseRequest

Modifier and Type	Method	Description
void	ConfigLocator.locateAndDispatch(CouchbaseRequest request, List<Node> nodes, ClusterConfig config, CoreEnvironment env, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
void	KeyValueLocator.locateAndDispatch(CouchbaseRequest request, List<Node> nodes, ClusterConfig cluster, 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	ViewLocator.locateAndDispatch(CouchbaseRequest request, List<Node> nodes, ClusterConfig config, CoreEnvironment env, com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)

Uses of CouchbaseRequest in com.couchbase.client.core.retry

Methods in com.couchbase.client.core.retry with parameters of type CouchbaseRequest

Modifier and Type	Method	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	BestEffortRetryStrategy.shouldRetry(CouchbaseRequest request, CoreEnvironment env)
boolean	FailFastRetryStrategy.shouldRetry(CouchbaseRequest request, CoreEnvironment env)
boolean	RetryStrategy.shouldRetry(CouchbaseRequest request, CoreEnvironment environment)	Decides whether the given CouchbaseRequest should be retried or cancelled.

Uses of CouchbaseRequest in com.couchbase.client.core.service

Methods in com.couchbase.client.core.service with parameters of type CouchbaseRequest

Modifier and Type	Method	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	PooledService.send(CouchbaseRequest request)
void	Service.send(CouchbaseRequest request)	Sends a CouchbaseRequest into the service and eventually returns a CouchbaseResponse.

Uses of CouchbaseRequest in com.couchbase.client.core.service.strategies

Methods in com.couchbase.client.core.service.strategies with parameters of type CouchbaseRequest

Modifier and Type	Method	Description
Endpoint	PartitionSelectionStrategy.select(CouchbaseRequest request, List<Endpoint> endpoints)
Endpoint	RandomSelectionStrategy.select(CouchbaseRequest request, List<Endpoint> endpoints)
Endpoint	RoundRobinSelectionStrategy.select(CouchbaseRequest request, List<Endpoint> endpoints)	Selects an Endpoint for the given CouchbaseRequest.
Endpoint	SelectionStrategy.select(CouchbaseRequest request, List<Endpoint> endpoints)	Selects an Endpoint for the given CouchbaseRequest.

Uses of CouchbaseRequest in com.couchbase.client.core.tracing

Methods in com.couchbase.client.core.tracing that return CouchbaseRequest

Modifier and Type	Method	Description
CouchbaseRequest	ThresholdLogSpan.request()

Methods in com.couchbase.client.core.tracing with parameters of type CouchbaseRequest

Modifier and Type	Method	Description
void	RingBufferMonitor.addRequest(CouchbaseRequest request)
void	RingBufferMonitor.removeRequest(CouchbaseRequest request)
void	ThresholdLogSpan.request(CouchbaseRequest request)