case class BesuTxPoolNonceManager(conf: EthereumLedgerNodeConfig[AlreadyDeployed], loggerFactory: NamedLoggerFactory) extends NamedLogging with NonceManager with Product with Serializable
Transaction manager for Besu networks. Relies on the Besu API method txpool_besuPendingTransactions.
The most important method is hydrate: it fetches the complete transaction pool and the number of accepted
transactions so far. Based on that, it computes the next nonces which should be used.
Whenever an Ethereum transaction fails for any reason, we hydrate the state of the transaction manager before
returning a result to getNonce.
- Annotations
- @SuppressWarnings()
- Alphabetic
- By Inheritance
- BesuTxPoolNonceManager
- NonceManager
- Serializable
- Product
- Equals
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new BesuTxPoolNonceManager(conf: EthereumLedgerNodeConfig[AlreadyDeployed], loggerFactory: NamedLoggerFactory)
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- val conf: EthereumLedgerNodeConfig[AlreadyDeployed]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- lazy val ethereumAccount: Credentials
The Ethereum account that nonces are being managed for.
The Ethereum account that nonces are being managed for.
- Attributes
- protected
- Definition Classes
- BesuTxPoolNonceManager → NonceManager
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getNonce: BigInteger
Returns the next nonce that should be used for an Ethereum transaction by
ethereumAccount.Returns the next nonce that should be used for an Ethereum transaction by
ethereumAccount. The implementation is thread-safe, i.e., it returns the correct next nonce even when called concurrently. The nonces returned are such that they are the next nonces missing forethereumAccount. For example, if the current nonce is 5, then the next two calls return 5 and 6. If the implementation inspects the transaction pool, it also fills out potential 'gaps' in the transaction pool. For example, if the current nonce is 2, but the transaction pool already contains nonces with values 3 and 5, then the next calls return 2, 4, 6, 7 etc.- Definition Classes
- BesuTxPoolNonceManager → NonceManager
- def hydrateBeforeNext(): Unit
Signal that the cached nonce should be refreshed before the next nonce is returned.
Signal that the cached nonce should be refreshed before the next nonce is returned.
- Definition Classes
- BesuTxPoolNonceManager → NonceManager
- val hydrateBeforeNextInternal: AtomicBoolean
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- BesuTxPoolNonceManager → NamedLogging
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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])