Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
|
com.couchbase.client.core.config | |
com.couchbase.client.core.config.refresher | |
com.couchbase.client.core.event.system | |
com.couchbase.client.core.message.cluster | |
com.couchbase.client.core.node.locate |
Modifier and Type | Method and Description |
---|---|
rx.Observable<ClusterConfig> |
RequestHandler.reconfigure(ClusterConfig config)
Helper method which grabs the current configuration and checks if the node setup is out of sync.
|
Modifier and Type | Method and Description |
---|---|
rx.Observable<ClusterConfig> |
RequestHandler.reconfigure(ClusterConfig config)
Helper method which grabs the current configuration and checks if the node setup is out of sync.
|
Constructor and Description |
---|
RequestHandler(CoreEnvironment environment,
rx.Observable<ClusterConfig> configObservable,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Create a new
RequestHandler . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultClusterConfig
Default implementation of a
ClusterConfig . |
Modifier and Type | Method and Description |
---|---|
ClusterConfig |
DefaultConfigurationProvider.config() |
ClusterConfig |
ConfigurationProvider.config()
Returns the current config or null if not set.
|
Modifier and Type | Method and Description |
---|---|
rx.Observable<ClusterConfig> |
DefaultConfigurationProvider.closeBucket(String name) |
rx.Observable<ClusterConfig> |
ConfigurationProvider.closeBucket(String name) |
rx.Observable<ClusterConfig> |
DefaultConfigurationProvider.configs() |
rx.Observable<ClusterConfig> |
ConfigurationProvider.configs()
Returns an
Observable , which pushes a new ClusterConfig once available. |
rx.Observable<ClusterConfig> |
DefaultConfigurationProvider.openBucket(String bucket,
String password) |
rx.Observable<ClusterConfig> |
ConfigurationProvider.openBucket(String name,
String password)
Start to fetch a config for the given bucket and also watch for changes, depending on the mechanism used.
|
rx.Observable<ClusterConfig> |
DefaultConfigurationProvider.openBucket(String bucket,
String username,
String password) |
rx.Observable<ClusterConfig> |
ConfigurationProvider.openBucket(String name,
String username,
String password)
Start to fetch a config for the given bucket and also watch for changes, depending on the mechanism used.
|
Modifier and Type | Method and Description |
---|---|
void |
Refresher.refresh(ClusterConfig config)
If pull based, refresh configs for registered buckets.
|
void |
HttpRefresher.refresh(ClusterConfig config) |
void |
CarrierRefresher.refresh(ClusterConfig config) |
Constructor and Description |
---|
ConfigUpdatedEvent(ClusterConfig clusterConfig) |
Modifier and Type | Method and Description |
---|---|
ClusterConfig |
GetClusterConfigResponse.config() |
Constructor and Description |
---|
GetClusterConfigResponse(ClusterConfig config,
ResponseStatus status) |
Modifier and Type | Method and Description |
---|---|
void |
ViewLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
QueryLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
Locator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer)
Given with the environment and node information, the implementation locates the right set of nodes and dispatches the request into them.
|
void |
KeyValueLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig cluster,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
void |
ConfigLocator.locateAndDispatch(CouchbaseRequest request,
List<Node> nodes,
ClusterConfig config,
CoreEnvironment env,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Copyright © 2017 Couchbase, Inc.. All rights reserved.