eth1

Documentation

Index

• func UpdateForkChoiceArrivalDelay(blockTime uint64)
• func UpdateForkChoiceDepth(depth uint64)
• func UpdateForkChoiceDuration(start time.Time)
• type EthereumExecutionModule
  • func NewEthereumExecutionModule(blockReader services.FullBlockReader, db kv.RwDB, ...) *EthereumExecutionModule
  • func (e *EthereumExecutionModule) AssembleBlock(ctx context.Context, req *execution.AssembleBlockRequest) (*execution.AssembleBlockResponse, error)
  • func (e *EthereumExecutionModule) CurrentHeader(ctx context.Context, _ *emptypb.Empty) (*execution.GetHeaderResponse, error)
  • func (e *EthereumExecutionModule) FrozenBlocks(ctx context.Context, _ *emptypb.Empty) (*execution.FrozenBlocksResponse, error)
  • func (e *EthereumExecutionModule) GetAssembledBlock(ctx context.Context, req *execution.GetAssembledBlockRequest) (*execution.GetAssembledBlockResponse, error)
  • func (e *EthereumExecutionModule) GetBodiesByHashes(ctx context.Context, req *execution.GetBodiesByHashesRequest) (*execution.GetBodiesBatchResponse, error)
  • func (e *EthereumExecutionModule) GetBodiesByRange(ctx context.Context, req *execution.GetBodiesByRangeRequest) (*execution.GetBodiesBatchResponse, error)
  • func (e *EthereumExecutionModule) GetBody(ctx context.Context, req *execution.GetSegmentRequest) (*execution.GetBodyResponse, error)
  • func (e *EthereumExecutionModule) GetForkChoice(ctx context.Context, _ *emptypb.Empty) (*execution.ForkChoice, error)
  • func (e *EthereumExecutionModule) GetHeader(ctx context.Context, req *execution.GetSegmentRequest) (*execution.GetHeaderResponse, error)
  • func (e *EthereumExecutionModule) GetHeaderHashNumber(ctx context.Context, req *types2.H256) (*execution.GetHeaderHashNumberResponse, error)
  • func (e *EthereumExecutionModule) GetTD(ctx context.Context, req *execution.GetSegmentRequest) (*execution.GetTDResponse, error)
  • func (e *EthereumExecutionModule) HasBlock(ctx context.Context, in *execution.GetSegmentRequest) (*execution.HasBlockResponse, error)
  • func (e *EthereumExecutionModule) InsertBlocks(ctx context.Context, req *execution.InsertBlocksRequest) (*execution.InsertionResult, error)
  • func (e *EthereumExecutionModule) IsCanonicalHash(ctx context.Context, req *types2.H256) (*execution.IsCanonicalResponse, error)
  • func (e *EthereumExecutionModule) Ready(ctx context.Context, _ *emptypb.Empty) (*execution.ReadyResponse, error)
  • func (e *EthereumExecutionModule) Start(ctx context.Context)
  • func (e *EthereumExecutionModule) UpdateForkChoice(ctx context.Context, req *execution.ForkChoice) (*execution.ForkChoiceReceipt, error)
  • func (e *EthereumExecutionModule) ValidateChain(ctx context.Context, req *execution.ValidationRequest) (*execution.ValidationReceipt, error)

Functions

func UpdateForkChoiceArrivalDelay

func UpdateForkChoiceArrivalDelay(blockTime uint64)

func UpdateForkChoiceDepth

func UpdateForkChoiceDepth(depth uint64)

func UpdateForkChoiceDuration

func UpdateForkChoiceDuration(start time.Time)

Types

type EthereumExecutionModule

type EthereumExecutionModule struct {
	execution.UnimplementedExecutionServer
	// contains filtered or unexported fields
}

EthereumExecutionModule describes ethereum execution logic and indexing.

func NewEthereumExecutionModule

func NewEthereumExecutionModule(blockReader services.FullBlockReader, db kv.RwDB,
	executionPipeline *stagedsync.Sync, forkValidator *engine_helpers.ForkValidator,
	config *chain.Config, builderFunc builder.BlockBuilderFunc,
	hook *stages.Hook, accumulator *shards.Accumulator,
	stateChangeConsumer shards.StateChangeConsumer,
	logger log.Logger, engine consensus.Engine,
	syncCfg ethconfig.Sync,
	ctx context.Context,
) *EthereumExecutionModule

func (*EthereumExecutionModule) AssembleBlock

func (e *EthereumExecutionModule) AssembleBlock(ctx context.Context, req *execution.AssembleBlockRequest) (*execution.AssembleBlockResponse, error)

Missing: NewPayload, AssembleBlock

func (*EthereumExecutionModule) CurrentHeader

func (e *EthereumExecutionModule) CurrentHeader(ctx context.Context, _ *emptypb.Empty) (*execution.GetHeaderResponse, error)

func (*EthereumExecutionModule) FrozenBlocks

func (e *EthereumExecutionModule) FrozenBlocks(ctx context.Context, _ *emptypb.Empty) (*execution.FrozenBlocksResponse, error)

func (*EthereumExecutionModule) GetAssembledBlock

func (e *EthereumExecutionModule) GetAssembledBlock(ctx context.Context, req *execution.GetAssembledBlockRequest) (*execution.GetAssembledBlockResponse, error)

func (*EthereumExecutionModule) GetBodiesByHashes

func (e *EthereumExecutionModule) GetBodiesByHashes(ctx context.Context, req *execution.GetBodiesByHashesRequest) (*execution.GetBodiesBatchResponse, error)

func (*EthereumExecutionModule) GetBodiesByRange

func (e *EthereumExecutionModule) GetBodiesByRange(ctx context.Context, req *execution.GetBodiesByRangeRequest) (*execution.GetBodiesBatchResponse, error)

func (*EthereumExecutionModule) GetBody

func (e *EthereumExecutionModule) GetBody(ctx context.Context, req *execution.GetSegmentRequest) (*execution.GetBodyResponse, error)

func (*EthereumExecutionModule) GetForkChoice

func (e *EthereumExecutionModule) GetForkChoice(ctx context.Context, _ *emptypb.Empty) (*execution.ForkChoice, error)

func (*EthereumExecutionModule) GetHeader

func (e *EthereumExecutionModule) GetHeader(ctx context.Context, req *execution.GetSegmentRequest) (*execution.GetHeaderResponse, error)

func (*EthereumExecutionModule) GetHeaderHashNumber

func (e *EthereumExecutionModule) GetHeaderHashNumber(ctx context.Context, req *types2.H256) (*execution.GetHeaderHashNumberResponse, error)

func (*EthereumExecutionModule) GetTD

func (e *EthereumExecutionModule) GetTD(ctx context.Context, req *execution.GetSegmentRequest) (*execution.GetTDResponse, error)

func (*EthereumExecutionModule) HasBlock

func (e *EthereumExecutionModule) HasBlock(ctx context.Context, in *execution.GetSegmentRequest) (*execution.HasBlockResponse, error)

func (*EthereumExecutionModule) InsertBlocks

func (e *EthereumExecutionModule) InsertBlocks(ctx context.Context, req *execution.InsertBlocksRequest) (*execution.InsertionResult, error)

func (*EthereumExecutionModule) IsCanonicalHash

func (e *EthereumExecutionModule) IsCanonicalHash(ctx context.Context, req *types2.H256) (*execution.IsCanonicalResponse, error)

func (*EthereumExecutionModule) Ready

func (e *EthereumExecutionModule) Ready(ctx context.Context, _ *emptypb.Empty) (*execution.ReadyResponse, error)

func (*EthereumExecutionModule) Start

func (e *EthereumExecutionModule) Start(ctx context.Context)

func (*EthereumExecutionModule) UpdateForkChoice

func (e *EthereumExecutionModule) UpdateForkChoice(ctx context.Context, req *execution.ForkChoice) (*execution.ForkChoiceReceipt, error)

func (*EthereumExecutionModule) ValidateChain

func (e *EthereumExecutionModule) ValidateChain(ctx context.Context, req *execution.ValidationRequest) (*execution.ValidationReceipt, error)