io.vertx.sqlclient.impl.pool

Class ConnectionPool

java.lang.Object

io.vertx.sqlclient.impl.pool.ConnectionPool

public class ConnectionPool
extends Object

Todo : - handle timeout when acquiring a connection - for per statement pooling, have several physical connection and use the less busy one to avoid head of line blocking effect

Author:

Julien Viet

Constructor Summary

Constructors

Constructor and Description
ConnectionPool(ConnectionFactory connector, EventLoopContext context, int maxSize, int maxWaitQueueSize, long idleTimeout)
ConnectionPool(ConnectionFactory connector, int maxSize)
ConnectionPool(ConnectionFactory connector, int maxSize, int maxWaitQueueSize)

Method Summary

Modifier and Type	Method and Description
void	acquire(Handler<AsyncResult<Connection>> waiter)
int	available()
Future<Void>	close()
void	close(Promise<Void> promise)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionPool

public ConnectionPool(ConnectionFactory connector,
                      int maxSize)

ConnectionPool

public ConnectionPool(ConnectionFactory connector,
                      int maxSize,
                      int maxWaitQueueSize)

ConnectionPool

public ConnectionPool(ConnectionFactory connector,
                      EventLoopContext context,
                      int maxSize,
                      int maxWaitQueueSize,
                      long idleTimeout)

Method Detail

available

public int available()

size

public int size()

acquire

public void acquire(Handler<AsyncResult<Connection>> waiter)

close

public Future<Void> close()

close

public void close(Promise<Void> promise)