Uses of Interface
com.couchbase.client.core.msg.Request
Package
Description
-
Uses of Request in com.couchbase.client.core
Modifier and TypeMethodDescriptionvoid
Registers the given request to be tracked with its timeout value.Core.responseMetric
(Request<?> request, Throwable err) void
Timer.scheduleForRetry
(Core core, Request<? extends Response> request, Duration runAfter) Schedules a request to be retried after the given duration.<R extends Response>
voidSends a command into the core layer and registers the request with the timeout timer.<R extends Response>
voidSends a command into the core layer and allows to avoid timeout registration.static <T> Mono
<T> Reactor.wrap
(Request<?> request, CompletableFuture<T> response, boolean propagateCancellation) -
Uses of Request in com.couchbase.client.core.callbacks
-
Uses of Request in com.couchbase.client.core.classic
Modifier and TypeMethodDescriptionstatic <T,
RES extends Response>
CoreAsyncResponse<T> ClassicHelper.newAsyncResponse
(Request<RES> request, CompletableFuture<T> future) Returns a new async response whose cancellation task callscancel(CancellationReason)
.static void
ClassicHelper.setClientContext
(Request<?> request, CoreCommonOptions common) -
Uses of Request in com.couchbase.client.core.cnc
-
Uses of Request in com.couchbase.client.core.endpoint
-
Uses of Request in com.couchbase.client.core.endpoint.http
-
Uses of Request in com.couchbase.client.core.error
Modifier and TypeMethodDescriptionAuthenticationFailureException.onAuthError
(Request<? extends Response> request, Throwable cause) Must only be called on an AUTHENTICATION_ERROR RetryReason.ModifierConstructorDescriptionHttpStatusCodeException
(com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpResponseStatus status, String content, Request<?> request, ErrorContext errorContext) -
Uses of Request in com.couchbase.client.core.error.context
ModifierConstructorDescriptionGenericHttpRequestErrorContext
(Request<?> request, int httpStatusCode) GenericRequestErrorContext
(Request<?> request) -
Uses of Request in com.couchbase.client.core.io.netty
ModifierConstructorDescriptionprotected
ChunkedHandlerSwitcher
(com.couchbase.client.core.deps.io.netty.channel.ChannelInboundHandler chunkedHandler, NonChunkedHttpMessageHandler nonChunkedHandler, Class<? extends Request> chunkedClass) Creates a new chunked handler switcher. -
Uses of Request in com.couchbase.client.core.msg
Modifier and TypeInterfaceDescriptioninterface
HttpRequest<H extends ChunkHeader,
ROW extends ChunkRow, T extends ChunkTrailer, R extends ChunkedResponse<H, ROW, T>> interface
NonChunkedHttpRequest<R extends Response>
Modifier and TypeClassDescriptionclass
BaseRequest<R extends Response>
Base class for allRequests
.ModifierConstructorDescriptionRequestContext
(CoreContext ctx, Request<? extends Response> request) RequestContext
(Core core, long contextId, CoreEnvironment environment, Authenticator authenticator, Request<? extends Response> request) -
Uses of Request in com.couchbase.client.core.msg.analytics
-
Uses of Request in com.couchbase.client.core.msg.kv
Modifier and TypeInterfaceDescriptioninterface
KeyValueRequest<R extends Response>
Main parent interface for all Key/Value requests.Modifier and TypeClassDescriptionclass
class
BaseKeyValueRequest<R extends Response>
TheBaseKeyValueRequest
should be subclassed by all KeyValue requests since it provides common ground for all of them (i.e.class
class
A request to fetch a global configuration.class
class
Represents a KV GetAndTouch operation.class
Represents a KV GetAndTouch operation.class
Fetches the collection ID from the cluster based on aCollectionIdentifier
.class
class
Represents a kv get meta operation.class
Represents a KV Get (full document) operation.class
class
Uses the KV "add" command to insert documents if they do not already exist.class
class
Special observe request implementation to handle more than one key at the same time.class
Represents a NOOP KV Request, doing nothing.class
class
class
PredeterminedPartitionRequest<R extends Response>
Parent class for requests which have their partition already set at creation time.class
class
class
class
class
Represents a KV delete operation.class
Uses the KV replace command to replace a document if it exists.class
class
class
class
class
class
class
Uses the KV "set" command to unconditionally replace or insert documents regardless if they exist or not. -
Uses of Request in com.couchbase.client.core.msg.manager
Modifier and TypeInterfaceDescriptioninterface
ManagerRequest<R extends Response>
Parent interface for all requests going to the cluster manager.Modifier and TypeClassDescriptionclass
BaseManagerRequest<R extends Response>
Base class for the manager requests, mainly to define the service type in a uniform way.class
class
Performs a (potential endless) streaming request against the cluster manager for the given bucket.class
Deprecated. -
Uses of Request in com.couchbase.client.core.msg.query
-
Uses of Request in com.couchbase.client.core.msg.search
-
Uses of Request in com.couchbase.client.core.msg.view
-
Uses of Request in com.couchbase.client.core.node
Modifier and TypeMethodDescriptionNode.send
(R request) Sends the request into thisNode
.Node.sendIntoRetry
(R request) Retries the request.Modifier and TypeMethodDescriptionprotected 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 Request in com.couchbase.client.core.protostellar
Modifier and TypeClassDescriptionclass
Where the public API requires aRequest
, create one dynamically. -
Uses of Request in com.couchbase.client.core.retry
Modifier and TypeMethodDescriptionstatic 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
.BestEffortRetryStrategy.shouldRetry
(Request<? extends Response> request, RetryReason reason) Determines if a request should be retried or not (and if so, after which duration).FailFastRetryStrategy.shouldRetry
(Request<? extends Response> request, RetryReason reason) 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 Request in com.couchbase.client.core.service
-
Uses of Request in com.couchbase.client.core.service.strategy
-
Uses of Request in com.couchbase.client.core.transaction.components
Modifier and TypeClassDescriptionclass
This doesn't correspond to an individual server request.
CoreHttpClient
.