Package io.openlineage.client.circuitBreaker

Class JavaRuntimeCircuitBreakerConfig

java.lang.Object

io.openlineage.client.circuitBreaker.JavaRuntimeCircuitBreakerConfig

All Implemented Interfaces:

CircuitBreakerConfig, MergeConfig<JavaRuntimeCircuitBreakerConfig>

public final class JavaRuntimeCircuitBreakerConfig
extends Object
implements CircuitBreakerConfig, MergeConfig<JavaRuntimeCircuitBreakerConfig>

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_GC_CPU_THRESHOLD
static final int	DEFAULT_MEMORY_THRESHOLD

Constructor Summary

Constructors

Constructor	Description
JavaRuntimeCircuitBreakerConfig()
JavaRuntimeCircuitBreakerConfig(int memoryThreshold, int gcCpuThreshold)
JavaRuntimeCircuitBreakerConfig(int memoryThreshold, int gcCpuThreshold, int circuitCheckIntervalInMillis)
JavaRuntimeCircuitBreakerConfig(Integer memoryThreshold, Integer gcCpuThreshold, Integer circuitCheckIntervalInMillis, Integer timeoutInSeconds)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Integer	getCircuitCheckIntervalInMillis()
Integer	getGcCpuThreshold()
Integer	getMemoryThreshold()
Optional<Duration>	getTimeout()
Integer	getTimeoutInSeconds()
int	hashCode()
JavaRuntimeCircuitBreakerConfig	mergeWithNonNull(JavaRuntimeCircuitBreakerConfig other)	Method to create new config class based on current instance and non-null argument value.
void	setCircuitCheckIntervalInMillis(Integer circuitCheckIntervalInMillis)
void	setGcCpuThreshold(Integer gcCpuThreshold)
void	setMemoryThreshold(Integer memoryThreshold)
void	setTimeoutInSeconds(Integer timeoutInSeconds)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.openlineage.client.MergeConfig

mergePropertyWith, mergePropertyWith, mergeWith, mergeWithDefaultValue

Field Details

DEFAULT_MEMORY_THRESHOLD

public static final int DEFAULT_MEMORY_THRESHOLD

See Also:

• Constant Field Values

DEFAULT_GC_CPU_THRESHOLD

public static final int DEFAULT_GC_CPU_THRESHOLD

See Also:

• Constant Field Values

Constructor Details

JavaRuntimeCircuitBreakerConfig

public JavaRuntimeCircuitBreakerConfig(int memoryThreshold,
 int gcCpuThreshold,
 int circuitCheckIntervalInMillis)

JavaRuntimeCircuitBreakerConfig

public JavaRuntimeCircuitBreakerConfig(int memoryThreshold,
 int gcCpuThreshold)

JavaRuntimeCircuitBreakerConfig

public JavaRuntimeCircuitBreakerConfig()

JavaRuntimeCircuitBreakerConfig

public JavaRuntimeCircuitBreakerConfig(Integer memoryThreshold,
 Integer gcCpuThreshold,
 Integer circuitCheckIntervalInMillis,
 Integer timeoutInSeconds)

Method Details

mergeWithNonNull

public JavaRuntimeCircuitBreakerConfig mergeWithNonNull(JavaRuntimeCircuitBreakerConfig other)

Description copied from interface: MergeConfig

Method to create new config class based on current instance and non-null argument value. In most cases, implementation needs to create a new instance of T, while merging all the properties.

Specified by:

mergeWithNonNull in interface MergeConfig<JavaRuntimeCircuitBreakerConfig>

Parameters:

other - overwrite value

Returns:

merged config entry

getTimeout

public Optional<Duration> getTimeout()

Specified by:

getTimeout in interface CircuitBreakerConfig

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getMemoryThreshold

public Integer getMemoryThreshold()

setMemoryThreshold

public void setMemoryThreshold(Integer memoryThreshold)

getGcCpuThreshold

public Integer getGcCpuThreshold()

setGcCpuThreshold

public void setGcCpuThreshold(Integer gcCpuThreshold)

getCircuitCheckIntervalInMillis

public Integer getCircuitCheckIntervalInMillis()

setCircuitCheckIntervalInMillis

public void setCircuitCheckIntervalInMillis(Integer circuitCheckIntervalInMillis)

getTimeoutInSeconds

public Integer getTimeoutInSeconds()

setTimeoutInSeconds

public void setTimeoutInSeconds(Integer timeoutInSeconds)