Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
|
com.couchbase.client.core.node | |
com.couchbase.client.core.node.locate |
Modifier and Type | Method and Description |
---|---|
Node |
RequestHandler.nodeBy(InetAddress hostname)
Returns the node by its hostname.
|
Modifier and Type | Class and Description |
---|---|
class |
CouchbaseNode
The general implementation of a
Node . |
Modifier and Type | Method and Description |
---|---|
protected boolean |
SearchLocator.checkNode(Node node) |
protected boolean |
QueryLocator.checkNode(Node node) |
protected boolean |
ViewLocator.checkNode(Node node,
CouchbaseBucketConfig config) |
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 |
DCPLocator.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.