Uses of Class
com.couchbase.client.core.Core

Packages that use Core

Package	Description
com.couchbase.client.core
com.couchbase.client.core.api
com.couchbase.client.core.api.manager.search
com.couchbase.client.core.api.search
com.couchbase.client.core.api.search.util
com.couchbase.client.core.classic
com.couchbase.client.core.classic.kv
com.couchbase.client.core.classic.manager
com.couchbase.client.core.classic.query
com.couchbase.client.core.config
com.couchbase.client.core.config.loader
com.couchbase.client.core.config.refresher
com.couchbase.client.core.diagnostics
com.couchbase.client.core.endpoint.http
com.couchbase.client.core.kv
com.couchbase.client.core.manager
com.couchbase.client.core.msg
com.couchbase.client.core.retry
com.couchbase.client.core.service.kv
com.couchbase.client.core.transaction
com.couchbase.client.core.transaction.cleanup
com.couchbase.client.core.transaction.components
com.couchbase.client.core.transaction.forwards
com.couchbase.client.core.transaction.support
com.couchbase.client.core.transaction.util
com.couchbase.client.core.util

Uses of Core in com.couchbase.client.core

Methods in com.couchbase.client.core that return Core

Modifier and Type	Method	Description
Core	CoreContext.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. Please use create(CoreEnvironment, Authenticator, ConnectionString) instead.

Methods in com.couchbase.client.core with parameters of type Core

Modifier and Type	Method	Description
void	Timer.scheduleForRetry(Core core, Request<? extends Response> request, Duration runAfter)	Schedules a request to be retried after the given duration.

Constructors in com.couchbase.client.core with parameters of type Core

Modifier	Constructor	Description
	CoreContext(Core core, long id, CoreEnvironment env, Authenticator authenticator)	Creates a new CoreContext.

Uses of Core in com.couchbase.client.core.api

Methods in com.couchbase.client.core.api that return Core

Modifier and Type	Method	Description
default Core	CoreCouchbaseOps.asCore()	Deprecated. This method goes away after the Core / Protostellar refactor.

Uses of Core in com.couchbase.client.core.api.manager.search

Fields in com.couchbase.client.core.api.manager.search declared as Core

Modifier and Type	Field	Description
protected final Core	ClassicCoreBaseSearchIndexManager.core

Constructors in com.couchbase.client.core.api.manager.search with parameters of type Core

Modifier	Constructor	Description
	ClassicCoreBaseSearchIndexManager(Core core)
	ClassicCoreClusterSearchIndexManager(Core core)
	ClassicCoreScopeSearchIndexManager(Core core, CoreBucketAndScope scope)

Uses of Core in com.couchbase.client.core.api.search

Constructors in com.couchbase.client.core.api.search with parameters of type Core

Modifier	Constructor	Description
	ClassicCoreSearchOps(Core core, CoreBucketAndScope scope)

Uses of Core in com.couchbase.client.core.api.search.util

Methods in com.couchbase.client.core.api.search.util with parameters of type Core

Modifier and Type	Method	Description
static 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

Methods in com.couchbase.client.core.classic with parameters of type Core

Modifier and Type	Method	Description
static <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

Methods in com.couchbase.client.core.classic.kv with parameters of type Core

Modifier and Type	Method	Description
static 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)

Constructors in com.couchbase.client.core.classic.kv with parameters of type Core

Modifier	Constructor	Description
	ClassicCoreKvBinaryOps(Core core, CoreKeyspace keyspace)
	ClassicCoreKvOps(Core core, CoreKeyspace keyspace)

Uses of Core in com.couchbase.client.core.classic.manager

Constructors in com.couchbase.client.core.classic.manager with parameters of type Core

Modifier	Constructor	Description
	ClassicCoreBucketManager(Core core)
	ClassicCoreCollectionManagerOps(Core core, String bucketName)

Uses of Core in com.couchbase.client.core.classic.query

Constructors in com.couchbase.client.core.classic.query with parameters of type Core

Modifier	Constructor	Description
	ClassicCoreQueryOps(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

Constructors in com.couchbase.client.core.config with parameters of type Core

Modifier	Constructor	Description
	DefaultConfigurationProvider(Core core, ConnectionString connectionString)	Creates a new configuration provider.

Uses of Core in com.couchbase.client.core.config.loader

Methods in com.couchbase.client.core.config.loader that return Core

Modifier and Type	Method	Description
protected Core	BaseBucketLoader.core()	Returns the attached Core to be used by implementations.

Constructors in com.couchbase.client.core.config.loader with parameters of type Core

Modifier	Constructor	Description
	ClusterManagerBucketLoader(Core core)
	GlobalLoader(Core core)
	KeyValueBucketLoader(Core core)

Uses of Core in com.couchbase.client.core.config.refresher

Constructors in com.couchbase.client.core.config.refresher with parameters of type Core

Modifier	Constructor	Description
	ClusterManagerBucketRefresher(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

Methods in com.couchbase.client.core.diagnostics with parameters of type Core

Modifier and Type	Method	Description
static 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

Methods in com.couchbase.client.core.endpoint.http with parameters of type Core

Modifier and Type	Method	Description
CompletableFuture<CoreHttpResponse>	CoreHttpRequest.Builder.exec(Core core)
CompletableFuture<CoreHttpResponse>	CoreHttpRequest.exec(Core core)

Constructors in com.couchbase.client.core.endpoint.http with parameters of type Core

Modifier	Constructor	Description
	CoreHttpClient(Core core, RequestTarget target)

Uses of Core in com.couchbase.client.core.kv

Constructors in com.couchbase.client.core.kv with parameters of type Core

Modifier	Constructor	Description
	RangeScanOrchestrator(Core core, CollectionIdentifier collectionIdentifier)	Creates a new RangeScanOrchestrator which can be shared across calls.

Uses of Core in com.couchbase.client.core.manager

Fields in com.couchbase.client.core.manager declared as Core

Modifier and Type	Field	Description
protected final Core	CoreViewIndexManager.core

Constructors in com.couchbase.client.core.manager with parameters of type Core

Modifier	Constructor	Description
	CoreAnalyticsLinkManager(Core core)
	CoreBucketManager(Core core)	Deprecated.
	CoreEventingFunctionManager(Core core)
	CoreEventingFunctionManager(Core core, CoreBucketAndScope scope)
	CoreViewIndexManager(Core core, String bucket)

Uses of Core in com.couchbase.client.core.msg

Constructors in com.couchbase.client.core.msg with parameters of type Core

Modifier	Constructor	Description
	RequestContext(Core core, long contextId, CoreEnvironment environment, Authenticator authenticator, Request<? extends Response> request)

Uses of Core in com.couchbase.client.core.retry

Methods in com.couchbase.client.core.retry with parameters of type Core

Modifier and Type	Method	Description
static Throwable	AuthErrorDecider.getTlsHandshakeFailure(Core core)

Uses of Core in com.couchbase.client.core.service.kv

Methods in com.couchbase.client.core.service.kv with parameters of type Core

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, 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 replicas
static <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 replicas
static <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)

Uses of Core in com.couchbase.client.core.transaction

Methods in com.couchbase.client.core.transaction that return Core

Modifier and Type	Method	Description
Core	CoreTransactionAttemptContext.core()
Core	CoreTransactionsReactive.core()

Constructors in com.couchbase.client.core.transaction with parameters of type Core

Modifier	Constructor	Description
	CoreTransactionAttemptContext(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

Methods in com.couchbase.client.core.transaction.cleanup with parameters of type Core

Modifier and Type	Method	Description
TransactionsCleaner	CleanerFactory.create(Core core, CoreTransactionsSupportedExtensions supported)
TransactionsCleaner	CleanerMockFactory.create(Core core, CoreTransactionsSupportedExtensions supported)
ClientRecord	ClientRecordFactory.create(Core core)
ClientRecord	ClientRecordFactoryMock.create(Core core)

Constructors in com.couchbase.client.core.transaction.cleanup with parameters of type Core

Modifier	Constructor	Description
	ClientRecord(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

Methods in com.couchbase.client.core.transaction.components with parameters of type Core

Modifier and Type	Method	Description
static 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, boolean preferredReplicaMode)
static Mono<Optional<ActiveTransactionRecords>>	ActiveTransactionRecord.getAtr(Core core, CollectionIdentifier atrCollection, String atrId, Duration timeout, SpanWrapper pspan)	TXNJ-13: Get the ATR.
static Mono<Optional<Tuple2<CoreTransactionGetResult,CoreSubdocGetResult>>>	DocumentGetter.justGetDoc(Core core, CollectionIdentifier collection, String docId, Duration timeout, SpanWrapper span, boolean accessDeleted, CoreTransactionLogger logger, MeteringUnits.MeteringUnitsBuilder units, boolean preferredReplicaMode)

Uses of Core in com.couchbase.client.core.transaction.forwards

Methods in com.couchbase.client.core.transaction.forwards with parameters of type Core

Modifier and Type	Method	Description
static Mono<Void>	ForwardCompatibility.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

Methods in com.couchbase.client.core.transaction.support with parameters of type Core

Modifier and Type	Method	Description
CoreTransactionAttemptContext	TransactionAttemptContextFactory.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

Methods in com.couchbase.client.core.transaction.util with parameters of type Core

Modifier and Type	Method	Description
CoreTransactionAttemptContext	TestTransactionAttemptContextFactory.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<CoreSubdocGetResult>	TransactionKVHandler.lookupIn(Core core, CollectionIdentifier collectionIdentifier, String id, Duration timeout, boolean accessDeleted, Map<String,Object> clientContext, SpanWrapper pspan, boolean preferredReplicaMode, 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

Methods in com.couchbase.client.core.util with parameters of type Core

Modifier and Type	Method	Description
static 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)