com.aerospike.client.cluster

Class Node

java.lang.Object

com.aerospike.client.cluster.Node

All Implemented Interfaces:

Closeable, AutoCloseable

public class Node
extends Object
implements Closeable

Server node representation. This class manages server node connections and health status.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Node.AsyncPool

Field Summary

Fields

Modifier and Type	Field and Description
static int	HAS_BATCH_ANY
static int	HAS_PARTITION_QUERY
static int	HAS_PARTITION_SCAN
static int	HAS_QUERY_SHOW
static int	PARTITIONS Number of partitions for each namespace.

Constructor Summary

Constructors

Constructor and Description
Node(com.aerospike.client.cluster.Cluster cluster, com.aerospike.client.cluster.NodeValidator nv) Initialize server node with connection parameters.

Method Summary

Modifier and Type	Method and Description
void	addBytesIn(String namespace, long count) Add to the count of bytes received from the node.
void	addBytesOut(String namespace, long count) Add to the count of bytes sent to the node.
void	addError(String namespace) Increment transaction error count.
void	addKeyBusy(String namespace) Increment the key busy counter.
void	addLatency(String namespace, LatencyType type, long elapsed) Add elapsed time in nanoseconds to latency buckets corresponding to latency type.
void	addTimeout(String namespace) Increment transaction timeout count.
boolean	areMetricsEnabled() Return metrics enablement status
void	balanceAsyncConnections(EventLoop eventLoop)
void	close() Close all socket connections.
void	closeAsyncConnection(com.aerospike.client.async.AsyncConnection conn, int index) Close async connection on error.
void	closeAsyncConnections(int index) Close asynchronous connections.
void	closeAsyncIdleConnection(com.aerospike.client.async.AsyncConnection conn, int index) Close async connection without incrementing error count.
void	closeConnection(com.aerospike.client.cluster.Connection conn) Close pooled connection on error and decrement connection count.
void	closeConnectionOnError(com.aerospike.client.cluster.Connection conn) Close any connection on error.
void	closeConnections(AtomicInteger eventLoopCount, int index) Close all node socket connections from event loop.
void	closeIdleConnection(com.aerospike.client.cluster.Connection conn) Close connection without incrementing error count.
void	closeSyncConnections() Close synchronous connections.
void	connectionOpened(int index)
void	createMinConnections()
void	decrAsyncConnection(int index)
void	enableMetrics(MetricsPolicy policy)
boolean	equals(Object obj)
boolean	errorRateWithinLimit()
InetSocketAddress	getAddress() Return node IP address.
com.aerospike.client.async.AsyncConnection	getAsyncConnection(int index, ByteBuffer byteBuffer)
ConnectionStats	getAsyncConnectionStats()
Node.AsyncPool	getAsyncPool(int index)
long	getBytesInByNS(String namespace) Return count of bytes in by namespace.
long	getBytesOutByNS(String namespace) Return count of bytes out by namespace.
com.aerospike.client.cluster.Connection	getConnection(int timeoutMillis) Get a socket connection from connection pool to the server node.
com.aerospike.client.cluster.Connection	getConnection(int connectTimeout, int socketTimeout) Get a socket connection from connection pool to the server node.
com.aerospike.client.cluster.Connection	getConnection(com.aerospike.client.command.SyncCommand cmd, int connectTimeout, int socketTimeout, int timeoutDelay) Get a socket connection from connection pool to the server node.
ConnectionStats	getConnectionStats()
long	getErrorCount() Return error count.
long	getErrorCountByNS(String namespace) Return error count by namespace.
Host	getHost() Return server node IP address and port.
long	getKeyBusyCount() Return key busy count.
long	getKeyBusyCountByNS(String namespace) Return key busy count for a given namespace.
NodeMetrics	getMetrics()
String	getName() Return server node name.
int	getPartitionGeneration() Return current generation of partition maps.
int	getPeersGeneration() Return current generation of cluster peers.
int	getRebalanceGeneration() Return current generation of racks.
byte[]	getSessionToken() Return node session token.
long	getTimeoutCount() Return timeout count.
long	getTimeoutCountbyNS(String namespace) Return timeout count.
com.aerospike.client.util.Version	getVersion() Return this node's build version
boolean	hasBatchAny()
int	hashCode()
boolean	hasPartitionQuery()
boolean	hasQueryShow()
boolean	hasRack(String namespace, int rackId) Return if this node has the same rack as the client for the given namespace.
void	incrErrorRate()
boolean	isActive() Return whether node is currently active.
boolean	putAsyncConnection(com.aerospike.client.async.AsyncConnection conn, int index)
void	putConnection(com.aerospike.client.cluster.Connection conn) Put connection back into connection pool.
void	refresh(com.aerospike.client.cluster.Peers peers) Request current status from server node.
boolean	reserveAsyncConnectionSlot(int index)
void	resetErrorRate()
void	signalLogin()
String	toString() Does server support partition scans.
void	validateErrorCount()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Detail

PARTITIONS

public static final int PARTITIONS

Number of partitions for each namespace.

See Also:

Constant Field Values

HAS_PARTITION_SCAN

public static final int HAS_PARTITION_SCAN

See Also:

Constant Field Values

HAS_QUERY_SHOW

public static final int HAS_QUERY_SHOW

See Also:

Constant Field Values

HAS_BATCH_ANY

public static final int HAS_BATCH_ANY

See Also:

Constant Field Values

HAS_PARTITION_QUERY

public static final int HAS_PARTITION_QUERY

See Also:

Constant Field Values

Constructor Detail

Node

public Node(com.aerospike.client.cluster.Cluster cluster,
            com.aerospike.client.cluster.NodeValidator nv)

Initialize server node with connection parameters.

Parameters:

cluster - collection of active server nodes

nv - connection parameters

Method Detail

createMinConnections

public final void createMinConnections()

refresh

public final void refresh(com.aerospike.client.cluster.Peers peers)

Request current status from server node.

signalLogin

public final void signalLogin()

getConnection

public final com.aerospike.client.cluster.Connection getConnection(int timeoutMillis)

Get a socket connection from connection pool to the server node.

getConnection

public final com.aerospike.client.cluster.Connection getConnection(int connectTimeout,
                                                                   int socketTimeout)

Get a socket connection from connection pool to the server node.

getConnection

public final com.aerospike.client.cluster.Connection getConnection(com.aerospike.client.command.SyncCommand cmd,
                                                                   int connectTimeout,
                                                                   int socketTimeout,
                                                                   int timeoutDelay)

Get a socket connection from connection pool to the server node.

putConnection

public final void putConnection(com.aerospike.client.cluster.Connection conn)

Put connection back into connection pool.

Parameters:

conn - socket connection

closeConnection

public final void closeConnection(com.aerospike.client.cluster.Connection conn)

Close pooled connection on error and decrement connection count.

closeConnectionOnError

public final void closeConnectionOnError(com.aerospike.client.cluster.Connection conn)

Close any connection on error.

closeIdleConnection

public final void closeIdleConnection(com.aerospike.client.cluster.Connection conn)

Close connection without incrementing error count.

getConnectionStats

public final ConnectionStats getConnectionStats()

getAsyncConnection

public final com.aerospike.client.async.AsyncConnection getAsyncConnection(int index,
                                                                           ByteBuffer byteBuffer)

reserveAsyncConnectionSlot

public final boolean reserveAsyncConnectionSlot(int index)

connectionOpened

public final void connectionOpened(int index)

putAsyncConnection

public final boolean putAsyncConnection(com.aerospike.client.async.AsyncConnection conn,
                                        int index)

closeAsyncConnection

public final void closeAsyncConnection(com.aerospike.client.async.AsyncConnection conn,
                                       int index)

Close async connection on error.

closeAsyncIdleConnection

public final void closeAsyncIdleConnection(com.aerospike.client.async.AsyncConnection conn,
                                           int index)

Close async connection without incrementing error count.

decrAsyncConnection

public final void decrAsyncConnection(int index)

getAsyncPool

public final Node.AsyncPool getAsyncPool(int index)

balanceAsyncConnections

public final void balanceAsyncConnections(EventLoop eventLoop)

getAsyncConnectionStats

public final ConnectionStats getAsyncConnectionStats()

enableMetrics

public final void enableMetrics(MetricsPolicy policy)

getMetrics

public final NodeMetrics getMetrics()

addLatency

public final void addLatency(String namespace,
                             LatencyType type,
                             long elapsed)

Add elapsed time in nanoseconds to latency buckets corresponding to latency type.

incrErrorRate

public final void incrErrorRate()

resetErrorRate

public final void resetErrorRate()

errorRateWithinLimit

public final boolean errorRateWithinLimit()

validateErrorCount

public final void validateErrorCount()

addError

public void addError(String namespace)

Increment transaction error count. If the error is retryable, multiple errors per transaction may occur.

addTimeout

public void addTimeout(String namespace)

Increment transaction timeout count. If the timeout is retryable (ie socketTimeout), multiple timeouts per transaction may occur.

addKeyBusy

public void addKeyBusy(String namespace)

Increment the key busy counter.

addBytesOut

public void addBytesOut(String namespace,
                        long count)

Add to the count of bytes sent to the node.

addBytesIn

public void addBytesIn(String namespace,
                       long count)

Add to the count of bytes received from the node.

getErrorCount

public long getErrorCount()

Return error count. The value is cumulative and not reset per metrics interval.

getErrorCountByNS

public long getErrorCountByNS(String namespace)

Return error count by namespace. The value is cumulative and not reset per metrics interval.

getTimeoutCount

public long getTimeoutCount()

Return timeout count. The value is cumulative and not reset per metrics interval.

getTimeoutCountbyNS

public long getTimeoutCountbyNS(String namespace)

Return timeout count. The value is cumulative and not reset per metrics interval.

getKeyBusyCount

public long getKeyBusyCount()

Return key busy count. The value is cumulative and not reset per metrics interval.

getKeyBusyCountByNS

public long getKeyBusyCountByNS(String namespace)

Return key busy count for a given namespace. The value is cumulative and not reset per metrics interval.

getBytesInByNS

public long getBytesInByNS(String namespace)

Return count of bytes in by namespace. The value is cumulative and not reset per metrics interval.

getBytesOutByNS

public long getBytesOutByNS(String namespace)

Return count of bytes out by namespace. The value is cumulative and not reset per metrics interval.

getHost

public final Host getHost()

Return server node IP address and port.

isActive

public final boolean isActive()

Return whether node is currently active.

getName

public final String getName()

Return server node name.

getAddress

public final InetSocketAddress getAddress()

Return node IP address.

getSessionToken

public final byte[] getSessionToken()

Return node session token.

getPeersGeneration

public final int getPeersGeneration()

Return current generation of cluster peers.

getPartitionGeneration

public final int getPartitionGeneration()

Return current generation of partition maps.

getRebalanceGeneration

public final int getRebalanceGeneration()

Return current generation of racks.

getVersion

public com.aerospike.client.util.Version getVersion()

Return this node's build version

areMetricsEnabled

public boolean areMetricsEnabled()

Return metrics enablement status

hasRack

public final boolean hasRack(String namespace,
                             int rackId)

Return if this node has the same rack as the client for the given namespace.

hasQueryShow

public final boolean hasQueryShow()

hasBatchAny

public final boolean hasBatchAny()

hasPartitionQuery

public final boolean hasPartitionQuery()

toString

public final String toString()

Does server support partition scans.

Overrides:

toString in class Object

hashCode

public final int hashCode()

Overrides:

hashCode in class Object

equals

public final boolean equals(Object obj)

Overrides:

equals in class Object

close

public final void close()

Close all socket connections.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

closeConnections

public final void closeConnections(AtomicInteger eventLoopCount,
                                   int index)

Close all node socket connections from event loop. Must be called from event loop thread.

closeAsyncConnections

public final void closeAsyncConnections(int index)

Close asynchronous connections. Must be called from event loop thread.

closeSyncConnections

public final void closeSyncConnections()

Close synchronous connections.