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.

Field Summary

Fields

Modifier and Type	Field and Description
static int	HAS_BATCH_INDEX
static int	HAS_CLUSTER_STABLE
static int	HAS_DOUBLE
static int	HAS_GEO
static int	HAS_PEERS
static int	HAS_REPLICAS
static int	HAS_REPLICAS_ALL
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	close() Close all socket connections.
void	closeAsyncConnection(com.aerospike.client.async.AsyncConnection conn, int index)
void	closeAsyncConnections(int index) Close asynchronous connections.
void	closeConnection(com.aerospike.client.cluster.Connection conn) Close connection and decrement connection count.
void	closeConnections(AtomicInteger eventLoopCount, int index) Close all node socket connections from event loop.
void	closeSyncConnections() Close synchronous connections.
void	decrAsyncConnection(int index)
boolean	equals(Object obj)
InetSocketAddress	getAddress() Return node IP address.
com.aerospike.client.async.AsyncConnection	getAsyncConnection(int index, ByteBuffer byteBuffer)
ConnectionStats	getAsyncConnectionStats()
com.aerospike.client.cluster.Connection	getConnection(int timeoutMillis) Get a socket connection from connection pool to the server node.
ConnectionStats	getConnectionStats()
Host	getHost() Return server node IP address and port.
String	getName() Return server node name.
byte[]	getSessionToken() Return node session token.
boolean	hasBatchIndex() Does server support batch index protocol.
boolean	hasClusterStable() Does server support cluster-stable info command.
boolean	hasDouble() Does server support double particle types.
int	hashCode()
boolean	hasPeers() Does server support peers info command.
boolean	hasReplicas() Does server support replicas info command.
boolean	hasReplicasAll() Does server support replicas-all info command.
boolean	isActive() Return whether node is currently active.
void	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.
void	signalLogin()
String	toString()
boolean	useNewBatch(BatchPolicy policy) Use new batch protocol if server supports it and useBatchDirect is not set.

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_GEO

public static final int HAS_GEO

See Also:

Constant Field Values

HAS_DOUBLE

public static final int HAS_DOUBLE

See Also:

Constant Field Values

HAS_BATCH_INDEX

public static final int HAS_BATCH_INDEX

See Also:

Constant Field Values

HAS_REPLICAS_ALL

public static final int HAS_REPLICAS_ALL

See Also:

Constant Field Values

HAS_PEERS

public static final int HAS_PEERS

See Also:

Constant Field Values

HAS_REPLICAS

public static final int HAS_REPLICAS

See Also:

Constant Field Values

HAS_CLUSTER_STABLE

public static final int HAS_CLUSTER_STABLE

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

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)
                                                            throws AerospikeException

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

Parameters:

timeoutMillis - connection timeout value in milliseconds if a new connection is created

Returns:

socket connection

Throws:

AerospikeException - if a connection could not be provided

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 connection and decrement connection count.

getConnectionStats

public final ConnectionStats getConnectionStats()

getAsyncConnection

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

putAsyncConnection

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

closeAsyncConnection

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

decrAsyncConnection

public final void decrAsyncConnection(int index)

getAsyncConnectionStats

public final ConnectionStats getAsyncConnectionStats()

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.

useNewBatch

public final boolean useNewBatch(BatchPolicy policy)

Use new batch protocol if server supports it and useBatchDirect is not set.

hasBatchIndex

public final boolean hasBatchIndex()

Does server support batch index protocol.

hasClusterStable

public final boolean hasClusterStable()

Does server support cluster-stable info command.

hasDouble

public final boolean hasDouble()

Does server support double particle types.

hasReplicas

public final boolean hasReplicas()

Does server support replicas info command.

hasReplicasAll

public final boolean hasReplicasAll()

Does server support replicas-all info command.

hasPeers

public final boolean hasPeers()

Does server support peers info command.

toString

public final String toString()

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.