Interface ConcurrentScannerThrottlingAware
-
- All Superinterfaces:
ConcurrentDocumentFetcherScanner
public interface ConcurrentScannerThrottlingAware extends ConcurrentDocumentFetcherScanner
The scanner will implement this to if it wants platform level throttling support. It extendsConcurrentDocumentFetcherScanner
since throttling is needed only when multiple threads try to access the server concurrently.
-
-
Field Summary
-
Fields inherited from interface com.attivio.sdk.scanner.concurrency.ConcurrentDocumentFetcherScanner
FetcherTimeoutDefault, ThreadpoolSizeDefault
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description long
getDocumentRequestsUpperLimit()
An upper limit on the number of fetch requests the connector framework implementation will executedefault long
getTimePeriodMillis()
void
setDocumentRequestsUpperLimit(long documentRequestsUpperLimit)
Sets an upper limit on the number of fetch requests the connector framework implementation will executedefault void
setTimePeriodMillis(long timePeriodMillis)
Sets time period for which to test the upper limit-
Methods inherited from interface com.attivio.sdk.scanner.concurrency.ConcurrentDocumentFetcherScanner
getFetcherTimeout, getThreadpoolSize, setConcurrencyProvider, setFetcherTimeout, setThreadpoolSize, stop
-
-
-
-
Method Detail
-
setDocumentRequestsUpperLimit
void setDocumentRequestsUpperLimit(long documentRequestsUpperLimit)
Sets an upper limit on the number of fetch requests the connector framework implementation will execute- Parameters:
docRequestsPerTimePeriod
- -1 is no limit
-
getDocumentRequestsUpperLimit
long getDocumentRequestsUpperLimit()
An upper limit on the number of fetch requests the connector framework implementation will execute- Returns:
- -1 for no limit
-
setTimePeriodMillis
default void setTimePeriodMillis(long timePeriodMillis)
Sets time period for which to test the upper limit
-
getTimePeriodMillis
default long getTimePeriodMillis()
- Returns:
- The time period for which to test the upper limit
-
-