Constructor and Description |
---|
CollectionMapRefreshFailedEvent(Duration duration,
Context context,
CollectionIdentifier collectionIdentifier,
Throwable cause,
CollectionMapRefreshFailedEvent.Reason reason) |
CollectionMapRefreshSucceededEvent(Duration duration,
Context context,
CollectionIdentifier collectionIdentifier,
long cid) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultConfigurationProvider.refreshCollectionId(CollectionIdentifier identifier) |
void |
ConfigurationProvider.refreshCollectionId(CollectionIdentifier identifier)
Helper method to refresh the collection map for the given collection.
|
Modifier and Type | Method and Description |
---|---|
static ReducedKeyValueErrorContext |
ReducedKeyValueErrorContext.create(String id,
CollectionIdentifier collectionIdentifier) |
Modifier and Type | Method and Description |
---|---|
static CollectionIdentifier |
CollectionIdentifier.fromDefault(String bucket) |
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
CollectionIdentifier |
BaseKeyValueRequest.collectionIdentifier() |
CollectionIdentifier |
KeyValueRequest.collectionIdentifier() |
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) |
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,
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,
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,
int flags,
Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
Optional<DurabilityLevel> syncReplicationType,
RequestSpan span) |
Modifier and Type | Method and Description |
---|---|
CollectionIdentifier |
ObserveContext.collectionIdentifier() |
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) |
Copyright © 2021 Couchbase, Inc.. All rights reserved.