public class RequestStarterGroup
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
class |
RequestStarterGroup.MyRequestThrottle |
static class |
RequestStarterGroup.PrioritySchedulerCallback |
Modifier and Type | Method and Description |
---|---|
long |
countQueuedRequests() |
java.lang.String |
diagnosticThrottlesLine(boolean mode) |
double |
getDelay(boolean isSSK,
boolean isInsert,
boolean realTime) |
double |
getRealWindow(boolean realTime) |
double |
getRTT(boolean isSSK,
boolean isInsert,
boolean realTime) |
ClientRequestScheduler |
getScheduler(boolean ssk,
boolean insert,
boolean realTime) |
ThrottleWindowManager |
getThrottleWindow(boolean realTime) |
double |
getWindow(boolean realTime) |
void |
rejectedOverload(boolean isSSK,
boolean isInsert,
boolean realTime) |
void |
requestCompleted(boolean isSSK,
boolean isInsert,
Key key,
boolean realTime) |
void |
setGlobalSalt(byte[] salt) |
void |
start() |
java.lang.String |
statsPageLine(boolean isSSK,
boolean isInsert,
boolean realTime) |
public final ClientRequestScheduler chkFetchSchedulerBulk
public final ClientRequestScheduler chkPutSchedulerBulk
public final ClientRequestScheduler sskFetchSchedulerBulk
public final ClientRequestScheduler sskPutSchedulerBulk
public final ClientRequestScheduler chkFetchSchedulerRT
public final ClientRequestScheduler chkPutSchedulerRT
public final ClientRequestScheduler sskFetchSchedulerRT
public final ClientRequestScheduler sskPutSchedulerRT
public void start()
public ThrottleWindowManager getThrottleWindow(boolean realTime)
public void requestCompleted(boolean isSSK, boolean isInsert, Key key, boolean realTime)
public void rejectedOverload(boolean isSSK, boolean isInsert, boolean realTime)
public double getWindow(boolean realTime)
public double getRTT(boolean isSSK, boolean isInsert, boolean realTime)
public double getDelay(boolean isSSK, boolean isInsert, boolean realTime)
public java.lang.String statsPageLine(boolean isSSK, boolean isInsert, boolean realTime)
public java.lang.String diagnosticThrottlesLine(boolean mode)
public double getRealWindow(boolean realTime)
public long countQueuedRequests()
public ClientRequestScheduler getScheduler(boolean ssk, boolean insert, boolean realTime)
public void setGlobalSalt(byte[] salt)