Uses of Class
com.couchbase.client.core.Core
Package
Description
-
Uses of Core in com.couchbase.client.core
Modifier and TypeMethodDescriptionCoreContext.core()
Returns the core to which this context belongs.static Core
Core.create
(CoreEnvironment environment, Authenticator authenticator, ConnectionString connectionString) static Core
Core.create
(CoreEnvironment environment, Authenticator authenticator, Set<SeedNode> seedNodes) Deprecated.Modifier and TypeMethodDescriptionvoid
Timer.scheduleForRetry
(Core core, Request<? extends Response> request, Duration runAfter) Schedules a request to be retried after the given duration.ModifierConstructorDescriptionCoreContext
(Core core, long id, CoreEnvironment env, Authenticator authenticator) Creates a newCoreContext
. -
Uses of Core in com.couchbase.client.core.api
-
Uses of Core in com.couchbase.client.core.api.manager.search
ModifierConstructorDescriptionClassicCoreScopeSearchIndexManager
(Core core, CoreBucketAndScope scope) -
Uses of Core in com.couchbase.client.core.api.search
-
Uses of Core in com.couchbase.client.core.api.search.util
Modifier and TypeMethodDescriptionstatic CompletableFuture<Void>
SearchCapabilityCheck.scopedSearchIndexCapabilityCheck
(Core core, Duration timeout) static CompletableFuture<Void>
SearchCapabilityCheck.vectorSearchCapabilityCheck
(Core core, Duration timeout) -
Uses of Core in com.couchbase.client.core.classic
Modifier and TypeMethodDescriptionstatic <T extends CoreMutationResult>
CompletableFuture<T>ClassicHelper.maybeWrapWithLegacyDurability
(CompletableFuture<T> input, String key, CoreDurability durability, Core core, KeyValueRequest<?> request) Helper method to wrap a mutation result to perform legacy durability requirements if needed. -
Uses of Core in com.couchbase.client.core.classic.kv
Modifier and TypeMethodDescriptionstatic CompletableFuture<CoreMutationResult>
BinaryAccessor.append
(Core core, AppendRequest request, String key, CoreKeyspace keyspace, CoreDurability durability) static CompletableFuture<CoreCounterResult>
BinaryAccessor.decrement
(Core core, DecrementRequest request, String id, CoreKeyspace keyspace, CoreDurability durability) static CompletableFuture<CoreCounterResult>
BinaryAccessor.increment
(Core core, IncrementRequest request, String id, CoreKeyspace keyspace, CoreDurability durability) static CompletableFuture<CoreMutationResult>
BinaryAccessor.prepend
(Core core, PrependRequest request, String key, CoreKeyspace keyspace, CoreDurability durability) ModifierConstructorDescriptionClassicCoreKvBinaryOps
(Core core, CoreKeyspace keyspace) ClassicCoreKvOps
(Core core, CoreKeyspace keyspace) -
Uses of Core in com.couchbase.client.core.classic.manager
ModifierConstructorDescriptionClassicCoreBucketManager
(Core core) ClassicCoreCollectionManagerOps
(Core core, String bucketName) -
Uses of Core in com.couchbase.client.core.classic.query
ModifierConstructorDescriptionClassicCoreQueryOps
(Core core) EnhancedPreparedStatementStrategy
(Core core, int cacheSize) LegacyPreparedStatementStrategy
(Core core, int cacheSize) PreparedStatementStrategy
(Core core, int cacheSize) -
Uses of Core in com.couchbase.client.core.config
ModifierConstructorDescriptionDefaultConfigurationProvider
(Core core, ConnectionString connectionString) Creates a new configuration provider. -
Uses of Core in com.couchbase.client.core.config.loader
Modifier and TypeMethodDescriptionprotected Core
BaseBucketLoader.core()
Returns the attachedCore
to be used by implementations. -
Uses of Core in com.couchbase.client.core.config.refresher
ModifierConstructorDescriptionClusterManagerBucketRefresher
(ConfigurationProvider provider, Core core) GlobalRefresher
(ConfigurationProvider provider, Core core) Creates a new global refresher.KeyValueBucketRefresher
(ConfigurationProvider provider, Core core) -
Uses of Core in com.couchbase.client.core.diagnostics
Modifier and TypeMethodDescriptionstatic Mono<PingResult>
HealthPinger.ping
(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, Optional<String> bucketName) static Mono<PingResult>
HealthPinger.ping
(Core core, Optional<Duration> timeout, RetryStrategy retryStrategy, Set<ServiceType> serviceTypes, Optional<String> reportId, Optional<String> bucketName, WaitUntilReadyHelper.WaitUntilReadyLogger log) Performs a service ping against all or (if given) the services provided.static CompletableFuture<Void>
WaitUntilReadyHelper.waitUntilReady
(Core core, Set<ServiceType> serviceTypes, Duration timeout, ClusterState desiredState, Optional<String> bucketName) -
Uses of Core in com.couchbase.client.core.endpoint.http
Modifier and TypeMethodDescription -
Uses of Core in com.couchbase.client.core.kv
ModifierConstructorDescriptionRangeScanOrchestrator
(Core core, CollectionIdentifier collectionIdentifier) Creates a newRangeScanOrchestrator
which can be shared across calls. -
Uses of Core in com.couchbase.client.core.manager
ModifierConstructorDescriptionCoreAnalyticsLinkManager
(Core core) CoreBucketManager
(Core core) Deprecated.CoreEventingFunctionManager
(Core core, CoreBucketAndScope scope) CoreViewIndexManager
(Core core, String bucket) -
Uses of Core in com.couchbase.client.core.msg
ModifierConstructorDescriptionRequestContext
(Core core, long contextId, CoreEnvironment environment, Authenticator authenticator, Request<? extends Response> request) -
Uses of Core in com.couchbase.client.core.retry
Modifier and TypeMethodDescriptionstatic Throwable
AuthErrorDecider.getTlsHandshakeFailure
(Core core) -
Uses of Core 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) -
Uses of Core in com.couchbase.client.core.transaction
Modifier and TypeMethodDescriptionCoreTransactionAttemptContext.core()
CoreTransactionsReactive.core()
ModifierConstructorDescriptionCoreTransactionAttemptContext
(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan, CoreTransactionAttemptContextHooks hooks) CoreTransactionsReactive
(Core core, CoreTransactionsConfig config) -
Uses of Core in com.couchbase.client.core.transaction.cleanup
Modifier and TypeMethodDescriptionCleanerFactory.create
(Core core, CoreTransactionsSupportedExtensions supported) CleanerMockFactory.create
(Core core, CoreTransactionsSupportedExtensions supported) ModifierConstructorDescriptionClientRecord
(Core core) CoreTransactionsCleanup
(Core core, CoreTransactionsConfig config) LostCleanupDistributed
(Core core, CoreTransactionsConfig config, Supplier<TransactionsCleaner> cleanerSupplier) TransactionsCleaner
(Core core, CleanerHooks hooks, CoreTransactionsSupportedExtensions supported) -
Uses of Core in com.couchbase.client.core.transaction.components
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.DocumentGetter.justGetDoc
(Core core, CollectionIdentifier collection, String docId, Duration timeout, SpanWrapper span, boolean accessDeleted, CoreTransactionLogger logger, MeteringUnits.MeteringUnitsBuilder units) -
Uses of Core in com.couchbase.client.core.transaction.forwards
Modifier and TypeMethodDescriptionForwardCompatibility.check
(Core core, ForwardCompatibilityStage fc, Optional<ForwardCompatibility> forwardCompatibility, CoreTransactionLogger logger, CoreTransactionsSupportedExtensions supported) Returns empty if it's ok to continue, otherwise an error: -
Uses of Core in com.couchbase.client.core.transaction.support
Modifier and TypeMethodDescriptionTransactionAttemptContextFactory.create
(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan) static Duration
OptionsUtil.kvTimeoutMutating
(Core core) The timeout to use for important mutating KV operations.static Duration
OptionsUtil.kvTimeoutNonMutating
(Core core) The timeout to use for non-mutating KV operations (or mutating operations that aren't important enough to justify durability.) -
Uses of Core in com.couchbase.client.core.transaction.util
Modifier and TypeMethodDescriptionTestTransactionAttemptContextFactory.create
(Core core, CoreTransactionContext overall, CoreMergedTransactionConfig config, String attemptId, CoreTransactionsReactive parent, Optional<SpanWrapper> parentSpan) 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) -
Uses of Core in com.couchbase.client.core.util
Modifier and TypeMethodDescriptionstatic Mono<BucketConfig>
BucketConfigUtil.waitForBucketConfig
(Core core, String bucketName, Duration timeout) A bucket config can be null while the bucket has not been opened.static Mono<Map<ServiceType,
Set<ClusterCapabilities>>> ClusterCapabilitiesUtil.waitForClusterCapabilities
(Core core, Duration timeout) static void
ConsistencyUtil.waitUntilBucketDropped
(Core core, String name) static void
ConsistencyUtil.waitUntilBucketPresent
(Core core, String name) static void
ConsistencyUtil.waitUntilCollectionDropped
(Core core, String bucketName, String scopeName, String collectionName) static void
ConsistencyUtil.waitUntilCollectionPresent
(Core core, String bucketName, String scopeName, String collectionName) static void
ConsistencyUtil.waitUntilDesignDocumentDropped
(Core core, String bucketName, String designDocument) static void
ConsistencyUtil.waitUntilDesignDocumentPresent
(Core core, String bucketName, String designDocument) static void
ConsistencyUtil.waitUntilGroupDropped
(Core core, String name) static void
ConsistencyUtil.waitUntilGroupPresent
(Core core, String name) static void
ConsistencyUtil.waitUntilScopeDropped
(Core core, String bucketName, String scopeName) static void
ConsistencyUtil.waitUntilScopePresent
(Core core, String bucketName, String scopeName) static void
ConsistencyUtil.waitUntilSearchIndexDropped
(Core core, String indexName) static void
ConsistencyUtil.waitUntilSearchIndexPresent
(Core core, String indexName) static void
ConsistencyUtil.waitUntilUserDropped
(Core core, String domain, String name) static void
ConsistencyUtil.waitUntilUserPresent
(Core core, String domain, String name) static void
ConsistencyUtil.waitUntilViewDropped
(Core core, String bucketName, String designDocument, String viewName) static void
ConsistencyUtil.waitUntilViewPresent
(Core core, String bucketName, String designDocument, String viewName)
create(CoreEnvironment, Authenticator, ConnectionString)
instead.