eth1_chain_reader

Documentation

Index

• type ChainReaderWriterEth1
  • func NewChainReaderEth1(cfg *chain.Config, executionModule execution.ExecutionClient, ...) ChainReaderWriterEth1
  • func (c ChainReaderWriterEth1) AssembleBlock(baseHash libcommon.Hash, attributes *engine_types.PayloadAttributes) (id uint64, err error)
  • func (c ChainReaderWriterEth1) Config() *chain.Config
  • func (c ChainReaderWriterEth1) CurrentHeader(ctx context.Context) *types.Header
  • func (c ChainReaderWriterEth1) FrozenBlocks(ctx context.Context) (uint64, bool)
  • func (c ChainReaderWriterEth1) GetAssembledBlock(id uint64) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)
  • func (c ChainReaderWriterEth1) GetBlockByHash(ctx context.Context, hash libcommon.Hash) *types.Block
  • func (c ChainReaderWriterEth1) GetBlockByNumber(ctx context.Context, number uint64) *types.Block
  • func (c ChainReaderWriterEth1) GetBodiesByHashes(ctx context.Context, hashes []libcommon.Hash) ([]*types.RawBody, error)
  • func (c ChainReaderWriterEth1) GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error)
  • func (c ChainReaderWriterEth1) GetForkChoice(ctx context.Context) (headHash, finalizedHash, safeHash libcommon.Hash, err error)
  • func (c ChainReaderWriterEth1) GetHeader(ctx context.Context, hash libcommon.Hash, number uint64) *types.Header
  • func (c ChainReaderWriterEth1) GetHeaderByHash(ctx context.Context, hash libcommon.Hash) *types.Header
  • func (c ChainReaderWriterEth1) GetHeaderByNumber(ctx context.Context, number uint64) *types.Header
  • func (c ChainReaderWriterEth1) GetTd(ctx context.Context, hash libcommon.Hash, number uint64) *big.Int
  • func (c ChainReaderWriterEth1) HasBlock(ctx context.Context, hash libcommon.Hash) (bool, error)
  • func (c ChainReaderWriterEth1) HeaderNumber(ctx context.Context, hash libcommon.Hash) (*uint64, error)
  • func (c ChainReaderWriterEth1) InsertBlockAndWait(ctx context.Context, block *types.Block) error
  • func (c ChainReaderWriterEth1) InsertBlocks(ctx context.Context, blocks []*types.Block) error
  • func (c ChainReaderWriterEth1) InsertBlocksAndWait(ctx context.Context, blocks []*types.Block) error
  • func (c ChainReaderWriterEth1) IsCanonicalHash(ctx context.Context, hash libcommon.Hash) (bool, error)
  • func (c ChainReaderWriterEth1) Ready(ctx context.Context) (bool, error)
  • func (c ChainReaderWriterEth1) UpdateForkChoice(ctx context.Context, headHash, safeHash, finalizeHash libcommon.Hash) (execution.ExecutionStatus, *string, libcommon.Hash, error)
  • func (c ChainReaderWriterEth1) ValidateChain(ctx context.Context, hash libcommon.Hash, number uint64) (execution.ExecutionStatus, *string, libcommon.Hash, error)

Types

type ChainReaderWriterEth1

type ChainReaderWriterEth1 struct {
	// contains filtered or unexported fields
}

func NewChainReaderEth1

func NewChainReaderEth1(cfg *chain.Config, executionModule execution.ExecutionClient, fcuTimeoutMillis uint64) ChainReaderWriterEth1

func (ChainReaderWriterEth1) AssembleBlock

func (c ChainReaderWriterEth1) AssembleBlock(baseHash libcommon.Hash, attributes *engine_types.PayloadAttributes) (id uint64, err error)

func (ChainReaderWriterEth1) Config

func (c ChainReaderWriterEth1) Config() *chain.Config

func (ChainReaderWriterEth1) CurrentHeader

func (c ChainReaderWriterEth1) CurrentHeader(ctx context.Context) *types.Header

func (ChainReaderWriterEth1) FrozenBlocks

func (c ChainReaderWriterEth1) FrozenBlocks(ctx context.Context) (uint64, bool)

func (ChainReaderWriterEth1) GetAssembledBlock

func (c ChainReaderWriterEth1) GetAssembledBlock(id uint64) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)

func (ChainReaderWriterEth1) GetBlockByHash

func (c ChainReaderWriterEth1) GetBlockByHash(ctx context.Context, hash libcommon.Hash) *types.Block

func (ChainReaderWriterEth1) GetBlockByNumber

func (c ChainReaderWriterEth1) GetBlockByNumber(ctx context.Context, number uint64) *types.Block

func (ChainReaderWriterEth1) GetBodiesByHashes

func (c ChainReaderWriterEth1) GetBodiesByHashes(ctx context.Context, hashes []libcommon.Hash) ([]*types.RawBody, error)

func (ChainReaderWriterEth1) GetBodiesByRange

func (c ChainReaderWriterEth1) GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error)

func (ChainReaderWriterEth1) GetForkChoice

func (c ChainReaderWriterEth1) GetForkChoice(ctx context.Context) (headHash, finalizedHash, safeHash libcommon.Hash, err error)

func (ChainReaderWriterEth1) GetHeader

func (c ChainReaderWriterEth1) GetHeader(ctx context.Context, hash libcommon.Hash, number uint64) *types.Header

func (ChainReaderWriterEth1) GetHeaderByHash

func (c ChainReaderWriterEth1) GetHeaderByHash(ctx context.Context, hash libcommon.Hash) *types.Header

func (ChainReaderWriterEth1) GetHeaderByNumber

func (c ChainReaderWriterEth1) GetHeaderByNumber(ctx context.Context, number uint64) *types.Header

func (ChainReaderWriterEth1) GetTd

func (c ChainReaderWriterEth1) GetTd(ctx context.Context, hash libcommon.Hash, number uint64) *big.Int

func (ChainReaderWriterEth1) HasBlock

func (c ChainReaderWriterEth1) HasBlock(ctx context.Context, hash libcommon.Hash) (bool, error)

func (ChainReaderWriterEth1) HeaderNumber

func (c ChainReaderWriterEth1) HeaderNumber(ctx context.Context, hash libcommon.Hash) (*uint64, error)

func (ChainReaderWriterEth1) InsertBlockAndWait

func (c ChainReaderWriterEth1) InsertBlockAndWait(ctx context.Context, block *types.Block) error

func (ChainReaderWriterEth1) InsertBlocks

func (c ChainReaderWriterEth1) InsertBlocks(ctx context.Context, blocks []*types.Block) error

func (ChainReaderWriterEth1) InsertBlocksAndWait

func (c ChainReaderWriterEth1) InsertBlocksAndWait(ctx context.Context, blocks []*types.Block) error

func (ChainReaderWriterEth1) IsCanonicalHash

func (c ChainReaderWriterEth1) IsCanonicalHash(ctx context.Context, hash libcommon.Hash) (bool, error)

func (ChainReaderWriterEth1) Ready

func (c ChainReaderWriterEth1) Ready(ctx context.Context) (bool, error)

func (ChainReaderWriterEth1) UpdateForkChoice

func (c ChainReaderWriterEth1) UpdateForkChoice(ctx context.Context, headHash, safeHash, finalizeHash libcommon.Hash) (execution.ExecutionStatus, *string, libcommon.Hash, error)

func (ChainReaderWriterEth1) ValidateChain

func (c ChainReaderWriterEth1) ValidateChain(ctx context.Context, hash libcommon.Hash, number uint64) (execution.ExecutionStatus, *string, libcommon.Hash, error)