voldemort.coordinator
Class CoordinatorService

java.lang.Object
  extended by voldemort.common.service.AbstractService
      extended by voldemort.coordinator.CoordinatorService
All Implemented Interfaces:
VoldemortService

public class CoordinatorService
extends AbstractService

A Netty based HTTP service that accepts REST requests from the Voldemort thin clients and invokes the corresponding Fat client API.


Field Summary
static org.apache.avro.Schema CLIENT_CONFIGS_AVRO_SCHEMA
           
protected  java.util.concurrent.ThreadPoolExecutor workerPool
           
 
Constructor Summary
CoordinatorService(CoordinatorConfig config)
           
 
Method Summary
 double getAverageDeleteCompletionTimeInMs()
           
 double getAverageGetAllCompletionTimeInMs()
           
 double getAverageGetCompletionTimeInMs()
           
 double getAveragePutCompletionTimeInMs()
           
 int getNumberOfActiveThreads()
           
 int getNumberOfThreads()
           
 long getQ99DeleteLatency()
           
 long getQ99GetAllLatency()
           
 long getQ99GetLatency()
           
 long getQ99PutLatency()
           
 int getQueuedRequests()
           
static void main(java.lang.String[] args)
           
protected  void startInner()
           
protected  void stopInner()
           
 
Methods inherited from class voldemort.common.service.AbstractService
getType, isStarted, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

CLIENT_CONFIGS_AVRO_SCHEMA

public static final org.apache.avro.Schema CLIENT_CONFIGS_AVRO_SCHEMA

workerPool

protected java.util.concurrent.ThreadPoolExecutor workerPool
Constructor Detail

CoordinatorService

public CoordinatorService(CoordinatorConfig config)
Method Detail

startInner

protected void startInner()
Specified by:
startInner in class AbstractService

stopInner

protected void stopInner()
Specified by:
stopInner in class AbstractService

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception
Throws:
java.lang.Exception

getNumberOfActiveThreads

public int getNumberOfActiveThreads()

getNumberOfThreads

public int getNumberOfThreads()

getQueuedRequests

public int getQueuedRequests()

getAverageGetCompletionTimeInMs

public double getAverageGetCompletionTimeInMs()

getAveragePutCompletionTimeInMs

public double getAveragePutCompletionTimeInMs()

getAverageGetAllCompletionTimeInMs

public double getAverageGetAllCompletionTimeInMs()

getAverageDeleteCompletionTimeInMs

public double getAverageDeleteCompletionTimeInMs()

getQ99GetLatency

public long getQ99GetLatency()

getQ99PutLatency

public long getQ99PutLatency()

getQ99GetAllLatency

public long getQ99GetAllLatency()

getQ99DeleteLatency

public long getQ99DeleteLatency()


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