Uses of Class
com.couchbase.client.core.io.CollectionIdentifier
-
-
Uses of CollectionIdentifier in com.couchbase.client.core.cnc.events.config
Methods in com.couchbase.client.core.cnc.events.config that return CollectionIdentifier Modifier and Type Method Description CollectionIdentifier
CollectionMapRefreshFailedEvent. collectionIdentifier()
CollectionIdentifier
CollectionMapRefreshIgnoredEvent. collectionIdentifier()
Constructors in com.couchbase.client.core.cnc.events.config with parameters of type CollectionIdentifier Constructor Description CollectionMapRefreshFailedEvent(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
Constructors in com.couchbase.client.core.cnc.events.io with parameters of type CollectionIdentifier Constructor Description CollectionOutdatedHandledEvent(CollectionIdentifier collectionIdentifier, RetryReason retryReason, IoContext context)
-
Uses of CollectionIdentifier in com.couchbase.client.core.config
Methods in com.couchbase.client.core.config with parameters of type CollectionIdentifier Modifier and Type Method Description boolean
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
Methods in com.couchbase.client.core.error.context with parameters of type CollectionIdentifier Modifier and Type Method Description static ReducedKeyValueErrorContext
ReducedKeyValueErrorContext. create(String id, CollectionIdentifier collectionIdentifier)
-
Uses of CollectionIdentifier in com.couchbase.client.core.io
Methods in com.couchbase.client.core.io that return CollectionIdentifier Modifier and Type Method Description static CollectionIdentifier
CollectionIdentifier. fromDefault(String bucket)
Methods in com.couchbase.client.core.io that return types with arguments of type CollectionIdentifier Modifier and Type Method Description Map<CollectionIdentifier,byte[]>
CollectionMap. inner()
Returns the inner map, mainly for print/debug purposes.Methods in com.couchbase.client.core.io with parameters of type CollectionIdentifier Modifier and Type Method Description byte[]
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.msg.kv
Methods in com.couchbase.client.core.msg.kv that return CollectionIdentifier Modifier and Type Method Description CollectionIdentifier
BaseKeyValueRequest. collectionIdentifier()
CollectionIdentifier
KeyValueRequest. collectionIdentifier()
Constructors in com.couchbase.client.core.msg.kv with parameters of type CollectionIdentifier Constructor 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)
BaseKeyValueRequest(Duration timeout, CoreContext ctx, RetryStrategy retryStrategy, String key, CollectionIdentifier collectionIdentifier, RequestSpan span)
CarrierBucketConfigRequest(Duration timeout, CoreContext ctx, CollectionIdentifier collectionIdentifier, RetryStrategy retryStrategy, NodeIdentifier target)
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)
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 accessDeleted, boolean createAsDeleted, List<SubdocMutateRequest.Command> 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
Methods in com.couchbase.client.core.service.kv that return CollectionIdentifier Modifier and Type Method Description CollectionIdentifier
ObserveContext. collectionIdentifier()
Methods in com.couchbase.client.core.service.kv with parameters of type CollectionIdentifier Modifier and Type Method 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 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 Mono<ReplicaHelper.GetReplicaResponse>
ReplicaHelper. getAnyReplicaReactive(Core core, CollectionIdentifier collectionIdentifier, String documentId, Duration timeout, RetryStrategy retryStrategy, Map<String,Object> clientContext, RequestSpan parentSpan)
Constructors in com.couchbase.client.core.service.kv with parameters of type CollectionIdentifier Constructor 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)
-