voldemort.coordinator
Class FatClientWrapper

java.lang.Object
  extended by voldemort.coordinator.FatClientWrapper

public class FatClientWrapper
extends java.lang.Object

A Wrapper class to provide asynchronous API for calling the fat client methods. These methods will be invoked by the Netty request handler instead of invoking the Fat Client methods on its own


Constructor Summary
FatClientWrapper(java.lang.String storeName, CoordinatorConfig config, ClientConfig clientConfig, java.lang.String storesXml, java.lang.String clusterXml, CoordinatorErrorStats errorStats, StoreStats coordinatorPerfStats)
           
 
Method Summary
 void close()
           
 int getNumberOfActiveThreads()
           
 int getNumberOfThreads()
           
 int getQueuedRequests()
           
 void submitDeleteRequest(CompositeVoldemortRequest<ByteArray,byte[]> deleteRequestObject, org.jboss.netty.channel.MessageEvent deleteRequestEvent, long startTimestampInNs)
          Interface to perform delete operation on the fat client
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

FatClientWrapper

public FatClientWrapper(java.lang.String storeName,
                        CoordinatorConfig config,
                        ClientConfig clientConfig,
                        java.lang.String storesXml,
                        java.lang.String clusterXml,
                        CoordinatorErrorStats errorStats,
                        StoreStats coordinatorPerfStats)
Parameters:
storeName - Store to connect to via this fat client
config - Bootstrap URLs for the intended cluster
clientConfig - The config used to bootstrap the fat client
storesXml - Stores XML used to bootstrap the fat client
clusterXml - Cluster XML used to bootstrap the fat client
errorStats -
coordinatorPerfStats -
Method Detail

close

public void close()

submitDeleteRequest

public void submitDeleteRequest(CompositeVoldemortRequest<ByteArray,byte[]> deleteRequestObject,
                                org.jboss.netty.channel.MessageEvent deleteRequestEvent,
                                long startTimestampInNs)
Interface to perform delete operation on the fat client

Parameters:
deleteRequestObject - Contains the key and the version used in the delete operation
deleteRequestEvent - MessageEvent to write the response back to
startTimestampInNs - The start timestamp used to measure turnaround time

getNumberOfActiveThreads

public int getNumberOfActiveThreads()

getNumberOfThreads

public int getNumberOfThreads()

getQueuedRequests

public int getQueuedRequests()


Jay Kreps, Roshan Sumbaly, Alex Feinberg, Bhupesh Bansal, Lei Gao, Chinmay Soman, Vinoth Chandar, Zhongjie Wu