Modifier and Type | Method and Description |
---|---|
protected Node |
Core.createNode(NodeIdentifier identifier,
Optional<String> alternateAddress)
Create a
Node from the given identifier. |
Mono<Void> |
Core.ensureServiceAt(NodeIdentifier identifier,
ServiceType serviceType,
int port,
Optional<String> bucket,
Optional<String> alternateAddress)
This method can be used by a caller to make sure a certain service is enabled at the given
target node.
|
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
NodeInfo.identifier() |
NodeIdentifier |
PortInfo.identifier() |
NodeIdentifier |
MemcachedBucketConfig.nodeForId(byte[] id) |
Modifier and Type | Method and Description |
---|---|
protected Mono<byte[]> |
ClusterManagerBucketLoader.discoverConfig(NodeIdentifier seed,
String bucket) |
protected abstract Mono<byte[]> |
BaseBucketLoader.discoverConfig(NodeIdentifier seed,
String bucket)
To be implemented by the actual child, performs the actual fetching of a config.
|
protected Mono<byte[]> |
KeyValueBucketLoader.discoverConfig(NodeIdentifier seed,
String bucket) |
Mono<ProposedGlobalConfigContext> |
GlobalLoader.load(NodeIdentifier seed,
int port)
Tries to load the global configuration.
|
Mono<ProposedBucketConfigContext> |
BucketLoader.load(NodeIdentifier seed,
int port,
String bucket,
Optional<String> alternateAddress)
Attempts to load a config for the given seed node.
|
Mono<ProposedBucketConfigContext> |
BaseBucketLoader.load(NodeIdentifier seed,
int port,
String bucket,
Optional<String> alternateAddress)
Performs the config loading through multiple steps.
|
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
HealthPinger.PingTarget.nodeIdentifier() |
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
TargetedRequest.target()
The target where this request must be dispatched to.
|
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
AnalyticsPingRequest.target() |
Constructor and Description |
---|
AnalyticsPingRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
NodeIdentifier target) |
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
KvPingRequest.target() |
NodeIdentifier |
CarrierGlobalConfigRequest.target() |
NodeIdentifier |
CarrierBucketConfigRequest.target() |
Constructor and Description |
---|
CarrierBucketConfigRequest(Duration timeout,
CoreContext ctx,
CollectionIdentifier collectionIdentifier,
RetryStrategy retryStrategy,
NodeIdentifier target) |
CarrierGlobalConfigRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
NodeIdentifier target) |
KvPingRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
CollectionIdentifier identifier,
NodeIdentifier target) |
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
BucketConfigRequest.target() |
Constructor and Description |
---|
BucketConfigRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String bucketName,
Authenticator authenticator,
NodeIdentifier target) |
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
QueryPingRequest.target() |
Constructor and Description |
---|
QueryPingRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
NodeIdentifier target) |
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
SearchPingRequest.target() |
Constructor and Description |
---|
SearchPingRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
NodeIdentifier target) |
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
ViewPingRequest.target() |
Constructor and Description |
---|
ViewPingRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
String bucket,
NodeIdentifier target) |
Modifier and Type | Method and Description |
---|---|
NodeIdentifier |
Node.identifier()
Returns the node identifier.
|
Modifier and Type | Method and Description |
---|---|
static Node |
Node.create(CoreContext ctx,
NodeIdentifier identifier,
Optional<String> alternateAddress) |
Constructor and Description |
---|
Node(CoreContext ctx,
NodeIdentifier identifier,
Optional<String> alternateAddress) |
NodeContext(CoreContext ctx,
NodeIdentifier nodeIdentifier,
Optional<String> alternateAddress) |
Copyright © 2020 Couchbase, Inc.. All rights reserved.