public interface IConcurrentConnectionManager
| Modifier and Type | Interface and Description |
|---|---|
static class |
IConcurrentConnectionManager.ReservationType |
| Modifier and Type | Method and Description |
|---|---|
void |
addToWhitelist(java.lang.String nodeId) |
java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.Reservation>> |
getActiveReservationsByNodeByPool() |
java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.NodeConnectionStatistics>> |
getNodeConnectionStatisticsByPoolByNodeId() |
java.util.Map<java.lang.String,java.util.Date> |
getPullReservationsByNodeId() |
java.util.Map<java.lang.String,java.util.Date> |
getPushReservationsByNodeId() |
int |
getReservationCount(java.lang.String poolId) |
java.lang.String[] |
getWhiteList() |
boolean |
releaseConnection(java.lang.String nodeId,
java.lang.String poolId) |
boolean |
releaseConnection(java.lang.String nodeId,
java.lang.String channelId,
java.lang.String poolId) |
void |
removeFromWhiteList(java.lang.String nodeId) |
boolean |
reserveConnection(java.lang.String nodeId,
java.lang.String poolId,
IConcurrentConnectionManager.ReservationType reservationRequest) |
boolean |
reserveConnection(java.lang.String nodeId,
java.lang.String channelId,
java.lang.String poolId,
IConcurrentConnectionManager.ReservationType reservationRequest) |
boolean reserveConnection(java.lang.String nodeId,
java.lang.String poolId,
IConcurrentConnectionManager.ReservationType reservationRequest)
nodeId - reservationRequest - if true then hold onto reservation for the time it
typically takes for a node to reconnect after the initial
request. Otherwise, we know that the node has actually
connected for activity.boolean reserveConnection(java.lang.String nodeId,
java.lang.String channelId,
java.lang.String poolId,
IConcurrentConnectionManager.ReservationType reservationRequest)
boolean releaseConnection(java.lang.String nodeId,
java.lang.String poolId)
boolean releaseConnection(java.lang.String nodeId,
java.lang.String channelId,
java.lang.String poolId)
int getReservationCount(java.lang.String poolId)
java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.NodeConnectionStatistics>> getNodeConnectionStatisticsByPoolByNodeId()
java.util.Map<java.lang.String,java.util.Map<java.lang.String,ConcurrentConnectionManager.Reservation>> getActiveReservationsByNodeByPool()
void addToWhitelist(java.lang.String nodeId)
java.lang.String[] getWhiteList()
void removeFromWhiteList(java.lang.String nodeId)
java.util.Map<java.lang.String,java.util.Date> getPullReservationsByNodeId()
java.util.Map<java.lang.String,java.util.Date> getPushReservationsByNodeId()