Documentation ¶
Overview ¶
Package execution_client is a generated GoMock package.
Index ¶
- Constants
- type ExecutionClientDirect
- func (cc *ExecutionClientDirect) CurrentHeader(ctx context.Context) (*types.Header, error)
- func (cc *ExecutionClientDirect) ForkChoiceUpdate(ctx context.Context, finalized libcommon.Hash, head libcommon.Hash, ...) ([]byte, error)
- func (cc *ExecutionClientDirect) FrozenBlocks(ctx context.Context) uint64
- func (cc *ExecutionClientDirect) GetAssembledBlock(_ context.Context, idBytes []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)
- func (cc *ExecutionClientDirect) GetBodiesByHashes(ctx context.Context, hashes []libcommon.Hash) ([]*types.RawBody, error)
- func (cc *ExecutionClientDirect) GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error)
- func (cc *ExecutionClientDirect) HasBlock(ctx context.Context, hash libcommon.Hash) (bool, error)
- func (cc *ExecutionClientDirect) HasGapInSnapshots(ctx context.Context) bool
- func (cc *ExecutionClientDirect) InsertBlock(ctx context.Context, blk *types.Block) error
- func (cc *ExecutionClientDirect) InsertBlocks(ctx context.Context, blocks []*types.Block, wait bool) error
- func (cc *ExecutionClientDirect) IsCanonicalHash(ctx context.Context, hash libcommon.Hash) (bool, error)
- func (cc *ExecutionClientDirect) NewPayload(ctx context.Context, payload *cltypes.Eth1Block, ...) (PayloadStatus, error)
- func (cc *ExecutionClientDirect) Ready(ctx context.Context) (bool, error)
- func (cc *ExecutionClientDirect) SupportInsertion() bool
- type ExecutionClientRpc
- func (cc *ExecutionClientRpc) CurrentHeader(ctx context.Context) (*types.Header, error)
- func (cc *ExecutionClientRpc) ForkChoiceUpdate(ctx context.Context, finalized libcommon.Hash, head libcommon.Hash, ...) ([]byte, error)
- func (cc *ExecutionClientRpc) FrozenBlocks(ctx context.Context) uint64
- func (cc *ExecutionClientRpc) GetAssembledBlock(ctx context.Context, id []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)
- func (cc *ExecutionClientRpc) GetBodiesByHashes(ctx context.Context, hashes []libcommon.Hash) ([]*types.RawBody, error)
- func (cc *ExecutionClientRpc) GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error)
- func (cc *ExecutionClientRpc) HasBlock(ctx context.Context, hash libcommon.Hash) (bool, error)
- func (cc *ExecutionClientRpc) HasGapInSnapshots(ctx context.Context) bool
- func (cc *ExecutionClientRpc) InsertBlock(ctx context.Context, block *types.Block) error
- func (cc *ExecutionClientRpc) InsertBlocks(ctx context.Context, blocks []*types.Block, wait bool) error
- func (cc *ExecutionClientRpc) IsCanonicalHash(ctx context.Context, hash libcommon.Hash) (bool, error)
- func (cc *ExecutionClientRpc) NewPayload(ctx context.Context, payload *cltypes.Eth1Block, ...) (PayloadStatus, error)
- func (cc *ExecutionClientRpc) Ready(ctx context.Context) (bool, error)
- func (cc *ExecutionClientRpc) SupportInsertion() bool
- type ExecutionEngine
- type MockExecutionEngine
- func (m *MockExecutionEngine) CurrentHeader(ctx context.Context) (*types.Header, error)
- func (m *MockExecutionEngine) EXPECT() *MockExecutionEngineMockRecorder
- func (m *MockExecutionEngine) ForkChoiceUpdate(ctx context.Context, finalized, head common.Hash, ...) ([]byte, error)
- func (m *MockExecutionEngine) FrozenBlocks(ctx context.Context) uint64
- func (m *MockExecutionEngine) GetAssembledBlock(ctx context.Context, id []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)
- func (m *MockExecutionEngine) GetBodiesByHashes(ctx context.Context, hashes []common.Hash) ([]*types.RawBody, error)
- func (m *MockExecutionEngine) GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error)
- func (m *MockExecutionEngine) HasBlock(ctx context.Context, hash common.Hash) (bool, error)
- func (m *MockExecutionEngine) HasGapInSnapshots(ctx context.Context) bool
- func (m *MockExecutionEngine) InsertBlock(ctx context.Context, block *types.Block) error
- func (m *MockExecutionEngine) InsertBlocks(ctx context.Context, blocks []*types.Block, wait bool) error
- func (m *MockExecutionEngine) IsCanonicalHash(ctx context.Context, hash common.Hash) (bool, error)
- func (m *MockExecutionEngine) NewPayload(ctx context.Context, payload *cltypes.Eth1Block, beaconParentRoot *common.Hash, ...) (PayloadStatus, error)
- func (m *MockExecutionEngine) Ready(ctx context.Context) (bool, error)
- func (m *MockExecutionEngine) SupportInsertion() bool
- type MockExecutionEngineCurrentHeaderCall
- func (c *MockExecutionEngineCurrentHeaderCall) Do(f func(context.Context) (*types.Header, error)) *MockExecutionEngineCurrentHeaderCall
- func (c *MockExecutionEngineCurrentHeaderCall) DoAndReturn(f func(context.Context) (*types.Header, error)) *MockExecutionEngineCurrentHeaderCall
- func (c *MockExecutionEngineCurrentHeaderCall) Return(arg0 *types.Header, arg1 error) *MockExecutionEngineCurrentHeaderCall
- type MockExecutionEngineForkChoiceUpdateCall
- func (c *MockExecutionEngineForkChoiceUpdateCall) Do(...) *MockExecutionEngineForkChoiceUpdateCall
- func (c *MockExecutionEngineForkChoiceUpdateCall) DoAndReturn(...) *MockExecutionEngineForkChoiceUpdateCall
- func (c *MockExecutionEngineForkChoiceUpdateCall) Return(arg0 []byte, arg1 error) *MockExecutionEngineForkChoiceUpdateCall
- type MockExecutionEngineFrozenBlocksCall
- func (c *MockExecutionEngineFrozenBlocksCall) Do(f func(context.Context) uint64) *MockExecutionEngineFrozenBlocksCall
- func (c *MockExecutionEngineFrozenBlocksCall) DoAndReturn(f func(context.Context) uint64) *MockExecutionEngineFrozenBlocksCall
- func (c *MockExecutionEngineFrozenBlocksCall) Return(arg0 uint64) *MockExecutionEngineFrozenBlocksCall
- type MockExecutionEngineGetAssembledBlockCall
- func (c *MockExecutionEngineGetAssembledBlockCall) Do(...) *MockExecutionEngineGetAssembledBlockCall
- func (c *MockExecutionEngineGetAssembledBlockCall) DoAndReturn(...) *MockExecutionEngineGetAssembledBlockCall
- func (c *MockExecutionEngineGetAssembledBlockCall) Return(arg0 *cltypes.Eth1Block, arg1 *engine_types.BlobsBundleV1, arg2 *big.Int, ...) *MockExecutionEngineGetAssembledBlockCall
- type MockExecutionEngineGetBodiesByHashesCall
- func (c *MockExecutionEngineGetBodiesByHashesCall) Do(f func(context.Context, []common.Hash) ([]*types.RawBody, error)) *MockExecutionEngineGetBodiesByHashesCall
- func (c *MockExecutionEngineGetBodiesByHashesCall) DoAndReturn(f func(context.Context, []common.Hash) ([]*types.RawBody, error)) *MockExecutionEngineGetBodiesByHashesCall
- func (c *MockExecutionEngineGetBodiesByHashesCall) Return(arg0 []*types.RawBody, arg1 error) *MockExecutionEngineGetBodiesByHashesCall
- type MockExecutionEngineGetBodiesByRangeCall
- func (c *MockExecutionEngineGetBodiesByRangeCall) Do(f func(context.Context, uint64, uint64) ([]*types.RawBody, error)) *MockExecutionEngineGetBodiesByRangeCall
- func (c *MockExecutionEngineGetBodiesByRangeCall) DoAndReturn(f func(context.Context, uint64, uint64) ([]*types.RawBody, error)) *MockExecutionEngineGetBodiesByRangeCall
- func (c *MockExecutionEngineGetBodiesByRangeCall) Return(arg0 []*types.RawBody, arg1 error) *MockExecutionEngineGetBodiesByRangeCall
- type MockExecutionEngineHasBlockCall
- func (c *MockExecutionEngineHasBlockCall) Do(f func(context.Context, common.Hash) (bool, error)) *MockExecutionEngineHasBlockCall
- func (c *MockExecutionEngineHasBlockCall) DoAndReturn(f func(context.Context, common.Hash) (bool, error)) *MockExecutionEngineHasBlockCall
- func (c *MockExecutionEngineHasBlockCall) Return(arg0 bool, arg1 error) *MockExecutionEngineHasBlockCall
- type MockExecutionEngineHasGapInSnapshotsCall
- func (c *MockExecutionEngineHasGapInSnapshotsCall) Do(f func(context.Context) bool) *MockExecutionEngineHasGapInSnapshotsCall
- func (c *MockExecutionEngineHasGapInSnapshotsCall) DoAndReturn(f func(context.Context) bool) *MockExecutionEngineHasGapInSnapshotsCall
- func (c *MockExecutionEngineHasGapInSnapshotsCall) Return(arg0 bool) *MockExecutionEngineHasGapInSnapshotsCall
- type MockExecutionEngineInsertBlockCall
- func (c *MockExecutionEngineInsertBlockCall) Do(f func(context.Context, *types.Block) error) *MockExecutionEngineInsertBlockCall
- func (c *MockExecutionEngineInsertBlockCall) DoAndReturn(f func(context.Context, *types.Block) error) *MockExecutionEngineInsertBlockCall
- func (c *MockExecutionEngineInsertBlockCall) Return(arg0 error) *MockExecutionEngineInsertBlockCall
- type MockExecutionEngineInsertBlocksCall
- func (c *MockExecutionEngineInsertBlocksCall) Do(f func(context.Context, []*types.Block, bool) error) *MockExecutionEngineInsertBlocksCall
- func (c *MockExecutionEngineInsertBlocksCall) DoAndReturn(f func(context.Context, []*types.Block, bool) error) *MockExecutionEngineInsertBlocksCall
- func (c *MockExecutionEngineInsertBlocksCall) Return(arg0 error) *MockExecutionEngineInsertBlocksCall
- type MockExecutionEngineIsCanonicalHashCall
- func (c *MockExecutionEngineIsCanonicalHashCall) Do(f func(context.Context, common.Hash) (bool, error)) *MockExecutionEngineIsCanonicalHashCall
- func (c *MockExecutionEngineIsCanonicalHashCall) DoAndReturn(f func(context.Context, common.Hash) (bool, error)) *MockExecutionEngineIsCanonicalHashCall
- func (c *MockExecutionEngineIsCanonicalHashCall) Return(arg0 bool, arg1 error) *MockExecutionEngineIsCanonicalHashCall
- type MockExecutionEngineMockRecorder
- func (mr *MockExecutionEngineMockRecorder) CurrentHeader(ctx any) *MockExecutionEngineCurrentHeaderCall
- func (mr *MockExecutionEngineMockRecorder) ForkChoiceUpdate(ctx, finalized, head, attributes any) *MockExecutionEngineForkChoiceUpdateCall
- func (mr *MockExecutionEngineMockRecorder) FrozenBlocks(ctx any) *MockExecutionEngineFrozenBlocksCall
- func (mr *MockExecutionEngineMockRecorder) GetAssembledBlock(ctx, id any) *MockExecutionEngineGetAssembledBlockCall
- func (mr *MockExecutionEngineMockRecorder) GetBodiesByHashes(ctx, hashes any) *MockExecutionEngineGetBodiesByHashesCall
- func (mr *MockExecutionEngineMockRecorder) GetBodiesByRange(ctx, start, count any) *MockExecutionEngineGetBodiesByRangeCall
- func (mr *MockExecutionEngineMockRecorder) HasBlock(ctx, hash any) *MockExecutionEngineHasBlockCall
- func (mr *MockExecutionEngineMockRecorder) HasGapInSnapshots(ctx any) *MockExecutionEngineHasGapInSnapshotsCall
- func (mr *MockExecutionEngineMockRecorder) InsertBlock(ctx, block any) *MockExecutionEngineInsertBlockCall
- func (mr *MockExecutionEngineMockRecorder) InsertBlocks(ctx, blocks, wait any) *MockExecutionEngineInsertBlocksCall
- func (mr *MockExecutionEngineMockRecorder) IsCanonicalHash(ctx, hash any) *MockExecutionEngineIsCanonicalHashCall
- func (mr *MockExecutionEngineMockRecorder) NewPayload(ctx, payload, beaconParentRoot, versionedHashes any) *MockExecutionEngineNewPayloadCall
- func (mr *MockExecutionEngineMockRecorder) Ready(ctx any) *MockExecutionEngineReadyCall
- func (mr *MockExecutionEngineMockRecorder) SupportInsertion() *MockExecutionEngineSupportInsertionCall
- type MockExecutionEngineNewPayloadCall
- func (c *MockExecutionEngineNewPayloadCall) Do(...) *MockExecutionEngineNewPayloadCall
- func (c *MockExecutionEngineNewPayloadCall) DoAndReturn(...) *MockExecutionEngineNewPayloadCall
- func (c *MockExecutionEngineNewPayloadCall) Return(arg0 PayloadStatus, arg1 error) *MockExecutionEngineNewPayloadCall
- type MockExecutionEngineReadyCall
- func (c *MockExecutionEngineReadyCall) Do(f func(context.Context) (bool, error)) *MockExecutionEngineReadyCall
- func (c *MockExecutionEngineReadyCall) DoAndReturn(f func(context.Context) (bool, error)) *MockExecutionEngineReadyCall
- func (c *MockExecutionEngineReadyCall) Return(arg0 bool, arg1 error) *MockExecutionEngineReadyCall
- type MockExecutionEngineSupportInsertionCall
- func (c *MockExecutionEngineSupportInsertionCall) Do(f func() bool) *MockExecutionEngineSupportInsertionCall
- func (c *MockExecutionEngineSupportInsertionCall) DoAndReturn(f func() bool) *MockExecutionEngineSupportInsertionCall
- func (c *MockExecutionEngineSupportInsertionCall) Return(arg0 bool) *MockExecutionEngineSupportInsertionCall
- type PayloadStatus
Constants ¶
const ( PayloadStatusNone = iota PayloadStatusNotValidated PayloadStatusInvalidated PayloadStatusValidated )
const DefaultRPCHTTPTimeout = time.Second * 30
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecutionClientDirect ¶
type ExecutionClientDirect struct {
// contains filtered or unexported fields
}
func NewExecutionClientDirect ¶
func NewExecutionClientDirect(chainRW eth1_chain_reader.ChainReaderWriterEth1) (*ExecutionClientDirect, error)
func (*ExecutionClientDirect) CurrentHeader ¶
func (*ExecutionClientDirect) ForkChoiceUpdate ¶
func (cc *ExecutionClientDirect) ForkChoiceUpdate(ctx context.Context, finalized libcommon.Hash, head libcommon.Hash, attr *engine_types.PayloadAttributes) ([]byte, error)
func (*ExecutionClientDirect) FrozenBlocks ¶
func (cc *ExecutionClientDirect) FrozenBlocks(ctx context.Context) uint64
func (*ExecutionClientDirect) GetAssembledBlock ¶
func (cc *ExecutionClientDirect) GetAssembledBlock(_ context.Context, idBytes []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)
func (*ExecutionClientDirect) GetBodiesByHashes ¶
func (cc *ExecutionClientDirect) GetBodiesByHashes(ctx context.Context, hashes []libcommon.Hash) ([]*types.RawBody, error)
GetBodiesByHashes gets block bodies with given hashes
func (*ExecutionClientDirect) GetBodiesByRange ¶
func (cc *ExecutionClientDirect) GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error)
GetBodiesByRange gets block bodies in given block range
func (*ExecutionClientDirect) HasGapInSnapshots ¶
func (cc *ExecutionClientDirect) HasGapInSnapshots(ctx context.Context) bool
func (*ExecutionClientDirect) InsertBlock ¶
func (*ExecutionClientDirect) InsertBlocks ¶
func (*ExecutionClientDirect) IsCanonicalHash ¶
func (*ExecutionClientDirect) NewPayload ¶
func (*ExecutionClientDirect) Ready ¶
func (cc *ExecutionClientDirect) Ready(ctx context.Context) (bool, error)
func (*ExecutionClientDirect) SupportInsertion ¶
func (cc *ExecutionClientDirect) SupportInsertion() bool
type ExecutionClientRpc ¶
type ExecutionClientRpc struct {
// contains filtered or unexported fields
}
func NewExecutionClientRPC ¶
func NewExecutionClientRPC(jwtSecret []byte, addr string, port int) (*ExecutionClientRpc, error)
func (*ExecutionClientRpc) CurrentHeader ¶
func (*ExecutionClientRpc) ForkChoiceUpdate ¶
func (cc *ExecutionClientRpc) ForkChoiceUpdate(ctx context.Context, finalized libcommon.Hash, head libcommon.Hash, attributes *engine_types.PayloadAttributes) ([]byte, error)
func (*ExecutionClientRpc) FrozenBlocks ¶
func (cc *ExecutionClientRpc) FrozenBlocks(ctx context.Context) uint64
func (*ExecutionClientRpc) GetAssembledBlock ¶
func (cc *ExecutionClientRpc) GetAssembledBlock(ctx context.Context, id []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)
func (*ExecutionClientRpc) GetBodiesByHashes ¶
func (cc *ExecutionClientRpc) GetBodiesByHashes(ctx context.Context, hashes []libcommon.Hash) ([]*types.RawBody, error)
GetBodiesByHashes gets block bodies with given hashes
func (*ExecutionClientRpc) GetBodiesByRange ¶
func (cc *ExecutionClientRpc) GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error)
GetBodiesByRange gets block bodies in given block range
func (*ExecutionClientRpc) HasGapInSnapshots ¶
func (cc *ExecutionClientRpc) HasGapInSnapshots(ctx context.Context) bool
func (*ExecutionClientRpc) InsertBlock ¶
func (*ExecutionClientRpc) InsertBlocks ¶
func (*ExecutionClientRpc) IsCanonicalHash ¶
func (*ExecutionClientRpc) NewPayload ¶
func (*ExecutionClientRpc) Ready ¶
func (cc *ExecutionClientRpc) Ready(ctx context.Context) (bool, error)
func (*ExecutionClientRpc) SupportInsertion ¶
func (cc *ExecutionClientRpc) SupportInsertion() bool
type ExecutionEngine ¶
type ExecutionEngine interface { NewPayload(ctx context.Context, payload *cltypes.Eth1Block, beaconParentRoot *libcommon.Hash, versionedHashes []libcommon.Hash) (PayloadStatus, error) ForkChoiceUpdate(ctx context.Context, finalized libcommon.Hash, head libcommon.Hash, attributes *engine_types.PayloadAttributes) ([]byte, error) SupportInsertion() bool InsertBlocks(ctx context.Context, blocks []*types.Block, wait bool) error InsertBlock(ctx context.Context, block *types.Block) error CurrentHeader(ctx context.Context) (*types.Header, error) IsCanonicalHash(ctx context.Context, hash libcommon.Hash) (bool, error) Ready(ctx context.Context) (bool, error) // Range methods GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error) GetBodiesByHashes(ctx context.Context, hashes []libcommon.Hash) ([]*types.RawBody, error) HasBlock(ctx context.Context, hash libcommon.Hash) (bool, error) // Snapshots FrozenBlocks(ctx context.Context) uint64 HasGapInSnapshots(ctx context.Context) bool // Block production GetAssembledBlock(ctx context.Context, id []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error) }
type MockExecutionEngine ¶
type MockExecutionEngine struct {
// contains filtered or unexported fields
}
MockExecutionEngine is a mock of ExecutionEngine interface.
func NewMockExecutionEngine ¶
func NewMockExecutionEngine(ctrl *gomock.Controller) *MockExecutionEngine
NewMockExecutionEngine creates a new mock instance.
func (*MockExecutionEngine) CurrentHeader ¶
CurrentHeader mocks base method.
func (*MockExecutionEngine) EXPECT ¶
func (m *MockExecutionEngine) EXPECT() *MockExecutionEngineMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockExecutionEngine) ForkChoiceUpdate ¶
func (m *MockExecutionEngine) ForkChoiceUpdate(ctx context.Context, finalized, head common.Hash, attributes *engine_types.PayloadAttributes) ([]byte, error)
ForkChoiceUpdate mocks base method.
func (*MockExecutionEngine) FrozenBlocks ¶
func (m *MockExecutionEngine) FrozenBlocks(ctx context.Context) uint64
FrozenBlocks mocks base method.
func (*MockExecutionEngine) GetAssembledBlock ¶
func (m *MockExecutionEngine) GetAssembledBlock(ctx context.Context, id []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)
GetAssembledBlock mocks base method.
func (*MockExecutionEngine) GetBodiesByHashes ¶
func (m *MockExecutionEngine) GetBodiesByHashes(ctx context.Context, hashes []common.Hash) ([]*types.RawBody, error)
GetBodiesByHashes mocks base method.
func (*MockExecutionEngine) GetBodiesByRange ¶
func (m *MockExecutionEngine) GetBodiesByRange(ctx context.Context, start, count uint64) ([]*types.RawBody, error)
GetBodiesByRange mocks base method.
func (*MockExecutionEngine) HasGapInSnapshots ¶
func (m *MockExecutionEngine) HasGapInSnapshots(ctx context.Context) bool
HasGapInSnapshots mocks base method.
func (*MockExecutionEngine) InsertBlock ¶
InsertBlock mocks base method.
func (*MockExecutionEngine) InsertBlocks ¶
func (m *MockExecutionEngine) InsertBlocks(ctx context.Context, blocks []*types.Block, wait bool) error
InsertBlocks mocks base method.
func (*MockExecutionEngine) IsCanonicalHash ¶
IsCanonicalHash mocks base method.
func (*MockExecutionEngine) NewPayload ¶
func (m *MockExecutionEngine) NewPayload(ctx context.Context, payload *cltypes.Eth1Block, beaconParentRoot *common.Hash, versionedHashes []common.Hash) (PayloadStatus, error)
NewPayload mocks base method.
func (*MockExecutionEngine) Ready ¶
func (m *MockExecutionEngine) Ready(ctx context.Context) (bool, error)
Ready mocks base method.
func (*MockExecutionEngine) SupportInsertion ¶
func (m *MockExecutionEngine) SupportInsertion() bool
SupportInsertion mocks base method.
type MockExecutionEngineCurrentHeaderCall ¶
MockExecutionEngineCurrentHeaderCall wrap *gomock.Call
func (*MockExecutionEngineCurrentHeaderCall) Do ¶
func (c *MockExecutionEngineCurrentHeaderCall) Do(f func(context.Context) (*types.Header, error)) *MockExecutionEngineCurrentHeaderCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineCurrentHeaderCall) DoAndReturn ¶
func (c *MockExecutionEngineCurrentHeaderCall) DoAndReturn(f func(context.Context) (*types.Header, error)) *MockExecutionEngineCurrentHeaderCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineCurrentHeaderCall) Return ¶
func (c *MockExecutionEngineCurrentHeaderCall) Return(arg0 *types.Header, arg1 error) *MockExecutionEngineCurrentHeaderCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineForkChoiceUpdateCall ¶
MockExecutionEngineForkChoiceUpdateCall wrap *gomock.Call
func (*MockExecutionEngineForkChoiceUpdateCall) Do ¶
func (c *MockExecutionEngineForkChoiceUpdateCall) Do(f func(context.Context, common.Hash, common.Hash, *engine_types.PayloadAttributes) ([]byte, error)) *MockExecutionEngineForkChoiceUpdateCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineForkChoiceUpdateCall) DoAndReturn ¶
func (c *MockExecutionEngineForkChoiceUpdateCall) DoAndReturn(f func(context.Context, common.Hash, common.Hash, *engine_types.PayloadAttributes) ([]byte, error)) *MockExecutionEngineForkChoiceUpdateCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineForkChoiceUpdateCall) Return ¶
func (c *MockExecutionEngineForkChoiceUpdateCall) Return(arg0 []byte, arg1 error) *MockExecutionEngineForkChoiceUpdateCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineFrozenBlocksCall ¶
MockExecutionEngineFrozenBlocksCall wrap *gomock.Call
func (*MockExecutionEngineFrozenBlocksCall) Do ¶
func (c *MockExecutionEngineFrozenBlocksCall) Do(f func(context.Context) uint64) *MockExecutionEngineFrozenBlocksCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineFrozenBlocksCall) DoAndReturn ¶
func (c *MockExecutionEngineFrozenBlocksCall) DoAndReturn(f func(context.Context) uint64) *MockExecutionEngineFrozenBlocksCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineFrozenBlocksCall) Return ¶
func (c *MockExecutionEngineFrozenBlocksCall) Return(arg0 uint64) *MockExecutionEngineFrozenBlocksCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineGetAssembledBlockCall ¶
MockExecutionEngineGetAssembledBlockCall wrap *gomock.Call
func (*MockExecutionEngineGetAssembledBlockCall) Do ¶
func (c *MockExecutionEngineGetAssembledBlockCall) Do(f func(context.Context, []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)) *MockExecutionEngineGetAssembledBlockCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineGetAssembledBlockCall) DoAndReturn ¶
func (c *MockExecutionEngineGetAssembledBlockCall) DoAndReturn(f func(context.Context, []byte) (*cltypes.Eth1Block, *engine_types.BlobsBundleV1, *big.Int, error)) *MockExecutionEngineGetAssembledBlockCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineGetAssembledBlockCall) Return ¶
func (c *MockExecutionEngineGetAssembledBlockCall) Return(arg0 *cltypes.Eth1Block, arg1 *engine_types.BlobsBundleV1, arg2 *big.Int, arg3 error) *MockExecutionEngineGetAssembledBlockCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineGetBodiesByHashesCall ¶
MockExecutionEngineGetBodiesByHashesCall wrap *gomock.Call
func (*MockExecutionEngineGetBodiesByHashesCall) Do ¶
func (c *MockExecutionEngineGetBodiesByHashesCall) Do(f func(context.Context, []common.Hash) ([]*types.RawBody, error)) *MockExecutionEngineGetBodiesByHashesCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineGetBodiesByHashesCall) DoAndReturn ¶
func (c *MockExecutionEngineGetBodiesByHashesCall) DoAndReturn(f func(context.Context, []common.Hash) ([]*types.RawBody, error)) *MockExecutionEngineGetBodiesByHashesCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineGetBodiesByHashesCall) Return ¶
func (c *MockExecutionEngineGetBodiesByHashesCall) Return(arg0 []*types.RawBody, arg1 error) *MockExecutionEngineGetBodiesByHashesCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineGetBodiesByRangeCall ¶
MockExecutionEngineGetBodiesByRangeCall wrap *gomock.Call
func (*MockExecutionEngineGetBodiesByRangeCall) Do ¶
func (c *MockExecutionEngineGetBodiesByRangeCall) Do(f func(context.Context, uint64, uint64) ([]*types.RawBody, error)) *MockExecutionEngineGetBodiesByRangeCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineGetBodiesByRangeCall) DoAndReturn ¶
func (c *MockExecutionEngineGetBodiesByRangeCall) DoAndReturn(f func(context.Context, uint64, uint64) ([]*types.RawBody, error)) *MockExecutionEngineGetBodiesByRangeCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineGetBodiesByRangeCall) Return ¶
func (c *MockExecutionEngineGetBodiesByRangeCall) Return(arg0 []*types.RawBody, arg1 error) *MockExecutionEngineGetBodiesByRangeCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineHasBlockCall ¶
MockExecutionEngineHasBlockCall wrap *gomock.Call
func (*MockExecutionEngineHasBlockCall) Do ¶
func (c *MockExecutionEngineHasBlockCall) Do(f func(context.Context, common.Hash) (bool, error)) *MockExecutionEngineHasBlockCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineHasBlockCall) DoAndReturn ¶
func (c *MockExecutionEngineHasBlockCall) DoAndReturn(f func(context.Context, common.Hash) (bool, error)) *MockExecutionEngineHasBlockCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineHasBlockCall) Return ¶
func (c *MockExecutionEngineHasBlockCall) Return(arg0 bool, arg1 error) *MockExecutionEngineHasBlockCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineHasGapInSnapshotsCall ¶
MockExecutionEngineHasGapInSnapshotsCall wrap *gomock.Call
func (*MockExecutionEngineHasGapInSnapshotsCall) Do ¶
func (c *MockExecutionEngineHasGapInSnapshotsCall) Do(f func(context.Context) bool) *MockExecutionEngineHasGapInSnapshotsCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineHasGapInSnapshotsCall) DoAndReturn ¶
func (c *MockExecutionEngineHasGapInSnapshotsCall) DoAndReturn(f func(context.Context) bool) *MockExecutionEngineHasGapInSnapshotsCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineHasGapInSnapshotsCall) Return ¶
func (c *MockExecutionEngineHasGapInSnapshotsCall) Return(arg0 bool) *MockExecutionEngineHasGapInSnapshotsCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineInsertBlockCall ¶
MockExecutionEngineInsertBlockCall wrap *gomock.Call
func (*MockExecutionEngineInsertBlockCall) Do ¶
func (c *MockExecutionEngineInsertBlockCall) Do(f func(context.Context, *types.Block) error) *MockExecutionEngineInsertBlockCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineInsertBlockCall) DoAndReturn ¶
func (c *MockExecutionEngineInsertBlockCall) DoAndReturn(f func(context.Context, *types.Block) error) *MockExecutionEngineInsertBlockCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineInsertBlockCall) Return ¶
func (c *MockExecutionEngineInsertBlockCall) Return(arg0 error) *MockExecutionEngineInsertBlockCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineInsertBlocksCall ¶
MockExecutionEngineInsertBlocksCall wrap *gomock.Call
func (*MockExecutionEngineInsertBlocksCall) Do ¶
func (c *MockExecutionEngineInsertBlocksCall) Do(f func(context.Context, []*types.Block, bool) error) *MockExecutionEngineInsertBlocksCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineInsertBlocksCall) DoAndReturn ¶
func (c *MockExecutionEngineInsertBlocksCall) DoAndReturn(f func(context.Context, []*types.Block, bool) error) *MockExecutionEngineInsertBlocksCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineInsertBlocksCall) Return ¶
func (c *MockExecutionEngineInsertBlocksCall) Return(arg0 error) *MockExecutionEngineInsertBlocksCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineIsCanonicalHashCall ¶
MockExecutionEngineIsCanonicalHashCall wrap *gomock.Call
func (*MockExecutionEngineIsCanonicalHashCall) Do ¶
func (c *MockExecutionEngineIsCanonicalHashCall) Do(f func(context.Context, common.Hash) (bool, error)) *MockExecutionEngineIsCanonicalHashCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineIsCanonicalHashCall) DoAndReturn ¶
func (c *MockExecutionEngineIsCanonicalHashCall) DoAndReturn(f func(context.Context, common.Hash) (bool, error)) *MockExecutionEngineIsCanonicalHashCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineIsCanonicalHashCall) Return ¶
func (c *MockExecutionEngineIsCanonicalHashCall) Return(arg0 bool, arg1 error) *MockExecutionEngineIsCanonicalHashCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineMockRecorder ¶
type MockExecutionEngineMockRecorder struct {
// contains filtered or unexported fields
}
MockExecutionEngineMockRecorder is the mock recorder for MockExecutionEngine.
func (*MockExecutionEngineMockRecorder) CurrentHeader ¶
func (mr *MockExecutionEngineMockRecorder) CurrentHeader(ctx any) *MockExecutionEngineCurrentHeaderCall
CurrentHeader indicates an expected call of CurrentHeader.
func (*MockExecutionEngineMockRecorder) ForkChoiceUpdate ¶
func (mr *MockExecutionEngineMockRecorder) ForkChoiceUpdate(ctx, finalized, head, attributes any) *MockExecutionEngineForkChoiceUpdateCall
ForkChoiceUpdate indicates an expected call of ForkChoiceUpdate.
func (*MockExecutionEngineMockRecorder) FrozenBlocks ¶
func (mr *MockExecutionEngineMockRecorder) FrozenBlocks(ctx any) *MockExecutionEngineFrozenBlocksCall
FrozenBlocks indicates an expected call of FrozenBlocks.
func (*MockExecutionEngineMockRecorder) GetAssembledBlock ¶
func (mr *MockExecutionEngineMockRecorder) GetAssembledBlock(ctx, id any) *MockExecutionEngineGetAssembledBlockCall
GetAssembledBlock indicates an expected call of GetAssembledBlock.
func (*MockExecutionEngineMockRecorder) GetBodiesByHashes ¶
func (mr *MockExecutionEngineMockRecorder) GetBodiesByHashes(ctx, hashes any) *MockExecutionEngineGetBodiesByHashesCall
GetBodiesByHashes indicates an expected call of GetBodiesByHashes.
func (*MockExecutionEngineMockRecorder) GetBodiesByRange ¶
func (mr *MockExecutionEngineMockRecorder) GetBodiesByRange(ctx, start, count any) *MockExecutionEngineGetBodiesByRangeCall
GetBodiesByRange indicates an expected call of GetBodiesByRange.
func (*MockExecutionEngineMockRecorder) HasBlock ¶
func (mr *MockExecutionEngineMockRecorder) HasBlock(ctx, hash any) *MockExecutionEngineHasBlockCall
HasBlock indicates an expected call of HasBlock.
func (*MockExecutionEngineMockRecorder) HasGapInSnapshots ¶
func (mr *MockExecutionEngineMockRecorder) HasGapInSnapshots(ctx any) *MockExecutionEngineHasGapInSnapshotsCall
HasGapInSnapshots indicates an expected call of HasGapInSnapshots.
func (*MockExecutionEngineMockRecorder) InsertBlock ¶
func (mr *MockExecutionEngineMockRecorder) InsertBlock(ctx, block any) *MockExecutionEngineInsertBlockCall
InsertBlock indicates an expected call of InsertBlock.
func (*MockExecutionEngineMockRecorder) InsertBlocks ¶
func (mr *MockExecutionEngineMockRecorder) InsertBlocks(ctx, blocks, wait any) *MockExecutionEngineInsertBlocksCall
InsertBlocks indicates an expected call of InsertBlocks.
func (*MockExecutionEngineMockRecorder) IsCanonicalHash ¶
func (mr *MockExecutionEngineMockRecorder) IsCanonicalHash(ctx, hash any) *MockExecutionEngineIsCanonicalHashCall
IsCanonicalHash indicates an expected call of IsCanonicalHash.
func (*MockExecutionEngineMockRecorder) NewPayload ¶
func (mr *MockExecutionEngineMockRecorder) NewPayload(ctx, payload, beaconParentRoot, versionedHashes any) *MockExecutionEngineNewPayloadCall
NewPayload indicates an expected call of NewPayload.
func (*MockExecutionEngineMockRecorder) Ready ¶
func (mr *MockExecutionEngineMockRecorder) Ready(ctx any) *MockExecutionEngineReadyCall
Ready indicates an expected call of Ready.
func (*MockExecutionEngineMockRecorder) SupportInsertion ¶
func (mr *MockExecutionEngineMockRecorder) SupportInsertion() *MockExecutionEngineSupportInsertionCall
SupportInsertion indicates an expected call of SupportInsertion.
type MockExecutionEngineNewPayloadCall ¶
MockExecutionEngineNewPayloadCall wrap *gomock.Call
func (*MockExecutionEngineNewPayloadCall) Do ¶
func (c *MockExecutionEngineNewPayloadCall) Do(f func(context.Context, *cltypes.Eth1Block, *common.Hash, []common.Hash) (PayloadStatus, error)) *MockExecutionEngineNewPayloadCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineNewPayloadCall) DoAndReturn ¶
func (c *MockExecutionEngineNewPayloadCall) DoAndReturn(f func(context.Context, *cltypes.Eth1Block, *common.Hash, []common.Hash) (PayloadStatus, error)) *MockExecutionEngineNewPayloadCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineNewPayloadCall) Return ¶
func (c *MockExecutionEngineNewPayloadCall) Return(arg0 PayloadStatus, arg1 error) *MockExecutionEngineNewPayloadCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineReadyCall ¶
MockExecutionEngineReadyCall wrap *gomock.Call
func (*MockExecutionEngineReadyCall) Do ¶
func (c *MockExecutionEngineReadyCall) Do(f func(context.Context) (bool, error)) *MockExecutionEngineReadyCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineReadyCall) DoAndReturn ¶
func (c *MockExecutionEngineReadyCall) DoAndReturn(f func(context.Context) (bool, error)) *MockExecutionEngineReadyCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineReadyCall) Return ¶
func (c *MockExecutionEngineReadyCall) Return(arg0 bool, arg1 error) *MockExecutionEngineReadyCall
Return rewrite *gomock.Call.Return
type MockExecutionEngineSupportInsertionCall ¶
MockExecutionEngineSupportInsertionCall wrap *gomock.Call
func (*MockExecutionEngineSupportInsertionCall) Do ¶
func (c *MockExecutionEngineSupportInsertionCall) Do(f func() bool) *MockExecutionEngineSupportInsertionCall
Do rewrite *gomock.Call.Do
func (*MockExecutionEngineSupportInsertionCall) DoAndReturn ¶
func (c *MockExecutionEngineSupportInsertionCall) DoAndReturn(f func() bool) *MockExecutionEngineSupportInsertionCall
DoAndReturn rewrite *gomock.Call.DoAndReturn
func (*MockExecutionEngineSupportInsertionCall) Return ¶
func (c *MockExecutionEngineSupportInsertionCall) Return(arg0 bool) *MockExecutionEngineSupportInsertionCall
Return rewrite *gomock.Call.Return
type PayloadStatus ¶
type PayloadStatus int