Versions in this module Expand all Collapse all v1 v1.0.2 Jan 15, 2024 v1.0.1 Jan 15, 2024 Changes in this version + const DbWriteThresholdBlocks + const DbWriteThresholdBytes + const DefaultFetchBlockRange + const DefaultPollInterval + const LogProgressInterval + var L1MessageQueueABI = L1MessageQueueMetaData.ABI + var L1MessageQueueMetaData = &bind.MetaData + type BridgeClient struct + type EthClient interface + BlockByHash func(ctx context.Context, hash common.Hash) (*types.Block, error) + BlockNumber func(ctx context.Context) (uint64, error) + ChainID func(ctx context.Context) (*big.Int, error) + FilterLogs func(ctx context.Context, q ethereum.FilterQuery) ([]types.Log, error) + HeaderByNumber func(ctx context.Context, number *big.Int) (*types.Header, error) + SubscribeFilterLogs func(ctx context.Context, query ethereum.FilterQuery, ch chan<- types.Log) (ethereum.Subscription, error) + TransactionByHash func(ctx context.Context, txHash common.Hash) (tx *types.Transaction, isPending bool, err error) + type L1MessageQueueFilterer struct + func NewL1MessageQueueFilterer(address common.Address, filterer bind.ContractFilterer) (*L1MessageQueueFilterer, error) + func (_L1MessageQueue *L1MessageQueueFilterer) FilterQueueTransaction(opts *bind.FilterOpts, sender []common.Address, target []common.Address) (*L1MessageQueueQueueTransactionIterator, error) + type L1MessageQueueQueueTransaction struct + Data []byte + GasLimit *big.Int + QueueIndex uint64 + Raw types.Log + Sender common.Address + Target common.Address + Value *big.Int + type L1MessageQueueQueueTransactionIterator struct + Event *L1MessageQueueQueueTransaction + func (it *L1MessageQueueQueueTransactionIterator) Close() error + func (it *L1MessageQueueQueueTransactionIterator) Error() error + func (it *L1MessageQueueQueueTransactionIterator) Next() bool + type SyncService struct + func NewSyncService(ctx context.Context, genesisConfig *params.ChainConfig, ...) (*SyncService, error) + func (s *SyncService) Start() + func (s *SyncService) Stop() + func (s *SyncService) SubscribeNewL1MsgsEvent(ch chan<- core.NewL1MsgsEvent) event.Subscription