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 timeoutSeconds, Long shutdownTimeoutSeconds, Integer circuitCheckIntervalInMillis)

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
boolean	equals(Object o)
Integer	getCircuitCheckIntervalInMillis()
Integer	getQueueSize()
Long	getShutdownTimeoutSeconds()
Integer	getThreadCount()
Long	getTimeoutSeconds()
int	hashCode()
TaskQueueCircuitBreakerConfig	mergeWithNonNull(TaskQueueCircuitBreakerConfig other)	Method to create new config class based on current instance and non-null argument value.
void	setCircuitCheckIntervalInMillis(Integer circuitCheckIntervalInMillis)
void	setQueueSize(Integer queueSize)
void	setShutdownTimeoutSeconds(Long shutdownTimeoutSeconds)
void	setThreadCount(Integer threadCount)
void	setTimeoutSeconds(Long timeoutSeconds)
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

Constructor Details

TaskQueueCircuitBreakerConfig

public TaskQueueCircuitBreakerConfig()

TaskQueueCircuitBreakerConfig

public TaskQueueCircuitBreakerConfig(Integer threadCount,
 Integer queueSize,
 Long timeoutSeconds,
 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)

getTimeoutSeconds

public Long getTimeoutSeconds()

setTimeoutSeconds

public void setTimeoutSeconds(Long timeoutSeconds)

getShutdownTimeoutSeconds

public Long getShutdownTimeoutSeconds()

setShutdownTimeoutSeconds

public void setShutdownTimeoutSeconds(Long shutdownTimeoutSeconds)

getCircuitCheckIntervalInMillis

public Integer getCircuitCheckIntervalInMillis()

setCircuitCheckIntervalInMillis

public void setCircuitCheckIntervalInMillis(Integer circuitCheckIntervalInMillis)