source

package

Go to main page

Versions in this module

v1

v1.9.4

Oct 8, 2024

Changes in this version

type ChainProcessor

+ func (s *ChainProcessor) Close()

+ type ChainsDBClientForLogProcessor interface

+ AddLog func(chain types.ChainID, logHash common.Hash, parentBlock eth.BlockID, ...) error

+ SealBlock func(chain types.ChainID, block eth.BlockRef) error

type DatabaseRewinder

+ LatestBlockNum func(chain types.ChainID) (num uint64, ok bool)

type HeadProcessorFn

+ func OnNewHead(id types.ChainID, apply func(id types.ChainID, v heads.HeadPointer) error) HeadProcessorFn

+ type LogProcessor interface

+ ProcessLogs func(ctx context.Context, block eth.BlockRef, receipts gethtypes.Receipts) error

+ type Source interface

+ FetchReceipts func(ctx context.Context, blockHash common.Hash) (eth.BlockInfo, gethtypes.Receipts, error)

+ L1BlockRefByNumber func(ctx context.Context, number uint64) (eth.L1BlockRef, error)

v1.9.3

Sep 25, 2024

Changes in this version

type LogStorage

+ SealBlock func(chain types.ChainID, parentHash common.Hash, block eth.BlockID, ...) error

v1.9.2

Sep 5, 2024

v1.9.1

Aug 28, 2024

Changes in this version

+ type EventDecoder interface

+ DecodeExecutingMessageLog func(log *ethTypes.Log) (backendTypes.ExecutingMessage, error)

v1.9.0

Aug 7, 2024

v1.8.0

Jul 17, 2024

Changes in this version

+ type BlockByNumberSource interface

+ L1BlockRefByNumber func(ctx context.Context, number uint64) (eth.L1BlockRef, error)

+ type BlockProcessor interface

+ ProcessBlock func(ctx context.Context, block eth.L1BlockRef) error

+ type BlockProcessorFn func(ctx context.Context, block eth.L1BlockRef) error

+ func (fn BlockProcessorFn) ProcessBlock(ctx context.Context, block eth.L1BlockRef) error

+ type ChainMonitor struct

+ func NewChainMonitor(ctx context.Context, logger log.Logger, m Metrics, chainID types.ChainID, ...) (*ChainMonitor, error)

+ func (c *ChainMonitor) Start() error

+ func (c *ChainMonitor) Stop() error

+ type ChainProcessor struct

+ func NewChainProcessor(log log.Logger, client BlockByNumberSource, chain types.ChainID, ...) *ChainProcessor

+ func (s *ChainProcessor) OnNewHead(ctx context.Context, head eth.L1BlockRef)

+ type DatabaseRewinder interface

+ Rewind func(chain types.ChainID, headBlockNum uint64) error

+ type HeadChangeCallback interface

+ OnNewFinalizedHead func(ctx context.Context, block eth.L1BlockRef)

+ OnNewSafeHead func(ctx context.Context, block eth.L1BlockRef)

+ OnNewUnsafeHead func(ctx context.Context, block eth.L1BlockRef)

+ type HeadMonitor struct

+ func NewHeadMonitor(logger log.Logger, epochPollInterval time.Duration, rpc HeadMonitorClient, ...) *HeadMonitor

+ func (h *HeadMonitor) Start() error

+ func (h *HeadMonitor) Stop() error

+ type HeadMonitorClient interface

+ type HeadProcessor interface

+ OnNewHead func(ctx context.Context, head eth.L1BlockRef)

+ type HeadProcessorFn func(ctx context.Context, head eth.L1BlockRef)

+ func (f HeadProcessorFn) OnNewHead(ctx context.Context, head eth.L1BlockRef)

+ type LogSource interface

+ FetchReceipts func(ctx context.Context, blockHash common.Hash) (eth.BlockInfo, types.Receipts, error)

+ type LogStorage interface

+ AddLog func(chain supTypes.ChainID, logHash types.TruncatedHash, block eth.BlockID, ...) error

+ type Metrics interface

+ type ReceiptProcessor interface

+ ProcessLogs func(ctx context.Context, block eth.L1BlockRef, rcpts types.Receipts) error

+ type ReceiptProcessorFn func(ctx context.Context, block eth.L1BlockRef, rcpts types.Receipts) error

+ func (r ReceiptProcessorFn) ProcessLogs(ctx context.Context, block eth.L1BlockRef, rcpts types.Receipts) error

+ type Storage interface

+ LatestBlockNum func(chainID types.ChainID) uint64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL