public class

RoundRobinExecuteWithFailover

extends AbstractExecuteWithFailoverImpl<CL, R>
java.lang.Object
   ↳ com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl<CL, R>
     ↳ com.netflix.astyanax.connectionpool.impl.RoundRobinExecuteWithFailover<CL, R>

Summary

Fields
protected HostConnectionPool<CL> pool
protected final List<HostConnectionPool<CL>> pools
protected int size
protected int waitDelta
protected int waitMultiplier
[Expand]
Inherited Fields
From class com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl
Public Constructors
RoundRobinExecuteWithFailover(ConnectionPoolConfiguration config, ConnectionPoolMonitor monitor, List<HostConnectionPool<CL>> pools, int index)
Public Methods
Connection<CL> borrowConnection(Operation<CL, R> operation)
boolean canRetry()
HostConnectionPool<CL> getCurrentHostConnectionPool()
int getNextHostIndex()
[Expand]
Inherited Methods
From class com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl
From class java.lang.Object
From interface com.netflix.astyanax.connectionpool.ExecuteWithFailover

Fields

protected HostConnectionPool<CL> pool

protected final List<HostConnectionPool<CL>> pools

protected int size

protected int waitDelta

protected int waitMultiplier

Public Constructors

public RoundRobinExecuteWithFailover (ConnectionPoolConfiguration config, ConnectionPoolMonitor monitor, List<HostConnectionPool<CL>> pools, int index)

Throws
ConnectionException

Public Methods

public Connection<CL> borrowConnection (Operation<CL, R> operation)

Throws
ConnectionException

public boolean canRetry ()

public HostConnectionPool<CL> getCurrentHostConnectionPool ()

public int getNextHostIndex ()