Class FlowController (2.59.0)

Version latest

• 2.59.0 (latest)
• 2.58.0
• 2.57.0
• 2.55.0
• 2.54.1
• 2.53.0
• 2.52.0
• 2.51.0
• 2.50.0
• 2.49.0
• 2.48.1
• 2.47.0
• 2.46.1
• 2.45.0
• 2.43.0
• 2.42.0
• 2.41.0
• 2.39.0
• 2.38.0
• 2.37.0
• 2.36.0
• 2.35.0
• 2.34.1
• 2.33.0
• 2.32.1
• 2.31.1
• 2.30.1
• 2.24.0
• 2.23.3
• 2.22.0
• 2.21.0
• 2.20.1
• 2.19.6
• 2.18.7
• 2.17.0
• 2.16.0
• 2.15.0
• 2.14.0
• 2.13.0
• 2.12.2
• 2.11.0
• 2.10.0
• 2.9.0
• 2.8.1
• 2.7.1

public class FlowController

Provides flow control capability.

Inheritance

java.lang.Object > FlowController

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

FlowController(DynamicFlowControlSettings settings)

public FlowController(DynamicFlowControlSettings settings)

Internal Only: This feature is not stable for application use.

For google-cloud-java client use only

Parameter
Name	Description
settings	DynamicFlowControlSettings

FlowController(FlowControlSettings settings)

public FlowController(FlowControlSettings settings)

Parameter
Name	Description
settings	FlowControlSettings

Methods

decreaseThresholds(long elementSteps, long byteSteps)

public void decreaseThresholds(long elementSteps, long byteSteps)

Internal Only: This feature is not stable for application use.

For google-cloud-java client use only

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()

Internal Only: This feature is not stable for application use.

For google-cloud-java client use only

Returns
Type	Description
Long

getCurrentRequestBytesLimit()

public Long getCurrentRequestBytesLimit()

Internal Only: This feature is not stable for application use.

For google-cloud-java client use only

Returns
Type	Description
Long

getFlowControlEventStats()

public FlowControlEventStats getFlowControlEventStats()

Internal Only: This feature is not stable for application use.

For google-cloud-java client use only

Returns
Type	Description
FlowControlEventStats

getMaxElementCountLimit()

public Long getMaxElementCountLimit()

Internal Only: This feature is not stable for application use.

For internal use by google-cloud-java clients only

Returns
Type	Description
Long

getMaxRequestBytesLimit()

public Long getMaxRequestBytesLimit()

Internal Only: This feature is not stable for application use.

For internal use by google-cloud-java clients only

Returns
Type	Description
Long

getMinElementCountLimit()

public Long getMinElementCountLimit()

Internal Only: This feature is not stable for application use.

For google-cloud-java client use only

Returns
Type	Description
Long

getMinRequestBytesLimit()

public Long getMinRequestBytesLimit()

Internal Only: This feature is not stable for application use.

For google-cloud-java client use only

Returns
Type	Description
Long

increaseThresholds(long elementSteps, long byteSteps)

public void increaseThresholds(long elementSteps, long byteSteps)

Internal Only: This feature is not stable for application use.

For google-cloud-java client use only

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

Exceptions
Type	Description
FlowController.FlowControlException