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.
|
Optional<Flux<ServiceState>> |
Core.serviceState(NodeIdentifier nodeIdentifier,
ServiceType type,
Optional<String> bucket)
If present, returns a flux that allows to monitor the state changes of a specific service.
|
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<ProposedBucketConfigContext> |
DefaultConfigurationProvider.loadBucketConfigForSeed(NodeIdentifier identifier,
int mappedKvPort,
int mappedManagerPort,
String name,
Optional<String> alternateAddress)
Encapsulates the logic to load the bucket config from kv and then fall back to manager.
|
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 |
RequestContext.lastDispatchedToNode() |
NodeIdentifier |
TargetedRequest.target()
The target where this request must be dispatched to.
|
Modifier and Type | Method and Description |
---|---|
RequestContext |
RequestContext.lastDispatchedToNode(NodeIdentifier lastDispatchedToNode) |
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 |
MultiObserveViaCasRequest.target() |
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) |
MultiObserveViaCasRequest(Duration timeout,
CoreContext ctx,
RetryStrategy retryStrategy,
CollectionIdentifier collectionIdentifier,
NodeIdentifier target,
Map<byte[],Short> keys,
Predicate<ObserveViaCasResponse.ObserveStatus> responsePredicate) |
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.