c
com.digitalasset.canton.domain.sequencing.sequencer.ethereum
EthereumLedgerConnection
Companion object EthereumLedgerConnection
class EthereumLedgerConnection extends NamedLogging with AutoCloseable with HasDegradationState[Warn]
Wrapper class that calls the generated methods of the generated web3j code. This class supports Sequencer.sol revisions 1.0.0 and 1.0.1.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- EthereumLedgerConnection
- HasDegradationState
- AutoCloseable
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new EthereumLedgerConnection(conf: EthereumLedgerNodeConfig[AlreadyDeployed], domainManagerId: DomainTopologyManagerId, clock: Clock, loggingConfig: LoggingConfig, loggerFactory: NamedLoggerFactory, skipInitTransactions: Boolean = false)(implicit executionContext: ExecutionContext)
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 authorizeEthAccount(toAuthorize: String)(implicit traceContext: TraceContext): Future[TransactionHash]
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def close(): Unit
- Definition Classes
- EthereumLedgerConnection → AutoCloseable
- val conf: EthereumLedgerNodeConfig[AlreadyDeployed]
- def degradationOccurred(error: Warn): Unit
Track that the given error has occurred for the specified key
Track that the given error has occurred for the specified key
- Definition Classes
- HasDegradationState
- val degradationState: AtomicReference[Option[Warn]]
- Attributes
- protected
- Definition Classes
- HasDegradationState
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- val gasProvider: StaticGasProvider
- Attributes
- protected
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getDegradationState: Option[Warn]
- Definition Classes
- HasDegradationState
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def isDegraded: Boolean
- Definition Classes
- HasDegradationState
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- EthereumLedgerConnection → 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
- val nonceManager: NonceManager
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def readSequencerBlocksFlowable(configuredOrPersistedFirstBlock: BlockHeight): Flowable[UnparsedBlockContents]
Read sequencer related events block by block from the Ethereum ledger.
Read sequencer related events block by block from the Ethereum ledger. The events are provided as instances of the raw web3j generated java classes. These will likely need to be converted own events however this is left to the caller as it can result in deserialization errors.
- Annotations
- @SuppressWarnings()
- val receiptProcessor: LessBrokenQueuingTransactionReceiptProcessor
- Attributes
- protected
- def registerMember(member: String)(implicit traceContext: TraceContext): Future[TransactionHash]
- def resolveDegradationIfExists(message: (Warn) => String): Unit
- Definition Classes
- HasDegradationState
- def sendAsync(submissionRequest: SubmissionRequest, protocolVersion: ProtocolVersion)(implicit traceContext: TraceContext): Future[TransactionHash]
- def sequencer: Sequencer
- Annotations
- @VisibleForTesting()
- def status: Future[SequencerHealthStatus]
- def submitAsync(description: String)(call: RemoteFunctionCall[TransactionReceipt])(implicit traceContext: TraceContext): Future[TransactionHash]
Asynchronously submit a transaction to the configured ethereum node.
Asynchronously submit a transaction to the configured ethereum node.
- description
loggable description that will be logged with the transaction hash which can be collated to the later logging from the transaction result callback
- Attributes
- protected
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- 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])
- val web3j: Web3j