Uses of Interface
com.couchbase.client.core.msg.Response
-
-
Uses of Response in com.couchbase.client.core
Methods in com.couchbase.client.core with type parameters of type Response Modifier and Type Method Description <R extends Response>
voidCore. send(Request<R> request)
Sends a command into the core layer and registers the request with the timeout timer.<R extends Response>
voidCore. send(Request<R> request, boolean registerForTimeout)
Sends a command into the core layer and allows to avoid timeout registration.Method parameters in com.couchbase.client.core with type arguments of type Response Modifier and Type Method Description void
Timer. register(Request<Response> request)
Registers the given request to be tracked with its timeout value.void
Timer. scheduleForRetry(Core core, Request<? extends Response> request, Duration runAfter)
Schedules a request to be retried after the given duration. -
Uses of Response in com.couchbase.client.core.endpoint
Methods in com.couchbase.client.core.endpoint with type parameters of type Response Modifier and Type Method Description <R extends Request<? extends Response>>
voidBaseEndpoint. send(R request)
<R extends Request<? extends Response>>
voidEndpoint. send(R request)
Sends the request into thisEndpoint
. -
Uses of Response in com.couchbase.client.core.endpoint.http
Classes in com.couchbase.client.core.endpoint.http that implement Response Modifier and Type Class Description class
CoreHttpResponse
-
Uses of Response in com.couchbase.client.core.error
Methods in com.couchbase.client.core.error with parameters of type Response Modifier and Type Method Description static CouchbaseException
DefaultErrorUtil. keyValueStatusToException(KeyValueRequest<? extends Response> request, Response response)
Maps common KV response status codes to their corresponding user-level exceptions.Method parameters in com.couchbase.client.core.error with type arguments of type Response Modifier and Type Method Description static CouchbaseException
DefaultErrorUtil. keyValueStatusToException(KeyValueRequest<? extends Response> request, Response response)
Maps common KV response status codes to their corresponding user-level exceptions. -
Uses of Response in com.couchbase.client.core.io.netty
Method parameters in com.couchbase.client.core.io.netty with type arguments of type Response Modifier and Type Method Description protected Exception
NonChunkedHttpMessageHandler. failRequestWith(com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpResponseStatus status, String content, NonChunkedHttpRequest<Response> request)
To be implemented by children, should return the proper service exception type for each.static void
TracingUtils. setCommonKVSpanAttributes(RequestSpan span, KeyValueRequest<Response> request)
Sets attributes that are usefully duplicated across multiple spans. -
Uses of Response in com.couchbase.client.core.io.netty.eventing
Method parameters in com.couchbase.client.core.io.netty.eventing with type arguments of type Response Modifier and Type Method Description protected Exception
NonChunkedEventingMessageHandler. failRequestWith(com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpResponseStatus status, String content, NonChunkedHttpRequest<Response> request)
-
Uses of Response in com.couchbase.client.core.msg
Classes in com.couchbase.client.core.msg with type parameters of type Response Modifier and Type Class Description class
BaseRequest<R extends Response>
Base class for allRequests
.interface
NonChunkedHttpRequest<R extends Response>
interface
Request<R extends Response>
Represents aRequest
flowing through the client.Classes in com.couchbase.client.core.msg that implement Response Modifier and Type Class Description class
BaseResponse
The parent class for all responses passing through the SDK.Methods in com.couchbase.client.core.msg that return types with arguments of type Response Modifier and Type Method Description Request<? extends Response>
RequestContext. request()
Constructor parameters in com.couchbase.client.core.msg with type arguments of type Response Constructor Description RequestContext(CoreContext ctx, Request<? extends Response> request)
Creates a newRequestContext
. -
Uses of Response in com.couchbase.client.core.msg.analytics
Classes in com.couchbase.client.core.msg.analytics that implement Response Modifier and Type Class Description class
AnalyticsResponse
-
Uses of Response in com.couchbase.client.core.msg.chunk
Subinterfaces of Response in com.couchbase.client.core.msg.chunk Modifier and Type Interface Description interface
ChunkedResponse<H extends ChunkHeader,R extends ChunkRow,T extends ChunkTrailer>
Describes a full chunked response with its required sections. -
Uses of Response in com.couchbase.client.core.msg.kv
Classes in com.couchbase.client.core.msg.kv with type parameters of type Response Modifier and Type Class Description class
BaseKeyValueRequest<R extends Response>
TheBaseKeyValueRequest
should be subclassed by all KeyValue requests since it provides common ground for all of them (i.e.interface
KeyValueRequest<R extends Response>
Main parent interface for all Key/Value requests. -
Uses of Response in com.couchbase.client.core.msg.manager
Classes in com.couchbase.client.core.msg.manager with type parameters of type Response Modifier and Type Class Description class
BaseManagerRequest<R extends Response>
Base class for the manager requests, mainly to define the service type in a uniform way.interface
ManagerRequest<R extends Response>
Parent interface for all requests going to the cluster manager.Classes in com.couchbase.client.core.msg.manager that implement Response Modifier and Type Class Description class
BucketConfigResponse
class
BucketConfigStreamingResponse
class
GenericManagerResponse
-
Uses of Response in com.couchbase.client.core.msg.query
Classes in com.couchbase.client.core.msg.query that implement Response Modifier and Type Class Description class
QueryResponse
-
Uses of Response in com.couchbase.client.core.msg.search
Classes in com.couchbase.client.core.msg.search that implement Response Modifier and Type Class Description class
SearchResponse
-
Uses of Response in com.couchbase.client.core.msg.view
Classes in com.couchbase.client.core.msg.view that implement Response Modifier and Type Class Description class
ViewResponse
-
Uses of Response in com.couchbase.client.core.node
Methods in com.couchbase.client.core.node with type parameters of type Response Modifier and Type Method Description <R extends Request<? extends Response>>
voidNode. send(R request)
Sends the request into thisNode
.protected <R extends Request<? extends Response>>
voidNode. sendIntoRetry(R request)
Retries the request.Method parameters in com.couchbase.client.core.node with type arguments of type Response Modifier and Type Method Description protected boolean
AnalyticsLocator. checkServiceNotAvailable(Request<? extends Response> request, ClusterConfig config)
protected boolean
RoundRobinLocator. checkServiceNotAvailable(Request<? extends Response> request, ClusterConfig config)
Can be overridden to check if a request should be cancelled immediately that the service is not supported.protected boolean
ViewLocator. checkServiceNotAvailable(Request<? extends Response> request, ClusterConfig config)
void
KeyValueLocator. dispatch(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx)
void
Locator. dispatch(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx)
Given the environment and node information, the implementation locates the right set of nodes and dispatches the request into them.void
RoundRobinLocator. dispatch(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx)
protected boolean
RoundRobinLocator. nodeCanBeUsed(Node node, Request<? extends Response> request, ClusterConfig config)
This method can be overridden for additional per-node checks in addition to the service-type based check already performed inRoundRobinLocator.filterNodes(List, Request, ClusterConfig)
.protected boolean
ViewLocator. nodeCanBeUsed(Node node, Request<? extends Response> request, ClusterConfig config)
In addition to checking that the view service is enabled, for view dispatching it is vital that a request is only ever sent to a node which has active primary KV partitions. -
Uses of Response in com.couchbase.client.core.retry
Method parameters in com.couchbase.client.core.retry with type arguments of type Response Modifier and Type Method Description static Duration
RetryOrchestrator. capDuration(Duration uncappedDuration, Request<? extends Response> request)
Calculates the potentially capped retry duration so we do not schedule a longer retry than the actual total timeout.static void
RetryOrchestrator. maybeRetry(CoreContext ctx, Request<? extends Response> request, RetryReason reason)
Retry or cancel the given request, depending on its state and the configuredRetryStrategy
.CompletableFuture<RetryAction>
BestEffortRetryStrategy. shouldRetry(Request<? extends Response> request, RetryReason reason)
Determines if a request should be retried or not (and if so, after which duration).CompletableFuture<RetryAction>
FailFastRetryStrategy. shouldRetry(Request<? extends Response> request, RetryReason reason)
CompletableFuture<RetryAction>
RetryStrategy. shouldRetry(Request<? extends Response> request, RetryReason reason)
Checks if the given request should be retried and how long the retry delay should be. -
Uses of Response in com.couchbase.client.core.service
Methods in com.couchbase.client.core.service with type parameters of type Response Modifier and Type Method Description <R extends Request<? extends Response>>
EndpointEndpointSelectionStrategy. select(R request, List<Endpoint> endpoints)
<R extends Request<? extends Response>>
voidService. send(R request)
Sends the request into thisService
. -
Uses of Response in com.couchbase.client.core.service.strategy
Methods in com.couchbase.client.core.service.strategy with type parameters of type Response Modifier and Type Method Description <R extends Request<? extends Response>>
EndpointPartitionSelectionStrategy. select(R request, List<Endpoint> endpoints)
<R extends Request<? extends Response>>
EndpointRoundRobinSelectionStrategy. select(R request, List<Endpoint> endpoints)
-