Package | Description |
---|---|
com.couchbase.client.core | |
com.couchbase.client.core.config | |
com.couchbase.client.core.node |
Modifier and Type | Method and Description |
---|---|
ClusterConfig |
Core.clusterConfig()
This API provides access to the current config that is published throughout the core.
|
Modifier and Type | Method and Description |
---|---|
ClusterConfig |
DefaultConfigurationProvider.config() |
ClusterConfig |
ConfigurationProvider.config()
Returns the current
ClusterConfig . |
Modifier and Type | Method and Description |
---|---|
Flux<ClusterConfig> |
DefaultConfigurationProvider.configs() |
Flux<ClusterConfig> |
ConfigurationProvider.configs()
This is a hot stream which when attached will return the current config as well as
all subsequent ones.
|
Modifier and Type | Method and Description |
---|---|
static List<DefaultConfigurationProvider.AlternateAddressHolder> |
DefaultConfigurationProvider.extractAlternateAddressInfos(ClusterConfig config)
Helper method to turn either the port info or the node info into a list of hosts to use for the
alternate address resolution.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
ViewLocator.checkServiceNotAvailable(Request<? extends Response> request,
ClusterConfig config) |
protected boolean |
RoundRobinLocator.checkServiceNotAvailable(Request<? extends Response> request,
ClusterConfig config)
Can be overridden to check if a request should be cancelled immediately that the service is not
supported.
|
void |
Locator.dispatch(Request<? extends Response> request,
List<Node> nodes,
ClusterConfig config,
CoreContext ctx)
Given the environment and node information, the implementation locates the right set of
nodes and dispatches the request into them.
|
void |
KeyValueLocator.dispatch(Request<? extends Response> request,
List<Node> nodes,
ClusterConfig config,
CoreContext ctx) |
void |
RoundRobinLocator.dispatch(Request<? extends Response> request,
List<Node> nodes,
ClusterConfig config,
CoreContext ctx) |
protected boolean |
ViewLocator.nodeCanBeUsed(Node node,
Request<? extends Response> request,
ClusterConfig config)
In addition to checking that the view service is enabled, for view dispatching it is vital that
a request is only ever sent to a node which has active primary KV partitions.
|
protected boolean |
RoundRobinLocator.nodeCanBeUsed(Node node,
Request<? extends Response> request,
ClusterConfig config)
This method can be overridden for additional per-node checks in addition to the service-type
based check already performed in
RoundRobinLocator.filterNodes(List, Request, ClusterConfig) . |
Copyright © 2021 Couchbase, Inc.. All rights reserved.