Uses of Interface
com.couchbase.client.core.cnc.RequestSpan
Package
Description
-
Uses of RequestSpan in com.couchbase.client.core.cnc
Modifier and TypeMethodDescriptionstatic RequestSpan
CbTracing.newSpan
(RequestTracer tracer, String spanName, RequestSpan parent) Deprecated.static RequestSpan
CbTracing.newSpan
(CoreContext coreContext, String spanName, RequestSpan parent) Returns a new span with the `db.system` attribute set to `couchbase`.RequestTracer.requestSpan
(String name, RequestSpan parent) Creates a new request span with or without a parent.Modifier and TypeMethodDescriptionstatic 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
(RequestTracer tracer, String spanName, RequestSpan parent) Deprecated.In favor ofRequestTracer.requestSpan(String, RequestSpan)
, which now always sets the `db.system` attribute.static RequestSpan
CbTracing.newSpan
(CoreContext coreContext, String spanName, RequestSpan parent) Returns a new span with the `db.system` attribute set to `couchbase`.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) -
Uses of RequestSpan in com.couchbase.client.core.cnc.tracing
Modifier and TypeClassDescriptionclass
A NOOP implementation of a request span, utilized by theNoopRequestTracer
.class
Modifier and TypeMethodDescriptionNoopRequestTracer.requestSpan
(String operationName, RequestSpan parent) ThresholdLoggingTracer.requestSpan
(String name, RequestSpan parent) Modifier and TypeMethodDescriptionNoopRequestTracer.requestSpan
(String operationName, RequestSpan parent) ThresholdLoggingTracer.requestSpan
(String name, RequestSpan parent) -
Uses of RequestSpan in com.couchbase.client.core.endpoint.http
Modifier and TypeMethodDescriptionstatic CoreCommonOptions
CoreCommonOptions.of
(Duration timeout, RetryStrategy retryStrategy, RequestSpan parentSpan) default CoreCommonOptions
CoreCommonOptions.withParentSpan
(RequestSpan span) Modifier and TypeMethodDescriptionCoreHttpRequest.Builder.trace
(String spanName, Consumer<RequestSpan> attributeSetter) -
Uses of RequestSpan in com.couchbase.client.core.io.netty
Modifier and TypeMethodDescriptionstatic 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). -
Uses of RequestSpan in com.couchbase.client.core.msg
Modifier and TypeMethodDescriptionBaseRequest.requestSpan()
Request.requestSpan()
Holds the internal span for this request.ModifierConstructorDescriptionBaseRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, RequestSpan requestSpan) Creates a basic request that has all the required properties to be executed in general. -
Uses of RequestSpan in com.couchbase.client.core.msg.analytics
ModifierConstructorDescriptionAnalyticsRequest
(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, boolean translateExceptions, int apiVersion) -
Uses of RequestSpan in com.couchbase.client.core.msg.kv
Modifier and TypeMethodDescriptiondefault void
SyncDurabilityRequest.applyLevelOnSpan
(Optional<DurabilityLevel> level, RequestSpan span) Helper method to apply the durability level if present to the request span.static ReplicaSubdocGetRequest
ReplicaSubdocGetRequest.create
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<CoreSubdocGetCommand> commands, short replica, RequestSpan span) static SubdocGetRequest
SubdocGetRequest.create
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte flags, List<CoreSubdocGetCommand> commands, RequestSpan span) ModifierConstructorDescriptionAppendRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, byte[] content, long cas, Optional<DurabilityLevel> syncReplicationType, RequestSpan span) protected
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, int userFlags, 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) -
Uses of RequestSpan in com.couchbase.client.core.msg.manager
ModifierConstructorDescriptionGenericManagerRequest
(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. -
Uses of RequestSpan in com.couchbase.client.core.msg.query
ModifierConstructorDescriptionQueryRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String statement, byte[] query, boolean idempotent, String contextId, RequestSpan span, String bucket, String scope, NodeIdentifier target) -
Uses of RequestSpan in com.couchbase.client.core.msg.search
ModifierConstructorDescriptionServerSearchRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String indexName, byte[] content, RequestSpan span, CoreBucketAndScope scope) -
Uses of RequestSpan in com.couchbase.client.core.msg.view
ModifierConstructorDescriptionViewRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, Authenticator authenticator, String bucket, String design, String view, String query, Optional<byte[]> keysJson, boolean development, RequestSpan span) -
Uses of RequestSpan in com.couchbase.client.core.protostellar
Modifier and TypeMethodDescriptionstatic RequestSpan
CoreProtostellarUtil.createSpan
(CoreProtostellar core, String spanName, CoreDurability durability, RequestSpan parent) ProtostellarBaseRequest.requestSpan()
ProtostellarRequest.span()
Modifier and TypeMethodDescriptionGrpcAwareRequestTracer.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) ModifierConstructorDescriptionProtostellarCollectionManagerRequest
(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) -
Uses of RequestSpan in com.couchbase.client.core.service.kv
Modifier and TypeMethodDescriptionstatic <R> CompletableFuture
<List<CompletableFuture<R>>> ReplicaHelper.getAllReplicasAsync
(Core core, CollectionIdentifier collectionIdentifier, String documentId, Duration timeout, RetryStrategy retryStrategy, Map<String, Object> clientContext, RequestSpan parentSpan, CoreReadPreference readPreference, 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, CoreReadPreference readPreference) static CompletableFuture
<Stream<GetRequest>> ReplicaHelper.getAllReplicasRequests
(Core core, CollectionIdentifier collectionIdentifier, String documentId, Map<String, Object> clientContext, RetryStrategy retryStrategy, Duration timeout, RequestSpan parent, CoreReadPreference readPreference) Helper method to assemble a stream of requests to the active and all replicasstatic <R> CompletableFuture
<R> ReplicaHelper.getAnyReplicaAsync
(Core core, CollectionIdentifier collectionIdentifier, String documentId, Duration timeout, RetryStrategy retryStrategy, Map<String, Object> clientContext, RequestSpan parentSpan, CoreReadPreference readPreference, 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, CoreReadPreference readPreference, 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, CoreReadPreference readPreference) 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, CoreReadPreference readPreference) Helper method to assemble a stream of requests to the active and all replicasstatic <R> CompletableFuture
<R> ReplicaHelper.lookupInAnyReplicaAsync
(Core core, CollectionIdentifier collectionIdentifier, String documentId, List<CoreSubdocGetCommand> commands, Duration timeout, RetryStrategy retryStrategy, Map<String, Object> clientContext, RequestSpan parentSpan, CoreReadPreference readPreference, Function<CoreSubdocGetResult, R> responseMapper) ModifierConstructorDescriptionObserveContext
(CoreContext ctx, Observe.ObservePersistTo persistTo, Observe.ObserveReplicateTo replicateTo, Optional<MutationToken> mutationToken, long cas, CollectionIdentifier collectionIdentifier, String key, boolean remove, Duration timeout, RequestSpan parentSpan) -
Uses of RequestSpan in com.couchbase.client.core.transaction
Modifier and TypeMethodDescriptionCoreTransactionsReactive.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.CoreTransactionsReactive.queryBlocking
(String statement, CoreQueryContext qc, CoreQueryOptions queryOptions, Optional<RequestSpan> parentSpan) -
Uses of RequestSpan in com.couchbase.client.core.transaction.components
ModifierConstructorDescriptionCoreTransactionRequest
(Duration timeout, CoreContext ctx, RequestSpan span) -
Uses of RequestSpan in com.couchbase.client.core.transaction.config
Modifier and TypeMethodDescriptionCoreMergedTransactionConfig.parentSpan()
CoreTransactionOptions.parentSpan()
Modifier and TypeMethodDescriptionstatic CoreTransactionOptions
CoreTransactionOptions.create
(RequestSpan parentSpan) -
Uses of RequestSpan in com.couchbase.client.core.transaction.support
-
Uses of RequestSpan in com.couchbase.client.core.util
Modifier and TypeMethodDescriptionstatic AutoCloseable
ProtostellarUtil.activateSpan
(Optional<RequestSpan> parentSpan, RequestSpan span, RequestTracer tracer) Modifier and TypeMethodDescriptionstatic AutoCloseable
ProtostellarUtil.activateSpan
(Optional<RequestSpan> parentSpan, RequestSpan span, RequestTracer tracer)
RequestTracer.requestSpan(String, RequestSpan)
, which now always sets the `db.system` attribute.