final case class ProcessingTimeout(unbounded: NonNegativeDuration = DefaultProcessingTimeouts.unbounded, io: NonNegativeDuration = DefaultProcessingTimeouts.io, default: NonNegativeDuration = DefaultProcessingTimeouts.default, network: NonNegativeDuration = DefaultProcessingTimeouts.network, shutdownProcessing: NonNegativeDuration = DefaultProcessingTimeouts.shutdownProcessing, shutdownNetwork: NonNegativeDuration = DefaultProcessingTimeouts.shutdownNetwork, shutdownShort: NonNegativeDuration = DefaultProcessingTimeouts.shutdownShort, closing: NonNegativeDuration = DefaultProcessingTimeouts.closing, inspection: NonNegativeDuration = DefaultProcessingTimeouts.inspection, storageMaxRetryInterval: NonNegativeDuration = DefaultProcessingTimeouts.maxRetryInterval, verifyActive: NonNegativeDuration = DefaultProcessingTimeouts.verifyActive, activeInit: NonNegativeDuration = DefaultProcessingTimeouts.activeInit, slowFutureWarn: NonNegativeDuration = DefaultProcessingTimeouts.slowFutureWarn, activeInitRetryDelay: NonNegativeDuration = DefaultProcessingTimeouts.activeInitRetryDelay, sequencerInfo: NonNegativeDuration = DefaultProcessingTimeouts.sequencerInfo, topologyDispatching: NonNegativeDuration = DefaultProcessingTimeouts.topologyDispatching) extends Product with Serializable
Configuration for internal await timeouts
- unbounded
timeout on how long "unbounded" operations can run. should be infinite in theory.
- io
timeout for disk based operations
- default
default finite processing timeout
- network
timeout for things related to networking
- shutdownProcessing
timeout used for shutdown of some processing where we'd like to keep the result (long)
- shutdownNetwork
timeout used for shutdown where we interact with some remote system
- shutdownShort
everything else shutdown releated (default)
- closing
our closing time (which should be strictly larger than any of the shutdown values)
- inspection
timeout for the storage inspection commands (can run a long long time)
- storageMaxRetryInterval
max retry interval for storage
- verifyActive
how long should we wait for the domain to tell us whether we are active or not
- activeInit
how long a passive replica should wait for the initialization by the active replica
- slowFutureWarn
when using future supervision, when should we start to warn about a slow future
- activeInitRetryDelay
delay between attempts while waiting for initialization of the active replica
- sequencerInfo
how long are we going to try to get the sequencer connection information. setting this high means that connect calls will take quite a while if one of the sequencers is offline.
- topologyDispatching
how long we wait for the topology to retry the dispatching of a message
- Alphabetic
- By Inheritance
- ProcessingTimeout
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new ProcessingTimeout(unbounded: NonNegativeDuration = DefaultProcessingTimeouts.unbounded, io: NonNegativeDuration = DefaultProcessingTimeouts.io, default: NonNegativeDuration = DefaultProcessingTimeouts.default, network: NonNegativeDuration = DefaultProcessingTimeouts.network, shutdownProcessing: NonNegativeDuration = DefaultProcessingTimeouts.shutdownProcessing, shutdownNetwork: NonNegativeDuration = DefaultProcessingTimeouts.shutdownNetwork, shutdownShort: NonNegativeDuration = DefaultProcessingTimeouts.shutdownShort, closing: NonNegativeDuration = DefaultProcessingTimeouts.closing, inspection: NonNegativeDuration = DefaultProcessingTimeouts.inspection, storageMaxRetryInterval: NonNegativeDuration = DefaultProcessingTimeouts.maxRetryInterval, verifyActive: NonNegativeDuration = DefaultProcessingTimeouts.verifyActive, activeInit: NonNegativeDuration = DefaultProcessingTimeouts.activeInit, slowFutureWarn: NonNegativeDuration = DefaultProcessingTimeouts.slowFutureWarn, activeInitRetryDelay: NonNegativeDuration = DefaultProcessingTimeouts.activeInitRetryDelay, sequencerInfo: NonNegativeDuration = DefaultProcessingTimeouts.sequencerInfo, topologyDispatching: NonNegativeDuration = DefaultProcessingTimeouts.topologyDispatching)
- unbounded
timeout on how long "unbounded" operations can run. should be infinite in theory.
- io
timeout for disk based operations
- default
default finite processing timeout
- network
timeout for things related to networking
- shutdownProcessing
timeout used for shutdown of some processing where we'd like to keep the result (long)
- shutdownNetwork
timeout used for shutdown where we interact with some remote system
- shutdownShort
everything else shutdown releated (default)
- closing
our closing time (which should be strictly larger than any of the shutdown values)
- inspection
timeout for the storage inspection commands (can run a long long time)
- storageMaxRetryInterval
max retry interval for storage
- verifyActive
how long should we wait for the domain to tell us whether we are active or not
- activeInit
how long a passive replica should wait for the initialization by the active replica
- slowFutureWarn
when using future supervision, when should we start to warn about a slow future
- activeInitRetryDelay
delay between attempts while waiting for initialization of the active replica
- sequencerInfo
how long are we going to try to get the sequencer connection information. setting this high means that connect calls will take quite a while if one of the sequencers is offline.
- topologyDispatching
how long we wait for the topology to retry the dispatching of a message
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val activeInit: NonNegativeDuration
- val activeInitRetryDelay: NonNegativeDuration
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- val closing: NonNegativeDuration
- val default: NonNegativeDuration
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- val inspection: NonNegativeDuration
- val io: NonNegativeDuration
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val network: NonNegativeDuration
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val sequencerInfo: NonNegativeDuration
- val shutdownNetwork: NonNegativeDuration
- val shutdownProcessing: NonNegativeDuration
- val shutdownShort: NonNegativeDuration
- val slowFutureWarn: NonNegativeDuration
- val storageMaxRetryInterval: NonNegativeDuration
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val topologyDispatching: NonNegativeDuration
- val unbounded: NonNegativeDuration
- val verifyActive: NonNegativeDuration
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])