protected static class Throttler.FetchThrottler extends Object implements IFetchThrottler
Modifier and Type | Field and Description |
---|---|
protected String[] |
binNames |
protected Throttler.ThrottlingGroup |
parent |
_rcsid
Constructor and Description |
---|
Throttler.FetchThrottler(Throttler.ThrottlingGroup parent,
String[] binNames) |
Modifier and Type | Method and Description |
---|---|
IStreamThrottler |
createFetchStream()
Open a fetch stream.
|
boolean |
obtainFetchDocumentPermission()
Get permission to fetch a document.
|
boolean |
obtainFetchDocumentPermission(IBreakCheck breakCheck)
Get permission to fetch a document.
|
protected final Throttler.ThrottlingGroup parent
protected final String[] binNames
public Throttler.FetchThrottler(Throttler.ThrottlingGroup parent, String[] binNames)
public boolean obtainFetchDocumentPermission() throws InterruptedException
obtainFetchDocumentPermission
in interface IFetchThrottler
InterruptedException
public boolean obtainFetchDocumentPermission(IBreakCheck breakCheck) throws InterruptedException, BreakException
obtainFetchDocumentPermission
in interface IFetchThrottler
InterruptedException
BreakException
public IStreamThrottler createFetchStream()
createFetchStream
in interface IFetchThrottler