Modifier and Type | Method and Description |
---|---|
static RequestSpan |
CbTracing.newSpan(CoreContext coreContext,
String spanName,
RequestSpan parent)
Returns a new span with the `db.system` attribute set to `couchbase`.
|
static RequestSpan |
CbTracing.newSpan(RequestTracer tracer,
String spanName,
RequestSpan parent)
Returns a new span with the `db.system` attribute set to `couchbase`.
|
RequestSpan |
RequestTracer.requestSpan(String name,
RequestSpan parent)
Creates a new request span with or without a parent.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
CbTracing.isInternalSpan(RequestSpan span)
Returns true if the span is an internal one (noop or threshold) so that particular
optimizations can be applied.
|
static RequestSpan |
CbTracing.newSpan(CoreContext coreContext,
String spanName,
RequestSpan parent)
Returns a new span with the `db.system` attribute set to `couchbase`.
|
static RequestSpan |
CbTracing.newSpan(RequestTracer tracer,
String spanName,
RequestSpan parent)
Returns a new span with the `db.system` attribute set to `couchbase`.
|
RequestSpan |
RequestTracer.requestSpan(String name,
RequestSpan parent)
Creates a new request span with or without a parent.
|
static void |
CbTracing.setAttributes(RequestSpan span,
Map<String,?> attributes) |
Modifier and Type | Class and Description |
---|---|
class |
NoopRequestSpan
A NOOP implementation of a request span, utilized by the
NoopRequestTracer . |
class |
ThresholdRequestSpan |
Modifier and Type | Method and Description |
---|---|
RequestSpan |
ThresholdLoggingTracer.requestSpan(String name,
RequestSpan parent) |
RequestSpan |
NoopRequestTracer.requestSpan(String operationName,
RequestSpan parent) |
Modifier and Type | Method and Description |
---|---|
RequestSpan |
ThresholdLoggingTracer.requestSpan(String name,
RequestSpan parent) |
RequestSpan |
NoopRequestTracer.requestSpan(String operationName,
RequestSpan parent) |
Modifier and Type | Method and Description |
---|---|
Optional<RequestSpan> |
CoreCommonOptions.parentSpan() |
Modifier and Type | Method and Description |
---|---|
static CoreCommonOptions |
CoreCommonOptions.of(Duration timeout,
RetryStrategy retryStrategy,
RequestSpan parentSpan) |
default CoreCommonOptions |
CoreCommonOptions.withParentSpan(RequestSpan span) |
Modifier and Type | Method and Description |
---|---|
static CoreCommonOptions |
CoreCommonOptions.ofOptional(Optional<Duration> timeout,
Optional<RetryStrategy> retryStrategy,
Optional<RequestSpan> parentSpan) |
Modifier and Type | Method and Description |
---|---|
static void |
TracingUtils.setCommonDispatchSpanAttributes(RequestSpan span,
String localId,
String localHost,
int localPort,
String remoteHost,
int remotePort,
String operationId)
Sets common dispatch span attributes as per spec.
|
static void |
TracingUtils.setCommonKVSpanAttributes(RequestSpan span,
KeyValueRequest<Response> request)
Sets attributes that are usefully duplicated across multiple spans.
|
static void |
TracingUtils.setNumericOperationId(RequestSpan span,
long operationId)
Sets the operation ID as a numeric value.
|
static void |
TracingUtils.setServerDurationAttribute(RequestSpan span,
long serverDuration)
Sets the server duration attribute, if larger than 0 (will ignore it otherwise).
|
Modifier and Type | Method and Description |
---|---|
RequestSpan |
Request.requestSpan()
Holds the internal span for this request.
|
RequestSpan |
BaseRequest.requestSpan() |
Constructor and Description |
---|
BaseRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
RequestSpan requestSpan)
Creates a basic request that has all the required properties to be
executed in general.
|
Constructor and Description |
---|
AnalyticsRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
byte[] query,
int priority,
boolean idempotent,
String contextId,
String statement,
RequestSpan span,
String bucket,
String scope) |
AnalyticsRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
byte[] query,
int priority,
boolean idempotent,
String contextId,
String statement,
RequestSpan span,
String bucket,
String scope,
String uri,
com.couchbase.client.core.deps.io.netty.handler.codec.http.HttpMethod httpMethod) |
Modifier and Type | Method and Description |
---|---|
default void |
SyncDurabilityRequest.applyLevelOnSpan(Optional<DurabilityLevel> level,
RequestSpan span)
Helper method to apply the durability level if present to the request span.
|
static SubdocGetRequest |
SubdocGetRequest.create(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte flags,
List<CoreSubdocGetCommand> commands,
RequestSpan span) |
static ReplicaSubdocGetRequest |
ReplicaSubdocGetRequest.create(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte flags,
List<CoreSubdocGetCommand> commands,
short replica,
RequestSpan span) |
Constructor and Description |
---|
AppendRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte[] content,
long cas,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
BaseKeyValueRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String key,
CollectionIdentifier collectionIdentifier,
RequestSpan span) |
DecrementRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
long delta,
Optional<Long> initial,
long expiry,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
GetAndLockRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Duration lockFor,
RequestSpan span) |
GetAndTouchRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
long expiration,
RequestSpan span) |
GetMetaRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
RequestSpan span) |
GetRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
RequestSpan span) |
IncrementRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
long delta,
Optional<Long> initial,
long expiration,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
InsertRequest(String key,
byte[] content,
long expiration,
int flags,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
ObserveViaSeqnoRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
int replica,
boolean active,
long vbucketUUID,
String key,
RequestSpan span) |
PredeterminedPartitionRequest(short partition,
Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String key,
CollectionIdentifier collectionIdentifier,
RequestSpan span) |
PrependRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte[] content,
long cas,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
RemoveRequest(String key,
long cas,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
ReplaceRequest(String key,
byte[] content,
long expiration,
boolean preserveExpiry,
int flags,
Duration timeout,
long cas,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
ReplicaGetRequest(String key,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
short replica,
RequestSpan span) |
SubdocGetRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
byte flags,
List<SubdocGetRequest.Command> commands,
RequestSpan span) |
SubdocMutateRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
BucketConfig bucketConfig,
RetryStrategy retryStrategy,
String key,
boolean insertDocument,
boolean upsertDocument,
boolean reviveDocument,
boolean accessDeleted,
boolean createAsDeleted,
List<SubdocMutateRequest.Command> commands,
long expiration,
boolean preserveExpiry,
long cas,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span)
Deprecated.
Please use the other constructor instead.
|
SubdocMutateRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
BucketConfig bucketConfig,
RetryStrategy retryStrategy,
String key,
CoreStoreSemantics storeSemantics,
boolean accessDeleted,
boolean createAsDeleted,
List<CoreSubdocMutateCommand> commands,
long expiration,
boolean preserveExpiry,
long cas,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
TouchRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
long expiry,
RequestSpan span) |
UnlockRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
String key,
long cas,
RequestSpan span) |
UpsertRequest(String key,
byte[] content,
long expiration,
boolean preserveExpiry,
int flags,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
Constructor and Description |
---|
GenericManagerRequest(CoreContext ctx,
Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier,
boolean idempotent,
RequestSpan span)
Deprecated.
|
GenericManagerRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Supplier<com.couchbase.client.core.deps.io.netty.handler.codec.http.FullHttpRequest> requestSupplier,
boolean idempotent,
RequestSpan span)
Deprecated.
|
Constructor and Description |
---|
QueryRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String statement,
byte[] query,
boolean idempotent,
String contextId,
RequestSpan span,
String bucket,
String scope,
NodeIdentifier target) |
Constructor and Description |
---|
ServerSearchRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String indexName,
byte[] content,
RequestSpan span,
CoreBucketAndScope scope) |
Constructor and Description |
---|
ViewRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
Authenticator authenticator,
String bucket,
String design,
String view,
String query,
Optional<byte[]> keysJson,
boolean development,
RequestSpan span) |
Modifier and Type | Method and Description |
---|---|
static RequestSpan |
CoreProtostellarUtil.createSpan(CoreProtostellar core,
String spanName,
CoreDurability durability,
RequestSpan parent) |
RequestSpan |
ProtostellarBaseRequest.requestSpan() |
RequestSpan |
ProtostellarRequest.span() |
Modifier and Type | Method and Description |
---|---|
AutoCloseable |
GrpcAwareRequestTracer.activateSpan(RequestSpan span)
Puts `span` into ThreadLocalStorage, ready to be picked up by libraries that rely on that mechanism and can't be passed the span explicitly.
|
static RequestSpan |
CoreProtostellarUtil.createSpan(CoreProtostellar core,
String spanName,
CoreDurability durability,
RequestSpan parent) |
Constructor and Description |
---|
ProtostellarCollectionManagerRequest(TGrpcRequest request,
CoreProtostellar core,
String bucketName,
String scopeName,
String collectionName,
String requestName,
RequestSpan span,
Duration timeout,
boolean readonly,
RetryStrategy retryStrategy,
Map<String,Object> clientContext) |
ProtostellarKeyValueRequest(TGrpcRequest request,
CoreProtostellar core,
CoreKeyspace keyspace,
String key,
CoreDurability durability,
String requestName,
RequestSpan span,
Duration timeout,
boolean readonly,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
long encodeDurationNanos) |
ProtostellarRequest(TGrpcRequest request,
CoreProtostellar core,
ServiceType serviceType,
String requestName,
RequestSpan span,
Duration timeout,
boolean readonly,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
long encodeDurationNanos,
Consumer<Map<String,Object>> contextSupplier) |
Modifier and Type | Method and Description |
---|---|
RequestSpan |
ObserveContext.parentSpan() |
Modifier and Type | Method and Description |
---|---|
static <R> CompletableFuture<List<CompletableFuture<R>>> |
ReplicaHelper.getAllReplicasAsync(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan,
Function<ReplicaHelper.GetReplicaResponse,R> responseMapper)
Reads from replicas or the active node based on the options and returns the results as a list
of futures that might complete or fail.
|
static Flux<ReplicaHelper.GetReplicaResponse> |
ReplicaHelper.getAllReplicasReactive(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan) |
static CompletableFuture<Stream<GetRequest>> |
ReplicaHelper.getAllReplicasRequests(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Map<String,Object> clientContext,
RetryStrategy retryStrategy,
Duration timeout,
RequestSpan parent)
Helper method to assemble a stream of requests to the active and all replicas
|
static <R> CompletableFuture<R> |
ReplicaHelper.getAnyReplicaAsync(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan,
Function<ReplicaHelper.GetReplicaResponse,R> responseMapper) |
static <R> CompletableFuture<List<CompletableFuture<R>>> |
ReplicaHelper.lookupInAllReplicasAsync(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
List<CoreSubdocGetCommand> commands,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan,
Function<CoreSubdocGetResult,R> responseMapper)
Reads from replicas or the active node based on the options and returns the results as a list
of futures that might complete or fail.
|
static Flux<CoreSubdocGetResult> |
ReplicaHelper.lookupInAllReplicasReactive(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
List<CoreSubdocGetCommand> commands,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan) |
static CompletableFuture<Stream<SubdocGetRequest>> |
ReplicaHelper.lookupInAllReplicasRequests(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
List<CoreSubdocGetCommand> commands,
Map<String,Object> clientContext,
RetryStrategy retryStrategy,
Duration timeout,
RequestSpan parent)
Helper method to assemble a stream of requests to the active and all replicas
|
static <R> CompletableFuture<R> |
ReplicaHelper.lookupInAnyReplicaAsync(Core core,
CollectionIdentifier collectionIdentifier,
String documentId,
List<CoreSubdocGetCommand> commands,
Duration timeout,
RetryStrategy retryStrategy,
Map<String,Object> clientContext,
RequestSpan parentSpan,
Function<CoreSubdocGetResult,R> responseMapper) |
Constructor and Description |
---|
ObserveContext(CoreContext ctx,
Observe.ObservePersistTo persistTo,
Observe.ObserveReplicateTo replicateTo,
Optional<MutationToken> mutationToken,
long cas,
CollectionIdentifier collectionIdentifier,
String key,
boolean remove,
Duration timeout,
RequestSpan parentSpan) |
Modifier and Type | Method and Description |
---|---|
RequestSpan |
CoreTransactionAttemptContext.span() |
Modifier and Type | Method and Description |
---|---|
Mono<CoreReactiveQueryResult> |
CoreTransactionsReactive.query(String statement,
CoreQueryContext queryContext,
CoreQueryOptions queryOptions,
Optional<RequestSpan> parentSpan,
Function<Throwable,RuntimeException> errorConverter)
Performs a single query transaction, with a scope context and custom configuration.
|
Mono<CoreQueryResult> |
CoreTransactionsReactive.queryBlocking(String statement,
CoreQueryContext qc,
CoreQueryOptions queryOptions,
Optional<RequestSpan> parentSpan) |
Constructor and Description |
---|
CoreTransactionRequest(Duration timeout,
CoreContext ctx,
RequestSpan span) |
Modifier and Type | Method and Description |
---|---|
Optional<RequestSpan> |
CoreTransactionOptions.parentSpan() |
Optional<RequestSpan> |
CoreMergedTransactionConfig.parentSpan() |
Modifier and Type | Method and Description |
---|---|
static CoreTransactionOptions |
CoreTransactionOptions.create(RequestSpan parentSpan) |
Constructor and Description |
---|
CoreTransactionOptions(Optional<DurabilityLevel> durabilityLevel,
Optional<String> scanConsistency,
Optional<RequestSpan> parentSpan,
Optional<Duration> timeout,
Optional<CollectionIdentifier> metadataCollection,
Optional<TransactionAttemptContextFactory> attemptContextFactory) |
Modifier and Type | Method and Description |
---|---|
RequestSpan |
SpanWrapper.span() |
Constructor and Description |
---|
SpanWrapper(RequestSpan span) |
Modifier and Type | Method and Description |
---|---|
static AutoCloseable |
ProtostellarUtil.activateSpan(Optional<RequestSpan> parentSpan,
RequestSpan span,
RequestTracer tracer) |
Modifier and Type | Method and Description |
---|---|
static AutoCloseable |
ProtostellarUtil.activateSpan(Optional<RequestSpan> parentSpan,
RequestSpan span,
RequestTracer tracer) |
Copyright © 2024 Couchbase, Inc.. All rights reserved.