types

package
v0.0.0-...-eab7081 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2023 License: Apache-2.0 Imports: 27 Imported by: 2

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypePayForGas      = "payforgas"
	EventTypeGasDataSet     = "remotegasdataset"
	EventTypeSetGasOverhead = "destinationgasoverheadset"
	EventTypeCreateIgp      = "createigp"
	EventTypeUpdateOracle   = "updateoracle"
	EventTypeCreateOracle   = "createoracle"
	EventTypeSetBeneficiary = "setbeneficiary"

	AttributeIgpId             = "igpid"
	AttributeOracleAddress     = "oracle"
	AttributeBeneficiary       = "beneficiary"
	AttributeRemoteDomain      = "remotedomain"
	AttributeTokenExchangeRate = "tokenexchangerate"
	AttributeMessageId         = "messageid"
	AttributeGasPrice          = "gasprice"
	AttributeDestination       = "destination"
	AttributeOverheadAmount    = "amount"
	AttributeGasAmount         = "amount"
	AttributePayment           = "payment"
	AttributeKeySender         = "sender"
)
View Source 
const (
	// ModuleName for the hyperlane interchain-gas-paymaster
	ModuleName = "hyperlane-igp"

	// StoreKey is the store key string for hyperlane interchain-gas-paymaster
	StoreKey = ModuleName
)

Variables

View Source 
var (
	ErrGasPaid                 = errorsmod.Register(ModuleName, 2, "message gas already paid")
	ErrInvalidRelayer          = errorsmod.Register(ModuleName, 3, "invalid relayer")
	ErrOracleUnauthorized      = errorsmod.Register(ModuleName, 4, "unauthorized to set oracle configuration")
	ErrInvalidIgp              = errorsmod.Register(ModuleName, 5, "invalid IGP")
	ErrBeneficiaryUnauthorized = errorsmod.Register(ModuleName, 6, "unauthorized to set beneficiary")
	ErrExchangeRateScale       = errorsmod.Register(ModuleName, 7, "invalid exchange rate scale")
	ErrInvalidPaymentDenom     = errorsmod.Register(ModuleName, 8, "invalid payment denom")
	ErrEmptyMessageId          = errorsmod.Register(ModuleName, 9, "invalid message ID (empty string)")
	ErrInvalidOracleConfig     = errorsmod.Register(ModuleName, 10, "invalid oracle configuration (empty)")
	ErrExchangeRate            = errorsmod.Register(ModuleName, 11, "invalid token exchange rate")
	ErrGasPrice                = errorsmod.Register(ModuleName, 12, "invalid gas price, must be gt zero")
	ErrGasOverhead             = errorsmod.Register(ModuleName, 13, "invalid gas overhead, must be gte zero")
)
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 (
	ErrInvalidLengthIgp        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIgp          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIgp = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	GasOverhead       = []byte{0x00}
	GasPaidKey        = []byte{0x1}
	DefaultRelayerKey = []byte{0x2}
	OracleKey         = []byte{0x3}
	IgpKey            = []byte{0x4}
	ClaimsKey         = []byte{0x5}
)

KVStore keys

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 (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces registers the hyperlane igp implementations and interfaces.

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 GasOracle 

type GasOracle struct {
	// Address of the oracle that can update this config
	GasOracle string `protobuf:"bytes,1,opt,name=gas_oracle,json=gasOracle,proto3" json:"gas_oracle,omitempty"`
	// The domain of the message's destination chain
	RemoteDomain      uint32                                 `protobuf:"varint,2,opt,name=remote_domain,json=remoteDomain,proto3" json:"remote_domain,omitempty"`
	TokenExchangeRate github_com_cosmos_cosmos_sdk_types.Int `` /* 154-byte string literal not displayed */
	GasPrice          github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,4,opt,name=gas_price,json=gasPrice,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"gas_price"`
	// gas overhead for the remote domain
	GasOverhead github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */
}

Hyperlane's gas oracle to configure exchange rates between origin and destination

func (*GasOracle) Descriptor 

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

func (*GasOracle) Marshal 

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

func (*GasOracle) MarshalTo 

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

func (*GasOracle) MarshalToSizedBuffer 

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

func (*GasOracle) ProtoMessage 

func (*GasOracle) ProtoMessage()

func (*GasOracle) Reset 

func (m *GasOracle) Reset()

func (*GasOracle) Size 

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

func (*GasOracle) String 

func (m *GasOracle) String() string

func (*GasOracle) Unmarshal 

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

func (*GasOracle) XXX_DiscardUnknown 

func (m *GasOracle) XXX_DiscardUnknown()

func (*GasOracle) XXX_Marshal 

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

func (*GasOracle) XXX_Merge 

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

func (*GasOracle) XXX_Size 

func (m *GasOracle) XXX_Size() int

func (*GasOracle) XXX_Unmarshal 

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

type GasOracleConfig 

type GasOracleConfig struct {
	// The IGP that this gas oracle config belongs to
	IgpId uint32 `protobuf:"varint,1,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
	// The address that can update gas oracle configs for the remote domain
	GasOracle string `protobuf:"bytes,2,opt,name=gas_oracle,json=gasOracle,proto3" json:"gas_oracle,omitempty"`
	// The domain that the gas oracle can update gas related information for
	RemoteDomain uint32 `protobuf:"varint,3,opt,name=remote_domain,json=remoteDomain,proto3" json:"remote_domain,omitempty"`
}

Hyperlane's gas oracle to configure exchange rates between origin and destination

func (*GasOracleConfig) Descriptor 

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

func (*GasOracleConfig) Marshal 

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

func (*GasOracleConfig) MarshalTo 

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

func (*GasOracleConfig) MarshalToSizedBuffer 

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

func (*GasOracleConfig) ProtoMessage 

func (*GasOracleConfig) ProtoMessage()

func (*GasOracleConfig) Reset 

func (m *GasOracleConfig) Reset()

func (*GasOracleConfig) Size 

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

func (*GasOracleConfig) String 

func (m *GasOracleConfig) String() string

func (*GasOracleConfig) Unmarshal 

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

func (*GasOracleConfig) XXX_DiscardUnknown 

func (m *GasOracleConfig) XXX_DiscardUnknown()

func (*GasOracleConfig) XXX_Marshal 

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

func (*GasOracleConfig) XXX_Merge 

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

func (*GasOracleConfig) XXX_Size 

func (m *GasOracleConfig) XXX_Size() int

func (*GasOracleConfig) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct{}

Hyperlane InterchainGasPaymaster's keeper genesis state

func (*GenesisState) Descriptor 

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

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 GetBeneficiaryRequest 

type GetBeneficiaryRequest struct {
	// The IGP of the beneficiary
	IgpId uint32 `protobuf:"varint,3,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
}

GetBeneficiaryRequest is the request type for the Query/Tree RPC method.

func (*GetBeneficiaryRequest) Descriptor 

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

func (*GetBeneficiaryRequest) GetIgpId 

func (m *GetBeneficiaryRequest) GetIgpId() uint32

func (*GetBeneficiaryRequest) Marshal 

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

func (*GetBeneficiaryRequest) MarshalTo 

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

func (*GetBeneficiaryRequest) MarshalToSizedBuffer 

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

func (*GetBeneficiaryRequest) ProtoMessage 

func (*GetBeneficiaryRequest) ProtoMessage()

func (*GetBeneficiaryRequest) Reset 

func (m *GetBeneficiaryRequest) Reset()

func (*GetBeneficiaryRequest) Size 

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

func (*GetBeneficiaryRequest) String 

func (m *GetBeneficiaryRequest) String() string

func (*GetBeneficiaryRequest) Unmarshal 

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

func (*GetBeneficiaryRequest) XXX_DiscardUnknown 

func (m *GetBeneficiaryRequest) XXX_DiscardUnknown()

func (*GetBeneficiaryRequest) XXX_Marshal 

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

func (*GetBeneficiaryRequest) XXX_Merge 

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

func (*GetBeneficiaryRequest) XXX_Size 

func (m *GetBeneficiaryRequest) XXX_Size() int

func (*GetBeneficiaryRequest) XXX_Unmarshal 

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

type GetBeneficiaryResponse 

type GetBeneficiaryResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

GetBeneficiaryResponse is the response type for the Query/Tree RPC method.

func (*GetBeneficiaryResponse) Descriptor 

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

func (*GetBeneficiaryResponse) GetAddress 

func (m *GetBeneficiaryResponse) GetAddress() string

func (*GetBeneficiaryResponse) Marshal 

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

func (*GetBeneficiaryResponse) MarshalTo 

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

func (*GetBeneficiaryResponse) MarshalToSizedBuffer 

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

func (*GetBeneficiaryResponse) ProtoMessage 

func (*GetBeneficiaryResponse) ProtoMessage()

func (*GetBeneficiaryResponse) Reset 

func (m *GetBeneficiaryResponse) Reset()

func (*GetBeneficiaryResponse) Size 

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

func (*GetBeneficiaryResponse) String 

func (m *GetBeneficiaryResponse) String() string

func (*GetBeneficiaryResponse) Unmarshal 

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

func (*GetBeneficiaryResponse) XXX_DiscardUnknown 

func (m *GetBeneficiaryResponse) XXX_DiscardUnknown()

func (*GetBeneficiaryResponse) XXX_Marshal 

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

func (*GetBeneficiaryResponse) XXX_Merge 

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

func (*GetBeneficiaryResponse) XXX_Size 

func (m *GetBeneficiaryResponse) XXX_Size() int

func (*GetBeneficiaryResponse) XXX_Unmarshal 

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

type GetExchangeRateAndGasPriceRequest 

type GetExchangeRateAndGasPriceRequest struct {
	DestinationDomain uint32 `protobuf:"varint,1,opt,name=destination_domain,json=destinationDomain,proto3" json:"destination_domain,omitempty"`
	IgpId             uint32 `protobuf:"varint,2,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
}

GetExchangeRateAndGasPriceRequest is the request type for the Query/Tree RPC method.

func (*GetExchangeRateAndGasPriceRequest) Descriptor 

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

func (*GetExchangeRateAndGasPriceRequest) GetDestinationDomain 

func (m *GetExchangeRateAndGasPriceRequest) GetDestinationDomain() uint32

func (*GetExchangeRateAndGasPriceRequest) GetIgpId 

func (m *GetExchangeRateAndGasPriceRequest) GetIgpId() uint32

func (*GetExchangeRateAndGasPriceRequest) Marshal 

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

func (*GetExchangeRateAndGasPriceRequest) MarshalTo 

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

func (*GetExchangeRateAndGasPriceRequest) MarshalToSizedBuffer 

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

func (*GetExchangeRateAndGasPriceRequest) ProtoMessage 

func (*GetExchangeRateAndGasPriceRequest) ProtoMessage()

func (*GetExchangeRateAndGasPriceRequest) Reset 

func (m *GetExchangeRateAndGasPriceRequest) Reset()

func (*GetExchangeRateAndGasPriceRequest) Size 

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

func (*GetExchangeRateAndGasPriceRequest) String 

func (m *GetExchangeRateAndGasPriceRequest) String() string

func (*GetExchangeRateAndGasPriceRequest) Unmarshal 

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

func (*GetExchangeRateAndGasPriceRequest) XXX_DiscardUnknown 

func (m *GetExchangeRateAndGasPriceRequest) XXX_DiscardUnknown()

func (*GetExchangeRateAndGasPriceRequest) XXX_Marshal 

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

func (*GetExchangeRateAndGasPriceRequest) XXX_Merge 

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

func (*GetExchangeRateAndGasPriceRequest) XXX_Size 

func (m *GetExchangeRateAndGasPriceRequest) XXX_Size() int

func (*GetExchangeRateAndGasPriceRequest) XXX_Unmarshal 

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

type GetExchangeRateAndGasPriceResponse 

type GetExchangeRateAndGasPriceResponse struct {
	TokenExchangeRate github_com_cosmos_cosmos_sdk_types.Int `` /* 154-byte string literal not displayed */
	GasPrice          github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=gas_price,json=gasPrice,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"gas_price"`
}

GetExchangeRateAndGasPriceResponse is the response type for the Query/Tree RPC method.

func (*GetExchangeRateAndGasPriceResponse) Descriptor 

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

func (*GetExchangeRateAndGasPriceResponse) Marshal 

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

func (*GetExchangeRateAndGasPriceResponse) MarshalTo 

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

func (*GetExchangeRateAndGasPriceResponse) MarshalToSizedBuffer 

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

func (*GetExchangeRateAndGasPriceResponse) ProtoMessage 

func (*GetExchangeRateAndGasPriceResponse) ProtoMessage()

func (*GetExchangeRateAndGasPriceResponse) Reset 

func (m *GetExchangeRateAndGasPriceResponse) Reset()

func (*GetExchangeRateAndGasPriceResponse) Size 

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

func (*GetExchangeRateAndGasPriceResponse) String 

func (m *GetExchangeRateAndGasPriceResponse) String() string

func (*GetExchangeRateAndGasPriceResponse) Unmarshal 

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

func (*GetExchangeRateAndGasPriceResponse) XXX_DiscardUnknown 

func (m *GetExchangeRateAndGasPriceResponse) XXX_DiscardUnknown()

func (*GetExchangeRateAndGasPriceResponse) XXX_Marshal 

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

func (*GetExchangeRateAndGasPriceResponse) XXX_Merge 

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

func (*GetExchangeRateAndGasPriceResponse) XXX_Size 

func (m *GetExchangeRateAndGasPriceResponse) XXX_Size() int

func (*GetExchangeRateAndGasPriceResponse) XXX_Unmarshal 

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

type Igp 

type Igp struct {
	// Only the owner can update the IGP.
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// An owner can own multiple IGPs. This ID is globally unique.
	IgpId uint32 `protobuf:"varint,2,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
	// If a beneficiary is set, it will be paid relayer costs instead of the
	// owner.
	Beneficiary            string                                 `protobuf:"bytes,3,opt,name=beneficiary,proto3" json:"beneficiary,omitempty"`
	TokenExchangeRateScale github_com_cosmos_cosmos_sdk_types.Int `` /* 171-byte string literal not displayed */
	// Key is the remote domain of the gas oracle
	Oracles map[uint32]*GasOracle `` /* 156-byte string literal not displayed */
}

Hyperlane's IGP. An IGP instance always has one relayer beneficiary. Each IGP has gas oracles, one oracle for each destination it serves. The gas oracle is a cosmos address that is allowed to update gas prices.

func (*Igp) Descriptor 

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

func (*Igp) GetBeneficiary 

func (m *Igp) GetBeneficiary() string

func (*Igp) GetIgpId 

func (m *Igp) GetIgpId() uint32

func (*Igp) GetOracles 

func (m *Igp) GetOracles() map[uint32]*GasOracle

func (*Igp) GetOwner 

func (m *Igp) GetOwner() string

func (*Igp) Marshal 

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

func (*Igp) MarshalTo 

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

func (*Igp) MarshalToSizedBuffer 

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

func (*Igp) ProtoMessage 

func (*Igp) ProtoMessage()

func (*Igp) Reset 

func (m *Igp) Reset()

func (*Igp) Size 

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

func (*Igp) String 

func (m *Igp) String() string

func (*Igp) Unmarshal 

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

func (*Igp) XXX_DiscardUnknown 

func (m *Igp) XXX_DiscardUnknown()

func (*Igp) XXX_Marshal 

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

func (*Igp) XXX_Merge 

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

func (*Igp) XXX_Size 

func (m *Igp) XXX_Size() int

func (*Igp) XXX_Unmarshal 

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

type MsgClaim 

type MsgClaim struct {
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
}

MsgClaim defines the request type for the Claim rpc.

func (*MsgClaim) Descriptor 

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

func (MsgClaim) GetSigners 

func (m MsgClaim) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgClaim) Marshal 

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

func (*MsgClaim) MarshalTo 

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

func (*MsgClaim) MarshalToSizedBuffer 

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

func (*MsgClaim) ProtoMessage 

func (*MsgClaim) ProtoMessage()

func (*MsgClaim) Reset 

func (m *MsgClaim) Reset()

func (*MsgClaim) Size 

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

func (*MsgClaim) String 

func (m *MsgClaim) String() string

func (*MsgClaim) Unmarshal 

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

func (MsgClaim) ValidateBasic 

func (m MsgClaim) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgClaim) XXX_DiscardUnknown 

func (m *MsgClaim) XXX_DiscardUnknown()

func (*MsgClaim) XXX_Marshal 

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

func (*MsgClaim) XXX_Merge 

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

func (*MsgClaim) XXX_Size 

func (m *MsgClaim) XXX_Size() int

func (*MsgClaim) XXX_Unmarshal 

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

type MsgClaimResponse 

type MsgClaimResponse struct{}

MsgClaimResponse defines the Claim response type.

func (*MsgClaimResponse) Descriptor 

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

func (*MsgClaimResponse) Marshal 

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

func (*MsgClaimResponse) MarshalTo 

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

func (*MsgClaimResponse) MarshalToSizedBuffer 

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

func (*MsgClaimResponse) ProtoMessage 

func (*MsgClaimResponse) ProtoMessage()

func (*MsgClaimResponse) Reset 

func (m *MsgClaimResponse) Reset()

func (*MsgClaimResponse) Size 

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

func (*MsgClaimResponse) String 

func (m *MsgClaimResponse) String() string

func (*MsgClaimResponse) Unmarshal 

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

func (*MsgClaimResponse) XXX_DiscardUnknown 

func (m *MsgClaimResponse) XXX_DiscardUnknown()

func (*MsgClaimResponse) XXX_Marshal 

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

func (*MsgClaimResponse) XXX_Merge 

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

func (*MsgClaimResponse) XXX_Size 

func (m *MsgClaimResponse) XXX_Size() int

func (*MsgClaimResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// Create the IGP, optionally providing a beneficiary.
	CreateIgp(ctx context.Context, in *MsgCreateIgp, opts ...grpc.CallOption) (*MsgCreateIgpResponse, error)
	// Deposits a payment for the relaying of a message to its destination chain.
	PayForGas(ctx context.Context, in *MsgPayForGas, opts ...grpc.CallOption) (*MsgPayForGasResponse, error)
	// Sets the gas oracle data for a specific remote domain
	SetRemoteGasData(ctx context.Context, in *MsgSetRemoteGasData, opts ...grpc.CallOption) (*MsgSetRemoteGasDataResponse, error)
	// Sets the gas oracles for remote domains specified in the config array.
	SetGasOracles(ctx context.Context, in *MsgSetGasOracles, opts ...grpc.CallOption) (*MsgSetGasOraclesResponse, error)
	// Sets the beneficiary.
	SetBeneficiary(ctx context.Context, in *MsgSetBeneficiary, opts ...grpc.CallOption) (*MsgSetBeneficiaryResponse, error)
	// Sets the overhead gas for the destination domain. This is in the
	// destination gas denom and will be added to the required payForGas payment.
	SetDestinationGasOverhead(ctx context.Context, in *MsgSetDestinationGasOverhead, opts ...grpc.CallOption) (*MsgSetDestinationGasOverheadResponse, 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 MsgCreateIgp 

type MsgCreateIgp struct {
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// If empty, the sender will be considered the beneficiary
	Beneficiary string `protobuf:"bytes,2,opt,name=beneficiary,proto3" json:"beneficiary,omitempty"`
	// TODO: Do we really want this in the IGP creation (as it is in the hyperlane
	// .sol contract)? Or the gas oracle?
	TokenExchangeRateScale github_com_cosmos_cosmos_sdk_types.Int `` /* 171-byte string literal not displayed */
}

MsgCreateIgp defines the request type to create a hyperlane IGP.

func (*MsgCreateIgp) Descriptor 

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

func (MsgCreateIgp) GetSigners 

func (m MsgCreateIgp) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgCreateIgp) Marshal 

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

func (*MsgCreateIgp) MarshalTo 

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

func (*MsgCreateIgp) MarshalToSizedBuffer 

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

func (*MsgCreateIgp) ProtoMessage 

func (*MsgCreateIgp) ProtoMessage()

func (*MsgCreateIgp) Reset 

func (m *MsgCreateIgp) Reset()

func (*MsgCreateIgp) Size 

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

func (*MsgCreateIgp) String 

func (m *MsgCreateIgp) String() string

func (*MsgCreateIgp) Unmarshal 

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

func (MsgCreateIgp) ValidateBasic 

func (m MsgCreateIgp) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgCreateIgp) XXX_DiscardUnknown 

func (m *MsgCreateIgp) XXX_DiscardUnknown()

func (*MsgCreateIgp) XXX_Marshal 

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

func (*MsgCreateIgp) XXX_Merge 

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

func (*MsgCreateIgp) XXX_Size 

func (m *MsgCreateIgp) XXX_Size() int

func (*MsgCreateIgp) XXX_Unmarshal 

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

type MsgCreateIgpResponse 

type MsgCreateIgpResponse struct {
	// The unique ID assigned to the newly created IGP
	IgpId uint32 `protobuf:"varint,1,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
}

MsgCreateIgpResponse defines the MsgCreateIgp response type.

func (*MsgCreateIgpResponse) Descriptor 

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

func (*MsgCreateIgpResponse) GetIgpId 

func (m *MsgCreateIgpResponse) GetIgpId() uint32

func (*MsgCreateIgpResponse) Marshal 

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

func (*MsgCreateIgpResponse) MarshalTo 

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

func (*MsgCreateIgpResponse) MarshalToSizedBuffer 

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

func (*MsgCreateIgpResponse) ProtoMessage 

func (*MsgCreateIgpResponse) ProtoMessage()

func (*MsgCreateIgpResponse) Reset 

func (m *MsgCreateIgpResponse) Reset()

func (*MsgCreateIgpResponse) Size 

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

func (*MsgCreateIgpResponse) String 

func (m *MsgCreateIgpResponse) String() string

func (*MsgCreateIgpResponse) Unmarshal 

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

func (*MsgCreateIgpResponse) XXX_DiscardUnknown 

func (m *MsgCreateIgpResponse) XXX_DiscardUnknown()

func (*MsgCreateIgpResponse) XXX_Marshal 

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

func (*MsgCreateIgpResponse) XXX_Merge 

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

func (*MsgCreateIgpResponse) XXX_Size 

func (m *MsgCreateIgpResponse) XXX_Size() int

func (*MsgCreateIgpResponse) XXX_Unmarshal 

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

type MsgPayForGas 

type MsgPayForGas struct {
	Sender            string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	MessageId         string `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	DestinationDomain uint32 `protobuf:"varint,3,opt,name=destination_domain,json=destinationDomain,proto3" json:"destination_domain,omitempty"`
	// The amount of destination gas you are willing to pay for
	GasAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 128-byte string literal not displayed */
	// The maximum payment (in the chain's native denom) that will be paid for
	// relaying fees. If the required payment is less than this amount (according
	// to quoteGasPayment), the lesser is charged. If the required payment exceeds
	// this amount, the transaction will fail (no charge).
	MaximumPayment types.Coin `protobuf:"bytes,5,opt,name=maximum_payment,json=maximumPayment,proto3" json:"maximum_payment"`
	// If any IGP other than the default (0) was used, this should be specified.
	// We will use it to check gas costs to make sure the payer is not overpaying.
	IgpId uint32 `protobuf:"varint,6,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
}

MsgPayForGas submits payment for the relaying of a message to its destination chain..

func (*MsgPayForGas) Descriptor 

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

func (MsgPayForGas) GetSigners 

func (m MsgPayForGas) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgPayForGas) Marshal 

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

func (*MsgPayForGas) MarshalTo 

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

func (*MsgPayForGas) MarshalToSizedBuffer 

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

func (*MsgPayForGas) ProtoMessage 

func (*MsgPayForGas) ProtoMessage()

func (*MsgPayForGas) Reset 

func (m *MsgPayForGas) Reset()

func (*MsgPayForGas) Size 

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

func (*MsgPayForGas) String 

func (m *MsgPayForGas) String() string

func (*MsgPayForGas) Unmarshal 

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

func (MsgPayForGas) ValidateBasic 

func (m MsgPayForGas) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgPayForGas) XXX_DiscardUnknown 

func (m *MsgPayForGas) XXX_DiscardUnknown()

func (*MsgPayForGas) XXX_Marshal 

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

func (*MsgPayForGas) XXX_Merge 

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

func (*MsgPayForGas) XXX_Size 

func (m *MsgPayForGas) XXX_Size() int

func (*MsgPayForGas) XXX_Unmarshal 

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

type MsgPayForGasResponse 

type MsgPayForGasResponse struct{}

MsgPayForGasResponse defines the PayForGas response type.

func (*MsgPayForGasResponse) Descriptor 

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

func (*MsgPayForGasResponse) Marshal 

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

func (*MsgPayForGasResponse) MarshalTo 

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

func (*MsgPayForGasResponse) MarshalToSizedBuffer 

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

func (*MsgPayForGasResponse) ProtoMessage 

func (*MsgPayForGasResponse) ProtoMessage()

func (*MsgPayForGasResponse) Reset 

func (m *MsgPayForGasResponse) Reset()

func (*MsgPayForGasResponse) Size 

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

func (*MsgPayForGasResponse) String 

func (m *MsgPayForGasResponse) String() string

func (*MsgPayForGasResponse) Unmarshal 

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

func (*MsgPayForGasResponse) XXX_DiscardUnknown 

func (m *MsgPayForGasResponse) XXX_DiscardUnknown()

func (*MsgPayForGasResponse) XXX_Marshal 

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

func (*MsgPayForGasResponse) XXX_Merge 

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

func (*MsgPayForGasResponse) XXX_Size 

func (m *MsgPayForGasResponse) XXX_Size() int

func (*MsgPayForGasResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// Create the IGP, optionally providing a beneficiary.
	CreateIgp(context.Context, *MsgCreateIgp) (*MsgCreateIgpResponse, error)
	// Deposits a payment for the relaying of a message to its destination chain.
	PayForGas(context.Context, *MsgPayForGas) (*MsgPayForGasResponse, error)
	// Sets the gas oracle data for a specific remote domain
	SetRemoteGasData(context.Context, *MsgSetRemoteGasData) (*MsgSetRemoteGasDataResponse, error)
	// Sets the gas oracles for remote domains specified in the config array.
	SetGasOracles(context.Context, *MsgSetGasOracles) (*MsgSetGasOraclesResponse, error)
	// Sets the beneficiary.
	SetBeneficiary(context.Context, *MsgSetBeneficiary) (*MsgSetBeneficiaryResponse, error)
	// Sets the overhead gas for the destination domain. This is in the
	// destination gas denom and will be added to the required payForGas payment.
	SetDestinationGasOverhead(context.Context, *MsgSetDestinationGasOverhead) (*MsgSetDestinationGasOverheadResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetBeneficiary 

type MsgSetBeneficiary struct {
	Sender  string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// The IGP the beneficiary is being set for
	IgpId uint32 `protobuf:"varint,3,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
}

MsgSetBeneficiary defines the request type for the SetBeneficiary rpc.

func (*MsgSetBeneficiary) Descriptor 

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

func (MsgSetBeneficiary) GetSigners 

func (m MsgSetBeneficiary) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgSetBeneficiary) Marshal 

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

func (*MsgSetBeneficiary) MarshalTo 

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

func (*MsgSetBeneficiary) MarshalToSizedBuffer 

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

func (*MsgSetBeneficiary) ProtoMessage 

func (*MsgSetBeneficiary) ProtoMessage()

func (*MsgSetBeneficiary) Reset 

func (m *MsgSetBeneficiary) Reset()

func (*MsgSetBeneficiary) Size 

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

func (*MsgSetBeneficiary) String 

func (m *MsgSetBeneficiary) String() string

func (*MsgSetBeneficiary) Unmarshal 

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

func (MsgSetBeneficiary) ValidateBasic 

func (m MsgSetBeneficiary) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgSetBeneficiary) XXX_DiscardUnknown 

func (m *MsgSetBeneficiary) XXX_DiscardUnknown()

func (*MsgSetBeneficiary) XXX_Marshal 

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

func (*MsgSetBeneficiary) XXX_Merge 

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

func (*MsgSetBeneficiary) XXX_Size 

func (m *MsgSetBeneficiary) XXX_Size() int

func (*MsgSetBeneficiary) XXX_Unmarshal 

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

type MsgSetBeneficiaryResponse 

type MsgSetBeneficiaryResponse struct{}

MsgSetBeneficiaryResponse defines the MsgSetBeneficiary response type.

func (*MsgSetBeneficiaryResponse) Descriptor 

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

func (*MsgSetBeneficiaryResponse) Marshal 

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

func (*MsgSetBeneficiaryResponse) MarshalTo 

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

func (*MsgSetBeneficiaryResponse) MarshalToSizedBuffer 

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

func (*MsgSetBeneficiaryResponse) ProtoMessage 

func (*MsgSetBeneficiaryResponse) ProtoMessage()

func (*MsgSetBeneficiaryResponse) Reset 

func (m *MsgSetBeneficiaryResponse) Reset()

func (*MsgSetBeneficiaryResponse) Size 

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

func (*MsgSetBeneficiaryResponse) String 

func (m *MsgSetBeneficiaryResponse) String() string

func (*MsgSetBeneficiaryResponse) Unmarshal 

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

func (*MsgSetBeneficiaryResponse) XXX_DiscardUnknown 

func (m *MsgSetBeneficiaryResponse) XXX_DiscardUnknown()

func (*MsgSetBeneficiaryResponse) XXX_Marshal 

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

func (*MsgSetBeneficiaryResponse) XXX_Merge 

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

func (*MsgSetBeneficiaryResponse) XXX_Size 

func (m *MsgSetBeneficiaryResponse) XXX_Size() int

func (*MsgSetBeneficiaryResponse) XXX_Unmarshal 

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

type MsgSetDestinationGasOverhead 

type MsgSetDestinationGasOverhead struct {
	Sender            string                                 `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	DestinationDomain uint32                                 `protobuf:"varint,2,opt,name=destination_domain,json=destinationDomain,proto3" json:"destination_domain,omitempty"`
	GasOverhead       github_com_cosmos_cosmos_sdk_types.Int `` /* 134-byte string literal not displayed */
	// Identifies the IGP the gas overhead configuration applies to
	IgpId uint32 `protobuf:"varint,4,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
}

MsgSetDestinationGasOverhead defines the overhead gas amount for the given destination.

func (*MsgSetDestinationGasOverhead) Descriptor 

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

func (MsgSetDestinationGasOverhead) GetSigners 

func (m MsgSetDestinationGasOverhead) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgSetDestinationGasOverhead) Marshal 

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

func (*MsgSetDestinationGasOverhead) MarshalTo 

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

func (*MsgSetDestinationGasOverhead) MarshalToSizedBuffer 

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

func (*MsgSetDestinationGasOverhead) ProtoMessage 

func (*MsgSetDestinationGasOverhead) ProtoMessage()

func (*MsgSetDestinationGasOverhead) Reset 

func (m *MsgSetDestinationGasOverhead) Reset()

func (*MsgSetDestinationGasOverhead) Size 

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

func (*MsgSetDestinationGasOverhead) String 

func (m *MsgSetDestinationGasOverhead) String() string

func (*MsgSetDestinationGasOverhead) Unmarshal 

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

func (MsgSetDestinationGasOverhead) ValidateBasic 

func (m MsgSetDestinationGasOverhead) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgSetDestinationGasOverhead) XXX_DiscardUnknown 

func (m *MsgSetDestinationGasOverhead) XXX_DiscardUnknown()

func (*MsgSetDestinationGasOverhead) XXX_Marshal 

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

func (*MsgSetDestinationGasOverhead) XXX_Merge 

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

func (*MsgSetDestinationGasOverhead) XXX_Size 

func (m *MsgSetDestinationGasOverhead) XXX_Size() int

func (*MsgSetDestinationGasOverhead) XXX_Unmarshal 

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

type MsgSetDestinationGasOverheadResponse 

type MsgSetDestinationGasOverheadResponse struct{}

MsgSetDestinationGasOverheadResponse defines the SetDestinationGasOverhead response type.

func (*MsgSetDestinationGasOverheadResponse) Descriptor 

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

func (*MsgSetDestinationGasOverheadResponse) Marshal 

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

func (*MsgSetDestinationGasOverheadResponse) MarshalTo 

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

func (*MsgSetDestinationGasOverheadResponse) MarshalToSizedBuffer 

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

func (*MsgSetDestinationGasOverheadResponse) ProtoMessage 

func (*MsgSetDestinationGasOverheadResponse) ProtoMessage()

func (*MsgSetDestinationGasOverheadResponse) Reset 

func (m *MsgSetDestinationGasOverheadResponse) Reset()

func (*MsgSetDestinationGasOverheadResponse) Size 

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

func (*MsgSetDestinationGasOverheadResponse) String 

func (m *MsgSetDestinationGasOverheadResponse) String() string

func (*MsgSetDestinationGasOverheadResponse) Unmarshal 

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

func (*MsgSetDestinationGasOverheadResponse) XXX_DiscardUnknown 

func (m *MsgSetDestinationGasOverheadResponse) XXX_DiscardUnknown()

func (*MsgSetDestinationGasOverheadResponse) XXX_Marshal 

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

func (*MsgSetDestinationGasOverheadResponse) XXX_Merge 

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

func (*MsgSetDestinationGasOverheadResponse) XXX_Size 

func (m *MsgSetDestinationGasOverheadResponse) XXX_Size() int

func (*MsgSetDestinationGasOverheadResponse) XXX_Unmarshal 

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

type MsgSetGasOracles 

type MsgSetGasOracles struct {
	Sender  string             `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Configs []*GasOracleConfig `protobuf:"bytes,2,rep,name=configs,proto3" json:"configs,omitempty"`
}

MsgSetGasOracles set the addresses allowed to define spot prices for relay fee payment.

func (*MsgSetGasOracles) Descriptor 

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

func (MsgSetGasOracles) GetSigners 

func (m MsgSetGasOracles) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgSetGasOracles) Marshal 

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

func (*MsgSetGasOracles) MarshalTo 

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

func (*MsgSetGasOracles) MarshalToSizedBuffer 

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

func (*MsgSetGasOracles) ProtoMessage 

func (*MsgSetGasOracles) ProtoMessage()

func (*MsgSetGasOracles) Reset 

func (m *MsgSetGasOracles) Reset()

func (*MsgSetGasOracles) Size 

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

func (*MsgSetGasOracles) String 

func (m *MsgSetGasOracles) String() string

func (*MsgSetGasOracles) Unmarshal 

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

func (MsgSetGasOracles) ValidateBasic 

func (m MsgSetGasOracles) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgSetGasOracles) XXX_DiscardUnknown 

func (m *MsgSetGasOracles) XXX_DiscardUnknown()

func (*MsgSetGasOracles) XXX_Marshal 

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

func (*MsgSetGasOracles) XXX_Merge 

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

func (*MsgSetGasOracles) XXX_Size 

func (m *MsgSetGasOracles) XXX_Size() int

func (*MsgSetGasOracles) XXX_Unmarshal 

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

type MsgSetGasOraclesResponse 

type MsgSetGasOraclesResponse struct{}

MsgSetGasOraclesResponse defines the Claim response type.

func (*MsgSetGasOraclesResponse) Descriptor 

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

func (*MsgSetGasOraclesResponse) Marshal 

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

func (*MsgSetGasOraclesResponse) MarshalTo 

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

func (*MsgSetGasOraclesResponse) MarshalToSizedBuffer 

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

func (*MsgSetGasOraclesResponse) ProtoMessage 

func (*MsgSetGasOraclesResponse) ProtoMessage()

func (*MsgSetGasOraclesResponse) Reset 

func (m *MsgSetGasOraclesResponse) Reset()

func (*MsgSetGasOraclesResponse) Size 

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

func (*MsgSetGasOraclesResponse) String 

func (m *MsgSetGasOraclesResponse) String() string

func (*MsgSetGasOraclesResponse) Unmarshal 

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

func (*MsgSetGasOraclesResponse) XXX_DiscardUnknown 

func (m *MsgSetGasOraclesResponse) XXX_DiscardUnknown()

func (*MsgSetGasOraclesResponse) XXX_Marshal 

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

func (*MsgSetGasOraclesResponse) XXX_Merge 

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

func (*MsgSetGasOraclesResponse) XXX_Size 

func (m *MsgSetGasOraclesResponse) XXX_Size() int

func (*MsgSetGasOraclesResponse) XXX_Unmarshal 

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

type MsgSetRemoteGasData 

type MsgSetRemoteGasData struct {
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	// The IGP that this gas oracle config belongs to
	IgpId             uint32                                 `protobuf:"varint,2,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
	RemoteDomain      uint32                                 `protobuf:"varint,3,opt,name=remote_domain,json=remoteDomain,proto3" json:"remote_domain,omitempty"`
	TokenExchangeRate github_com_cosmos_cosmos_sdk_types.Int `` /* 154-byte string literal not displayed */
	GasPrice          github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,5,opt,name=gas_price,json=gasPrice,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"gas_price"`
}

MsgSetRemoteGasData defines the gas exchange rate and gas price

func (*MsgSetRemoteGasData) Descriptor 

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

func (MsgSetRemoteGasData) GetSigners 

func (m MsgSetRemoteGasData) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgSetRemoteGasData) Marshal 

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

func (*MsgSetRemoteGasData) MarshalTo 

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

func (*MsgSetRemoteGasData) MarshalToSizedBuffer 

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

func (*MsgSetRemoteGasData) ProtoMessage 

func (*MsgSetRemoteGasData) ProtoMessage()

func (*MsgSetRemoteGasData) Reset 

func (m *MsgSetRemoteGasData) Reset()

func (*MsgSetRemoteGasData) Size 

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

func (*MsgSetRemoteGasData) String 

func (m *MsgSetRemoteGasData) String() string

func (*MsgSetRemoteGasData) Unmarshal 

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

func (MsgSetRemoteGasData) ValidateBasic 

func (m MsgSetRemoteGasData) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgSetRemoteGasData) XXX_DiscardUnknown 

func (m *MsgSetRemoteGasData) XXX_DiscardUnknown()

func (*MsgSetRemoteGasData) XXX_Marshal 

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

func (*MsgSetRemoteGasData) XXX_Merge 

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

func (*MsgSetRemoteGasData) XXX_Size 

func (m *MsgSetRemoteGasData) XXX_Size() int

func (*MsgSetRemoteGasData) XXX_Unmarshal 

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

type MsgSetRemoteGasDataResponse 

type MsgSetRemoteGasDataResponse struct{}

MsgSetRemoteGasDataResponse defines the MsgSetRemoteGasData response type.

func (*MsgSetRemoteGasDataResponse) Descriptor 

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

func (*MsgSetRemoteGasDataResponse) Marshal 

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

func (*MsgSetRemoteGasDataResponse) MarshalTo 

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

func (*MsgSetRemoteGasDataResponse) MarshalToSizedBuffer 

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

func (*MsgSetRemoteGasDataResponse) ProtoMessage 

func (*MsgSetRemoteGasDataResponse) ProtoMessage()

func (*MsgSetRemoteGasDataResponse) Reset 

func (m *MsgSetRemoteGasDataResponse) Reset()

func (*MsgSetRemoteGasDataResponse) Size 

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

func (*MsgSetRemoteGasDataResponse) String 

func (m *MsgSetRemoteGasDataResponse) String() string

func (*MsgSetRemoteGasDataResponse) Unmarshal 

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

func (*MsgSetRemoteGasDataResponse) XXX_DiscardUnknown 

func (m *MsgSetRemoteGasDataResponse) XXX_DiscardUnknown()

func (*MsgSetRemoteGasDataResponse) XXX_Marshal 

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

func (*MsgSetRemoteGasDataResponse) XXX_Merge 

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

func (*MsgSetRemoteGasDataResponse) XXX_Size 

func (m *MsgSetRemoteGasDataResponse) XXX_Size() int

func (*MsgSetRemoteGasDataResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Gets the beneficiary
	GetBeneficiary(ctx context.Context, in *GetBeneficiaryRequest, opts ...grpc.CallOption) (*GetBeneficiaryResponse, error)
	// Quotes the amount of native tokens to pay for interchain gas.
	QuoteGasPayment(ctx context.Context, in *QuoteGasPaymentRequest, opts ...grpc.CallOption) (*QuoteGasPaymentResponse, error)
	// Gets the token exchange rate and gas price from the configured gas oracle
	// for a given destination domain.
	GetExchangeRateAndGasPrice(ctx context.Context, in *GetExchangeRateAndGasPriceRequest, opts ...grpc.CallOption) (*GetExchangeRateAndGasPriceResponse, 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 QueryServer 

type QueryServer interface {
	// Gets the beneficiary
	GetBeneficiary(context.Context, *GetBeneficiaryRequest) (*GetBeneficiaryResponse, error)
	// Quotes the amount of native tokens to pay for interchain gas.
	QuoteGasPayment(context.Context, *QuoteGasPaymentRequest) (*QuoteGasPaymentResponse, error)
	// Gets the token exchange rate and gas price from the configured gas oracle
	// for a given destination domain.
	GetExchangeRateAndGasPrice(context.Context, *GetExchangeRateAndGasPriceRequest) (*GetExchangeRateAndGasPriceResponse, error)
}

QueryServer is the server API for Query service.

type QuoteGasPaymentRequest 

type QuoteGasPaymentRequest struct {
	IgpId             uint32                                 `protobuf:"varint,1,opt,name=igp_id,json=igpId,proto3" json:"igp_id,omitempty"`
	DestinationDomain uint32                                 `protobuf:"varint,2,opt,name=destination_domain,json=destinationDomain,proto3" json:"destination_domain,omitempty"`
	GasAmount         github_com_cosmos_cosmos_sdk_types.Int `` /* 128-byte string literal not displayed */
}

QuoteGasPaymentRequest is the request type for quoteGasPayment.

func (*QuoteGasPaymentRequest) Descriptor 

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

func (*QuoteGasPaymentRequest) GetDestinationDomain 

func (m *QuoteGasPaymentRequest) GetDestinationDomain() uint32

func (*QuoteGasPaymentRequest) GetIgpId 

func (m *QuoteGasPaymentRequest) GetIgpId() uint32

func (*QuoteGasPaymentRequest) Marshal 

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

func (*QuoteGasPaymentRequest) MarshalTo 

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

func (*QuoteGasPaymentRequest) MarshalToSizedBuffer 

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

func (*QuoteGasPaymentRequest) ProtoMessage 

func (*QuoteGasPaymentRequest) ProtoMessage()

func (*QuoteGasPaymentRequest) Reset 

func (m *QuoteGasPaymentRequest) Reset()

func (*QuoteGasPaymentRequest) Size 

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

func (*QuoteGasPaymentRequest) String 

func (m *QuoteGasPaymentRequest) String() string

func (*QuoteGasPaymentRequest) Unmarshal 

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

func (*QuoteGasPaymentRequest) XXX_DiscardUnknown 

func (m *QuoteGasPaymentRequest) XXX_DiscardUnknown()

func (*QuoteGasPaymentRequest) XXX_Marshal 

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

func (*QuoteGasPaymentRequest) XXX_Merge 

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

func (*QuoteGasPaymentRequest) XXX_Size 

func (m *QuoteGasPaymentRequest) XXX_Size() int

func (*QuoteGasPaymentRequest) XXX_Unmarshal 

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

type QuoteGasPaymentResponse 

type QuoteGasPaymentResponse struct {
	Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	Denom  string                                 `protobuf:"bytes,2,opt,name=denom,proto3" json:"denom,omitempty"`
}

QuoteGasPaymentResponse is the response type for quoteGasPayment. We use amount and denom (instead of Coin) to better match the hyperlane spec. The denom will always match the chain's native staking denom.

func (*QuoteGasPaymentResponse) Descriptor 

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

func (*QuoteGasPaymentResponse) GetDenom 

func (m *QuoteGasPaymentResponse) GetDenom() string

func (*QuoteGasPaymentResponse) Marshal 

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

func (*QuoteGasPaymentResponse) MarshalTo 

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

func (*QuoteGasPaymentResponse) MarshalToSizedBuffer 

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

func (*QuoteGasPaymentResponse) ProtoMessage 

func (*QuoteGasPaymentResponse) ProtoMessage()

func (*QuoteGasPaymentResponse) Reset 

func (m *QuoteGasPaymentResponse) Reset()

func (*QuoteGasPaymentResponse) Size 

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

func (*QuoteGasPaymentResponse) String 

func (m *QuoteGasPaymentResponse) String() string

func (*QuoteGasPaymentResponse) Unmarshal 

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

func (*QuoteGasPaymentResponse) XXX_DiscardUnknown 

func (m *QuoteGasPaymentResponse) XXX_DiscardUnknown()

func (*QuoteGasPaymentResponse) XXX_Marshal 

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

func (*QuoteGasPaymentResponse) XXX_Merge 

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

func (*QuoteGasPaymentResponse) XXX_Size 

func (m *QuoteGasPaymentResponse) XXX_Size() int

func (*QuoteGasPaymentResponse) XXX_Unmarshal 

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

type StakingKeeper 

type StakingKeeper interface {
	BondDenom(ctx sdk.Context) string
}

StakingKeeper expected staking keeper

type UnimplementedMsgServer 

type UnimplementedMsgServer struct{}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreateIgp 

func (*UnimplementedMsgServer) CreateIgp(ctx context.Context, req *MsgCreateIgp) (*MsgCreateIgpResponse, error)

func (*UnimplementedMsgServer) PayForGas 

func (*UnimplementedMsgServer) PayForGas(ctx context.Context, req *MsgPayForGas) (*MsgPayForGasResponse, error)

func (*UnimplementedMsgServer) SetBeneficiary 

func (*UnimplementedMsgServer) SetBeneficiary(ctx context.Context, req *MsgSetBeneficiary) (*MsgSetBeneficiaryResponse, error)

func (*UnimplementedMsgServer) SetDestinationGasOverhead 

func (*UnimplementedMsgServer) SetDestinationGasOverhead(ctx context.Context, req *MsgSetDestinationGasOverhead) (*MsgSetDestinationGasOverheadResponse, error)

func (*UnimplementedMsgServer) SetGasOracles 

func (*UnimplementedMsgServer) SetGasOracles(ctx context.Context, req *MsgSetGasOracles) (*MsgSetGasOraclesResponse, error)

func (*UnimplementedMsgServer) SetRemoteGasData 

func (*UnimplementedMsgServer) SetRemoteGasData(ctx context.Context, req *MsgSetRemoteGasData) (*MsgSetRemoteGasDataResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct{}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetBeneficiary 

func (*UnimplementedQueryServer) GetBeneficiary(ctx context.Context, req *GetBeneficiaryRequest) (*GetBeneficiaryResponse, error)

func (*UnimplementedQueryServer) GetExchangeRateAndGasPrice 

func (*UnimplementedQueryServer) GetExchangeRateAndGasPrice(ctx context.Context, req *GetExchangeRateAndGasPriceRequest) (*GetExchangeRateAndGasPriceResponse, error)

func (*UnimplementedQueryServer) QuoteGasPayment 

func (*UnimplementedQueryServer) QuoteGasPayment(ctx context.Context, req *QuoteGasPaymentRequest) (*QuoteGasPaymentResponse, 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.