voldemort.rest.coordinator
Class CoordinatorService

java.lang.Object
  voldemort.common.service.AbstractService
      voldemort.rest.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()
double	getQ99DeleteLatency()
double	getQ99GetAllLatency()
double	getQ99GetLatency()
double	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 double getQ99GetLatency()

getQ99PutLatency

public double getQ99PutLatency()

getQ99GetAllLatency

public double getQ99GetAllLatency()

getQ99DeleteLatency

public double getQ99DeleteLatency()