types

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Nov 13, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation ¶

Overview ¶

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index ¶

Constants ¶

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

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

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_goat"
)
View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default global index

View Source 
const (
	EventTypeNewEthBlock = "new_eth_block"
)

Variables ¶

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGoat        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGoat          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGoat = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ParamsKey   = collections.NewPrefix(0)
	BlockKey    = collections.NewPrefix(1)
	ConsHashKey = collections.NewPrefix(2)
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
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 Msg_serviceDesc = _Msg_serviceDesc
View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions ¶

func KeyPrefix ¶ 

func KeyPrefix(p string) []byte

func NewEthBlockEvent ¶ 

func NewEthBlockEvent(number uint64, hash []byte) sdktypes.Event

func PayloadToExecutableData ¶ 

func PayloadToExecutableData(data *ExecutionPayload) *engine.ExecutableData

func RegisterInterfaces ¶ 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer ¶ 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler ¶ 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient ¶ 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint ¶ 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer ¶ 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer ¶ 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types ¶

type AccountKeeper ¶ 

type AccountKeeper interface {
	// Return a new account with the next account number and the specified address. Does not save the new account to the store.
	NewAccountWithAddress(context.Context, sdk.AccAddress) sdk.AccountI

	// Return a new account with the next account number. Does not save the new account to the store.
	NewAccount(context.Context, sdk.AccountI) sdk.AccountI

	// Check if an account exists in the store.
	HasAccount(context.Context, sdk.AccAddress) bool

	// Retrieve an account from the store.
	GetAccount(context.Context, sdk.AccAddress) sdk.AccountI

	// Set an account in the store.
	SetAccount(context.Context, sdk.AccountI)

	// Fetch the sequence of an account at a specified address.
	GetSequence(context.Context, sdk.AccAddress) (uint64, error)

	// Fetch the next account number, and increment the internal counter.
	NextAccountNumber(context.Context) uint64

	// AddressCodec returns the account address codec.
	AddressCodec() address.Codec

	RemoveAccount(ctx context.Context, acc sdk.AccountI)
}

AccountKeeper defines the expected interface for the Account module.

type BitcoinKeeper ¶ 

type BitcoinKeeper interface {
	DequeueBitcoinModuleTx(ctx context.Context) ([]*ethtypes.Transaction, error)
	ProcessBridgeRequest(ctx context.Context, req goattypes.BridgeRequests) error
}

type ExecutionPayload ¶ 

type ExecutionPayload struct {
	ParentHash    []byte                `protobuf:"bytes,1,opt,name=parent_hash,json=parentHash,proto3" json:"parent_hash,omitempty"`
	FeeRecipient  []byte                `protobuf:"bytes,2,opt,name=fee_recipient,json=feeRecipient,proto3" json:"fee_recipient,omitempty"`
	StateRoot     []byte                `protobuf:"bytes,3,opt,name=state_root,json=stateRoot,proto3" json:"state_root,omitempty"`
	ReceiptsRoot  []byte                `protobuf:"bytes,4,opt,name=receipts_root,json=receiptsRoot,proto3" json:"receipts_root,omitempty"`
	LogsBloom     []byte                `protobuf:"bytes,5,opt,name=logs_bloom,json=logsBloom,proto3" json:"logs_bloom,omitempty"`
	PrevRandao    []byte                `protobuf:"bytes,6,opt,name=prev_randao,json=prevRandao,proto3" json:"prev_randao,omitempty"`
	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 cosmossdk_io_math.Int `` /* 128-byte string literal not displayed */
	BlockHash     []byte                `protobuf:"bytes,13,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	Transactions  [][]byte              `protobuf:"bytes,14,rep,name=transactions,proto3" json:"transactions,omitempty"`
	BeaconRoot    []byte                `protobuf:"bytes,15,opt,name=beacon_root,json=beaconRoot,proto3" json:"beacon_root,omitempty"`
	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"`
	Requests      [][]byte              `protobuf:"bytes,24,rep,name=requests,proto3" json:"requests,omitempty"`
}

ExecutionPayload

func ExecutableDataToPayload ¶ 

func ExecutableDataToPayload(data *engine.ExecutableData, beaconRoot []byte, execRequests [][]byte) *ExecutionPayload

func (*ExecutionPayload) Descriptor ¶ 

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

func (*ExecutionPayload) GetBeaconRoot ¶ 

func (m *ExecutionPayload) GetBeaconRoot() []byte

func (*ExecutionPayload) GetBlobGasUsed ¶ 

func (m *ExecutionPayload) GetBlobGasUsed() uint64

func (*ExecutionPayload) GetBlockHash ¶ 

func (m *ExecutionPayload) GetBlockHash() []byte

func (*ExecutionPayload) GetBlockNumber ¶ 

func (m *ExecutionPayload) GetBlockNumber() uint64

func (*ExecutionPayload) GetExcessBlobGas ¶ 

func (m *ExecutionPayload) GetExcessBlobGas() uint64

func (*ExecutionPayload) GetExtraData ¶ 

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

func (*ExecutionPayload) GetFeeRecipient ¶ 

func (m *ExecutionPayload) GetFeeRecipient() []byte

func (*ExecutionPayload) GetGasLimit ¶ 

func (m *ExecutionPayload) GetGasLimit() uint64

func (*ExecutionPayload) GetGasUsed ¶ 

func (m *ExecutionPayload) GetGasUsed() uint64

func (*ExecutionPayload) GetLogsBloom ¶ 

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

func (*ExecutionPayload) GetParentHash ¶ 

func (m *ExecutionPayload) GetParentHash() []byte

func (*ExecutionPayload) GetPrevRandao ¶ 

func (m *ExecutionPayload) GetPrevRandao() []byte

func (*ExecutionPayload) GetReceiptsRoot ¶ 

func (m *ExecutionPayload) GetReceiptsRoot() []byte

func (*ExecutionPayload) GetRequests ¶ 

func (m *ExecutionPayload) GetRequests() [][]byte

func (*ExecutionPayload) GetStateRoot ¶ 

func (m *ExecutionPayload) GetStateRoot() []byte

func (*ExecutionPayload) GetTimestamp ¶ 

func (m *ExecutionPayload) GetTimestamp() uint64

func (*ExecutionPayload) GetTransactions ¶ 

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

func (*ExecutionPayload) LogKeyVals ¶ 

func (payload *ExecutionPayload) LogKeyVals() []any

func (*ExecutionPayload) Marshal ¶ 

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

func (*ExecutionPayload) MarshalTo ¶ 

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

func (*ExecutionPayload) MarshalToSizedBuffer ¶ 

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

func (*ExecutionPayload) ProtoMessage ¶ 

func (*ExecutionPayload) ProtoMessage()

func (*ExecutionPayload) Reset ¶ 

func (m *ExecutionPayload) Reset()

func (*ExecutionPayload) Size ¶ 

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

func (*ExecutionPayload) String ¶ 

func (m *ExecutionPayload) String() string

func (*ExecutionPayload) Unmarshal ¶ 

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

func (*ExecutionPayload) XXX_DiscardUnknown ¶ 

func (m *ExecutionPayload) XXX_DiscardUnknown()

func (*ExecutionPayload) XXX_Marshal ¶ 

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

func (*ExecutionPayload) XXX_Merge ¶ 

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

func (*ExecutionPayload) XXX_Size ¶ 

func (m *ExecutionPayload) XXX_Size() int

func (*ExecutionPayload) XXX_Unmarshal ¶ 

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

type GenesisState ¶ 

type GenesisState struct {
	// params defines all the parameters of the module.
	Params     Params           `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	EthBlock   ExecutionPayload `protobuf:"bytes,2,opt,name=eth_block,json=ethBlock,proto3" json:"eth_block"`
	BeaconRoot []byte           `protobuf:"bytes,3,opt,name=beacon_root,json=beaconRoot,proto3" json:"beacon_root,omitempty"`
}

GenesisState defines the goat module's genesis state.

func DefaultGenesis ¶ 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor ¶ 

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

func (*GenesisState) GetBeaconRoot ¶ 

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

func (*GenesisState) GetEthBlock ¶ 

func (m *GenesisState) GetEthBlock() ExecutionPayload

func (*GenesisState) GetParams ¶ 

func (m *GenesisState) GetParams() Params

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) Validate ¶ 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

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 LockingKeeper ¶ 

type LockingKeeper interface {
	DequeueLockingModuleTx(ctx context.Context) ([]*ethtypes.Transaction, error)
	ProcessLockingRequest(ctx context.Context, req goattypes.LockingRequests) error
}

type MsgClient ¶ 

type MsgClient interface {
	// NewEthBlock
	NewEthBlock(ctx context.Context, in *MsgNewEthBlock, opts ...grpc.CallOption) (*MsgNewEthBlockResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient ¶ 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgNewEthBlock ¶ 

type MsgNewEthBlock struct {
	Proposer string            `protobuf:"bytes,1,opt,name=proposer,proto3" json:"proposer,omitempty"`
	Payload  *ExecutionPayload `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
}

MsgNewEthBlock is the Msg/NewEthBlock request type.

func (*MsgNewEthBlock) Descriptor ¶ 

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

func (*MsgNewEthBlock) GetPayload ¶ 

func (m *MsgNewEthBlock) GetPayload() *ExecutionPayload

func (*MsgNewEthBlock) GetProposer ¶ 

func (m *MsgNewEthBlock) GetProposer() string

func (*MsgNewEthBlock) Marshal ¶ 

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

func (*MsgNewEthBlock) MarshalTo ¶ 

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

func (*MsgNewEthBlock) MarshalToSizedBuffer ¶ 

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

func (*MsgNewEthBlock) ProtoMessage ¶ 

func (*MsgNewEthBlock) ProtoMessage()

func (*MsgNewEthBlock) Reset ¶ 

func (m *MsgNewEthBlock) Reset()

func (*MsgNewEthBlock) Size ¶ 

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

func (*MsgNewEthBlock) String ¶ 

func (m *MsgNewEthBlock) String() string

func (*MsgNewEthBlock) Unmarshal ¶ 

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

func (*MsgNewEthBlock) XXX_DiscardUnknown ¶ 

func (m *MsgNewEthBlock) XXX_DiscardUnknown()

func (*MsgNewEthBlock) XXX_Marshal ¶ 

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

func (*MsgNewEthBlock) XXX_Merge ¶ 

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

func (*MsgNewEthBlock) XXX_Size ¶ 

func (m *MsgNewEthBlock) XXX_Size() int

func (*MsgNewEthBlock) XXX_Unmarshal ¶ 

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

type MsgNewEthBlockResponse ¶ 

type MsgNewEthBlockResponse struct {
}

MsgNewEthBlockResponse is the Msg/NewEthBlock response type.

func (*MsgNewEthBlockResponse) Descriptor ¶ 

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

func (*MsgNewEthBlockResponse) Marshal ¶ 

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

func (*MsgNewEthBlockResponse) MarshalTo ¶ 

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

func (*MsgNewEthBlockResponse) MarshalToSizedBuffer ¶ 

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

func (*MsgNewEthBlockResponse) ProtoMessage ¶ 

func (*MsgNewEthBlockResponse) ProtoMessage()

func (*MsgNewEthBlockResponse) Reset ¶ 

func (m *MsgNewEthBlockResponse) Reset()

func (*MsgNewEthBlockResponse) Size ¶ 

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

func (*MsgNewEthBlockResponse) String ¶ 

func (m *MsgNewEthBlockResponse) String() string

func (*MsgNewEthBlockResponse) Unmarshal ¶ 

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

func (*MsgNewEthBlockResponse) XXX_DiscardUnknown ¶ 

func (m *MsgNewEthBlockResponse) XXX_DiscardUnknown()

func (*MsgNewEthBlockResponse) XXX_Marshal ¶ 

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

func (*MsgNewEthBlockResponse) XXX_Merge ¶ 

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

func (*MsgNewEthBlockResponse) XXX_Size ¶ 

func (m *MsgNewEthBlockResponse) XXX_Size() int

func (*MsgNewEthBlockResponse) XXX_Unmarshal ¶ 

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

type MsgServer ¶ 

type MsgServer interface {
	// NewEthBlock
	NewEthBlock(context.Context, *MsgNewEthBlock) (*MsgNewEthBlockResponse, error)
}

MsgServer is the server API for Msg service.

type Params ¶ 

type Params struct {
}

Params defines the parameters for the module.

func DefaultParams ¶ 

func DefaultParams() Params

DefaultParams returns a default set of parameters.

func NewParams ¶ 

func NewParams() Params

NewParams creates a new Params instance.

func (*Params) Descriptor ¶ 

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

func (*Params) Equal ¶ 

func (this *Params) Equal(that interface{}) bool

func (*Params) Marshal ¶ 

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

func (*Params) MarshalTo ¶ 

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

func (*Params) MarshalToSizedBuffer ¶ 

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

func (*Params) ProtoMessage ¶ 

func (*Params) ProtoMessage()

func (*Params) Reset ¶ 

func (m *Params) Reset()

func (*Params) Size ¶ 

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

func (*Params) String ¶ 

func (m *Params) String() string

func (*Params) Unmarshal ¶ 

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

func (Params) Validate ¶ 

func (p Params) Validate() error

Validate validates the set of params.

func (*Params) XXX_DiscardUnknown ¶ 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal ¶ 

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

func (*Params) XXX_Merge ¶ 

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

func (*Params) XXX_Size ¶ 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal ¶ 

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

type QueryClient ¶ 

type QueryClient interface {
	// EthBlock
	EthBlockTip(ctx context.Context, in *QueryEthBlockTipRequest, opts ...grpc.CallOption) (*QueryEthBlockTipResponse, 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 ¶ 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryEthBlockTipRequest ¶ 

type QueryEthBlockTipRequest struct {
}

QueryEthBlockRequest is request type for the Query/EthBlock RPC method.

func (*QueryEthBlockTipRequest) Descriptor ¶ 

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

func (*QueryEthBlockTipRequest) Marshal ¶ 

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

func (*QueryEthBlockTipRequest) MarshalTo ¶ 

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

func (*QueryEthBlockTipRequest) MarshalToSizedBuffer ¶ 

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

func (*QueryEthBlockTipRequest) ProtoMessage ¶ 

func (*QueryEthBlockTipRequest) ProtoMessage()

func (*QueryEthBlockTipRequest) Reset ¶ 

func (m *QueryEthBlockTipRequest) Reset()

func (*QueryEthBlockTipRequest) Size ¶ 

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

func (*QueryEthBlockTipRequest) String ¶ 

func (m *QueryEthBlockTipRequest) String() string

func (*QueryEthBlockTipRequest) Unmarshal ¶ 

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

func (*QueryEthBlockTipRequest) XXX_DiscardUnknown ¶ 

func (m *QueryEthBlockTipRequest) XXX_DiscardUnknown()

func (*QueryEthBlockTipRequest) XXX_Marshal ¶ 

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

func (*QueryEthBlockTipRequest) XXX_Merge ¶ 

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

func (*QueryEthBlockTipRequest) XXX_Size ¶ 

func (m *QueryEthBlockTipRequest) XXX_Size() int

func (*QueryEthBlockTipRequest) XXX_Unmarshal ¶ 

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

type QueryEthBlockTipResponse ¶ 

type QueryEthBlockTipResponse struct {
	Block ExecutionPayload `protobuf:"bytes,1,opt,name=block,proto3" json:"block"`
}

QueryEthBlockResponse is response type for the Query/EthBlock RPC method.

func (*QueryEthBlockTipResponse) Descriptor ¶ 

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

func (*QueryEthBlockTipResponse) GetBlock ¶ 

func (m *QueryEthBlockTipResponse) GetBlock() ExecutionPayload

func (*QueryEthBlockTipResponse) Marshal ¶ 

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

func (*QueryEthBlockTipResponse) MarshalTo ¶ 

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

func (*QueryEthBlockTipResponse) MarshalToSizedBuffer ¶ 

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

func (*QueryEthBlockTipResponse) ProtoMessage ¶ 

func (*QueryEthBlockTipResponse) ProtoMessage()

func (*QueryEthBlockTipResponse) Reset ¶ 

func (m *QueryEthBlockTipResponse) Reset()

func (*QueryEthBlockTipResponse) Size ¶ 

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

func (*QueryEthBlockTipResponse) String ¶ 

func (m *QueryEthBlockTipResponse) String() string

func (*QueryEthBlockTipResponse) Unmarshal ¶ 

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

func (*QueryEthBlockTipResponse) XXX_DiscardUnknown ¶ 

func (m *QueryEthBlockTipResponse) XXX_DiscardUnknown()

func (*QueryEthBlockTipResponse) XXX_Marshal ¶ 

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

func (*QueryEthBlockTipResponse) XXX_Merge ¶ 

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

func (*QueryEthBlockTipResponse) XXX_Size ¶ 

func (m *QueryEthBlockTipResponse) XXX_Size() int

func (*QueryEthBlockTipResponse) XXX_Unmarshal ¶ 

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

type QueryServer ¶ 

type QueryServer interface {
	// EthBlock
	EthBlockTip(context.Context, *QueryEthBlockTipRequest) (*QueryEthBlockTipResponse, error)
}

QueryServer is the server API for Query service.

type RelayerKeeper ¶ 

type RelayerKeeper interface {
	GetCurrentProposer(ctx context.Context) (sdk.AccAddress, error)
	ProcessRelayerRequest(ctx context.Context, req goattypes.RelayerRequests) error
	VerifyProposal(ctx context.Context, req relayer.IVoteMsg, verifyFn ...func(sigdoc []byte) error) (uint64, error)
	VerifyNonProposal(ctx context.Context, req relayer.INonVoteMsg) (relayer.IRelayer, error)
	UpdateRandao(ctx context.Context, req relayer.IVoteMsg) error
	HasPubkey(ctx context.Context, raw []byte) (bool, error)
	AddNewKey(ctx context.Context, raw []byte) error
	SetProposalSeq(ctx context.Context, seq uint64) error
}

type UnimplementedMsgServer ¶ 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) NewEthBlock ¶ 

func (*UnimplementedMsgServer) NewEthBlock(ctx context.Context, req *MsgNewEthBlock) (*MsgNewEthBlockResponse, error)

type UnimplementedQueryServer ¶ 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) EthBlockTip ¶ 

func (*UnimplementedQueryServer) EthBlockTip(ctx context.Context, req *QueryEthBlockTipRequest) (*QueryEthBlockTipResponse, 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.