Package org.infinispan.server.resp.commands.cluster

Class NODES

java.lang.Object

org.infinispan.server.resp.RespCommand

org.infinispan.server.resp.commands.cluster.NODES

All Implemented Interfaces:

Resp3Command

public class NODES
extends RespCommand
implements Resp3Command

CLUSTER NODES

A command that uses the current CacheTopology and ConsistentHash to retrieve information about the nodes. The response slightly changes with the node executing the command, as it is necessary to identify itself. The execution is broadcast for nodes in the topology to identify themselves. So the response are cached according to the node that executed the command and the topology.

Since:

15.0

See Also:

• CLUSTER NODES

Field Summary

Fields

Modifier and Type	Field	Description
protected ConsistentHash	hash
protected CompletionStage<CharSequence>	response

Fields inherited from class org.infinispan.server.resp.RespCommand

log

Constructor Summary

Constructors

Constructor	Description
NODES()

Method Summary

Modifier and Type	Method	Description
long	aclMask()
CompletionStage<RespRequestHandler>	perform(Resp3Handler handler, io.netty.channel.ChannelHandlerContext ctx, List<byte[]> arguments)
protected static CompletionStage<CharSequence>	requestClusterInformation(Resp3Handler handler, io.netty.channel.ChannelHandlerContext ctx, EmbeddedCacheManager ecm, CacheTopology topology)

Methods inherited from class org.infinispan.server.resp.RespCommand

extractKeys, fromByteBuf, getArity, getFirstKeyPos, getLastKeyPos, getName, getSteps, handleException, hasValidNumberOfArguments, match, size, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

hash

protected ConsistentHash hash

response

protected CompletionStage<CharSequence> response

Constructor Details

NODES

public NODES()

Method Details

aclMask

public long aclMask()

Specified by:

aclMask in class RespCommand

perform

public CompletionStage<RespRequestHandler> perform(Resp3Handler handler,
 io.netty.channel.ChannelHandlerContext ctx,
 List<byte[]> arguments)

Specified by:

perform in interface Resp3Command

requestClusterInformation

protected static CompletionStage<CharSequence> requestClusterInformation(Resp3Handler handler,
 io.netty.channel.ChannelHandlerContext ctx,
 EmbeddedCacheManager ecm,
 CacheTopology topology)