Package | Description |
---|---|
com.couchbase.client.core |
Couchbase Core IO - Domain Model and Architecture
|
com.couchbase.client.core.config | |
com.couchbase.client.core.config.loader | |
com.couchbase.client.core.event.system | |
com.couchbase.client.core.message.cluster | |
com.couchbase.client.core.message.config | |
com.couchbase.client.core.message.internal | |
com.couchbase.client.core.message.kv | |
com.couchbase.client.core.node | |
com.couchbase.client.core.utils |
Modifier and Type | Method and Description |
---|---|
rx.Observable<LifecycleState> |
RequestHandler.addNode(NetworkAddress hostname)
Add a
Node identified by its hostname. |
Node |
RequestHandler.nodeBy(NetworkAddress hostname)
Returns the node by its hostname.
|
rx.Observable<LifecycleState> |
RequestHandler.removeNode(NetworkAddress hostname)
Remove a
Node identified by its hostname. |
Modifier and Type | Method and Description |
---|---|
NetworkAddress |
PortInfo.hostname() |
NetworkAddress |
NodeInfo.hostname()
The inet address of the node.
|
NetworkAddress |
DefaultPortInfo.hostname() |
NetworkAddress |
DefaultNodeInfo.hostname() |
NetworkAddress |
MemcachedBucketConfig.nodeForId(byte[] id)
Returns the target node address for the given document id.
|
NetworkAddress |
DefaultMemcachedBucketConfig.nodeForId(byte[] id) |
Modifier and Type | Method and Description |
---|---|
Set<NetworkAddress> |
DefaultClusterConfig.allNodeAddresses() |
Set<NetworkAddress> |
ClusterConfig.allNodeAddresses()
Returns the addresses of all nodes in the cluster, accumulated from all open buckets.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultCouchbaseBucketConfig.hasPrimaryPartitionsOnNode(NetworkAddress hostname) |
boolean |
CouchbaseBucketConfig.hasPrimaryPartitionsOnNode(NetworkAddress hostname)
Checks if the given hostname has active primary partitions assigned to it.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultConfigurationProvider.seedHosts(Set<NetworkAddress> hosts,
boolean shuffle) |
boolean |
ConfigurationProvider.seedHosts(Set<NetworkAddress> hosts,
boolean shuffle)
Set the initial seed hosts for bootstrap.
|
Constructor and Description |
---|
DefaultNodeInfo(NetworkAddress hostname,
Map<ServiceType,Integer> direct,
Map<ServiceType,Integer> ssl)
Creates a new
DefaultNodeInfo with SSL services. |
Modifier and Type | Method and Description |
---|---|
protected rx.Observable<String> |
HttpLoader.discoverConfig(String bucket,
String username,
String password,
NetworkAddress hostname) |
protected rx.Observable<String> |
CarrierLoader.discoverConfig(String bucket,
String username,
String password,
NetworkAddress hostname) |
protected abstract rx.Observable<String> |
AbstractLoader.discoverConfig(String bucket,
String username,
String password,
NetworkAddress hostname)
Run the
BucketConfig discovery process. |
rx.Observable<Tuple2<LoaderType,BucketConfig>> |
Loader.loadConfig(NetworkAddress seedNode,
String bucket,
String password)
Deprecated.
|
rx.Observable<Tuple2<LoaderType,BucketConfig>> |
AbstractLoader.loadConfig(NetworkAddress seedNode,
String bucket,
String password)
Initiate the config loading process.
|
rx.Observable<Tuple2<LoaderType,BucketConfig>> |
Loader.loadConfig(NetworkAddress seedNode,
String bucket,
String username,
String password) |
rx.Observable<Tuple2<LoaderType,BucketConfig>> |
AbstractLoader.loadConfig(NetworkAddress seedNode,
String bucket,
String username,
String password)
Initiate the config loading process.
|
protected String |
AbstractLoader.replaceHostWildcard(String input,
NetworkAddress hostname)
Replaces the host wildcard from an incoming config with a proper hostname.
|
Modifier and Type | Method and Description |
---|---|
Set<NetworkAddress> |
ConfigUpdatedEvent.clusterNodesAsNetworkAddress()
Returns the
NetworkAddress of all nodes that are part of the cluster config. |
Constructor and Description |
---|
NodeConnectedEvent(NetworkAddress host) |
NodeDisconnectedEvent(NetworkAddress host) |
Modifier and Type | Method and Description |
---|---|
Set<NetworkAddress> |
SeedNodesRequest.nodes()
Returns the set list of seed hostnames.
|
Modifier and Type | Method and Description |
---|---|
NetworkAddress |
BucketConfigRequest.hostname() |
Constructor and Description |
---|
BucketConfigRequest(String path,
NetworkAddress hostname,
String bucket,
String password) |
BucketConfigRequest(String path,
NetworkAddress hostname,
String bucket,
String username,
String password) |
Modifier and Type | Method and Description |
---|---|
NetworkAddress |
RemoveServiceRequest.hostname() |
NetworkAddress |
RemoveNodeRequest.hostname() |
NetworkAddress |
AddServiceResponse.hostname() |
NetworkAddress |
AddServiceRequest.hostname() |
NetworkAddress |
AddNodeResponse.hostname() |
NetworkAddress |
AddNodeRequest.hostname() |
Constructor and Description |
---|
AddNodeRequest(NetworkAddress hostname) |
AddNodeResponse(ResponseStatus status,
NetworkAddress hostname) |
AddServiceRequest(ServiceType type,
String bucket,
String password,
int port,
NetworkAddress hostname) |
AddServiceRequest(ServiceType type,
String bucket,
String username,
String password,
int port,
NetworkAddress hostname) |
AddServiceResponse(ResponseStatus status,
NetworkAddress hostname) |
RemoveNodeRequest(NetworkAddress hostname) |
RemoveServiceRequest(ServiceType type,
String bucket,
NetworkAddress hostname) |
Modifier and Type | Method and Description |
---|---|
NetworkAddress |
StatRequest.hostname() |
NetworkAddress |
GetBucketConfigResponse.hostname() |
NetworkAddress |
GetBucketConfigRequest.hostname()
Returns the hostname of the node from where the config should be loaded.
|
NetworkAddress |
GetAllMutationTokensRequest.hostname() |
Constructor and Description |
---|
GetAllMutationTokensRequest(GetAllMutationTokensRequest.PartitionState partitionState,
NetworkAddress hostname,
String bucket) |
GetAllMutationTokensRequest(NetworkAddress hostname,
String bucket) |
GetBucketConfigRequest(String bucket,
NetworkAddress hostname)
Creates a new
GetBucketConfigRequest . |
GetBucketConfigResponse(ResponseStatus status,
short serverStatusCode,
String bucket,
ByteBuf content,
NetworkAddress hostname) |
StatRequest(String key,
NetworkAddress hostname,
String bucket) |
Modifier and Type | Method and Description |
---|---|
NetworkAddress |
Node.hostname()
Returns the configured hostname for the
Node . |
NetworkAddress |
CouchbaseNode.hostname() |
Modifier and Type | Method and Description |
---|---|
protected static String |
CouchbaseNode.logIdent(NetworkAddress hostname)
Simple log helper to give logs a common prefix.
|
Constructor and Description |
---|
CouchbaseNode(NetworkAddress hostname,
CoreEnvironment environment,
com.lmax.disruptor.RingBuffer<ResponseEvent> responseBuffer) |
Modifier and Type | Method and Description |
---|---|
static NetworkAddress |
NetworkAddress.create(String input)
Creates a new
NetworkAddress from either a hostname or ip address literal. |
static NetworkAddress |
NetworkAddress.localhost()
Creates a new
NetworkAddress for loopback. |
Copyright © 2017 Couchbase, Inc.. All rights reserved.