types

package
v0.13.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 25, 2025 License: GPL-3.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// ModuleName defines the module name.
	ModuleName = "evmengine"

	// StoreKey defines the primary module store key.
	StoreKey = ModuleName

	// MemStoreKey defines the in-memory store key.
	MemStoreKey = "mem_evmengine"
)

Variables

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var MsgService_serviceDesc = _MsgService_serviceDesc
View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions

func PayloadFromProto added in v0.13.0 

func PayloadFromProto(p *ExecutionPayloadDeneb) (engine.ExecutableData, error)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServiceServer 

func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)

func RegisterQueryServer added in v0.13.0 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func WithdrawalFromProto added in v0.13.0 

func WithdrawalFromProto(w Withdrawal) *ethtypes.Withdrawal

Types

type Address added in v0.13.0 

type Address common.Address

Address extends common.Address to implement customProtobufType.

func (Address) Marshal added in v0.13.0 

func (a Address) Marshal() ([]byte, error)

func (Address) MarshalJSON added in v0.13.0 

func (a Address) MarshalJSON() ([]byte, error)

func (Address) MarshalTo added in v0.13.0 

func (a Address) MarshalTo(data []byte) (int, error)

func (Address) Size added in v0.13.0 

func (Address) Size() int

func (*Address) Unmarshal added in v0.13.0 

func (a *Address) Unmarshal(data []byte) error

func (*Address) UnmarshalJSON added in v0.13.0 

func (a *Address) UnmarshalJSON(data []byte) error

type AddressProvider 

type AddressProvider interface {
	// LocalAddress returns the local validator's ethereum address.
	LocalAddress() common.Address
}

type EVMEvent 

type EVMEvent struct {
	Address []byte   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Topics  [][]byte `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	Data    []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

EVMEvent represents a contract log event. Derived fields are not included in the protobuf.

func (*EVMEvent) Descriptor 

func (*EVMEvent) Descriptor() ([]byte, []int)

func (*EVMEvent) GetAddress 

func (m *EVMEvent) GetAddress() []byte

func (*EVMEvent) GetData 

func (m *EVMEvent) GetData() []byte

func (*EVMEvent) GetTopics 

func (m *EVMEvent) GetTopics() [][]byte

func (*EVMEvent) Marshal 

func (m *EVMEvent) Marshal() (dAtA []byte, err error)

func (*EVMEvent) MarshalTo 

func (m *EVMEvent) MarshalTo(dAtA []byte) (int, error)

func (*EVMEvent) MarshalToSizedBuffer 

func (m *EVMEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EVMEvent) ProtoMessage 

func (*EVMEvent) ProtoMessage()

func (*EVMEvent) Reset 

func (m *EVMEvent) Reset()

func (*EVMEvent) Size 

func (m *EVMEvent) Size() (n int)

func (*EVMEvent) String 

func (m *EVMEvent) String() string

func (*EVMEvent) ToEthLog 

func (l *EVMEvent) ToEthLog() (ethtypes.Log, error)

ToEthLog converts an EVMEvent to an Ethereum Log. Note it assumes that Verify has been called before.

func (*EVMEvent) Unmarshal 

func (m *EVMEvent) Unmarshal(dAtA []byte) error

func (*EVMEvent) Verify 

func (l *EVMEvent) Verify() error

func (*EVMEvent) XXX_DiscardUnknown 

func (m *EVMEvent) XXX_DiscardUnknown()

func (*EVMEvent) XXX_Marshal 

func (m *EVMEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EVMEvent) XXX_Merge 

func (m *EVMEvent) XXX_Merge(src proto.Message)

func (*EVMEvent) XXX_Size 

func (m *EVMEvent) XXX_Size() int

func (*EVMEvent) XXX_Unmarshal 

func (m *EVMEvent) XXX_Unmarshal(b []byte) error

type EvmEventProcessor 

type EvmEventProcessor interface {
	// Name of the event processor (used for logs and metrics).
	Name() string
	// FilterParams defines the matching EVM log events, see github.com/ethereum/go-ethereum#FilterQuery.
	FilterParams() (addresses []common.Address, topics [][]common.Hash)
	// Deliver is called during ProcessPayload to process events.
	Deliver(ctx context.Context, blockHash common.Hash, log EVMEvent) error
}

EvmEventProcessor abstracts logic that processes EVM log events of the previous execution payload (current head) identified by the provided block hash.

EVMEngine calls this during PreparePayload to collect all EVM-log-events to include in the consensus block. It is also called during ProcessPayload to verify the proposed EVM events.

type ExecutionPayloadDeneb added in v0.13.0 

type ExecutionPayloadDeneb struct {
	ParentHash    Hash         `protobuf:"bytes,1,opt,name=parent_hash,json=parentHash,proto3,customtype=Hash" json:"parent_hash"`
	FeeRecipient  Address      `protobuf:"bytes,2,opt,name=fee_recipient,json=feeRecipient,proto3,customtype=Address" json:"fee_recipient"`
	StateRoot     Hash         `protobuf:"bytes,3,opt,name=state_root,json=stateRoot,proto3,customtype=Hash" json:"state_root"`
	ReceiptsRoot  Hash         `protobuf:"bytes,4,opt,name=receipts_root,json=receiptsRoot,proto3,customtype=Hash" json:"receipts_root"`
	LogsBloom     []byte       `protobuf:"bytes,5,opt,name=logs_bloom,json=logsBloom,proto3" json:"logs_bloom,omitempty"`
	PrevRandao    Hash         `protobuf:"bytes,6,opt,name=prev_randao,json=prevRandao,proto3,customtype=Hash" json:"prev_randao"`
	BlockNumber   uint64       `protobuf:"varint,7,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	GasLimit      uint64       `protobuf:"varint,8,opt,name=gas_limit,json=gasLimit,proto3" json:"gas_limit,omitempty"`
	GasUsed       uint64       `protobuf:"varint,9,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`
	Timestamp     uint64       `protobuf:"varint,10,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ExtraData     []byte       `protobuf:"bytes,11,opt,name=extra_data,json=extraData,proto3" json:"extra_data,omitempty"`
	BaseFeePerGas []byte       `protobuf:"bytes,12,opt,name=base_fee_per_gas,json=baseFeePerGas,proto3" json:"base_fee_per_gas,omitempty"`
	BlockHash     Hash         `protobuf:"bytes,13,opt,name=block_hash,json=blockHash,proto3,customtype=Hash" json:"block_hash"`
	Transactions  [][]byte     `protobuf:"bytes,14,rep,name=transactions,proto3" json:"transactions,omitempty"`
	Withdrawals   []Withdrawal `protobuf:"bytes,15,rep,name=withdrawals,proto3" json:"withdrawals"`
	BlobGasUsed   uint64       `protobuf:"varint,16,opt,name=blob_gas_used,json=blobGasUsed,proto3" json:"blob_gas_used,omitempty"`
	ExcessBlobGas uint64       `protobuf:"varint,17,opt,name=excess_blob_gas,json=excessBlobGas,proto3" json:"excess_blob_gas,omitempty"`
}

ExecutionPayloadDeneb represents the EVM execution payload. Copied from https://github.com/prysmaticlabs/prysm/blob/develop/proto/engine/v1/execution_engine.proto.

func PayloadToProto added in v0.13.0 

func PayloadToProto(p *engine.ExecutableData) (*ExecutionPayloadDeneb, error)

func (*ExecutionPayloadDeneb) Descriptor added in v0.13.0 

func (*ExecutionPayloadDeneb) Descriptor() ([]byte, []int)

func (*ExecutionPayloadDeneb) GetBaseFeePerGas added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetBaseFeePerGas() []byte

func (*ExecutionPayloadDeneb) GetBlobGasUsed added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetBlobGasUsed() uint64

func (*ExecutionPayloadDeneb) GetBlockNumber added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetBlockNumber() uint64

func (*ExecutionPayloadDeneb) GetExcessBlobGas added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetExcessBlobGas() uint64

func (*ExecutionPayloadDeneb) GetExtraData added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetExtraData() []byte

func (*ExecutionPayloadDeneb) GetGasLimit added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetGasLimit() uint64

func (*ExecutionPayloadDeneb) GetGasUsed added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetGasUsed() uint64

func (*ExecutionPayloadDeneb) GetLogsBloom added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetLogsBloom() []byte

func (*ExecutionPayloadDeneb) GetTimestamp added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetTimestamp() uint64

func (*ExecutionPayloadDeneb) GetTransactions added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetTransactions() [][]byte

func (*ExecutionPayloadDeneb) GetWithdrawals added in v0.13.0 

func (m *ExecutionPayloadDeneb) GetWithdrawals() []Withdrawal

func (*ExecutionPayloadDeneb) Marshal added in v0.13.0 

func (m *ExecutionPayloadDeneb) Marshal() (dAtA []byte, err error)

func (*ExecutionPayloadDeneb) MarshalTo added in v0.13.0 

func (m *ExecutionPayloadDeneb) MarshalTo(dAtA []byte) (int, error)

func (*ExecutionPayloadDeneb) MarshalToSizedBuffer added in v0.13.0 

func (m *ExecutionPayloadDeneb) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecutionPayloadDeneb) ProtoMessage added in v0.13.0 

func (*ExecutionPayloadDeneb) ProtoMessage()

func (*ExecutionPayloadDeneb) Reset added in v0.13.0 

func (m *ExecutionPayloadDeneb) Reset()

func (*ExecutionPayloadDeneb) Size added in v0.13.0 

func (m *ExecutionPayloadDeneb) Size() (n int)

func (*ExecutionPayloadDeneb) String added in v0.13.0 

func (m *ExecutionPayloadDeneb) String() string

func (*ExecutionPayloadDeneb) Unmarshal added in v0.13.0 

func (m *ExecutionPayloadDeneb) Unmarshal(dAtA []byte) error

func (*ExecutionPayloadDeneb) XXX_DiscardUnknown added in v0.13.0 

func (m *ExecutionPayloadDeneb) XXX_DiscardUnknown()

func (*ExecutionPayloadDeneb) XXX_Marshal added in v0.13.0 

func (m *ExecutionPayloadDeneb) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionPayloadDeneb) XXX_Merge added in v0.13.0 

func (m *ExecutionPayloadDeneb) XXX_Merge(src proto.Message)

func (*ExecutionPayloadDeneb) XXX_Size added in v0.13.0 

func (m *ExecutionPayloadDeneb) XXX_Size() int

func (*ExecutionPayloadDeneb) XXX_Unmarshal added in v0.13.0 

func (m *ExecutionPayloadDeneb) XXX_Unmarshal(b []byte) error

type ExecutionPayloadResponse 

type ExecutionPayloadResponse struct {
}

func (*ExecutionPayloadResponse) Descriptor 

func (*ExecutionPayloadResponse) Descriptor() ([]byte, []int)

func (*ExecutionPayloadResponse) Marshal 

func (m *ExecutionPayloadResponse) Marshal() (dAtA []byte, err error)

func (*ExecutionPayloadResponse) MarshalTo 

func (m *ExecutionPayloadResponse) MarshalTo(dAtA []byte) (int, error)

func (*ExecutionPayloadResponse) MarshalToSizedBuffer 

func (m *ExecutionPayloadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecutionPayloadResponse) ProtoMessage 

func (*ExecutionPayloadResponse) ProtoMessage()

func (*ExecutionPayloadResponse) Reset 

func (m *ExecutionPayloadResponse) Reset()

func (*ExecutionPayloadResponse) Size 

func (m *ExecutionPayloadResponse) Size() (n int)

func (*ExecutionPayloadResponse) String 

func (m *ExecutionPayloadResponse) String() string

func (*ExecutionPayloadResponse) Unmarshal 

func (m *ExecutionPayloadResponse) Unmarshal(dAtA []byte) error

func (*ExecutionPayloadResponse) XXX_DiscardUnknown 

func (m *ExecutionPayloadResponse) XXX_DiscardUnknown()

func (*ExecutionPayloadResponse) XXX_Marshal 

func (m *ExecutionPayloadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionPayloadResponse) XXX_Merge 

func (m *ExecutionPayloadResponse) XXX_Merge(src proto.Message)

func (*ExecutionPayloadResponse) XXX_Size 

func (m *ExecutionPayloadResponse) XXX_Size() int

func (*ExecutionPayloadResponse) XXX_Unmarshal 

func (m *ExecutionPayloadResponse) XXX_Unmarshal(b []byte) error

type FeeRecipientProvider 

type FeeRecipientProvider interface {
	// LocalFeeRecipient returns the local validator's fee recipient address.
	LocalFeeRecipient() common.Address
	// VerifyFeeRecipient returns true if the given address is a valid fee recipient
	VerifyFeeRecipient(proposedFeeRecipient common.Address) error
}

type GenesisState 

type GenesisState struct {
	ExecutionBlockHash []byte `protobuf:"bytes,1,opt,name=execution_block_hash,json=executionBlockHash,proto3" json:"execution_block_hash,omitempty"`
}

GenesisState is an empty genesis state required to trigger valsync genesis logic only.

func NewGenesisState 

func NewGenesisState(executionBlockHash common.Hash) *GenesisState

NewGenesisState creates a new GenesisState instance.

func (*GenesisState) Descriptor 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) GetExecutionBlockHash 

func (m *GenesisState) GetExecutionBlockHash() []byte

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

func (m *GenesisState) Size() (n int)

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type Hash added in v0.13.0 

type Hash common.Hash

Hash extends common.Hash to implement customProtobufType.

func (Hash) Marshal added in v0.13.0 

func (h Hash) Marshal() ([]byte, error)

func (Hash) MarshalJSON added in v0.13.0 

func (h Hash) MarshalJSON() ([]byte, error)

func (Hash) MarshalTo added in v0.13.0 

func (h Hash) MarshalTo(data []byte) (int, error)

func (Hash) Size added in v0.13.0 

func (Hash) Size() int

func (*Hash) Unmarshal added in v0.13.0 

func (h *Hash) Unmarshal(data []byte) error

func (*Hash) UnmarshalJSON added in v0.13.0 

func (h *Hash) UnmarshalJSON(data []byte) error

type InjectedEventProc 

type InjectedEventProc struct {
	EvmEventProcessor
}

InjectedEventProc wraps an EvmEventProcessor such that many instances can be injected during app wiring.

func InjectEventProc 

func InjectEventProc(proc EvmEventProcessor) InjectedEventProc

InjectEventProc returns an InjectedEventProc that wraps the given EvmEventProcessor.

func (InjectedEventProc) IsManyPerContainerType 

func (InjectedEventProc) IsManyPerContainerType()

type MsgExecutionPayload 

type MsgExecutionPayload struct {
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// TODO(corver): Reserve 2 and 3 during drake upgraded.
	ExecutionPayload      []byte                 `protobuf:"bytes,2,opt,name=execution_payload,json=executionPayload,proto3" json:"execution_payload,omitempty"`
	PrevPayloadEvents     []EVMEvent             `protobuf:"bytes,3,rep,name=prev_payload_events,json=prevPayloadEvents,proto3" json:"prev_payload_events"`
	BlobCommitments       [][]byte               `protobuf:"bytes,4,rep,name=blob_commitments,json=blobCommitments,proto3" json:"blob_commitments,omitempty"`
	ExecutionPayloadDeneb *ExecutionPayloadDeneb `` /* 126-byte string literal not displayed */
}

MsgExecutionPayload defines the next EVM execution payload and the logs from previous execution payload.

func (*MsgExecutionPayload) Descriptor 

func (*MsgExecutionPayload) Descriptor() ([]byte, []int)

func (*MsgExecutionPayload) GetAuthority 

func (m *MsgExecutionPayload) GetAuthority() string

func (*MsgExecutionPayload) GetBlobCommitments added in v0.11.0 

func (m *MsgExecutionPayload) GetBlobCommitments() [][]byte

func (*MsgExecutionPayload) GetExecutionPayload 

func (m *MsgExecutionPayload) GetExecutionPayload() []byte

func (*MsgExecutionPayload) GetExecutionPayloadDeneb added in v0.13.0 

func (m *MsgExecutionPayload) GetExecutionPayloadDeneb() *ExecutionPayloadDeneb

func (*MsgExecutionPayload) GetPrevPayloadEvents 

func (m *MsgExecutionPayload) GetPrevPayloadEvents() []EVMEvent

func (*MsgExecutionPayload) Marshal 

func (m *MsgExecutionPayload) Marshal() (dAtA []byte, err error)

func (*MsgExecutionPayload) MarshalTo 

func (m *MsgExecutionPayload) MarshalTo(dAtA []byte) (int, error)

func (*MsgExecutionPayload) MarshalToSizedBuffer 

func (m *MsgExecutionPayload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgExecutionPayload) ProtoMessage 

func (*MsgExecutionPayload) ProtoMessage()

func (*MsgExecutionPayload) Reset 

func (m *MsgExecutionPayload) Reset()

func (*MsgExecutionPayload) Size 

func (m *MsgExecutionPayload) Size() (n int)

func (*MsgExecutionPayload) String 

func (m *MsgExecutionPayload) String() string

func (*MsgExecutionPayload) Unmarshal 

func (m *MsgExecutionPayload) Unmarshal(dAtA []byte) error

func (*MsgExecutionPayload) XXX_DiscardUnknown 

func (m *MsgExecutionPayload) XXX_DiscardUnknown()

func (*MsgExecutionPayload) XXX_Marshal 

func (m *MsgExecutionPayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgExecutionPayload) XXX_Merge 

func (m *MsgExecutionPayload) XXX_Merge(src proto.Message)

func (*MsgExecutionPayload) XXX_Size 

func (m *MsgExecutionPayload) XXX_Size() int

func (*MsgExecutionPayload) XXX_Unmarshal 

func (m *MsgExecutionPayload) XXX_Unmarshal(b []byte) error

type MsgServiceClient 

type MsgServiceClient interface {
	// ExecutionPayload submits a new execution payload from consensus to the OmniEVM.
	ExecutionPayload(ctx context.Context, in *MsgExecutionPayload, opts ...grpc.CallOption) (*ExecutionPayloadResponse, error)
}

MsgServiceClient is the client API for MsgService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgServiceClient 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer 

type MsgServiceServer interface {
	// ExecutionPayload submits a new execution payload from consensus to the OmniEVM.
	ExecutionPayload(context.Context, *MsgExecutionPayload) (*ExecutionPayloadResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type QueryClient added in v0.13.0 

type QueryClient interface {
	// SumPendingWithdrawalsByAddress returns the sum of pending withdrawal amounts (in gwei) to requested address or 0 if none.
	SumPendingWithdrawalsByAddress(ctx context.Context, in *SumPendingWithdrawalsByAddressRequest, opts ...grpc.CallOption) (*SumPendingWithdrawalsByAddressResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient added in v0.13.0 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryServer added in v0.13.0 

type QueryServer interface {
	// SumPendingWithdrawalsByAddress returns the sum of pending withdrawal amounts (in gwei) to requested address or 0 if none.
	SumPendingWithdrawalsByAddress(context.Context, *SumPendingWithdrawalsByAddressRequest) (*SumPendingWithdrawalsByAddressResponse, error)
}

QueryServer is the server API for Query service.

type SumPendingWithdrawalsByAddressRequest added in v0.13.0 

type SumPendingWithdrawalsByAddressRequest struct {
	Address Address `protobuf:"bytes,1,opt,name=address,proto3,customtype=Address" json:"address"`
}

func (*SumPendingWithdrawalsByAddressRequest) Descriptor added in v0.13.0 

func (*SumPendingWithdrawalsByAddressRequest) Descriptor() ([]byte, []int)

func (*SumPendingWithdrawalsByAddressRequest) Marshal added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) Marshal() (dAtA []byte, err error)

func (*SumPendingWithdrawalsByAddressRequest) MarshalTo added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) MarshalTo(dAtA []byte) (int, error)

func (*SumPendingWithdrawalsByAddressRequest) MarshalToSizedBuffer added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SumPendingWithdrawalsByAddressRequest) ProtoMessage added in v0.13.0 

func (*SumPendingWithdrawalsByAddressRequest) ProtoMessage()

func (*SumPendingWithdrawalsByAddressRequest) Reset added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) Reset()

func (*SumPendingWithdrawalsByAddressRequest) Size added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) Size() (n int)

func (*SumPendingWithdrawalsByAddressRequest) String added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) String() string

func (*SumPendingWithdrawalsByAddressRequest) Unmarshal added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) Unmarshal(dAtA []byte) error

func (*SumPendingWithdrawalsByAddressRequest) XXX_DiscardUnknown added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) XXX_DiscardUnknown()

func (*SumPendingWithdrawalsByAddressRequest) XXX_Marshal added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SumPendingWithdrawalsByAddressRequest) XXX_Merge added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) XXX_Merge(src proto.Message)

func (*SumPendingWithdrawalsByAddressRequest) XXX_Size added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) XXX_Size() int

func (*SumPendingWithdrawalsByAddressRequest) XXX_Unmarshal added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressRequest) XXX_Unmarshal(b []byte) error

type SumPendingWithdrawalsByAddressResponse added in v0.13.0 

type SumPendingWithdrawalsByAddressResponse struct {
	SumGwei uint64 `protobuf:"varint,1,opt,name=sum_gwei,json=sumGwei,proto3" json:"sum_gwei,omitempty"`
}

func (*SumPendingWithdrawalsByAddressResponse) Descriptor added in v0.13.0 

func (*SumPendingWithdrawalsByAddressResponse) Descriptor() ([]byte, []int)

func (*SumPendingWithdrawalsByAddressResponse) GetSumGwei added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) GetSumGwei() uint64

func (*SumPendingWithdrawalsByAddressResponse) Marshal added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) Marshal() (dAtA []byte, err error)

func (*SumPendingWithdrawalsByAddressResponse) MarshalTo added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) MarshalTo(dAtA []byte) (int, error)

func (*SumPendingWithdrawalsByAddressResponse) MarshalToSizedBuffer added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SumPendingWithdrawalsByAddressResponse) ProtoMessage added in v0.13.0 

func (*SumPendingWithdrawalsByAddressResponse) ProtoMessage()

func (*SumPendingWithdrawalsByAddressResponse) Reset added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) Reset()

func (*SumPendingWithdrawalsByAddressResponse) Size added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) Size() (n int)

func (*SumPendingWithdrawalsByAddressResponse) String added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) String() string

func (*SumPendingWithdrawalsByAddressResponse) Unmarshal added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) Unmarshal(dAtA []byte) error

func (*SumPendingWithdrawalsByAddressResponse) XXX_DiscardUnknown added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) XXX_DiscardUnknown()

func (*SumPendingWithdrawalsByAddressResponse) XXX_Marshal added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SumPendingWithdrawalsByAddressResponse) XXX_Merge added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) XXX_Merge(src proto.Message)

func (*SumPendingWithdrawalsByAddressResponse) XXX_Size added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) XXX_Size() int

func (*SumPendingWithdrawalsByAddressResponse) XXX_Unmarshal added in v0.13.0 

func (m *SumPendingWithdrawalsByAddressResponse) XXX_Unmarshal(b []byte) error

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) ExecutionPayload 

func (*UnimplementedMsgServiceServer) ExecutionPayload(ctx context.Context, req *MsgExecutionPayload) (*ExecutionPayloadResponse, error)

type UnimplementedQueryServer added in v0.13.0 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) SumPendingWithdrawalsByAddress added in v0.13.0 

func (*UnimplementedQueryServer) SumPendingWithdrawalsByAddress(ctx context.Context, req *SumPendingWithdrawalsByAddressRequest) (*SumPendingWithdrawalsByAddressResponse, error)

type VoteExtensionProvider 

type VoteExtensionProvider interface {
	PrepareVotes(ctx context.Context, commit abci.ExtendedCommitInfo, commitHeight uint64) ([]sdk.Msg, error)
}

VoteExtensionProvider abstracts logic that provides consensus payload messages from the last commits vote extensions.

EVMEngine calls this during PreparePayload to collect all vote extensions msgs to include in the consensus block.

type Withdrawal added in v0.13.0 

type Withdrawal struct {
	// Withdrawal index for accounting purposes
	Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// The execution address receiving the funds
	Address Address `protobuf:"bytes,2,opt,name=address,proto3,customtype=Address" json:"address"`
	// The withdrawn amount in Gwei
	AmountGwei uint64 `protobuf:"varint,3,opt,name=amount_gwei,json=amountGwei,proto3" json:"amount_gwei,omitempty"`
}

The withdrawal receipt with the recipient address and amount withdrawn. Note that ValidatorIndex isn't used in Octane and is always 0.

func WithdrawalToProto added in v0.13.0 

func WithdrawalToProto(w *ethtypes.Withdrawal) (Withdrawal, error)

func (*Withdrawal) Descriptor added in v0.13.0 

func (*Withdrawal) Descriptor() ([]byte, []int)

func (*Withdrawal) GetAmountGwei added in v0.13.0 

func (m *Withdrawal) GetAmountGwei() uint64

func (*Withdrawal) GetIndex added in v0.13.0 

func (m *Withdrawal) GetIndex() uint64

func (*Withdrawal) Marshal added in v0.13.0 

func (m *Withdrawal) Marshal() (dAtA []byte, err error)

func (*Withdrawal) MarshalTo added in v0.13.0 

func (m *Withdrawal) MarshalTo(dAtA []byte) (int, error)

func (*Withdrawal) MarshalToSizedBuffer added in v0.13.0 

func (m *Withdrawal) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Withdrawal) ProtoMessage added in v0.13.0 

func (*Withdrawal) ProtoMessage()

func (*Withdrawal) Reset added in v0.13.0 

func (m *Withdrawal) Reset()

func (*Withdrawal) Size added in v0.13.0 

func (m *Withdrawal) Size() (n int)

func (*Withdrawal) String added in v0.13.0 

func (m *Withdrawal) String() string

func (*Withdrawal) Unmarshal added in v0.13.0 

func (m *Withdrawal) Unmarshal(dAtA []byte) error

func (*Withdrawal) XXX_DiscardUnknown added in v0.13.0 

func (m *Withdrawal) XXX_DiscardUnknown()

func (*Withdrawal) XXX_Marshal added in v0.13.0 

func (m *Withdrawal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Withdrawal) XXX_Merge added in v0.13.0 

func (m *Withdrawal) XXX_Merge(src proto.Message)

func (*Withdrawal) XXX_Size added in v0.13.0 

func (m *Withdrawal) XXX_Size() int

func (*Withdrawal) XXX_Unmarshal added in v0.13.0 

func (m *Withdrawal) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.