Class FlowController (2.49.0)
Stay organized with collections
Save and categorize content based on your preferences.
public class FlowController
Provides flow control capability.
Constructors
FlowController(DynamicFlowControlSettings settings)
public FlowController(DynamicFlowControlSettings settings)
FlowController(FlowControlSettings settings)
public FlowController(FlowControlSettings settings)
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 |
| Name |
Description |
elementSteps |
long
|
byteSteps |
long
|
getCurrentElementCountLimit()
public Long getCurrentElementCountLimit()
| Returns |
| Type |
Description |
Long |
|
getCurrentRequestBytesLimit()
public Long getCurrentRequestBytesLimit()
| Returns |
| Type |
Description |
Long |
|
getFlowControlEventStats()
public FlowControlEventStats getFlowControlEventStats()
getMaxElementCountLimit()
public Long getMaxElementCountLimit()
| Returns |
| Type |
Description |
Long |
|
getMaxRequestBytesLimit()
public Long getMaxRequestBytesLimit()
| Returns |
| Type |
Description |
Long |
|
getMinElementCountLimit()
public Long getMinElementCountLimit()
| Returns |
| Type |
Description |
Long |
|
getMinRequestBytesLimit()
public Long getMinRequestBytesLimit()
| Returns |
| Type |
Description |
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 |
| Name |
Description |
elementSteps |
long
|
byteSteps |
long
|
release(long elements, long bytes)
public void release(long elements, long bytes)
| Parameters |
| Name |
Description |
elements |
long
|
bytes |
long
|
reserve(long elements, long bytes)
public void reserve(long elements, long bytes)
| Parameters |
| Name |
Description |
elements |
long
|
bytes |
long
|
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2024-06-12 UTC.
[{
"type": "thumb-down",
"id": "hardToUnderstand",
"label":"Hard to understand"
},{
"type": "thumb-down",
"id": "incorrectInformationOrSampleCode",
"label":"Incorrect information or sample code"
},{
"type": "thumb-down",
"id": "missingTheInformationSamplesINeed",
"label":"Missing the information/samples I need"
},{
"type": "thumb-down",
"id": "otherDown",
"label":"Other"
}]
[{
"type": "thumb-up",
"id": "easyToUnderstand",
"label":"Easy to understand"
},{
"type": "thumb-up",
"id": "solvedMyProblem",
"label":"Solved my problem"
},{
"type": "thumb-up",
"id": "otherUp",
"label":"Other"
}]
