| Package | Description |
|---|---|
| org.gridgain.client |
Public Java client messages APIs.
|
| org.gridgain.client.balancer |
Provides API and implementations of simple load balancers.
|
| org.gridgain.client.impl |
GridGain Java client implementation.
|
| org.gridgain.client.impl.connection | |
| org.gridgain.client.util |
Client utility classes.
|
| Modifier and Type | Method and Description |
|---|---|
GridClientNode |
GridClientPartitionAffinity.node(Object key,
Collection<? extends GridClientNode> nodes)
Gets primary affinity node for a key.
|
GridClientNode |
GridClientDataAffinity.node(Object key,
Collection<? extends GridClientNode> nodes)
Gets primary affinity node for a key.
|
GridClientNode |
GridClientCompute.node(UUID id)
Gets cached node with given id from most recently refreshed topology.
|
GridClientNode |
GridClientCompute.refreshNode(String ip,
boolean includeAttrs,
boolean includeMetrics)
Refreshes and returns node by its IP address from remote grid.
|
GridClientNode |
GridClientCompute.refreshNode(UUID id,
boolean includeAttrs,
boolean includeMetrics)
Refreshes and returns node by its ID from remote grid.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridClientNode> |
GridClientCompute.daemonNodes()
Gets most recently refreshed set of daemon nodes.
|
Collection<GridClientNode> |
GridClientCompute.nodes()
Gets most recently refreshed topology (only non-daemon nodes included).
|
Collection<GridClientNode> |
GridClientCompute.nodes(Collection<UUID> ids)
Gets cached nodes for the given IDs based on most recently refreshed topology.
|
Collection<GridClientNode> |
GridClientCompute.nodes(GridClientPredicate<GridClientNode> filter)
Gets all cached nodes that pass the filter.
|
Collection<GridClientNode> |
GridClientData.pinnedNodes()
Gets pinned node or
null if no nodes were pinned. |
GridClientFuture<GridClientNode> |
GridClientCompute.refreshNodeAsync(String ip,
boolean includeAttrs,
boolean includeMetrics)
Asynchronously refreshes and returns node by its IP address from remote grid.
|
GridClientFuture<GridClientNode> |
GridClientCompute.refreshNodeAsync(UUID id,
boolean includeAttrs,
boolean includeMetrics)
Asynchronously refreshes and returns node by its ID from remote grid.
|
List<GridClientNode> |
GridClientCompute.refreshTopology(boolean includeAttrs,
boolean includeMetrics)
Refreshes and returns all nodes within topology.
|
GridClientFuture<List<GridClientNode>> |
GridClientCompute.refreshTopologyAsync(boolean includeAttrs,
boolean includeMetrics)
Asynchronously refreshes and returns all nodes within topology.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
GridClientPartitionAffinity.HashIdResolver.getHashId(GridClientNode node)
Gets alternate hash ID, other than node ID.
|
void |
GridClientPartitionAffinity.onNodeAdded(GridClientNode node)
Callback for new nodes joining the remote grid.
|
void |
GridClientTopologyListener.onNodeAdded(GridClientNode node)
Callback for new nodes joining the remote grid.
|
void |
GridClientPartitionAffinity.onNodeRemoved(GridClientNode node)
Callback for nodes leaving the remote grid.
|
void |
GridClientTopologyListener.onNodeRemoved(GridClientNode node)
Callback for nodes leaving the remote grid.
|
GridClientData |
GridClientData.pinNodes(GridClientNode node,
GridClientNode... nodes)
Gets client data projection which will only contact specified remote grid node.
|
GridClientData |
GridClientData.pinNodes(GridClientNode node,
GridClientNode... nodes)
Gets client data projection which will only contact specified remote grid node.
|
GridClientCompute |
GridClientCompute.projection(GridClientNode node)
Creates a projection that will communicate only with specified remote node.
|
| Modifier and Type | Method and Description |
|---|---|
GridClientNode |
GridClientPartitionAffinity.node(Object key,
Collection<? extends GridClientNode> nodes)
Gets primary affinity node for a key.
|
GridClientNode |
GridClientDataAffinity.node(Object key,
Collection<? extends GridClientNode> nodes)
Gets primary affinity node for a key.
|
Collection<GridClientNode> |
GridClientCompute.nodes(GridClientPredicate<GridClientNode> filter)
Gets all cached nodes that pass the filter.
|
GridClientCompute |
GridClientCompute.projection(Collection<GridClientNode> nodes)
Creates a projection that will communicate only with specified remote nodes.
|
GridClientCompute |
GridClientCompute.projection(Collection<GridClientNode> nodes,
GridClientLoadBalancer balancer)
Creates a projection that will communicate only with specified remote nodes.
|
GridClientCompute |
GridClientCompute.projection(GridClientPredicate<? super GridClientNode> filter)
Creates a projection that will communicate only with nodes that are accepted by the passed filter.
|
GridClientCompute |
GridClientCompute.projection(GridClientPredicate<? super GridClientNode> filter,
GridClientLoadBalancer balancer)
Creates a projection that will communicate only with nodes that are accepted by the passed filter.
|
| Modifier and Type | Method and Description |
|---|---|
GridClientNode |
GridClientLoadBalancer.balancedNode(Collection<? extends GridClientNode> nodes)
Gets next node for executing client command.
|
GridClientNode |
GridClientRandomBalancer.balancedNode(Collection<? extends GridClientNode> nodes)
Picks up a random node from a collection.
|
GridClientNode |
GridClientRoundRobinBalancer.balancedNode(Collection<? extends GridClientNode> nodes)
Gets next node for executing client command.
|
| Modifier and Type | Method and Description |
|---|---|
protected static Collection<GridClientNode> |
GridClientBalancerAdapter.selectDirectNodes(Collection<? extends GridClientNode> nodes)
Returns only directly available nodes from given collection.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridClientRoundRobinBalancer.onNodeAdded(GridClientNode node)
Callback for new nodes joining the remote grid.
|
void |
GridClientRoundRobinBalancer.onNodeRemoved(GridClientNode node)
Callback for nodes leaving the remote grid.
|
| Modifier and Type | Method and Description |
|---|---|
GridClientNode |
GridClientLoadBalancer.balancedNode(Collection<? extends GridClientNode> nodes)
Gets next node for executing client command.
|
GridClientNode |
GridClientRandomBalancer.balancedNode(Collection<? extends GridClientNode> nodes)
Picks up a random node from a collection.
|
GridClientNode |
GridClientRoundRobinBalancer.balancedNode(Collection<? extends GridClientNode> nodes)
Gets next node for executing client command.
|
protected static Collection<GridClientNode> |
GridClientBalancerAdapter.selectDirectNodes(Collection<? extends GridClientNode> nodes)
Returns only directly available nodes from given collection.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridClientNodeImpl
Client node implementation.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridClientNode> |
GridClientDataImpl.pinnedNodes()
Gets pinned node or
null if no nodes were pinned. |
| Modifier and Type | Method and Description |
|---|---|
static GridClientNodeImpl.Builder |
GridClientNodeImpl.builder(GridClientNode from,
boolean skipAttrs,
boolean skipMetrics)
Creates and returns a builder for a new instance
of this class, copying data from an input instance.
|
GridClientData |
GridClientDataImpl.pinNodes(GridClientNode node,
GridClientNode... nodes)
Gets client data projection which will only contact specified remote grid node.
|
GridClientData |
GridClientDataImpl.pinNodes(GridClientNode node,
GridClientNode... nodes)
Gets client data projection which will only contact specified remote grid node.
|
| Modifier and Type | Method and Description |
|---|---|
GridClientNode |
GridClientTopology.node(UUID id)
Gets node from last saved topology snapshot by it's id.
|
GridClientNode |
GridClientTopology.updateNode(GridClientNodeImpl node)
Updates topology if cache enabled.
|
| Modifier and Type | Method and Description |
|---|---|
abstract GridClientFuture<GridClientNode> |
GridClientConnection.node(String ipAddr,
boolean inclAttrs,
boolean includeMetrics,
UUID destNodeId)
Gets node by node IP.
|
GridClientFuture<GridClientNode> |
GridClientNioTcpConnection.node(String ipAddr,
boolean inclAttrs,
boolean includeMetrics,
UUID destNodeId)
Gets node by node IP.
|
abstract GridClientFuture<GridClientNode> |
GridClientConnection.node(UUID id,
boolean inclAttrs,
boolean inclMetrics,
UUID destNodeId)
Gets node by node ID.
|
GridClientFuture<GridClientNode> |
GridClientNioTcpConnection.node(UUID id,
boolean inclAttrs,
boolean inclMetrics,
UUID destNodeId)
Gets node by node ID.
|
Collection<GridClientNode> |
GridClientTopology.nodes(Iterable<UUID> ids)
Gets a collection of nodes from last saved topology snapshot by their ids.
|
abstract GridClientFuture<List<GridClientNode>> |
GridClientConnection.topology(boolean inclAttrs,
boolean inclMetrics,
UUID destNodeId)
Gets grid topology nodes.
|
GridClientFuture<List<GridClientNode>> |
GridClientNioTcpConnection.topology(boolean inclAttrs,
boolean inclMetrics,
UUID destNodeId)
Gets grid topology nodes.
|
Collection<? extends GridClientNode> |
GridClientTopology.updateTopology(Collection<GridClientNodeImpl> nodeList)
Updates (if cache is enabled) the whole topology.
|
| Modifier and Type | Method and Description |
|---|---|
GridClientConnection |
GridClientConnectionManagerImpl.connection(GridClientNode node)
Gets active communication facade.
|
GridClientConnection |
GridClientConnectionManager.connection(GridClientNode node)
Returns connection to the given node.
|
void |
GridClientConnectionManagerImpl.terminateConnection(GridClientConnection conn,
GridClientNode node,
Throwable e)
Callback method, which should be called by clients when they get connectivity errors.
|
void |
GridClientConnectionManager.terminateConnection(GridClientConnection conn,
GridClientNode node,
Throwable e)
Callback method, which should be called by clients when they get connectivity errors.
|
| Modifier and Type | Method and Description |
|---|---|
static boolean |
GridClientUtils.restAvailable(GridClientNode node,
GridClientProtocol p)
Checks if given REST protocol available for given node.
|
Copyright © 2014. All rights reserved.