|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use SocketDestination | |
---|---|
voldemort.client.protocol.admin | Classes that abstract admin based Voldemort requests. |
voldemort.store.socket | A store implementation that works remotely over a tcp/ip socket interacting with a SocketServer on the the other side. |
voldemort.store.socket.clientrequest | More classes related to how to parse client requests |
voldemort.store.stats | Store wrappers which deal with statistics |
Uses of SocketDestination in voldemort.client.protocol.admin |
---|
Methods in voldemort.client.protocol.admin with parameters of type SocketDestination | |
---|---|
void |
SocketPool.checkin(SocketDestination destination,
SocketAndStreams socket)
Check the socket back into the pool. |
SocketAndStreams |
SocketPool.checkout(SocketDestination destination)
Checkout a socket from the pool |
void |
SocketPool.close(SocketDestination destination)
|
SocketAndStreams |
SocketResourceFactory.create(SocketDestination dest)
Create a socket for the given host/port |
void |
SocketResourceFactory.destroy(SocketDestination dest,
SocketAndStreams sands)
Close the socket |
void |
SocketResourceFactory.setLastClosedTimestamp(SocketDestination socketDestination)
Assigns the last closed timestamp based on the current time in nanoseconds. |
boolean |
SocketResourceFactory.validate(SocketDestination dest,
SocketAndStreams sands)
|
Uses of SocketDestination in voldemort.store.socket |
---|
Methods in voldemort.store.socket with parameters of type SocketDestination | |
---|---|
void |
SocketStoreFactory.close(SocketDestination destination)
This closes the resources for a specific host, usually in response to an error in communicating with that host. |
Constructors in voldemort.store.socket with parameters of type SocketDestination | |
---|---|
SocketStore(java.lang.String storeName,
long timeoutMs,
SocketDestination dest,
ClientRequestExecutorPool pool,
RequestRoutingType requestRoutingType,
ClientSocketStats stats)
|
Uses of SocketDestination in voldemort.store.socket.clientrequest |
---|
Methods in voldemort.store.socket.clientrequest with parameters of type SocketDestination | ||
---|---|---|
void |
ClientRequestExecutorPool.checkin(SocketDestination destination,
ClientRequestExecutor clientRequestExecutor)
Check the socket back into the pool. |
|
ClientRequestExecutor |
ClientRequestExecutorPool.checkout(SocketDestination destination)
Checkout a socket from the pool |
|
void |
ClientRequestExecutorPool.close(SocketDestination destination)
Reset the pool of resources for a specific destination. |
|
ClientRequestExecutor |
ClientRequestExecutorFactory.create(SocketDestination dest)
Create a ClientRequestExecutor for the given SocketDestination . |
|
void |
ClientRequestExecutorFactory.destroy(SocketDestination dest,
ClientRequestExecutor clientRequestExecutor)
Close the ClientRequestExecutor. |
|
void |
ClientRequestExecutorFactory.setLastClosedTimestamp(SocketDestination socketDestination)
Assigns the last closed timestamp based on the current time in nanoseconds. |
|
|
ClientRequestExecutorPool.submitAsync(SocketDestination destination,
ClientRequest<T> delegate,
NonblockingStoreCallback callback,
long timeoutMs,
java.lang.String operationName)
|
|
boolean |
ClientRequestExecutorFactory.validate(SocketDestination dest,
ClientRequestExecutor clientRequestExecutor)
|
Uses of SocketDestination in voldemort.store.stats |
---|
Methods in voldemort.store.stats that return types with arguments of type SocketDestination | |
---|---|
java.util.concurrent.ConcurrentMap<SocketDestination,ClientSocketStats> |
ClientSocketStats.getStatsMap()
|
Methods in voldemort.store.stats with parameters of type SocketDestination | |
---|---|
int |
ClientSocketStats.getConnectionsActive(SocketDestination destination)
|
int |
ClientSocketStats.getConnectionsInPool(SocketDestination destination)
|
void |
ClientSocketStats.incrementCount(SocketDestination dest,
ClientSocketStats.Tracked metric)
|
void |
ClientSocketStats.recordAsyncOpTimeNs(SocketDestination dest,
long opTimeNs)
Record operation for async ops time |
void |
ClientSocketStats.recordCheckoutQueueLength(SocketDestination dest,
int queueLength)
Record the checkout queue length |
void |
ClientSocketStats.recordCheckoutTimeUs(SocketDestination dest,
long checkoutTimeUs)
Record the checkout wait time in us |
void |
ClientSocketStats.recordConnectionEstablishmentTimeUs(SocketDestination dest,
long connEstTimeUs)
Record the connection establishment time |
void |
ClientSocketStats.recordResourceRequestQueueLength(SocketDestination dest,
int queueLength)
Record the resource request queue length |
void |
ClientSocketStats.recordResourceRequestTimeUs(SocketDestination dest,
long resourceRequestTimeUs)
Record the resource request wait time in us |
void |
ClientSocketStats.recordSyncOpTimeNs(SocketDestination dest,
long opTimeNs)
Record operation for sync ops time |
Method parameters in voldemort.store.stats with type arguments of type SocketDestination | |
---|---|
void |
ClientSocketStats.setPool(QueuedKeyedResourcePool<SocketDestination,ClientRequestExecutor> pool)
|
Constructors in voldemort.store.stats with parameters of type SocketDestination | |
---|---|
ClientSocketStats(ClientSocketStats parent,
SocketDestination destination,
QueuedKeyedResourcePool<SocketDestination,ClientRequestExecutor> pool,
java.lang.String identifierString)
To construct a per node stats object |
Constructor parameters in voldemort.store.stats with type arguments of type SocketDestination | |
---|---|
ClientSocketStats(ClientSocketStats parent,
SocketDestination destination,
QueuedKeyedResourcePool<SocketDestination,ClientRequestExecutor> pool,
java.lang.String identifierString)
To construct a per node stats object |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |