Uses of Class
com.couchbase.client.core.io.CollectionIdentifier
Package
Description
-
Uses of CollectionIdentifier in com.couchbase.client.core
-
Uses of CollectionIdentifier in com.couchbase.client.core.api.kv
Modifier and TypeMethodDescriptionstatic void
CoreKvParamValidators.validateUnlockParams
(CoreCommonOptions common, String key, long cas, CollectionIdentifier collectionIdentifier) -
Uses of CollectionIdentifier in com.couchbase.client.core.cnc.events.config
Modifier and TypeMethodDescriptionCollectionMapRefreshFailedEvent.collectionIdentifier()
CollectionMapRefreshIgnoredEvent.collectionIdentifier()
ModifierConstructorDescriptionCollectionMapRefreshFailedEvent
(Duration duration, Context context, CollectionIdentifier collectionIdentifier, Throwable cause, CollectionMapRefreshFailedEvent.Reason reason) CollectionMapRefreshIgnoredEvent
(Context context, CollectionIdentifier collectionIdentifier) CollectionMapRefreshSucceededEvent
(Duration duration, Context context, CollectionIdentifier collectionIdentifier, long cid) -
Uses of CollectionIdentifier in com.couchbase.client.core.cnc.events.io
ModifierConstructorDescriptionCollectionOutdatedHandledEvent
(CollectionIdentifier collectionIdentifier, RetryReason retryReason, IoContext context) -
Uses of CollectionIdentifier in com.couchbase.client.core.cnc.events.transaction
ModifierConstructorDescriptionTransactionCleanupAttemptEvent
(Event.Severity severity, boolean success, boolean isRegular, List<TransactionLogEvent> logs, String attemptId, String atrId, CollectionIdentifier atrCollection, CleanupRequest req, String addlDebug) -
Uses of CollectionIdentifier in com.couchbase.client.core.config
Modifier and TypeMethodDescriptionboolean
ConfigurationProvider.collectionRefreshInProgress
(CollectionIdentifier identifier) Returns true if a collection refresh is in progress for the given identifier.boolean
DefaultConfigurationProvider.collectionRefreshInProgress
(CollectionIdentifier identifier) void
ConfigurationProvider.refreshCollectionId
(CollectionIdentifier identifier) Helper method to refresh the collection map for the given collection.void
DefaultConfigurationProvider.refreshCollectionId
(CollectionIdentifier identifier) -
Uses of CollectionIdentifier in com.couchbase.client.core.error.context
Modifier and TypeMethodDescriptionstatic ReducedKeyValueErrorContext
ReducedKeyValueErrorContext.create
(String id, CollectionIdentifier collectionIdentifier) ModifierConstructorDescriptionprotected
ReducedKeyValueErrorContext
(String id, CollectionIdentifier collectionIdentifier) -
Uses of CollectionIdentifier in com.couchbase.client.core.io
Modifier and TypeMethodDescriptionstatic CollectionIdentifier
CollectionIdentifier.fromDefault
(String bucket) Modifier and TypeMethodDescriptionMap<CollectionIdentifier,
byte[]> CollectionMap.inner()
Returns the inner map, mainly for print/debug purposes.Modifier and TypeMethodDescriptionbyte[]
CollectionMap.get
(CollectionIdentifier key) Retrieves the collection id for the given identifier.void
CollectionMap.put
(CollectionIdentifier key, byte[] value) Stores a new collection ID with the given identifier. -
Uses of CollectionIdentifier in com.couchbase.client.core.kv
ModifierConstructorDescriptionRangeScanOrchestrator
(Core core, CollectionIdentifier collectionIdentifier) Creates a newRangeScanOrchestrator
which can be shared across calls. -
Uses of CollectionIdentifier in com.couchbase.client.core.msg.kv
Modifier and TypeMethodDescriptionBaseKeyValueRequest.collectionIdentifier()
KeyValueRequest.collectionIdentifier()
Modifier and TypeMethodDescriptionstatic 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) static RangeScanCreateRequest
RangeScanCreateRequest.forRangeScan
(byte[] startTerm, CoreRangeScan rangeScan, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier, Map<Short, MutationToken> consistencyMap) static RangeScanCreateRequest
RangeScanCreateRequest.forSamplingScan
(CoreSamplingScan samplingScan, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier, Map<Short, MutationToken> consistencyMap) 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) protected
BaseKeyValueRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier, RequestSpan span) CarrierBucketConfigRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, NodeIdentifier target, ConfigVersion ifNewerThan) 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) GetCollectionIdRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier) GetCollectionManifestRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier) 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) KvPingRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier identifier, NodeIdentifier target) MultiObserveViaCasRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier, NodeIdentifier target, Map<byte[], Short> keys, Predicate<ObserveViaCasResponse.ObserveStatus> responsePredicate) NoopRequest
(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, CollectionIdentifier collectionIdentifier) ObserveViaCasRequest
(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, String key, boolean active, int replica) 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) RangeScanCancelRequest
(CoreRangeScanId id, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier) RangeScanContinueRequest
(CoreRangeScanId id, Sinks.Many<CoreRangeScanItem> sink, String key, CoreScanOptions options, short partition, CoreContext ctx, CollectionIdentifier collectionIdentifier) 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 CollectionIdentifier 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, 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 replicasstatic <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 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, 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 CollectionIdentifier in com.couchbase.client.core.transaction
Modifier and TypeMethodDescriptionstatic CoreTransactionGetResult
CoreTransactionGetResult.createFrom
(CollectionIdentifier collection, String documentId, SubdocGetResponse doc) CoreTransactionAttemptContext.get
(CollectionIdentifier collection, String id) Gets a document with the specifiedid
and from the specified Couchbasebucket
.CoreTransactionAttemptContext.insert
(CollectionIdentifier collection, String id, byte[] content, int flagsToStage, SpanWrapper pspan) Inserts a new document into the specified Couchbasecollection
.CoreTransactionAttemptContext.insert
(CollectionIdentifier collection, String id, byte[] content, SpanWrapper pspan) Deprecated.in favor ofCoreTransactionAttemptContext.insert(CollectionIdentifier, String, byte[], int, SpanWrapper)
which takes an additional 'flags' argument.ModifierConstructorDescriptionCoreTransactionGetResult
(String id, byte[] content, int userFlags, long cas, CollectionIdentifier collection, TransactionLinks links, Optional<DocumentMetadata> documentMetadata, Optional<com.couchbase.client.core.deps.com.fasterxml.jackson.databind.JsonNode> txnMeta, Optional<String> crc32OfGet) Note that it's intentionally obfuscated here as to whether both content and userFlags come from the document's current body, or staged in the transactional metadata. -
Uses of CollectionIdentifier in com.couchbase.client.core.transaction.cleanup
Modifier and TypeMethodDescriptionCoreTransactionsCleanup.cleanupSet()
LostCleanupDistributed.cleanupSet()
Modifier and TypeMethodDescriptionvoid
CoreTransactionsCleanup.addToCleanupSet
(CollectionIdentifier coll) void
LostCleanupDistributed.addToCleanupSet
(CollectionIdentifier coll) TransactionsCleaner.cleanupATREntry
(CollectionIdentifier atrCollection, String atrId, String attemptId, ActiveTransactionRecordEntry atrEntry, boolean isRegularCleanup) Kept purely for backwards compatibility with FIT performer.static CleanupRequest
CleanupRequest.fromAtrEntry
(CollectionIdentifier atrCollection, ActiveTransactionRecordEntry atrEntry) ClientRecord.getClientRecord
(CollectionIdentifier collection, SpanWrapper span) LostCleanupDistributed.handleATRCleanup
(String bp, CollectionIdentifier atrCollection, String atrId, ActiveTransactionRecordStats stats, Duration safetyMargin, SpanWrapper pspan) Looks at an ATR, finds any expired entries, and cleans them up.ClientRecord.processClient
(String clientUuid, CollectionIdentifier collection, CoreTransactionsConfig config, SpanWrapper pspan) Modifier and TypeMethodDescriptionClientRecord.removeClientFromClientRecord
(String clientUuid, Duration timeout, Set<CollectionIdentifier> collections) Called on shutdown to cleanly remove a client from the client-record.ClientRecord.removeClientFromClientRecord
(String clientUuid, Set<CollectionIdentifier> cleanupSet) ModifierConstructorDescriptionCleanupRequest
(String attemptId, String atrId, CollectionIdentifier atrCollection, AttemptState state, List<DocRecord> stagedReplaces, List<DocRecord> stagedRemoves, List<DocRecord> stagedInserts, Duration delay, Optional<ForwardCompatibility> forwardCompatibility, long ageMillis, Optional<DurabilityLevel> durabilityLevel) -
Uses of CollectionIdentifier in com.couchbase.client.core.transaction.components
Modifier and TypeMethodDescriptionActiveTransactionRecords.collection()
TransactionLinks.collection()
Modifier and TypeMethodDescriptionstatic Mono<Optional<ActiveTransactionRecordEntry>>
ActiveTransactionRecord.findEntryForTransaction
(Core core, CollectionIdentifier atrCollection, String atrId, String attemptId, CoreMergedTransactionConfig config, SpanWrapper pspan, CoreTransactionLogger logger) static Mono<Optional<ActiveTransactionRecordEntry>>
ActiveTransactionRecord.findEntryForTransaction
(Core core, CollectionIdentifier atrCollection, String atrId, String attemptId, CoreMergedTransactionConfig config, SpanWrapper pspan, CoreTransactionLogger logger, MeteringUnits.MeteringUnitsBuilder units) static Mono<Optional<CoreTransactionGetResult>>
DocumentGetter.getAsync
(Core core, CoreTransactionLogger LOGGER, CollectionIdentifier collection, CoreMergedTransactionConfig config, String docId, String byAttemptId, boolean justReturn, SpanWrapper span, Optional<String> resolvingMissingATREntry, MeteringUnits.MeteringUnitsBuilder units, CoreTransactionsSupportedExtensions supported) static Mono<Optional<ActiveTransactionRecords>>
ActiveTransactionRecord.getAtr
(Core core, CollectionIdentifier atrCollection, String atrId, Duration timeout, SpanWrapper pspan) TXNJ-13: Get the ATR.static RedactableArgument
ActiveTransactionRecordUtil.getAtrDebug
(CollectionIdentifier collection, String atrId) DocumentGetter.justGetDoc
(Core core, CollectionIdentifier collection, String docId, Duration timeout, SpanWrapper span, boolean accessDeleted, CoreTransactionLogger logger, MeteringUnits.MeteringUnitsBuilder units) Modifier and TypeMethodDescriptionstatic RedactableArgument
ActiveTransactionRecordUtil.getAtrDebug
(Optional<CollectionIdentifier> collection, Optional<String> atrId) ModifierConstructorDescriptionActiveTransactionRecords
(String id, CollectionIdentifier collection, long casInNanos, List<ActiveTransactionRecordEntry> entries, CasMode casMode) -
Uses of CollectionIdentifier in com.couchbase.client.core.transaction.config
Modifier and TypeMethodDescriptionCoreTransactionsCleanupConfig.cleanupSet()
CoreMergedTransactionConfig.metadataCollection()
CoreSingleQueryTransactionOptions.metadataCollection()
CoreTransactionOptions.metadataCollection()
CoreTransactionsConfig.metadataCollection()
Modifier and TypeMethodDescriptionstatic CoreTransactionsConfig
CoreTransactionsConfig.createForSingleQueryTransactions
(DurabilityLevel durabilityLevel, Duration timeout, TransactionAttemptContextFactory transactionAttemptContextFactory, Optional<CollectionIdentifier> metadataCollection, CoreTransactionsSupportedExtensions supported) ModifierConstructorDescriptionCoreTransactionsCleanupConfig
(boolean runLostAttemptsCleanupThread, boolean runRegularAttemptsCleanupThread, Duration cleanupWindow, Set<CollectionIdentifier> cleanupSet) CoreTransactionsConfig
(DurabilityLevel durabilityLevel, Duration timeout, CoreTransactionsCleanupConfig cleanupConfig, TransactionAttemptContextFactory attemptContextFactory, CleanerFactory cleanerFactory, ClientRecordFactory clientRecordFactory, int numAtrs, Optional<CollectionIdentifier> metadataCollection, Optional<String> scanConsistency, CoreTransactionsSupportedExtensions supported) -
Uses of CollectionIdentifier in com.couchbase.client.core.transaction.support
Modifier and TypeMethodDescriptionstatic SpanWrapper
SpanWrapperUtil.createOp
(CoreTransactionAttemptContext ctx, RequestTracer tracer, CollectionIdentifier collection, String id, String op, SpanWrapper attemptSpan) static SpanWrapper
SpanWrapperUtil.setAttributes
(SpanWrapper out, CoreTransactionAttemptContext ctx, CollectionIdentifier collection, String id) ModifierConstructorDescriptionStagedMutation
(String operationId, String id, CollectionIdentifier collection, long cas, Optional<DocumentMetadata> documentMetadata, Optional<String> crc32, int currentUserFlags, byte[] content, int stagedUserFlags, StagedMutationType type) -
Uses of CollectionIdentifier in com.couchbase.client.core.transaction.util
Modifier and TypeMethodDescriptionstatic LogDeferDocId
DebugUtil.docId
(CollectionIdentifier collection, String docId) static Mono<InsertResponse>
TransactionKVHandler.insert
(Core core, CollectionIdentifier collectionIdentifier, String id, byte[] transcodedContent, int flags, Duration timeout, Optional<DurabilityLevel> durabilityLevel, Map<String, Object> clientContext, SpanWrapper pspan) static Mono<SubdocGetResponse>
TransactionKVHandler.lookupIn
(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean accessDeleted, Map<String, Object> clientContext, SpanWrapper pspan, List<SubdocGetRequest.Command> commands) static Mono<SubdocMutateResponse>
TransactionKVHandler.mutateIn
(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, long cas, int userFlags, Optional<DurabilityLevel> durabilityLevel, Map<String, Object> clientContext, SpanWrapper span, List<SubdocMutateRequest.Command> commands) static Mono<SubdocMutateResponse>
TransactionKVHandler.mutateIn
(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean insertDocument, boolean upsertDocument, boolean reviveDocument, boolean accessDeleted, boolean createAsDeleted, long cas, int userFlags, Optional<DurabilityLevel> durabilityLevel, Map<String, Object> clientContext, SpanWrapper pspan, List<SubdocMutateRequest.Command> commands, CoreTransactionLogger logger) static Mono<RemoveResponse>
TransactionKVHandler.remove
(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, long cas, Optional<DurabilityLevel> durabilityLevel, Map<String, Object> clientContext, SpanWrapper pspan)