Package | Description |
---|---|
com.sm.store.client | |
com.sm.store.cluster |
Modifier and Type | Method and Description |
---|---|
static ConcurrentMap<Short,List<Connection>> |
Utils.buildClusterConnection(List<ClusterNodes> clusterNodesList,
TCPClientFactory.ClientType clientType) |
static List<Connection> |
Utils.buildConnections(String[] urls,
TCPClientFactory.ClientType clientType) |
ConcurrentMap<Short,List<Connection>> |
ClientConnections.getClusterConnections() |
Modifier and Type | Method and Description |
---|---|
static Client |
TCPClientFactory.createClient(TCPClientFactory.ClientType clientType,
Connection connection,
long timeout) |
Modifier and Type | Method and Description |
---|---|
protected Client |
ClientConnections.findConnection(int hashCode,
List<Connection> connectionList) |
static String |
Utils.getConnectionListStr(Map<Short,List<Connection>> clusterConnections) |
Modifier and Type | Method and Description |
---|---|
void |
Connection.putIfAbsent(BlockingQueue<Connection> queue) |
void |
Connection.remoteFromQueue(BlockingQueue<Connection> queue) |
Copyright © 2016. All rights reserved.