Package org.redisson.connection.pool

Class SlaveConnectionPool

java.lang.Object

org.redisson.connection.pool.SlaveConnectionPool

public class SlaveConnectionPool
extends Object

Connection pool for slave node

Author:

Nikita Koksharov

Field Summary

Fields

Modifier and Type	Field	Description
protected final Queue<ClientConnectionsEntry>	entries

Constructor Summary

Constructors

Constructor	Description
SlaveConnectionPool(MasterSlaveServersConfig config, ConnectionManager connectionManager, MasterSlaveEntry masterSlaveEntry)

Method Summary

Modifier and Type	Method	Description
protected final CompletableFuture<RedisConnection>	acquireConnection(RedisCommand<?> command, ClientConnectionsEntry entry)
final void	addEntry(ClientConnectionsEntry entry)
CompletableFuture<RedisConnection>	get(RedisCommand<?> command)
CompletableFuture<RedisConnection>	get(RedisCommand<?> command, ClientConnectionsEntry entry)
protected ConnectionsHolder<RedisConnection>	getConnectionHolder(ClientConnectionsEntry entry)
final void	returnConnection(ClientConnectionsEntry entry, RedisConnection connection)

Methods inherited from class java.lang.Object

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

Field Details

entries

protected final Queue<ClientConnectionsEntry> entries

Constructor Details

SlaveConnectionPool

public SlaveConnectionPool(MasterSlaveServersConfig config,
 ConnectionManager connectionManager,
 MasterSlaveEntry masterSlaveEntry)

Method Details

getConnectionHolder

protected ConnectionsHolder<RedisConnection> getConnectionHolder(ClientConnectionsEntry entry)

addEntry

public final void addEntry(ClientConnectionsEntry entry)

get

public CompletableFuture<RedisConnection> get(RedisCommand<?> command)

get

public CompletableFuture<RedisConnection> get(RedisCommand<?> command,
 ClientConnectionsEntry entry)

acquireConnection

protected final CompletableFuture<RedisConnection> acquireConnection(RedisCommand<?> command,
 ClientConnectionsEntry entry)

returnConnection

public final void returnConnection(ClientConnectionsEntry entry,
 RedisConnection connection)