Modifier and Type | Method and Description |
---|---|
void |
Timer.register(Request<Response> request)
Registers the given request to be tracked with its timeout value.
|
ValueRecorder |
Core.responseMetric(Request<?> request) |
void |
Timer.scheduleForRetry(Core core,
Request<? extends Response> request,
Duration runAfter)
Schedules a request to be retried after the given duration.
|
<R extends Response> |
Core.send(Request<R> request)
Sends a command into the core layer and registers the request with the timeout timer.
|
<R extends Response> |
Core.send(Request<R> request,
boolean registerForTimeout)
Sends 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)
|
Modifier and Type | Method and Description |
---|---|
void |
OrphanReporter.report(Request<?> request)
Reports an orphaned
Request . |
Constructor and Description |
---|
RequestNotRetriedEvent(Event.Severity severity,
Class<? extends Request> clazz,
RequestContext context,
RetryReason reason,
Throwable throwable) |
Modifier and Type | Method and Description |
---|---|
<R extends Request<? extends Response>> |
BaseEndpoint.send(R request) |
<R extends Request<? extends Response>> |
Endpoint.send(R request)
Sends the request into this
Endpoint . |
Constructor and Description |
---|
GenericRequestErrorContext(Request<?> request) |
Constructor and Description |
---|
ChunkedHandlerSwitcher(ChunkedMessageHandler chunkedHandler,
NonChunkedHttpMessageHandler nonChunkedHandler,
Class<? extends Request> chunkedClass)
Creates a new chunked handler switcher.
|
Modifier and Type | Interface and Description |
---|---|
interface |
HttpRequest<H extends ChunkHeader,ROW extends ChunkRow,T extends ChunkTrailer,R extends ChunkedResponse<H,ROW,T>> |
interface |
NonChunkedHttpRequest<R extends Response> |
Modifier and Type | Class and Description |
---|---|
class |
BaseRequest<R extends Response>
Base class for all
Requests . |
Modifier and Type | Method and Description |
---|---|
Request<? extends Response> |
RequestContext.request() |
Constructor and Description |
---|
RequestContext(CoreContext ctx,
Request<? extends Response> request)
Creates a new
RequestContext . |
Modifier and Type | Class and Description |
---|---|
class |
AnalyticsPingRequest |
class |
AnalyticsRequest |
class |
GenericAnalyticsRequest |
Modifier and Type | Interface and Description |
---|---|
interface |
KeyValueRequest<R extends Response>
Main parent interface for all Key/Value requests.
|
Modifier and Type | Class and Description |
---|---|
class |
AppendRequest |
class |
BaseKeyValueRequest<R extends Response>
The
BaseKeyValueRequest should be subclassed by all KeyValue requests since it
provides common ground for all of them (i.e. |
class |
CarrierBucketConfigRequest |
class |
CarrierGlobalConfigRequest
A request to fetch a global configuration.
|
class |
DecrementRequest |
class |
GetAndLockRequest
Represents a KV GetAndTouch operation.
|
class |
GetAndTouchRequest
Represents a KV GetAndTouch operation.
|
class |
GetCollectionIdRequest |
class |
GetCollectionManifestRequest |
class |
GetMetaRequest
Represents a kv get meta operation.
|
class |
GetRequest
Represents a KV Get (full document) operation.
|
class |
IncrementRequest |
class |
InsertRequest
Uses the KV "add" command to insert documents if they do not already exist.
|
class |
KvPingRequest |
class |
MultiObserveViaCasRequest
Special observe request implementation to handle more than one key at the same time.
|
class |
NoopRequest
Represents a NOOP KV Request, doing nothing.
|
class |
ObserveViaCasRequest |
class |
ObserveViaSeqnoRequest |
class |
PrependRequest |
class |
RemoveRequest
Represents a KV delete operation.
|
class |
ReplaceRequest
Uses the KV replace command to replace a document if it exists.
|
class |
ReplicaGetRequest |
class |
SubdocGetRequest |
class |
SubdocMutateRequest |
class |
TouchRequest |
class |
UnlockRequest |
class |
UpsertRequest
Uses the KV "set" command to unconditionally replace or insert documents regardless if they
exist or not.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ManagerRequest<R extends Response>
Parent interface for all requests going to the cluster manager.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseManagerRequest<R extends Response>
Base class for the manager requests, mainly to define the service type in a uniform way.
|
class |
BucketConfigRequest |
class |
BucketConfigStreamingRequest
Performs a (potential endless) streaming request against the cluster manager for the given bucket.
|
class |
GenericManagerRequest |
Modifier and Type | Class and Description |
---|---|
class |
QueryPingRequest |
class |
QueryRequest |
class |
TargetedQueryRequest |
Modifier and Type | Class and Description |
---|---|
class |
GenericSearchRequest |
class |
SearchPingRequest |
class |
SearchRequest |
Modifier and Type | Class and Description |
---|---|
class |
GenericViewRequest |
class |
ViewPingRequest |
class |
ViewRequest |
Modifier and Type | Method and Description |
---|---|
<R extends Request<? extends Response>> |
Node.send(R request)
Sends the request into this
Node . |
protected <R extends Request<? extends Response>> |
Node.sendIntoRetry(R request)
Retries the request.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
ViewLocator.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.
|
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 |
KeyValueLocator.dispatch(Request<? extends Response> request,
List<Node> nodes,
ClusterConfig config,
CoreContext ctx) |
void |
RoundRobinLocator.dispatch(Request<? extends Response> request,
List<Node> nodes,
ClusterConfig config,
CoreContext ctx) |
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.
|
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 in
RoundRobinLocator.filterNodes(List, Request, ClusterConfig) . |
Modifier and Type | Method and 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 configured
RetryStrategy . |
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.
|
CompletableFuture<RetryAction> |
FailFastRetryStrategy.shouldRetry(Request<? extends Response> request,
RetryReason reason) |
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).
|
Modifier and Type | Method and Description |
---|---|
<R extends Request<? extends Response>> |
EndpointSelectionStrategy.select(R request,
List<Endpoint> endpoints)
|
<R extends Request<? extends Response>> |
Service.send(R request)
Sends the request into this
Service . |
Modifier and Type | Method and Description |
---|---|
<R extends Request<? extends Response>> |
PartitionSelectionStrategy.select(R request,
List<Endpoint> endpoints) |
<R extends Request<? extends Response>> |
RoundRobinSelectionStrategy.select(R request,
List<Endpoint> endpoints) |
Copyright © 2021 Couchbase, Inc.. All rights reserved.