Modifier and Type | Method and Description |
---|---|
Core |
CoreContext.core()
Returns the core to which this context belongs.
|
static Core |
Core.create(CoreEnvironment environment,
Authenticator authenticator,
Set<SeedNode> seedNodes)
Creates a new
Core with the given environment. |
Modifier and Type | Method and Description |
---|---|
void |
Timer.scheduleForRetry(Core core,
Request<? extends Response> request,
Duration runAfter)
Schedules a request to be retried after the given duration.
|
Constructor and Description |
---|
CoreContext(Core core,
long id,
CoreEnvironment env,
Authenticator authenticator)
Creates a new
CoreContext . |
Constructor and Description |
---|
DefaultConfigurationProvider(Core core,
Set<SeedNode> seedNodes)
Creates a new configuration provider.
|
Modifier and Type | Method and Description |
---|---|
protected Core |
BaseBucketLoader.core()
Returns the attached
Core to be used by implementations. |
Constructor and Description |
---|
ClusterManagerBucketLoader(Core core) |
GlobalLoader(Core core) |
KeyValueBucketLoader(Core core) |
Constructor and Description |
---|
ClusterManagerBucketRefresher(ConfigurationProvider provider,
Core core) |
GlobalRefresher(ConfigurationProvider provider,
Core core)
Creates a new global refresher.
|
KeyValueBucketRefresher(ConfigurationProvider provider,
Core core) |
Modifier and Type | Method and Description |
---|---|
static Mono<PingResult> |
HealthPinger.ping(Core core,
Optional<Duration> timeout,
RetryStrategy retryStrategy,
Set<ServiceType> serviceTypes,
Optional<String> reportId,
Optional<String> bucketName)
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) |
Modifier and Type | Method and 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.
|
Copyright © 2021 Couchbase, Inc.. All rights reserved.