Package io.openlineage.client.circuitBreaker

Class TaskQueueCircuitBreakerConfig

java.lang.Object

io.openlineage.client.circuitBreaker.TaskQueueCircuitBreakerConfig

All Implemented Interfaces:

CircuitBreakerConfig, MergeConfig<TaskQueueCircuitBreakerConfig>

public class TaskQueueCircuitBreakerConfig
extends Object
implements CircuitBreakerConfig, MergeConfig<TaskQueueCircuitBreakerConfig>

Constructor Summary

Constructors

Constructor	Description
TaskQueueCircuitBreakerConfig()
TaskQueueCircuitBreakerConfig(Integer threadCount, Integer queueSize, Long blockingTimeInSeconds, Long shutdownTimeoutSeconds, Integer circuitCheckIntervalInMillis)

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
boolean	equals(Object o)
Long	getBlockingTimeInSeconds()
Integer	getCircuitCheckIntervalInMillis()
Integer	getQueueSize()
Long	getShutdownTimeoutSeconds()
Integer	getThreadCount()
int	hashCode()
TaskQueueCircuitBreakerConfig	mergeWithNonNull(TaskQueueCircuitBreakerConfig other)	Method to create new config class based on current instance and non-null argument value.
void	setBlockingTimeInSeconds(Long blockingTimeInSeconds)
void	setCircuitCheckIntervalInMillis(Integer circuitCheckIntervalInMillis)
void	setQueueSize(Integer queueSize)
void	setShutdownTimeoutSeconds(Long shutdownTimeoutSeconds)
void	setThreadCount(Integer threadCount)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.openlineage.client.circuitBreaker.CircuitBreakerConfig

getTimeout

Methods inherited from interface io.openlineage.client.MergeConfig

mergePropertyWith, mergePropertyWith, mergeWith, mergeWithDefaultValue

Constructor Details

TaskQueueCircuitBreakerConfig

public TaskQueueCircuitBreakerConfig()

TaskQueueCircuitBreakerConfig

public TaskQueueCircuitBreakerConfig(Integer threadCount,
 Integer queueSize,
 Long blockingTimeInSeconds,
 Long shutdownTimeoutSeconds,
 Integer circuitCheckIntervalInMillis)

Method Details

mergeWithNonNull

public TaskQueueCircuitBreakerConfig mergeWithNonNull(TaskQueueCircuitBreakerConfig 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<TaskQueueCircuitBreakerConfig>

Parameters:

other - overwrite value

Returns:

merged config entry

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

canEqual

protected boolean canEqual(Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getThreadCount

public Integer getThreadCount()

setThreadCount

public void setThreadCount(Integer threadCount)

getQueueSize

public Integer getQueueSize()

setQueueSize

public void setQueueSize(Integer queueSize)

getBlockingTimeInSeconds

public Long getBlockingTimeInSeconds()

setBlockingTimeInSeconds

public void setBlockingTimeInSeconds(Long blockingTimeInSeconds)

getShutdownTimeoutSeconds

public Long getShutdownTimeoutSeconds()

setShutdownTimeoutSeconds

public void setShutdownTimeoutSeconds(Long shutdownTimeoutSeconds)

getCircuitCheckIntervalInMillis

public Integer getCircuitCheckIntervalInMillis()

setCircuitCheckIntervalInMillis

public void setCircuitCheckIntervalInMillis(Integer circuitCheckIntervalInMillis)