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, topologyChangeWarnDelay: NonNegativeDuration = DefaultProcessingTimeouts.topologyChangeWarnDelay, sequencedEventProcessingBound: NonNegativeDuration = DefaultProcessingTimeouts.sequencedEventProcessingBound, dynamicStateConsistencyTimeout: NonNegativeDuration = NonNegativeDuration.ofSeconds(60)) extends UniformCantonConfigValidation with 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 synchronizer 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.
- topologyChangeWarnDelay
maximum delay between the timestamp of the topology snapshot used during submission and the sequencing timestamp, after which we log inconsistency errors as warnings
- sequencedEventProcessingBound
Maximum time we allow for locally processing a sequenced event. If local processing takes longer, the node will emit an error or crash.
- dynamicStateConsistencyTimeout
Timeout for dynamic state consistency checks. When we apply some state changes, we sometimes need to wait until they are applied to the entire node.
- Alphabetic
- By Inheritance
- ProcessingTimeout
- Serializable
- Product
- Equals
- UniformCantonConfigValidation
- CustomCantonConfigValidation
- CantonConfigValidation
- 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, topologyChangeWarnDelay: NonNegativeDuration = DefaultProcessingTimeouts.topologyChangeWarnDelay, sequencedEventProcessingBound: NonNegativeDuration = DefaultProcessingTimeouts.sequencedEventProcessingBound, dynamicStateConsistencyTimeout: NonNegativeDuration = NonNegativeDuration.ofSeconds(60))
- 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 synchronizer 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.
- topologyChangeWarnDelay
maximum delay between the timestamp of the topology snapshot used during submission and the sequencing timestamp, after which we log inconsistency errors as warnings
- sequencedEventProcessingBound
Maximum time we allow for locally processing a sequenced event. If local processing takes longer, the node will emit an error or crash.
- dynamicStateConsistencyTimeout
Timeout for dynamic state consistency checks. When we apply some state changes, we sometimes need to wait until they are applied to the entire node.
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]) @IntrinsicCandidate() @native()
- val closing: NonNegativeDuration
- val default: NonNegativeDuration
- final def doValidate(edition: CantonEdition): Seq[CantonConfigValidationError]
Returns all validation errors that are specific to this Canton configuration class.
Returns all validation errors that are specific to this Canton configuration class. Successful validation should return an empty sequence.
Validation errors of subconfigurations should not be reported by this method, but via the type class derivation.
- Attributes
- protected
- Definition Classes
- UniformCantonConfigValidation → CustomCantonConfigValidation
- val dynamicStateConsistencyTimeout: NonNegativeDuration
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- 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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val sequencedEventProcessingBound: NonNegativeDuration
- 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 topologyChangeWarnDelay: NonNegativeDuration
- val unbounded: NonNegativeDuration
- final def validate[T >: ProcessingTimeout.this.type](edition: CantonEdition)(implicit validator: CantonConfigValidator[T]): Either[NonEmpty[Seq[CantonConfigValidationError]], Unit]
- Definition Classes
- CantonConfigValidation
- 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])