Package org.redisson.connection

Class RedisClientEntry

org.redisson.connection.RedisClientEntry

All Implemented Interfaces:

ClusterNode, Node, NodeAsync

public class RedisClientEntry
extends 
implements ClusterNode

Author:

Nikita Koksharov

Nested Class Summary

Nested classes/interfaces inherited from interface org.redisson.api.Node

Node.InfoSection

Constructor Summary

Constructors

Constructor	Description
RedisClientEntry(RedisClient client, CommandAsyncExecutor commandExecutor, NodeType type)

Method Summary

Modifier and Type	Method	Description
<,>	clusterInfo()	Execute CLUSTER INFO operation.
<,>>	clusterInfoAsync()
boolean	obj)
	getAddr()	Get Redis node address
RedisClient	getClient()
NodeType	getType()	Returns node type
int	hashCode()
<,>	info(Node.InfoSection section)
<,>>	infoAsync(Node.InfoSection section)
boolean	ping()	Ping Redis node.
boolean	ping(long timeout, timeUnit)	Ping Redis node with specified timeout.
>	pingAsync()
>	pingAsync(long timeout, timeUnit)	Ping Redis node with specified timeout.
Time	time()	Returns current Redis server time in seconds
RFuture<Time>	timeAsync()
	toString()

Methods inherited from class java.lang.

, , , , , , ,

Constructor Detail

RedisClientEntry

public RedisClientEntry(RedisClient client,
                        CommandAsyncExecutor commandExecutor,
                        NodeType type)

Method Detail

getType

public NodeType getType()

Description copied from interface: Node

Returns node type

Specified by:

getType in interface Node

Returns:

node type

getClient

public RedisClient getClient()

getAddr

public  getAddr()

Description copied from interface: Node

Get Redis node address

Specified by:

getAddr in interface Node

Returns:

node address

pingAsync

public > pingAsync()

Specified by:

pingAsync in interface NodeAsync

pingAsync

public > pingAsync(long timeout,
                                   timeUnit)

Description copied from interface: NodeAsync

Ping Redis node with specified timeout.

Specified by:

pingAsync in interface NodeAsync

Parameters:

timeout - - ping timeout

timeUnit - - timeout unit

Returns:

true if "PONG" reply received, false otherwise

ping

public boolean ping()

Description copied from interface: Node

Ping Redis node. Default timeout is 1000 milliseconds

Specified by:

ping in interface Node

Returns:

true if "PONG" reply received, false otherwise

ping

public boolean ping(long timeout,
                     timeUnit)

Description copied from interface: Node

Ping Redis node with specified timeout.

Specified by:

ping in interface Node

Parameters:

timeout - - ping timeout

timeUnit - - timeout unit

Returns:

true if "PONG" reply received, false otherwise

hashCode

public int hashCode()

Overrides:

in class

equals

public boolean equals( obj)

Overrides:

in class

timeAsync

public RFuture<Time> timeAsync()

Specified by:

timeAsync in interface NodeAsync

time

public Time time()

Description copied from interface: Node

Returns current Redis server time in seconds

Specified by:

time in interface Node

Returns:

time in seconds

clusterInfoAsync

public <,>> clusterInfoAsync()

Specified by:

clusterInfoAsync in interface NodeAsync

clusterInfo

public <,> clusterInfo()

Description copied from interface: ClusterNode

Execute CLUSTER INFO operation.

Specified by:

clusterInfo in interface ClusterNode

Returns:

value mapped by field

info

public <,> info(Node.InfoSection section)

Specified by:

info in interface Node

infoAsync

public <,>> infoAsync(Node.InfoSection section)

Specified by:

infoAsync in interface NodeAsync

toString

public  toString()

Overrides:

in class