public class DefaultCouchbaseBucketConfig extends AbstractBucketConfig implements CouchbaseBucketConfig
Modifier and Type | Field and Description |
---|---|
static int |
PARTITION_NOT_EXISTENT |
Constructor and Description |
---|
DefaultCouchbaseBucketConfig(long rev,
String uuid,
String name,
String uri,
String streamingUri,
CouchbasePartitionInfo partitionInfo,
List<NodeInfo> nodeInfos,
List<PortInfo> portInfos,
List<BucketCapabilities> bucketCapabilities,
NetworkAddress origin)
Creates a new
CouchbaseBucketConfig . |
Modifier and Type | Method and Description |
---|---|
boolean |
ephemeral()
If this couchbase bucket is ephemeral.
|
boolean |
hasFastForwardMap()
Returns true if the config has a fast forward map that describes what the topology of the cluster will be after the current rebalance operation completes.
|
boolean |
hasPrimaryPartitionsOnNode(NetworkAddress hostname)
Checks if the given hostname has active primary partitions assigned to it.
|
NodeInfo |
nodeAtIndex(int nodeIndex)
Returns information for the node at the given index.
|
short |
nodeIndexForMaster(int partition,
boolean useFastForward)
Returns the node index for the given partition index and master.
|
short |
nodeIndexForReplica(int partition,
int replica,
boolean useFastForward)
Returns the node index for the given partition index and the replica.
|
int |
numberOfPartitions()
Returns the total number of partitions.
|
int |
numberOfReplicas()
The number of configured replicas for this bucket.
|
long |
rev()
Revision number (optional) for that configuration.
|
boolean |
tainted()
Returns true if the config indicates the cluster is undergoing a transition (such as a rebalance operation).
|
String |
toString() |
BucketType |
type()
The bucket type.
|
locator, name, nodes, password, password, serviceEnabled, streamingUri, uri, useAlternateNetwork, useAlternateNetwork, username, username, uuid
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
locator, name, nodes, password, password, serviceEnabled, streamingUri, uri, useAlternateNetwork, useAlternateNetwork, username, username, uuid
public static final int PARTITION_NOT_EXISTENT
public DefaultCouchbaseBucketConfig(long rev, String uuid, String name, String uri, String streamingUri, CouchbasePartitionInfo partitionInfo, List<NodeInfo> nodeInfos, List<PortInfo> portInfos, List<BucketCapabilities> bucketCapabilities, NetworkAddress origin)
Creates a new CouchbaseBucketConfig
.
rev
- the revision of the config.name
- the name of the bucket.uri
- the URI for this bucket.streamingUri
- the streaming URI for this bucket.partitionInfo
- partition info for this bucket.nodeInfos
- related node information.portInfos
- port info for the nodes, including services.public int numberOfReplicas()
CouchbaseBucketConfig
The number of configured replicas for this bucket.
numberOfReplicas
in interface CouchbaseBucketConfig
public boolean tainted()
BucketConfig
Returns true if the config indicates the cluster is undergoing a transition (such as a rebalance operation).
tainted
in interface BucketConfig
public boolean hasPrimaryPartitionsOnNode(NetworkAddress hostname)
CouchbaseBucketConfig
Checks if the given hostname has active primary partitions assigned to it.
hasPrimaryPartitionsOnNode
in interface CouchbaseBucketConfig
hostname
- the hostname of the node to check against.public short nodeIndexForMaster(int partition, boolean useFastForward)
CouchbaseBucketConfig
Returns the node index for the given partition index and master.
nodeIndexForMaster
in interface CouchbaseBucketConfig
partition
- the index of the partition.useFastForward
- if the fast forward config should be used.public short nodeIndexForReplica(int partition, int replica, boolean useFastForward)
CouchbaseBucketConfig
Returns the node index for the given partition index and the replica.
nodeIndexForReplica
in interface CouchbaseBucketConfig
partition
- the index of the partition.replica
- the replica number.useFastForward
- if the fast forward config should be used.public int numberOfPartitions()
CouchbaseBucketConfig
Returns the total number of partitions.
numberOfPartitions
in interface CouchbaseBucketConfig
public NodeInfo nodeAtIndex(int nodeIndex)
CouchbaseBucketConfig
Returns information for the node at the given index.
nodeAtIndex
in interface CouchbaseBucketConfig
nodeIndex
- the index of the node.public long rev()
BucketConfig
Revision number (optional) for that configuration.
rev
in interface BucketConfig
public BucketType type()
BucketConfig
The bucket type.
type
in interface BucketConfig
public boolean hasFastForwardMap()
BucketConfig
Returns true if the config has a fast forward map that describes what the topology of the cluster will be after the current rebalance operation completes.
hasFastForwardMap
in interface BucketConfig
public boolean ephemeral()
CouchbaseBucketConfig
If this couchbase bucket is ephemeral.
ephemeral
in interface CouchbaseBucketConfig
Copyright © 2018 Couchbase, Inc.. All rights reserved.