Class FlowController (2.13.0)

public class FlowController

Provides flow control capability.

Inheritance

java.lang.Object > FlowController

Constructors

FlowController(DynamicFlowControlSettings settings)

public FlowController(DynamicFlowControlSettings settings)
Parameter
NameDescription
settingsDynamicFlowControlSettings

FlowController(FlowControlSettings settings)

public FlowController(FlowControlSettings settings)
Parameter
NameDescription
settingsFlowControlSettings

Methods

decreaseThresholds(long elementSteps, long byteSteps)

public void decreaseThresholds(long elementSteps, long byteSteps)

Decrease flow control limits to allow elementSteps fewer elements and byteSteps fewer request bytes before enforcing flow control.

Parameters
NameDescription
elementStepslong
byteStepslong

getCurrentElementCountLimit()

public Long getCurrentElementCountLimit()
Returns
TypeDescription
Long

getCurrentRequestBytesLimit()

public Long getCurrentRequestBytesLimit()
Returns
TypeDescription
Long

getFlowControlEventStats()

public FlowControlEventStats getFlowControlEventStats()
Returns
TypeDescription
FlowControlEventStats

getMaxElementCountLimit()

public Long getMaxElementCountLimit()
Returns
TypeDescription
Long

getMaxRequestBytesLimit()

public Long getMaxRequestBytesLimit()
Returns
TypeDescription
Long

getMinElementCountLimit()

public Long getMinElementCountLimit()
Returns
TypeDescription
Long

getMinRequestBytesLimit()

public Long getMinRequestBytesLimit()
Returns
TypeDescription
Long

increaseThresholds(long elementSteps, long byteSteps)

public void increaseThresholds(long elementSteps, long byteSteps)

Increase flow control limits to allow extra elementSteps elements and byteSteps request bytes before enforcing flow control.

Parameters
NameDescription
elementStepslong
byteStepslong

release(long elements, long bytes)

public void release(long elements, long bytes)
Parameters
NameDescription
elementslong
byteslong

reserve(long elements, long bytes)

public void reserve(long elements, long bytes)
Parameters
NameDescription
elementslong
byteslong
Exceptions
TypeDescription
FlowController.FlowControlException