types

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Mar 13, 2026 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthEvmIbc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvmIbc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvmIbc = 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")
)

Functions

func RegisterMsgHandler

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

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

func RegisterMsgHandlerClient

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

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

func RegisterMsgHandlerFromEndpoint

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

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

func RegisterMsgHandlerServer

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

RegisterMsgHandlerServer registers the http handlers for service Msg to "mux". UnaryRPC :call MsgServer 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 RegisterMsgHandlerFromEndpoint instead.

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 MsgClient

type MsgClient interface {
	// TransferERC721 defines a method to transfer ERC721 tokens between chains via IBC
	TransferERC721(ctx context.Context, in *MsgTransferERC721, opts ...grpc.CallOption) (*MsgTransferERC721Response, 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 MsgServer

type MsgServer interface {
	// TransferERC721 defines a method to transfer ERC721 tokens between chains via IBC
	TransferERC721(context.Context, *MsgTransferERC721) (*MsgTransferERC721Response, error)
}

MsgServer is the server API for Msg service.

type MsgTransferERC721

type MsgTransferERC721 struct {
	EvmContractAddress string `protobuf:"bytes,1,opt,name=evm_contract_address,json=evmContractAddress,proto3" json:"evm_contract_address,omitempty"`
	// tokenID to convert
	EvmTokenIds []string `protobuf:"bytes,2,rep,name=evm_token_ids,json=evmTokenIds,proto3" json:"evm_token_ids,omitempty"`
	// the port on which the packet will be sent
	SourcePort string `protobuf:"bytes,3,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	// the channel by which the packet will be sent
	SourceChannel string `protobuf:"bytes,4,opt,name=source_channel,json=sourceChannel,proto3" json:"source_channel,omitempty"`
	// the class_id of tokens to be transferred
	ClassId string `protobuf:"bytes,5,opt,name=class_id,json=classId,proto3" json:"class_id,omitempty"`
	// the non fungible tokens to be transferred
	CosmosTokenIds []string `protobuf:"bytes,6,rep,name=cosmos_token_ids,json=cosmosTokenIds,proto3" json:"cosmos_token_ids,omitempty"`
	// the sender address
	CosmosSender string `protobuf:"bytes,7,opt,name=cosmos_sender,json=cosmosSender,proto3" json:"cosmos_sender,omitempty"`
	// the recipient address on the destination chain
	CosmosReceiver string `protobuf:"bytes,8,opt,name=cosmos_receiver,json=cosmosReceiver,proto3" json:"cosmos_receiver,omitempty"`
	// Timeout height relative to the current block height.
	// The timeout is disabled when set to 0.
	TimeoutHeight types.Height `protobuf:"bytes,9,opt,name=timeout_height,json=timeoutHeight,proto3" json:"timeout_height"`
	// Timeout timestamp in absolute nanoseconds since unix epoch.
	// The timeout is disabled when set to 0.
	TimeoutTimestamp uint64 `protobuf:"varint,10,opt,name=timeout_timestamp,json=timeoutTimestamp,proto3" json:"timeout_timestamp,omitempty"`
	// optional memo
	Memo string `protobuf:"bytes,11,opt,name=memo,proto3" json:"memo,omitempty"`
}

MsgTransferERC721 defines a message to transfer ERC721 tokens between chains via IBC It contains information about the token contract, token IDs, source and destination of the transfer, timeout parameters and optional memo

func (*MsgTransferERC721) Descriptor

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

func (*MsgTransferERC721) Marshal

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

func (*MsgTransferERC721) MarshalTo

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

func (*MsgTransferERC721) MarshalToSizedBuffer

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

func (*MsgTransferERC721) ProtoMessage

func (*MsgTransferERC721) ProtoMessage()

func (*MsgTransferERC721) Reset

func (m *MsgTransferERC721) Reset()

func (*MsgTransferERC721) Size

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

func (*MsgTransferERC721) String

func (m *MsgTransferERC721) String() string

func (*MsgTransferERC721) Unmarshal

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

func (*MsgTransferERC721) XXX_DiscardUnknown

func (m *MsgTransferERC721) XXX_DiscardUnknown()

func (*MsgTransferERC721) XXX_Marshal

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

func (*MsgTransferERC721) XXX_Merge

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

func (*MsgTransferERC721) XXX_Size

func (m *MsgTransferERC721) XXX_Size() int

func (*MsgTransferERC721) XXX_Unmarshal

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

type MsgTransferERC721Response

type MsgTransferERC721Response struct {
}

MsgTransferERC721Response defines the response type for TransferERC721 RPC

func (*MsgTransferERC721Response) Descriptor

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

func (*MsgTransferERC721Response) Marshal

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

func (*MsgTransferERC721Response) MarshalTo

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

func (*MsgTransferERC721Response) MarshalToSizedBuffer

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

func (*MsgTransferERC721Response) ProtoMessage

func (*MsgTransferERC721Response) ProtoMessage()

func (*MsgTransferERC721Response) Reset

func (m *MsgTransferERC721Response) Reset()

func (*MsgTransferERC721Response) Size

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

func (*MsgTransferERC721Response) String

func (m *MsgTransferERC721Response) String() string

func (*MsgTransferERC721Response) Unmarshal

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

func (*MsgTransferERC721Response) XXX_DiscardUnknown

func (m *MsgTransferERC721Response) XXX_DiscardUnknown()

func (*MsgTransferERC721Response) XXX_Marshal

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

func (*MsgTransferERC721Response) XXX_Merge

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

func (*MsgTransferERC721Response) XXX_Size

func (m *MsgTransferERC721Response) XXX_Size() int

func (*MsgTransferERC721Response) XXX_Unmarshal

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

type QueryClient

type QueryClient interface {
	// EvmContract retrieves a registered evm contract
	EvmContract(ctx context.Context, in *QueryEvmAddressRequest, opts ...grpc.CallOption) (*QueryTokenPairResponse, 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 QueryEvmAddressRequest

type QueryEvmAddressRequest struct {
	// token identifier can be either the hex contract address of the ERC721 or
	// the Cosmos nft classID
	Port    string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty"`
	Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	ClassId string `protobuf:"bytes,3,opt,name=class_id,json=classId,proto3" json:"class_id,omitempty"`
}

QueryEvmAddressRequest is the request type for the Query/TokenPair RPC method.

func (*QueryEvmAddressRequest) Descriptor

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

func (*QueryEvmAddressRequest) GetChannel

func (m *QueryEvmAddressRequest) GetChannel() string

func (*QueryEvmAddressRequest) GetClassId

func (m *QueryEvmAddressRequest) GetClassId() string

func (*QueryEvmAddressRequest) GetPort

func (m *QueryEvmAddressRequest) GetPort() string

func (*QueryEvmAddressRequest) Marshal

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

func (*QueryEvmAddressRequest) MarshalTo

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

func (*QueryEvmAddressRequest) MarshalToSizedBuffer

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

func (*QueryEvmAddressRequest) ProtoMessage

func (*QueryEvmAddressRequest) ProtoMessage()

func (*QueryEvmAddressRequest) Reset

func (m *QueryEvmAddressRequest) Reset()

func (*QueryEvmAddressRequest) Size

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

func (*QueryEvmAddressRequest) String

func (m *QueryEvmAddressRequest) String() string

func (*QueryEvmAddressRequest) Unmarshal

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

func (*QueryEvmAddressRequest) XXX_DiscardUnknown

func (m *QueryEvmAddressRequest) XXX_DiscardUnknown()

func (*QueryEvmAddressRequest) XXX_Marshal

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

func (*QueryEvmAddressRequest) XXX_Merge

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

func (*QueryEvmAddressRequest) XXX_Size

func (m *QueryEvmAddressRequest) XXX_Size() int

func (*QueryEvmAddressRequest) XXX_Unmarshal

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

type QueryServer

type QueryServer interface {
	// EvmContract retrieves a registered evm contract
	EvmContract(context.Context, *QueryEvmAddressRequest) (*QueryTokenPairResponse, error)
}

QueryServer is the server API for Query service.

type QueryTokenPairResponse

type QueryTokenPairResponse struct {
	TokenPair TokenPair `protobuf:"bytes,1,opt,name=token_pair,json=tokenPair,proto3" json:"token_pair"`
}

QueryTokenPairResponse is the response type for the Query/TokenPair RPC method.

func (*QueryTokenPairResponse) Descriptor

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

func (*QueryTokenPairResponse) GetTokenPair

func (m *QueryTokenPairResponse) GetTokenPair() TokenPair

func (*QueryTokenPairResponse) Marshal

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

func (*QueryTokenPairResponse) MarshalTo

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

func (*QueryTokenPairResponse) MarshalToSizedBuffer

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

func (*QueryTokenPairResponse) ProtoMessage

func (*QueryTokenPairResponse) ProtoMessage()

func (*QueryTokenPairResponse) Reset

func (m *QueryTokenPairResponse) Reset()

func (*QueryTokenPairResponse) Size

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

func (*QueryTokenPairResponse) String

func (m *QueryTokenPairResponse) String() string

func (*QueryTokenPairResponse) Unmarshal

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

func (*QueryTokenPairResponse) XXX_DiscardUnknown

func (m *QueryTokenPairResponse) XXX_DiscardUnknown()

func (*QueryTokenPairResponse) XXX_Marshal

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

func (*QueryTokenPairResponse) XXX_Merge

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

func (*QueryTokenPairResponse) XXX_Size

func (m *QueryTokenPairResponse) XXX_Size() int

func (*QueryTokenPairResponse) XXX_Unmarshal

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

type TokenPair

type TokenPair struct {
	// address of ERC721 contract token
	Erc721Address string `protobuf:"bytes,1,opt,name=erc721_address,json=erc721Address,proto3" json:"erc721_address,omitempty"`
	// cosmos nft class ID to be mapped to
	ClassId string `protobuf:"bytes,2,opt,name=class_id,json=classId,proto3" json:"class_id,omitempty"`
}

TokenPair defines an instance that records a pairing consisting of a native Cosmos Coin and an ERC721 token address.

func (*TokenPair) Descriptor

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

func (*TokenPair) GetClassId

func (m *TokenPair) GetClassId() string

func (*TokenPair) GetErc721Address

func (m *TokenPair) GetErc721Address() string

func (*TokenPair) Marshal

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

func (*TokenPair) MarshalTo

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

func (*TokenPair) MarshalToSizedBuffer

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

func (*TokenPair) ProtoMessage

func (*TokenPair) ProtoMessage()

func (*TokenPair) Reset

func (m *TokenPair) Reset()

func (*TokenPair) Size

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

func (*TokenPair) String

func (m *TokenPair) String() string

func (*TokenPair) Unmarshal

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

func (*TokenPair) XXX_DiscardUnknown

func (m *TokenPair) XXX_DiscardUnknown()

func (*TokenPair) XXX_Marshal

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

func (*TokenPair) XXX_Merge

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

func (*TokenPair) XXX_Size

func (m *TokenPair) XXX_Size() int

func (*TokenPair) XXX_Unmarshal

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

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) TransferERC721

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) EvmContract

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL