Uses of Interface
com.couchbase.client.core.msg.Request
Packages that use Request
Package
Description
-
Uses of Request in com.couchbase.client.core
Methods in com.couchbase.client.core with parameters of type RequestModifier and TypeMethodDescriptionvoidRegisters the given request to be tracked with its timeout value.Core.responseMetric(Request<?> request, Throwable err) voidTimer.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> reactor.core.publisher.Mono<T> Reactor.wrap(Request<?> request, CompletableFuture<T> response, boolean propagateCancellation) Wraps aRequestand returns it in aMono. -
Uses of Request in com.couchbase.client.core.callbacks
Methods in com.couchbase.client.core.callbacks with parameters of type Request -
Uses of Request in com.couchbase.client.core.classic
Methods in com.couchbase.client.core.classic with parameters of type RequestModifier 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 voidClassicHelper.setClientContext(Request<?> request, CoreCommonOptions common) -
Uses of Request in com.couchbase.client.core.cnc
Methods in com.couchbase.client.core.cnc with parameters of type Request -
Uses of Request in com.couchbase.client.core.cnc.apptelemetry.collector
Methods in com.couchbase.client.core.cnc.apptelemetry.collector with parameters of type RequestModifier and TypeMethodDescriptionvoidAppTelemetryCollector.increment(Request<?> request, AppTelemetryCounterType counterType) voidAppTelemetryCollectorImpl.increment(Request<?> request, AppTelemetryCounterType counterType) voidAppTelemetryCollector.recordLatency(Request<?> request) voidAppTelemetryCollectorImpl.recordLatency(Request<?> request) -
Uses of Request in com.couchbase.client.core.cnc.metrics
Methods in com.couchbase.client.core.cnc.metrics with parameters of type RequestModifier and TypeMethodDescriptionstatic ResponseMetricIdentifierResponseMetricIdentifier.fromRequest(Request<?> request, @Nullable String exceptionSimpleName, @Nullable ClusterIdentifier clusterIdent, boolean isDefaultLoggingMeter) -
Uses of Request in com.couchbase.client.core.endpoint
Methods in com.couchbase.client.core.endpoint with type parameters of type Request -
Uses of Request in com.couchbase.client.core.endpoint.http
Classes in com.couchbase.client.core.endpoint.http that implement Request -
Uses of Request in com.couchbase.client.core.error
Methods in com.couchbase.client.core.error with parameters of type RequestModifier and TypeMethodDescriptionAuthenticationFailureException.onAuthError(Request<? extends Response> request, Throwable cause) Must only be called on an AUTHENTICATION_ERROR RetryReason.Constructors in com.couchbase.client.core.error with parameters of type RequestModifierConstructorDescriptionHttpStatusCodeException(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
Constructors in com.couchbase.client.core.error.context with parameters of type RequestModifierConstructorDescriptionGenericHttpRequestErrorContext(Request<?> request, int httpStatusCode) GenericRequestErrorContext(Request<?> request) -
Uses of Request in com.couchbase.client.core.io.netty
Constructor parameters in com.couchbase.client.core.io.netty with type arguments of type RequestModifierConstructorDescriptionprotectedChunkedHandlerSwitcher(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
Subinterfaces of Request in com.couchbase.client.core.msgModifier and TypeInterfaceDescriptioninterfaceHttpRequest<H extends ChunkHeader,ROW extends ChunkRow, T extends ChunkTrailer, R extends ChunkedResponse<H, ROW, T>> interfaceNonChunkedHttpRequest<R extends Response>Classes in com.couchbase.client.core.msg that implement RequestModifier and TypeClassDescriptionclassBaseRequest<R extends Response>Base class for allRequests.Methods in com.couchbase.client.core.msg that return RequestConstructors in com.couchbase.client.core.msg with parameters of type RequestModifierConstructorDescriptionRequestContext(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
Classes in com.couchbase.client.core.msg.analytics that implement Request -
Uses of Request in com.couchbase.client.core.msg.kv
Subinterfaces of Request in com.couchbase.client.core.msg.kvModifier and TypeInterfaceDescriptioninterfaceKeyValueRequest<R extends Response>Main parent interface for all Key/Value requests.Classes in com.couchbase.client.core.msg.kv that implement RequestModifier and TypeClassDescriptionclassclassBaseKeyValueRequest<R extends Response>TheBaseKeyValueRequestshould be subclassed by all KeyValue requests since it provides common ground for all of them (i.e. adding the kv partition needed).classclassA request to fetch a global configuration.classclassRepresents a KV GetAndTouch operation.classRepresents a KV GetAndTouch operation.classFetches the collection ID from the cluster based on aCollectionIdentifier.classclassRepresents a kv get meta operation.classRepresents a KV Get (full document) operation.classclassUses the KV "add" command to insert documents if they do not already exist.classclassSpecial observe request implementation to handle more than one key at the same time.classRepresents a NOOP KV Request, doing nothing. really.classclassclassPredeterminedPartitionRequest<R extends Response>Parent class for requests which have their partition already set at creation time.classclassclassclassclassRepresents a KV delete operation.classUses the KV replace command to replace a document if it exists.classclassclassclassclassclassclassUses 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
Subinterfaces of Request in com.couchbase.client.core.msg.managerModifier and TypeInterfaceDescriptioninterfaceManagerRequest<R extends Response>Parent interface for all requests going to the cluster manager.Classes in com.couchbase.client.core.msg.manager that implement RequestModifier and TypeClassDescriptionclassBaseManagerRequest<R extends Response>Base class for the manager requests, mainly to define the service type in a uniform way.classclassPerforms a (potential endless) streaming request against the cluster manager for the given bucket.classDeprecated. -
Uses of Request in com.couchbase.client.core.msg.query
Classes in com.couchbase.client.core.msg.query that implement Request -
Uses of Request in com.couchbase.client.core.msg.search
Classes in com.couchbase.client.core.msg.search that implement Request -
Uses of Request in com.couchbase.client.core.msg.view
Classes in com.couchbase.client.core.msg.view that implement Request -
Uses of Request in com.couchbase.client.core.node
Methods in com.couchbase.client.core.node with type parameters of type RequestModifier and TypeMethodDescriptionNode.send(R request) Sends the request into thisNode.Node.sendIntoRetry(R request) Retries the request.Methods in com.couchbase.client.core.node with parameters of type RequestModifier and TypeMethodDescriptionprotected booleanAnalyticsLocator.checkServiceNotAvailable(Request<? extends Response> request, ClusterConfig config) protected booleanRoundRobinLocator.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 booleanViewLocator.checkServiceNotAvailable(Request<? extends Response> request, ClusterConfig config) voidKeyValueLocator.dispatch(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx) voidLocator.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.voidRoundRobinLocator.dispatch(Request<? extends Response> request, List<Node> nodes, ClusterConfig config, CoreContext ctx) protected booleanRoundRobinLocator.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 booleanViewLocator.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
Classes in com.couchbase.client.core.protostellar that implement RequestModifier and TypeClassDescriptionclassWhere the public API requires aRequest, create one dynamically. -
Uses of Request in com.couchbase.client.core.retry
Methods in com.couchbase.client.core.retry with parameters of type RequestModifier and TypeMethodDescriptionstatic DurationRetryOrchestrator.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 voidRetryOrchestrator.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
Methods in com.couchbase.client.core.service with type parameters of type Request -
Uses of Request in com.couchbase.client.core.service.strategy
Methods in com.couchbase.client.core.service.strategy with type parameters of type Request -
Uses of Request in com.couchbase.client.core.transaction.components
Classes in com.couchbase.client.core.transaction.components that implement RequestModifier and TypeClassDescriptionclassThis doesn't correspond to an individual server request.
CoreHttpClient.