types

package
v8.8.8 Latest Latest
Warning

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

Go to latest
Published: Jul 11, 2024 License: MIT Imports: 50 Imported by: 0

Documentation

Overview

NOTE: Usage of x/params to manage parameters is deprecated in favor of x/gov controlled execution of MsgUpdateParams messages. These types remains solely for migration purposes and will be removed in a future release. [#3621](https://github.com/cosmos/ibc-go/issues/3621)

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

View Source
const (
	EventTypeTimeout      = "timeout"
	EventTypePacket       = "fungible_token_packet"
	EventTypeTransfer     = "ibc_transfer"
	EventTypeChannelClose = "channel_closed"
	EventTypeDenom        = "denomination"

	AttributeKeySender         = "sender"
	AttributeKeyReceiver       = "receiver"
	AttributeKeyDenom          = "denom"
	AttributeKeyDenomHash      = "denom_hash"
	AttributeKeyTokens         = "tokens"
	AttributeKeyRefundReceiver = "refund_receiver"
	AttributeKeyRefundTokens   = "refund_tokens"
	AttributeKeyAckSuccess     = "success"
	AttributeKeyAck            = "acknowledgement"
	AttributeKeyAckError       = "error"
	AttributeKeyMemo           = "memo"
	AttributeKeyForwardingHops = "forwarding_hops"
)

IBC transfer events

View Source
const (
	// ModuleName defines the IBC transfer name
	ModuleName = "transfer"

	// PortID is the default port id that transfer module binds to
	PortID = "transfer"

	// StoreKey is the store key string for IBC transfer
	StoreKey = ModuleName

	// RouterKey is the message route for IBC transfer
	RouterKey = ModuleName

	// QuerierRoute is the querier route for IBC transfer
	QuerierRoute = ModuleName

	// DenomPrefix is the prefix used for internal SDK coin representation.
	DenomPrefix = "ibc"

	// AllowAllPacketDataKeys holds the string key that allows all memo strings in authz transfer messages
	AllowAllPacketDataKeys = "*"

	KeyTotalEscrowPrefix = "totalEscrowForDenom"

	ParamsKey = "params"

	KeyPacketForwardPrefix = "forwardedPacket"
)
View Source
const (
	// V1 defines first version of the IBC transfer module
	V1 = "ics20-1"

	// V2 defines the transfer version which introduces multidenom support
	// through the FungibleTokenPacketDataV2. It is the latest version.
	V2 = "ics20-2"
)
View Source
const (
	MaximumReceiverLength = 2048  // maximum length of the receiver address in bytes (value chosen arbitrarily)
	MaximumMemoLength     = 32768 // maximum length of the memo in bytes (value chosen arbitrarily)
	MaximumTokensLength   = 100   // maximum number of tokens that can be transferred in a single message (value chosen arbitrarily)
)
View Source
const (
	// DefaultSendEnabled enabled
	DefaultSendEnabled = true
	// DefaultReceiveEnabled enabled
	DefaultReceiveEnabled = true
)
View Source
const MaximumNumberOfForwardingHops = 8 // denotes the maximum number of forwarding hops allowed

Variables

View Source
var (
	ErrInvalidLengthAuthz        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuthz          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAuthz = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidPacketTimeout    = errorsmod.Register(ModuleName, 2, "invalid packet timeout")
	ErrInvalidDenomForTransfer = errorsmod.Register(ModuleName, 3, "invalid denomination for cross-chain transfer")
	ErrInvalidVersion          = errorsmod.Register(ModuleName, 4, "invalid ICS20 version")
	ErrInvalidAmount           = errorsmod.Register(ModuleName, 5, "invalid token amount")
	ErrDenomNotFound           = errorsmod.Register(ModuleName, 6, "denomination not found")
	ErrSendDisabled            = errorsmod.Register(ModuleName, 7, "fungible token transfers from this chain are disabled")
	ErrReceiveDisabled         = errorsmod.Register(ModuleName, 8, "fungible token transfers to this chain are disabled")
	ErrMaxTransferChannels     = errorsmod.Register(ModuleName, 9, "max transfer channels")
	ErrInvalidAuthorization    = errorsmod.Register(ModuleName, 10, "invalid transfer authorization")
	ErrInvalidMemo             = errorsmod.Register(ModuleName, 11, "invalid memo")
	ErrInvalidForwarding       = errorsmod.Register(ModuleName, 12, "invalid token forwarding")
	ErrForwardedPacketTimedOut = errorsmod.Register(ModuleName, 13, "forwarded packet timed out")
	ErrForwardedPacketFailed   = errorsmod.Register(ModuleName, 14, "forwarded packet failed")
)

IBC transfer sentinel errors

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 (
	// PortKey defines the key to store the port ID in store
	PortKey = []byte{0x01}
	// DenomTraceKey defines the key to store the denomination trace info in store
	DenomTraceKey = []byte{0x02}
	// DenomKey defines the key to store the token denomination in store
	DenomKey = []byte{0x03}

	// SupportedVersions defines all versions that are supported by the module
	SupportedVersions = []string{V2, V1}
)
View Source
var (
	ErrInvalidLengthPacket        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPacket          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPacket = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	// KeySendEnabled is store's key for SendEnabled Params
	KeySendEnabled = []byte("SendEnabled")
	// KeyReceiveEnabled is store's key for ReceiveEnabled Params
	KeyReceiveEnabled = []byte("ReceiveEnabled")
)
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 (
	ErrInvalidLengthQueryv2        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueryv2          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQueryv2 = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthToken        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowToken          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupToken = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthTransfer        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTransfer          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTransfer = 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")
)

ModuleCdc references the global x/ibc-transfer module codec. Note, the codec should ONLY be used in certain instances of tests and for JSON encoding.

The actual codec used for serialization should be provided to x/ibc transfer and defined at the application level.

Functions

func GetEscrowAddress

func GetEscrowAddress(portID, channelID string) sdk.AccAddress

GetEscrowAddress returns the escrow address for the specified channel. The escrow address follows the format as outlined in ADR 028: https://github.com/cosmos/cosmos-sdk/blob/master/docs/architecture/adr-028-public-key-addresses.md

func PacketForwardKey

func PacketForwardKey(portID, channelID string, sequence uint64) []byte

PacketForwardKey returns the store key under which the forwarded packet is stored for the provided portID, channelID, and packet sequence.

func ParamKeyTable

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable type declaration for parameters

func ParseHexHash

func ParseHexHash(hexHash string) (cmtbytes.HexBytes, error)

ParseHexHash parses a hex hash in string format to bytes and validates its correctness.

func RegisterInterfaces

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the ibc transfer module interfaces to protobuf Any.

func RegisterLegacyAminoCodec

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/ibc transfer interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.

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)

func RegisterQueryV2Handler

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

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

func RegisterQueryV2HandlerClient

func RegisterQueryV2HandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryV2Client) error

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

func RegisterQueryV2HandlerFromEndpoint

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

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

func RegisterQueryV2HandlerServer

func RegisterQueryV2HandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryV2Server) error

RegisterQueryV2HandlerServer registers the http handlers for service QueryV2 to "mux". UnaryRPC :call QueryV2Server 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 RegisterQueryV2HandlerFromEndpoint instead.

func RegisterQueryV2Server

func RegisterQueryV2Server(s grpc1.Server, srv QueryV2Server)

func TotalEscrowForDenomKey

func TotalEscrowForDenomKey(denom string) []byte

TotalEscrowForDenomKey returns the store key of under which the total amount of source chain tokens in escrow is stored.

func UnboundedSpendLimit

func UnboundedSpendLimit() sdkmath.Int

UnboundedSpendLimit returns the sentinel value that can be used as the amount for a denomination's spend limit for which spend limit updating should be disabled. Please note that using this sentinel value means that a grantee will be granted the privilege to do ICS20 token transfers for the total amount of the denomination available at the granter's account.

Types

type AccountKeeper

type AccountKeeper interface {
	GetModuleAddress(name string) sdk.AccAddress
	GetModuleAccount(ctx context.Context, name string) sdk.ModuleAccountI
}

AccountKeeper defines the contract required for account APIs.

type Allocation

type Allocation struct {
	// the port on which the packet will be sent
	SourcePort string `protobuf:"bytes,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	// the channel by which the packet will be sent
	SourceChannel string `protobuf:"bytes,2,opt,name=source_channel,json=sourceChannel,proto3" json:"source_channel,omitempty"`
	// spend limitation on the channel
	SpendLimit github_com_cosmos_cosmos_sdk_types.Coins `` /* 135-byte string literal not displayed */
	// allow list of receivers, an empty allow list permits any receiver address
	AllowList []string `protobuf:"bytes,4,rep,name=allow_list,json=allowList,proto3" json:"allow_list,omitempty"`
	// allow list of memo strings, an empty list prohibits all memo strings;
	// a list only with "*" permits any memo string
	AllowedPacketData []string `protobuf:"bytes,5,rep,name=allowed_packet_data,json=allowedPacketData,proto3" json:"allowed_packet_data,omitempty"`
	// Forwarding options that are allowed.
	AllowedForwarding []AllowedForwarding `protobuf:"bytes,6,rep,name=allowed_forwarding,json=allowedForwarding,proto3" json:"allowed_forwarding"`
}

Allocation defines the spend limit for a particular port and channel

func (*Allocation) Descriptor

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

func (*Allocation) GetAllowList

func (m *Allocation) GetAllowList() []string

func (*Allocation) GetAllowedForwarding

func (m *Allocation) GetAllowedForwarding() []AllowedForwarding

func (*Allocation) GetAllowedPacketData

func (m *Allocation) GetAllowedPacketData() []string

func (*Allocation) GetSourceChannel

func (m *Allocation) GetSourceChannel() string

func (*Allocation) GetSourcePort

func (m *Allocation) GetSourcePort() string

func (*Allocation) GetSpendLimit

func (*Allocation) Marshal

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

func (*Allocation) MarshalTo

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

func (*Allocation) MarshalToSizedBuffer

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

func (*Allocation) ProtoMessage

func (*Allocation) ProtoMessage()

func (*Allocation) Reset

func (m *Allocation) Reset()

func (*Allocation) Size

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

func (*Allocation) String

func (m *Allocation) String() string

func (*Allocation) Unmarshal

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

func (*Allocation) XXX_DiscardUnknown

func (m *Allocation) XXX_DiscardUnknown()

func (*Allocation) XXX_Marshal

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

func (*Allocation) XXX_Merge

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

func (*Allocation) XXX_Size

func (m *Allocation) XXX_Size() int

func (*Allocation) XXX_Unmarshal

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

type AllowedForwarding

type AllowedForwarding struct {
	// a list of allowed source port ID/channel ID pairs through which the packet is allowed to be forwarded until final
	// destination
	Hops []Hop `protobuf:"bytes,1,rep,name=hops,proto3" json:"hops"`
}

AllowedForwarding defines which options are allowed for forwarding.

func (*AllowedForwarding) Descriptor

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

func (*AllowedForwarding) GetHops

func (m *AllowedForwarding) GetHops() []Hop

func (*AllowedForwarding) Marshal

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

func (*AllowedForwarding) MarshalTo

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

func (*AllowedForwarding) MarshalToSizedBuffer

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

func (*AllowedForwarding) ProtoMessage

func (*AllowedForwarding) ProtoMessage()

func (*AllowedForwarding) Reset

func (m *AllowedForwarding) Reset()

func (*AllowedForwarding) Size

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

func (*AllowedForwarding) String

func (m *AllowedForwarding) String() string

func (*AllowedForwarding) Unmarshal

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

func (*AllowedForwarding) XXX_DiscardUnknown

func (m *AllowedForwarding) XXX_DiscardUnknown()

func (*AllowedForwarding) XXX_Marshal

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

func (*AllowedForwarding) XXX_Merge

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

func (*AllowedForwarding) XXX_Size

func (m *AllowedForwarding) XXX_Size() int

func (*AllowedForwarding) XXX_Unmarshal

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

type BankKeeper

type BankKeeper interface {
	SendCoins(ctx context.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	MintCoins(ctx context.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx context.Context, moduleName string, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx context.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx context.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	BlockedAddr(addr sdk.AccAddress) bool
	IsSendEnabledCoins(ctx context.Context, coins ...sdk.Coin) error
	HasDenomMetaData(ctx context.Context, denom string) bool
	SetDenomMetaData(ctx context.Context, denomMetaData banktypes.Metadata)
	GetBalance(ctx context.Context, addr sdk.AccAddress, denom string) sdk.Coin
	GetAllBalances(ctx context.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected bank keeper

type ChannelKeeper

type ChannelKeeper interface {
	GetChannel(ctx sdk.Context, srcPort, srcChan string) (channel channeltypes.Channel, found bool)
	GetNextSequenceSend(ctx sdk.Context, portID, channelID string) (uint64, bool)
	GetAllChannelsWithPortPrefix(ctx sdk.Context, portPrefix string) []channeltypes.IdentifiedChannel
	HasChannel(ctx sdk.Context, portID, channelID string) bool
}

ChannelKeeper defines the expected IBC channel keeper

type ClientKeeper

type ClientKeeper interface {
	GetClientConsensusState(ctx sdk.Context, clientID string) (connection ibcexported.ConsensusState, found bool)
}

ClientKeeper defines the expected IBC client keeper

type ConnectionKeeper

type ConnectionKeeper interface {
	GetConnection(ctx sdk.Context, connectionID string) (connection connectiontypes.ConnectionEnd, found bool)
}

ConnectionKeeper defines the expected IBC connection keeper

type Denom

type Denom struct {
	// the base token denomination
	Base string `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	// the trace of the token
	Trace []Hop `protobuf:"bytes,3,rep,name=trace,proto3" json:"trace"`
}

Denom holds the base denom of a Token and a trace of the chains it was sent through.

func ExtractDenomFromPath

func ExtractDenomFromPath(fullPath string) Denom

ExtractDenomFromPath returns the denom from the full path. Used to support v1 denoms.

func NewDenom

func NewDenom(base string, trace ...Hop) Denom

NewDenom creates a new Denom instance given the base denomination and a variable number of hops.

func (*Denom) Descriptor

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

func (*Denom) GetBase

func (m *Denom) GetBase() string

func (*Denom) GetTrace

func (m *Denom) GetTrace() []Hop

func (Denom) HasPrefix

func (d Denom) HasPrefix(portID, channelID string) bool

HasPrefix returns true if the first element of the trace of the denom matches the provided portId and channelId.

func (Denom) Hash

func (d Denom) Hash() cmtbytes.HexBytes

Hash returns the hex bytes of the SHA256 hash of the Denom fields using the following formula:

hash = sha256(trace + "/" + baseDenom)

func (Denom) IBCDenom

func (d Denom) IBCDenom() string

IBCDenom a coin denomination for an ICS20 fungible token in the format 'ibc/{hash(trace + baseDenom)}'. If the trace is empty, it will return the base denomination.

func (Denom) IsNative

func (d Denom) IsNative() bool

IsNative returns true if the denomination is native, thus containing no trace history.

func (*Denom) Marshal

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

func (*Denom) MarshalTo

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

func (*Denom) MarshalToSizedBuffer

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

func (Denom) Path

func (d Denom) Path() string

Path returns the full denomination according to the ICS20 specification: trace + "/" + baseDenom If there exists no trace then the base denomination is returned.

func (*Denom) ProtoMessage

func (*Denom) ProtoMessage()

func (*Denom) Reset

func (m *Denom) Reset()

func (*Denom) Size

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

func (*Denom) String

func (m *Denom) String() string

func (*Denom) Unmarshal

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

func (Denom) Validate

func (d Denom) Validate() error

Validate performs a basic validation of the Denom fields.

func (*Denom) XXX_DiscardUnknown

func (m *Denom) XXX_DiscardUnknown()

func (*Denom) XXX_Marshal

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

func (*Denom) XXX_Merge

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

func (*Denom) XXX_Size

func (m *Denom) XXX_Size() int

func (*Denom) XXX_Unmarshal

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

type Denoms

type Denoms []Denom

Denoms defines a wrapper type for a slice of Denom.

func (Denoms) Len

func (d Denoms) Len() int

Len implements sort.Interface for Denoms

func (Denoms) Less

func (d Denoms) Less(i, j int) bool

Less implements sort.Interface for Denoms

func (Denoms) Sort

func (d Denoms) Sort() Denoms

Sort is a helper function to sort the set of denomination in-place

func (Denoms) Swap

func (d Denoms) Swap(i, j int)

Swap implements sort.Interface for Denoms

func (Denoms) Validate

func (d Denoms) Validate() error

Validate performs a basic validation of each denomination trace info.

type Forwarding

type Forwarding struct {
	// optional unwinding for the token transfered
	Unwind bool `protobuf:"varint,1,opt,name=unwind,proto3" json:"unwind,omitempty"`
	// optional intermediate path through which packet will be forwarded
	Hops []Hop `protobuf:"bytes,2,rep,name=hops,proto3" json:"hops"`
}

Forwarding defines a list of port ID, channel ID pairs determining the path through which a packet must be forwarded, and an unwind boolean indicating if the coin should be unwinded to its native chain before forwarding.

func NewForwarding

func NewForwarding(unwind bool, hops ...Hop) *Forwarding

NewForwarding creates a new Forwarding instance given an unwind value and a variable number of hops.

func (*Forwarding) Descriptor

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

func (*Forwarding) GetHops

func (m *Forwarding) GetHops() []Hop

func (*Forwarding) GetUnwind

func (m *Forwarding) GetUnwind() bool

func (*Forwarding) Marshal

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

func (*Forwarding) MarshalTo

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

func (*Forwarding) MarshalToSizedBuffer

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

func (*Forwarding) ProtoMessage

func (*Forwarding) ProtoMessage()

func (*Forwarding) Reset

func (m *Forwarding) Reset()

func (*Forwarding) Size

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

func (*Forwarding) String

func (m *Forwarding) String() string

func (*Forwarding) Unmarshal

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

func (Forwarding) Validate

func (f Forwarding) Validate() error

Validate performs a basic validation of the Forwarding fields.

func (*Forwarding) XXX_DiscardUnknown

func (m *Forwarding) XXX_DiscardUnknown()

func (*Forwarding) XXX_Marshal

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

func (*Forwarding) XXX_Merge

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

func (*Forwarding) XXX_Size

func (m *Forwarding) XXX_Size() int

func (*Forwarding) XXX_Unmarshal

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

type ForwardingPacketData

type ForwardingPacketData struct {
	// optional memo consumed by final destination chain
	DestinationMemo string `protobuf:"bytes,1,opt,name=destination_memo,json=destinationMemo,proto3" json:"destination_memo,omitempty"`
	// optional intermediate path through which packet will be forwarded.
	Hops []Hop `protobuf:"bytes,2,rep,name=hops,proto3" json:"hops"`
}

ForwardingPacketData defines a list of port ID, channel ID pairs determining the path through which a packet must be forwarded, and the destination memo string to be used in the final destination of the tokens.

func NewForwardingPacketData

func NewForwardingPacketData(destinationMemo string, hops ...Hop) ForwardingPacketData

NewForwardingPacketData creates a new ForwardingPacketData instance given a memo and a variable number of hops.

func (*ForwardingPacketData) Descriptor

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

func (*ForwardingPacketData) GetDestinationMemo

func (m *ForwardingPacketData) GetDestinationMemo() string

func (*ForwardingPacketData) GetHops

func (m *ForwardingPacketData) GetHops() []Hop

func (*ForwardingPacketData) Marshal

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

func (*ForwardingPacketData) MarshalTo

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

func (*ForwardingPacketData) MarshalToSizedBuffer

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

func (*ForwardingPacketData) ProtoMessage

func (*ForwardingPacketData) ProtoMessage()

func (*ForwardingPacketData) Reset

func (m *ForwardingPacketData) Reset()

func (*ForwardingPacketData) Size

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

func (*ForwardingPacketData) String

func (m *ForwardingPacketData) String() string

func (*ForwardingPacketData) Unmarshal

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

func (ForwardingPacketData) Validate

func (fpd ForwardingPacketData) Validate() error

Validate performs a basic validation of the ForwardingPacketData fields.

func (*ForwardingPacketData) XXX_DiscardUnknown

func (m *ForwardingPacketData) XXX_DiscardUnknown()

func (*ForwardingPacketData) XXX_Marshal

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

func (*ForwardingPacketData) XXX_Merge

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

func (*ForwardingPacketData) XXX_Size

func (m *ForwardingPacketData) XXX_Size() int

func (*ForwardingPacketData) XXX_Unmarshal

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

type FungibleTokenPacketData

type FungibleTokenPacketData struct {
	// the token denomination to be transferred
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	// the token amount to be transferred
	Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"`
	// the sender address
	Sender string `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty"`
	// the recipient address on the destination chain
	Receiver string `protobuf:"bytes,4,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// optional memo
	Memo string `protobuf:"bytes,5,opt,name=memo,proto3" json:"memo,omitempty"`
}

FungibleTokenPacketData defines a struct for the packet payload See FungibleTokenPacketData spec: https://github.com/cosmos/ibc/tree/master/spec/app/ics-020-fungible-token-transfer#data-structures

func NewFungibleTokenPacketData

func NewFungibleTokenPacketData(
	denom string, amount string,
	sender, receiver string,
	memo string,
) FungibleTokenPacketData

NewFungibleTokenPacketData constructs a new FungibleTokenPacketData instance

func (*FungibleTokenPacketData) Descriptor

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

func (*FungibleTokenPacketData) GetAmount

func (m *FungibleTokenPacketData) GetAmount() string

func (FungibleTokenPacketData) GetBytes

func (ftpd FungibleTokenPacketData) GetBytes() []byte

GetBytes is a helper for serialising the packet to bytes. The memo field of FungibleTokenPacketData is marked with the JSON omitempty tag ensuring that the memo field is not included in the marshalled bytes if one is not specified.

func (FungibleTokenPacketData) GetCustomPacketData

func (ftpd FungibleTokenPacketData) GetCustomPacketData(key string) interface{}

GetCustomPacketData interprets the memo field of the packet data as a JSON object and returns the value associated with the given key. If the key is missing or the memo is not properly formatted, then nil is returned.

func (*FungibleTokenPacketData) GetDenom

func (m *FungibleTokenPacketData) GetDenom() string

func (*FungibleTokenPacketData) GetMemo

func (m *FungibleTokenPacketData) GetMemo() string

func (FungibleTokenPacketData) GetPacketSender

func (ftpd FungibleTokenPacketData) GetPacketSender(sourcePortID string) string

GetPacketSender returns the sender address embedded in the packet data.

NOTE:

  • The sender address is set by the module which requested the packet to be sent, and this module may not have validated the sender address by a signature check.
  • The sender address must only be used by modules on the sending chain.
  • sourcePortID is not used in this implementation.

func (*FungibleTokenPacketData) GetReceiver

func (m *FungibleTokenPacketData) GetReceiver() string

func (*FungibleTokenPacketData) GetSender

func (m *FungibleTokenPacketData) GetSender() string

func (*FungibleTokenPacketData) Marshal

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

func (*FungibleTokenPacketData) MarshalTo

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

func (*FungibleTokenPacketData) MarshalToSizedBuffer

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

func (*FungibleTokenPacketData) ProtoMessage

func (*FungibleTokenPacketData) ProtoMessage()

func (*FungibleTokenPacketData) Reset

func (m *FungibleTokenPacketData) Reset()

func (*FungibleTokenPacketData) Size

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

func (*FungibleTokenPacketData) String

func (m *FungibleTokenPacketData) String() string

func (*FungibleTokenPacketData) Unmarshal

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

func (*FungibleTokenPacketData) UnmarshalJSON

func (ftpd *FungibleTokenPacketData) UnmarshalJSON(bz []byte) error

UnmarshalJSON implements the Unmarshaller interface for FungibleTokenPacketData.

func (FungibleTokenPacketData) ValidateBasic

func (ftpd FungibleTokenPacketData) ValidateBasic() error

ValidateBasic is used for validating the token transfer. NOTE: The addresses formats are not validated as the sender and recipient can have different formats defined by their corresponding chains that are not known to IBC.

func (*FungibleTokenPacketData) XXX_DiscardUnknown

func (m *FungibleTokenPacketData) XXX_DiscardUnknown()

func (*FungibleTokenPacketData) XXX_Marshal

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

func (*FungibleTokenPacketData) XXX_Merge

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

func (*FungibleTokenPacketData) XXX_Size

func (m *FungibleTokenPacketData) XXX_Size() int

func (*FungibleTokenPacketData) XXX_Unmarshal

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

type FungibleTokenPacketDataV2

type FungibleTokenPacketDataV2 struct {
	// the tokens to be transferred
	Tokens []Token `protobuf:"bytes,1,rep,name=tokens,proto3" json:"tokens"`
	// the sender address
	Sender string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// the recipient address on the destination chain
	Receiver string `protobuf:"bytes,3,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// optional memo
	Memo string `protobuf:"bytes,4,opt,name=memo,proto3" json:"memo,omitempty"`
	// optional forwarding information
	Forwarding ForwardingPacketData `protobuf:"bytes,5,opt,name=forwarding,proto3" json:"forwarding"`
}

FungibleTokenPacketDataV2 defines a struct for the packet payload See FungibleTokenPacketDataV2 spec: https://github.com/cosmos/ibc/tree/master/spec/app/ics-020-fungible-token-transfer#data-structures

func NewFungibleTokenPacketDataV2

func NewFungibleTokenPacketDataV2(
	tokens []Token,
	sender, receiver string,
	memo string,
	forwarding ForwardingPacketData,
) FungibleTokenPacketDataV2

NewFungibleTokenPacketDataV2 constructs a new FungibleTokenPacketDataV2 instance

func (*FungibleTokenPacketDataV2) Descriptor

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

func (FungibleTokenPacketDataV2) GetBytes

func (ftpd FungibleTokenPacketDataV2) GetBytes() []byte

GetBytes is a helper for serialising a FungibleTokenPacketDataV2. It uses protobuf to serialise the packet data and panics on failure.

func (FungibleTokenPacketDataV2) GetCustomPacketData

func (ftpd FungibleTokenPacketDataV2) GetCustomPacketData(key string) interface{}

GetCustomPacketData interprets the memo field of the packet data as a JSON object and returns the value associated with the given key. If the key is missing or the memo is not properly formatted, then nil is returned.

func (*FungibleTokenPacketDataV2) GetForwarding

func (*FungibleTokenPacketDataV2) GetMemo

func (m *FungibleTokenPacketDataV2) GetMemo() string

func (FungibleTokenPacketDataV2) GetPacketSender

func (ftpd FungibleTokenPacketDataV2) GetPacketSender(sourcePortID string) string

GetPacketSender returns the sender address embedded in the packet data.

NOTE:

  • The sender address is set by the module which requested the packet to be sent, and this module may not have validated the sender address by a signature check.
  • The sender address must only be used by modules on the sending chain.
  • sourcePortID is not used in this implementation.

func (*FungibleTokenPacketDataV2) GetReceiver

func (m *FungibleTokenPacketDataV2) GetReceiver() string

func (*FungibleTokenPacketDataV2) GetSender

func (m *FungibleTokenPacketDataV2) GetSender() string

func (*FungibleTokenPacketDataV2) GetTokens

func (m *FungibleTokenPacketDataV2) GetTokens() []Token

func (FungibleTokenPacketDataV2) HasForwarding

func (ftpd FungibleTokenPacketDataV2) HasForwarding() bool

HasForwarding determines if the packet should be forwarded to the next hop.

func (*FungibleTokenPacketDataV2) Marshal

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

func (*FungibleTokenPacketDataV2) MarshalTo

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

func (*FungibleTokenPacketDataV2) MarshalToSizedBuffer

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

func (*FungibleTokenPacketDataV2) ProtoMessage

func (*FungibleTokenPacketDataV2) ProtoMessage()

func (*FungibleTokenPacketDataV2) Reset

func (m *FungibleTokenPacketDataV2) Reset()

func (*FungibleTokenPacketDataV2) Size

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

func (*FungibleTokenPacketDataV2) String

func (m *FungibleTokenPacketDataV2) String() string

func (*FungibleTokenPacketDataV2) Unmarshal

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

func (FungibleTokenPacketDataV2) ValidateBasic

func (ftpd FungibleTokenPacketDataV2) ValidateBasic() error

ValidateBasic is used for validating the token transfer. NOTE: The addresses formats are not validated as the sender and recipient can have different formats defined by their corresponding chains that are not known to IBC.

func (*FungibleTokenPacketDataV2) XXX_DiscardUnknown

func (m *FungibleTokenPacketDataV2) XXX_DiscardUnknown()

func (*FungibleTokenPacketDataV2) XXX_Marshal

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

func (*FungibleTokenPacketDataV2) XXX_Merge

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

func (*FungibleTokenPacketDataV2) XXX_Size

func (m *FungibleTokenPacketDataV2) XXX_Size() int

func (*FungibleTokenPacketDataV2) XXX_Unmarshal

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

type GenesisState

type GenesisState struct {
	PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	Denoms Denoms `protobuf:"bytes,2,rep,name=denoms,proto3,castrepeated=Denoms" json:"denoms"`
	Params Params `protobuf:"bytes,3,opt,name=params,proto3" json:"params"`
	// total_escrowed contains the total amount of tokens escrowed
	// by the transfer module
	TotalEscrowed github_com_cosmos_cosmos_sdk_types.Coins `` /* 144-byte string literal not displayed */
}

GenesisState defines the ibc-transfer genesis state

func DefaultGenesisState

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns a GenesisState with "transfer" as the default PortID.

func NewGenesisState

func NewGenesisState(portID string, denoms Denoms, params Params, totalEscrowed sdk.Coins) *GenesisState

NewGenesisState creates a new ibc-transfer GenesisState instance.

func (*GenesisState) Descriptor

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

func (*GenesisState) GetDenoms

func (m *GenesisState) GetDenoms() Denoms

func (*GenesisState) GetParams

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPortId

func (m *GenesisState) GetPortId() string

func (*GenesisState) GetTotalEscrowed

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 Hop

type Hop struct {
	PortId    string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
}

Hop defines a port ID, channel ID pair specifying where tokens must be forwarded next in a multihop transfer.

func NewHop

func NewHop(portID, channelID string) Hop

NewHop creates a Hop with the given port ID and channel ID.

func (*Hop) Descriptor

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

func (*Hop) GetChannelId

func (m *Hop) GetChannelId() string

func (*Hop) GetPortId

func (m *Hop) GetPortId() string

func (*Hop) Marshal

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

func (*Hop) MarshalTo

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

func (*Hop) MarshalToSizedBuffer

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

func (*Hop) ProtoMessage

func (*Hop) ProtoMessage()

func (*Hop) Reset

func (m *Hop) Reset()

func (*Hop) Size

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

func (Hop) String

func (h Hop) String() string

String returns the Hop in the format: <portID>/<channelID>

func (*Hop) Unmarshal

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

func (Hop) Validate

func (h Hop) Validate() error

Validate performs a basic validation of the Hop fields.

func (*Hop) XXX_DiscardUnknown

func (m *Hop) XXX_DiscardUnknown()

func (*Hop) XXX_Marshal

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

func (*Hop) XXX_Merge

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

func (*Hop) XXX_Size

func (m *Hop) XXX_Size() int

func (*Hop) XXX_Unmarshal

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

type MsgClient

type MsgClient interface {
	// Transfer defines a rpc handler method for MsgTransfer.
	Transfer(ctx context.Context, in *MsgTransfer, opts ...grpc.CallOption) (*MsgTransferResponse, error)
	// UpdateParams defines a rpc handler for MsgUpdateParams.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, 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 {
	// Transfer defines a rpc handler method for MsgTransfer.
	Transfer(context.Context, *MsgTransfer) (*MsgTransferResponse, error)
	// UpdateParams defines a rpc handler for MsgUpdateParams.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgTransfer

type MsgTransfer struct {
	// the port on which the packet will be sent
	SourcePort string `protobuf:"bytes,1,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty"`
	// the channel by which the packet will be sent
	SourceChannel string `protobuf:"bytes,2,opt,name=source_channel,json=sourceChannel,proto3" json:"source_channel,omitempty"`
	// the token to be transferred. this field has been replaced by the tokens field.
	Token types.Coin `protobuf:"bytes,3,opt,name=token,proto3" json:"token"` // Deprecated: Do not use.
	// the sender address
	Sender string `protobuf:"bytes,4,opt,name=sender,proto3" json:"sender,omitempty"`
	// the recipient address on the destination chain
	Receiver string `protobuf:"bytes,5,opt,name=receiver,proto3" json:"receiver,omitempty"`
	// Timeout height relative to the current block height.
	// The timeout is disabled when set to 0.
	TimeoutHeight types1.Height `protobuf:"bytes,6,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,7,opt,name=timeout_timestamp,json=timeoutTimestamp,proto3" json:"timeout_timestamp,omitempty"`
	// optional memo
	Memo string `protobuf:"bytes,8,opt,name=memo,proto3" json:"memo,omitempty"`
	// tokens to be transferred
	Tokens []types.Coin `protobuf:"bytes,9,rep,name=tokens,proto3" json:"tokens"`
	// optional forwarding information
	Forwarding *Forwarding `protobuf:"bytes,10,opt,name=forwarding,proto3" json:"forwarding,omitempty"`
}

MsgTransfer defines a msg to transfer fungible tokens (i.e Coins) between ICS20 enabled chains. See ICS Spec here: https://github.com/cosmos/ibc/tree/master/spec/app/ics-020-fungible-token-transfer#data-structures

func NewMsgTransfer

func NewMsgTransfer(
	sourcePort, sourceChannel string,
	tokens sdk.Coins, sender, receiver string,
	timeoutHeight clienttypes.Height, timeoutTimestamp uint64,
	memo string,
	forwarding *Forwarding,
) *MsgTransfer

NewMsgTransfer creates a new MsgTransfer instance

func (*MsgTransfer) Descriptor

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

func (MsgTransfer) GetCoins

func (msg MsgTransfer) GetCoins() sdk.Coins

GetCoins returns the tokens which will be transferred. If MsgTransfer is populated in the Token field, only that field will be returned in the coin array.

func (MsgTransfer) HasForwarding

func (msg MsgTransfer) HasForwarding() bool

HasForwarding determines if the transfer should be forwarded to the next hop.

func (*MsgTransfer) Marshal

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

func (*MsgTransfer) MarshalTo

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

func (*MsgTransfer) MarshalToSizedBuffer

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

func (*MsgTransfer) ProtoMessage

func (*MsgTransfer) ProtoMessage()

func (*MsgTransfer) Reset

func (m *MsgTransfer) Reset()

func (*MsgTransfer) Size

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

func (*MsgTransfer) String

func (m *MsgTransfer) String() string

func (*MsgTransfer) Unmarshal

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

func (MsgTransfer) ValidateBasic

func (msg MsgTransfer) ValidateBasic() error

ValidateBasic performs a basic check of the MsgTransfer fields. NOTE: timeout height or timestamp values can be 0 to disable the timeout. NOTE: The recipient addresses format is not validated as the format defined by the chain is not known to IBC.

func (*MsgTransfer) XXX_DiscardUnknown

func (m *MsgTransfer) XXX_DiscardUnknown()

func (*MsgTransfer) XXX_Marshal

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

func (*MsgTransfer) XXX_Merge

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

func (*MsgTransfer) XXX_Size

func (m *MsgTransfer) XXX_Size() int

func (*MsgTransfer) XXX_Unmarshal

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

type MsgTransferResponse

type MsgTransferResponse struct {
	// sequence number of the transfer packet sent
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

MsgTransferResponse defines the Msg/Transfer response type.

func (*MsgTransferResponse) Descriptor

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

func (*MsgTransferResponse) Marshal

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

func (*MsgTransferResponse) MarshalTo

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

func (*MsgTransferResponse) MarshalToSizedBuffer

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

func (*MsgTransferResponse) ProtoMessage

func (*MsgTransferResponse) ProtoMessage()

func (*MsgTransferResponse) Reset

func (m *MsgTransferResponse) Reset()

func (*MsgTransferResponse) Size

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

func (*MsgTransferResponse) String

func (m *MsgTransferResponse) String() string

func (*MsgTransferResponse) Unmarshal

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

func (*MsgTransferResponse) XXX_DiscardUnknown

func (m *MsgTransferResponse) XXX_DiscardUnknown()

func (*MsgTransferResponse) XXX_Marshal

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

func (*MsgTransferResponse) XXX_Merge

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

func (*MsgTransferResponse) XXX_Size

func (m *MsgTransferResponse) XXX_Size() int

func (*MsgTransferResponse) XXX_Unmarshal

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

type MsgUpdateParams

type MsgUpdateParams struct {
	// signer address
	Signer string `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer,omitempty"`
	// params defines the transfer parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the Msg/UpdateParams request type.

func NewMsgUpdateParams

func NewMsgUpdateParams(signer string, params Params) *MsgUpdateParams

NewMsgUpdateParams creates a new MsgUpdateParams instance

func (*MsgUpdateParams) Descriptor

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

func (*MsgUpdateParams) Marshal

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

func (*MsgUpdateParams) MarshalTo

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

func (*MsgUpdateParams) MarshalToSizedBuffer

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

func (*MsgUpdateParams) ProtoMessage

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size

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

func (*MsgUpdateParams) String

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal

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

func (MsgUpdateParams) ValidateBasic

func (msg MsgUpdateParams) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgUpdateParams) XXX_DiscardUnknown

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal

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

func (*MsgUpdateParams) XXX_Merge

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

func (*MsgUpdateParams) XXX_Size

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal

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

type MsgUpdateParamsResponse

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

func (*MsgUpdateParamsResponse) Descriptor

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

func (*MsgUpdateParamsResponse) Marshal

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

func (*MsgUpdateParamsResponse) MarshalTo

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer

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

func (*MsgUpdateParamsResponse) ProtoMessage

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size

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

func (*MsgUpdateParamsResponse) String

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal

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

func (*MsgUpdateParamsResponse) XXX_Merge

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

func (*MsgUpdateParamsResponse) XXX_Size

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal

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

type ParamSubspace

type ParamSubspace interface {
	GetParamSet(ctx sdk.Context, ps paramtypes.ParamSet)
}

ParamSubspace defines the expected Subspace interface for module parameters.

type Params

type Params struct {
	// send_enabled enables or disables all cross-chain token transfers from this
	// chain.
	SendEnabled bool `protobuf:"varint,1,opt,name=send_enabled,json=sendEnabled,proto3" json:"send_enabled,omitempty"`
	// receive_enabled enables or disables all cross-chain token transfers to this
	// chain.
	ReceiveEnabled bool `protobuf:"varint,2,opt,name=receive_enabled,json=receiveEnabled,proto3" json:"receive_enabled,omitempty"`
}

Params defines the set of IBC transfer parameters. NOTE: To prevent a single token from being transferred, set the TransfersEnabled parameter to true and then set the bank module's SendEnabled parameter for the denomination to false.

func DefaultParams

func DefaultParams() Params

DefaultParams is the default parameter configuration for the ibc-transfer module

func NewParams

func NewParams(enableSend, enableReceive bool) Params

NewParams creates a new parameter configuration for the ibc transfer module

func (*Params) Descriptor

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

func (*Params) GetReceiveEnabled

func (m *Params) GetReceiveEnabled() bool

func (*Params) GetSendEnabled

func (m *Params) GetSendEnabled() 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) ParamSetPairs

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs implements params.ParamSet

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) 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 PortKeeper

type PortKeeper interface {
	BindPort(ctx sdk.Context, portID string) *capabilitytypes.Capability
}

PortKeeper defines the expected IBC port keeper

type QueryClient

type QueryClient interface {
	// Params queries all parameters of the ibc-transfer module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// DenomHash queries a denomination hash information.
	DenomHash(ctx context.Context, in *QueryDenomHashRequest, opts ...grpc.CallOption) (*QueryDenomHashResponse, error)
	// EscrowAddress returns the escrow address for a particular port and channel id.
	EscrowAddress(ctx context.Context, in *QueryEscrowAddressRequest, opts ...grpc.CallOption) (*QueryEscrowAddressResponse, error)
	// TotalEscrowForDenom returns the total amount of tokens in escrow based on the denom.
	TotalEscrowForDenom(ctx context.Context, in *QueryTotalEscrowForDenomRequest, opts ...grpc.CallOption) (*QueryTotalEscrowForDenomResponse, 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 QueryDenomHashRequest

type QueryDenomHashRequest struct {
	// The denomination trace ([port_id]/[channel_id])+/[denom]
	Trace string `protobuf:"bytes,1,opt,name=trace,proto3" json:"trace,omitempty"`
}

QueryDenomHashRequest is the request type for the Query/DenomHash RPC method

func (*QueryDenomHashRequest) Descriptor

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

func (*QueryDenomHashRequest) GetTrace

func (m *QueryDenomHashRequest) GetTrace() string

func (*QueryDenomHashRequest) Marshal

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

func (*QueryDenomHashRequest) MarshalTo

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

func (*QueryDenomHashRequest) MarshalToSizedBuffer

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

func (*QueryDenomHashRequest) ProtoMessage

func (*QueryDenomHashRequest) ProtoMessage()

func (*QueryDenomHashRequest) Reset

func (m *QueryDenomHashRequest) Reset()

func (*QueryDenomHashRequest) Size

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

func (*QueryDenomHashRequest) String

func (m *QueryDenomHashRequest) String() string

func (*QueryDenomHashRequest) Unmarshal

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

func (*QueryDenomHashRequest) XXX_DiscardUnknown

func (m *QueryDenomHashRequest) XXX_DiscardUnknown()

func (*QueryDenomHashRequest) XXX_Marshal

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

func (*QueryDenomHashRequest) XXX_Merge

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

func (*QueryDenomHashRequest) XXX_Size

func (m *QueryDenomHashRequest) XXX_Size() int

func (*QueryDenomHashRequest) XXX_Unmarshal

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

type QueryDenomHashResponse

type QueryDenomHashResponse struct {
	// hash (in hex format) of the denomination trace information.
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

QueryDenomHashResponse is the response type for the Query/DenomHash RPC method.

func (*QueryDenomHashResponse) Descriptor

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

func (*QueryDenomHashResponse) GetHash

func (m *QueryDenomHashResponse) GetHash() string

func (*QueryDenomHashResponse) Marshal

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

func (*QueryDenomHashResponse) MarshalTo

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

func (*QueryDenomHashResponse) MarshalToSizedBuffer

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

func (*QueryDenomHashResponse) ProtoMessage

func (*QueryDenomHashResponse) ProtoMessage()

func (*QueryDenomHashResponse) Reset

func (m *QueryDenomHashResponse) Reset()

func (*QueryDenomHashResponse) Size

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

func (*QueryDenomHashResponse) String

func (m *QueryDenomHashResponse) String() string

func (*QueryDenomHashResponse) Unmarshal

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

func (*QueryDenomHashResponse) XXX_DiscardUnknown

func (m *QueryDenomHashResponse) XXX_DiscardUnknown()

func (*QueryDenomHashResponse) XXX_Marshal

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

func (*QueryDenomHashResponse) XXX_Merge

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

func (*QueryDenomHashResponse) XXX_Size

func (m *QueryDenomHashResponse) XXX_Size() int

func (*QueryDenomHashResponse) XXX_Unmarshal

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

type QueryDenomRequest

type QueryDenomRequest struct {
	// hash (in hex format) or denom (full denom with ibc prefix) of the on chain denomination.
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
}

QueryDenomRequest is the request type for the Query/Denom RPC method

func (*QueryDenomRequest) Descriptor

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

func (*QueryDenomRequest) GetHash

func (m *QueryDenomRequest) GetHash() string

func (*QueryDenomRequest) Marshal

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

func (*QueryDenomRequest) MarshalTo

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

func (*QueryDenomRequest) MarshalToSizedBuffer

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

func (*QueryDenomRequest) ProtoMessage

func (*QueryDenomRequest) ProtoMessage()

func (*QueryDenomRequest) Reset

func (m *QueryDenomRequest) Reset()

func (*QueryDenomRequest) Size

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

func (*QueryDenomRequest) String

func (m *QueryDenomRequest) String() string

func (*QueryDenomRequest) Unmarshal

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

func (*QueryDenomRequest) XXX_DiscardUnknown

func (m *QueryDenomRequest) XXX_DiscardUnknown()

func (*QueryDenomRequest) XXX_Marshal

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

func (*QueryDenomRequest) XXX_Merge

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

func (*QueryDenomRequest) XXX_Size

func (m *QueryDenomRequest) XXX_Size() int

func (*QueryDenomRequest) XXX_Unmarshal

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

type QueryDenomResponse

type QueryDenomResponse struct {
	// denom returns the requested denomination.
	Denom *Denom `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryDenomResponse is the response type for the Query/Denom RPC method.

func (*QueryDenomResponse) Descriptor

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

func (*QueryDenomResponse) GetDenom

func (m *QueryDenomResponse) GetDenom() *Denom

func (*QueryDenomResponse) Marshal

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

func (*QueryDenomResponse) MarshalTo

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

func (*QueryDenomResponse) MarshalToSizedBuffer

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

func (*QueryDenomResponse) ProtoMessage

func (*QueryDenomResponse) ProtoMessage()

func (*QueryDenomResponse) Reset

func (m *QueryDenomResponse) Reset()

func (*QueryDenomResponse) Size

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

func (*QueryDenomResponse) String

func (m *QueryDenomResponse) String() string

func (*QueryDenomResponse) Unmarshal

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

func (*QueryDenomResponse) XXX_DiscardUnknown

func (m *QueryDenomResponse) XXX_DiscardUnknown()

func (*QueryDenomResponse) XXX_Marshal

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

func (*QueryDenomResponse) XXX_Merge

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

func (*QueryDenomResponse) XXX_Size

func (m *QueryDenomResponse) XXX_Size() int

func (*QueryDenomResponse) XXX_Unmarshal

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

type QueryDenomTraceResponse

type QueryDenomTraceResponse struct{}

TODO: https://github.com/cosmos/ibc-go/issues/6421#issuecomment-2137516426 Kept around due to dependency. Empty and useless and ideally dropped before v9.

type QueryDenomTracesResponse

type QueryDenomTracesResponse struct{}

TODO: https://github.com/cosmos/ibc-go/issues/6421#issuecomment-2137516426 Kept around due to dependency. Empty and useless and ideally dropped before v9.

type QueryDenomsRequest

type QueryDenomsRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDenomsRequest is the request type for the Query/Denoms RPC method

func (*QueryDenomsRequest) Descriptor

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

func (*QueryDenomsRequest) GetPagination

func (m *QueryDenomsRequest) GetPagination() *query.PageRequest

func (*QueryDenomsRequest) Marshal

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

func (*QueryDenomsRequest) MarshalTo

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

func (*QueryDenomsRequest) MarshalToSizedBuffer

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

func (*QueryDenomsRequest) ProtoMessage

func (*QueryDenomsRequest) ProtoMessage()

func (*QueryDenomsRequest) Reset

func (m *QueryDenomsRequest) Reset()

func (*QueryDenomsRequest) Size

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

func (*QueryDenomsRequest) String

func (m *QueryDenomsRequest) String() string

func (*QueryDenomsRequest) Unmarshal

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

func (*QueryDenomsRequest) XXX_DiscardUnknown

func (m *QueryDenomsRequest) XXX_DiscardUnknown()

func (*QueryDenomsRequest) XXX_Marshal

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

func (*QueryDenomsRequest) XXX_Merge

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

func (*QueryDenomsRequest) XXX_Size

func (m *QueryDenomsRequest) XXX_Size() int

func (*QueryDenomsRequest) XXX_Unmarshal

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

type QueryDenomsResponse

type QueryDenomsResponse struct {
	// denoms returns all denominations.
	Denoms Denoms `protobuf:"bytes,1,rep,name=denoms,proto3,castrepeated=Denoms" json:"denoms"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDenomsResponse is the response type for the Query/Denoms RPC method.

func (*QueryDenomsResponse) Descriptor

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

func (*QueryDenomsResponse) GetDenoms

func (m *QueryDenomsResponse) GetDenoms() Denoms

func (*QueryDenomsResponse) GetPagination

func (m *QueryDenomsResponse) GetPagination() *query.PageResponse

func (*QueryDenomsResponse) Marshal

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

func (*QueryDenomsResponse) MarshalTo

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

func (*QueryDenomsResponse) MarshalToSizedBuffer

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

func (*QueryDenomsResponse) ProtoMessage

func (*QueryDenomsResponse) ProtoMessage()

func (*QueryDenomsResponse) Reset

func (m *QueryDenomsResponse) Reset()

func (*QueryDenomsResponse) Size

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

func (*QueryDenomsResponse) String

func (m *QueryDenomsResponse) String() string

func (*QueryDenomsResponse) Unmarshal

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

func (*QueryDenomsResponse) XXX_DiscardUnknown

func (m *QueryDenomsResponse) XXX_DiscardUnknown()

func (*QueryDenomsResponse) XXX_Marshal

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

func (*QueryDenomsResponse) XXX_Merge

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

func (*QueryDenomsResponse) XXX_Size

func (m *QueryDenomsResponse) XXX_Size() int

func (*QueryDenomsResponse) XXX_Unmarshal

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

type QueryEscrowAddressRequest

type QueryEscrowAddressRequest struct {
	// unique port identifier
	PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	// unique channel identifier
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
}

QueryEscrowAddressRequest is the request type for the EscrowAddress RPC method.

func (*QueryEscrowAddressRequest) Descriptor

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

func (*QueryEscrowAddressRequest) GetChannelId

func (m *QueryEscrowAddressRequest) GetChannelId() string

func (*QueryEscrowAddressRequest) GetPortId

func (m *QueryEscrowAddressRequest) GetPortId() string

func (*QueryEscrowAddressRequest) Marshal

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

func (*QueryEscrowAddressRequest) MarshalTo

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

func (*QueryEscrowAddressRequest) MarshalToSizedBuffer

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

func (*QueryEscrowAddressRequest) ProtoMessage

func (*QueryEscrowAddressRequest) ProtoMessage()

func (*QueryEscrowAddressRequest) Reset

func (m *QueryEscrowAddressRequest) Reset()

func (*QueryEscrowAddressRequest) Size

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

func (*QueryEscrowAddressRequest) String

func (m *QueryEscrowAddressRequest) String() string

func (*QueryEscrowAddressRequest) Unmarshal

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

func (*QueryEscrowAddressRequest) XXX_DiscardUnknown

func (m *QueryEscrowAddressRequest) XXX_DiscardUnknown()

func (*QueryEscrowAddressRequest) XXX_Marshal

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

func (*QueryEscrowAddressRequest) XXX_Merge

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

func (*QueryEscrowAddressRequest) XXX_Size

func (m *QueryEscrowAddressRequest) XXX_Size() int

func (*QueryEscrowAddressRequest) XXX_Unmarshal

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

type QueryEscrowAddressResponse

type QueryEscrowAddressResponse struct {
	// the escrow account address
	EscrowAddress string `protobuf:"bytes,1,opt,name=escrow_address,json=escrowAddress,proto3" json:"escrow_address,omitempty"`
}

QueryEscrowAddressResponse is the response type of the EscrowAddress RPC method.

func (*QueryEscrowAddressResponse) Descriptor

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

func (*QueryEscrowAddressResponse) GetEscrowAddress

func (m *QueryEscrowAddressResponse) GetEscrowAddress() string

func (*QueryEscrowAddressResponse) Marshal

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

func (*QueryEscrowAddressResponse) MarshalTo

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

func (*QueryEscrowAddressResponse) MarshalToSizedBuffer

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

func (*QueryEscrowAddressResponse) ProtoMessage

func (*QueryEscrowAddressResponse) ProtoMessage()

func (*QueryEscrowAddressResponse) Reset

func (m *QueryEscrowAddressResponse) Reset()

func (*QueryEscrowAddressResponse) Size

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

func (*QueryEscrowAddressResponse) String

func (m *QueryEscrowAddressResponse) String() string

func (*QueryEscrowAddressResponse) Unmarshal

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

func (*QueryEscrowAddressResponse) XXX_DiscardUnknown

func (m *QueryEscrowAddressResponse) XXX_DiscardUnknown()

func (*QueryEscrowAddressResponse) XXX_Marshal

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

func (*QueryEscrowAddressResponse) XXX_Merge

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

func (*QueryEscrowAddressResponse) XXX_Size

func (m *QueryEscrowAddressResponse) XXX_Size() int

func (*QueryEscrowAddressResponse) XXX_Unmarshal

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

type QueryParamsRequest

type QueryParamsRequest struct {
}

QueryParamsRequest is the request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor

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

func (*QueryParamsRequest) Marshal

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

func (*QueryParamsRequest) MarshalTo

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

func (*QueryParamsRequest) MarshalToSizedBuffer

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

func (*QueryParamsRequest) ProtoMessage

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size

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

func (*QueryParamsRequest) String

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal

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

func (*QueryParamsRequest) XXX_DiscardUnknown

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal

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

func (*QueryParamsRequest) XXX_Merge

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

func (*QueryParamsRequest) XXX_Size

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal

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

type QueryParamsResponse

type QueryParamsResponse struct {
	// params defines the parameters of the module.
	Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor

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

func (*QueryParamsResponse) GetParams

func (m *QueryParamsResponse) GetParams() *Params

func (*QueryParamsResponse) Marshal

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

func (*QueryParamsResponse) MarshalTo

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

func (*QueryParamsResponse) MarshalToSizedBuffer

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

func (*QueryParamsResponse) ProtoMessage

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size

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

func (*QueryParamsResponse) String

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal

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

func (*QueryParamsResponse) XXX_DiscardUnknown

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal

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

func (*QueryParamsResponse) XXX_Merge

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

func (*QueryParamsResponse) XXX_Size

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal

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

type QueryServer

type QueryServer interface {
	// Params queries all parameters of the ibc-transfer module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// DenomHash queries a denomination hash information.
	DenomHash(context.Context, *QueryDenomHashRequest) (*QueryDenomHashResponse, error)
	// EscrowAddress returns the escrow address for a particular port and channel id.
	EscrowAddress(context.Context, *QueryEscrowAddressRequest) (*QueryEscrowAddressResponse, error)
	// TotalEscrowForDenom returns the total amount of tokens in escrow based on the denom.
	TotalEscrowForDenom(context.Context, *QueryTotalEscrowForDenomRequest) (*QueryTotalEscrowForDenomResponse, error)
}

QueryServer is the server API for Query service.

type QueryTotalEscrowForDenomRequest

type QueryTotalEscrowForDenomRequest struct {
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryTotalEscrowForDenomRequest is the request type for TotalEscrowForDenom RPC method.

func (*QueryTotalEscrowForDenomRequest) Descriptor

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

func (*QueryTotalEscrowForDenomRequest) GetDenom

func (*QueryTotalEscrowForDenomRequest) Marshal

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

func (*QueryTotalEscrowForDenomRequest) MarshalTo

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

func (*QueryTotalEscrowForDenomRequest) MarshalToSizedBuffer

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

func (*QueryTotalEscrowForDenomRequest) ProtoMessage

func (*QueryTotalEscrowForDenomRequest) ProtoMessage()

func (*QueryTotalEscrowForDenomRequest) Reset

func (*QueryTotalEscrowForDenomRequest) Size

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

func (*QueryTotalEscrowForDenomRequest) String

func (*QueryTotalEscrowForDenomRequest) Unmarshal

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

func (*QueryTotalEscrowForDenomRequest) XXX_DiscardUnknown

func (m *QueryTotalEscrowForDenomRequest) XXX_DiscardUnknown()

func (*QueryTotalEscrowForDenomRequest) XXX_Marshal

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

func (*QueryTotalEscrowForDenomRequest) XXX_Merge

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

func (*QueryTotalEscrowForDenomRequest) XXX_Size

func (m *QueryTotalEscrowForDenomRequest) XXX_Size() int

func (*QueryTotalEscrowForDenomRequest) XXX_Unmarshal

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

type QueryTotalEscrowForDenomResponse

type QueryTotalEscrowForDenomResponse struct {
	Amount types.Coin `protobuf:"bytes,1,opt,name=amount,proto3" json:"amount"`
}

QueryTotalEscrowForDenomResponse is the response type for TotalEscrowForDenom RPC method.

func (*QueryTotalEscrowForDenomResponse) Descriptor

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

func (*QueryTotalEscrowForDenomResponse) GetAmount

func (*QueryTotalEscrowForDenomResponse) Marshal

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

func (*QueryTotalEscrowForDenomResponse) MarshalTo

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

func (*QueryTotalEscrowForDenomResponse) MarshalToSizedBuffer

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

func (*QueryTotalEscrowForDenomResponse) ProtoMessage

func (*QueryTotalEscrowForDenomResponse) ProtoMessage()

func (*QueryTotalEscrowForDenomResponse) Reset

func (*QueryTotalEscrowForDenomResponse) Size

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

func (*QueryTotalEscrowForDenomResponse) String

func (*QueryTotalEscrowForDenomResponse) Unmarshal

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

func (*QueryTotalEscrowForDenomResponse) XXX_DiscardUnknown

func (m *QueryTotalEscrowForDenomResponse) XXX_DiscardUnknown()

func (*QueryTotalEscrowForDenomResponse) XXX_Marshal

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

func (*QueryTotalEscrowForDenomResponse) XXX_Merge

func (*QueryTotalEscrowForDenomResponse) XXX_Size

func (m *QueryTotalEscrowForDenomResponse) XXX_Size() int

func (*QueryTotalEscrowForDenomResponse) XXX_Unmarshal

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

type QueryV2Client

type QueryV2Client interface {
	// Denoms queries all denominations
	Denoms(ctx context.Context, in *QueryDenomsRequest, opts ...grpc.CallOption) (*QueryDenomsResponse, error)
	// Denom queries a denomination
	Denom(ctx context.Context, in *QueryDenomRequest, opts ...grpc.CallOption) (*QueryDenomResponse, error)
}

QueryV2Client is the client API for QueryV2 service.

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

func NewQueryV2Client

func NewQueryV2Client(cc grpc1.ClientConn) QueryV2Client

type QueryV2Server

type QueryV2Server interface {
	// Denoms queries all denominations
	Denoms(context.Context, *QueryDenomsRequest) (*QueryDenomsResponse, error)
	// Denom queries a denomination
	Denom(context.Context, *QueryDenomRequest) (*QueryDenomResponse, error)
}

QueryV2Server is the server API for QueryV2 service.

type Token

type Token struct {
	// the token denomination
	Denom Denom `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom"`
	// the token amount to be transferred
	Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"`
}

Token defines a struct which represents a token to be transferred.

func (*Token) Descriptor

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

func (*Token) GetAmount

func (m *Token) GetAmount() string

func (*Token) GetDenom

func (m *Token) GetDenom() Denom

func (*Token) Marshal

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

func (*Token) MarshalTo

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

func (*Token) MarshalToSizedBuffer

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

func (*Token) ProtoMessage

func (*Token) ProtoMessage()

func (*Token) Reset

func (m *Token) Reset()

func (*Token) Size

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

func (*Token) String

func (m *Token) String() string

func (Token) ToCoin

func (t Token) ToCoin() (sdk.Coin, error)

ToCoin converts a Token to an sdk.Coin.

The function parses the Amount field of the Token into an sdkmath.Int and returns a new sdk.Coin with the IBCDenom of the Token's Denom field and the parsed Amount. If the Amount cannot be parsed, an error is returned with a wrapped error message.

func (*Token) Unmarshal

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

func (Token) Validate

func (t Token) Validate() error

Validate validates a token denomination and amount.

func (*Token) XXX_DiscardUnknown

func (m *Token) XXX_DiscardUnknown()

func (*Token) XXX_Marshal

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

func (*Token) XXX_Merge

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

func (*Token) XXX_Size

func (m *Token) XXX_Size() int

func (*Token) XXX_Unmarshal

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

type Tokens

type Tokens []Token

Tokens is a slice of Tokens

type TransferAuthorization

type TransferAuthorization struct {
	// port and channel amounts
	Allocations []Allocation `protobuf:"bytes,1,rep,name=allocations,proto3" json:"allocations"`
}

TransferAuthorization allows the grantee to spend up to spend_limit coins from the granter's account for ibc transfer on a specific channel

func NewTransferAuthorization

func NewTransferAuthorization(allocations ...Allocation) *TransferAuthorization

NewTransferAuthorization creates a new TransferAuthorization object.

func (TransferAuthorization) Accept

Accept implements Authorization.Accept.

func (*TransferAuthorization) Descriptor

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

func (*TransferAuthorization) GetAllocations

func (m *TransferAuthorization) GetAllocations() []Allocation

func (*TransferAuthorization) Marshal

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

func (*TransferAuthorization) MarshalTo

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

func (*TransferAuthorization) MarshalToSizedBuffer

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

func (TransferAuthorization) MsgTypeURL

func (TransferAuthorization) MsgTypeURL() string

MsgTypeURL implements Authorization.MsgTypeURL.

func (*TransferAuthorization) ProtoMessage

func (*TransferAuthorization) ProtoMessage()

func (*TransferAuthorization) Reset

func (m *TransferAuthorization) Reset()

func (*TransferAuthorization) Size

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

func (*TransferAuthorization) String

func (m *TransferAuthorization) String() string

func (*TransferAuthorization) Unmarshal

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

func (TransferAuthorization) ValidateBasic

func (a TransferAuthorization) ValidateBasic() error

ValidateBasic implements Authorization.ValidateBasic.

func (*TransferAuthorization) XXX_DiscardUnknown

func (m *TransferAuthorization) XXX_DiscardUnknown()

func (*TransferAuthorization) XXX_Marshal

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

func (*TransferAuthorization) XXX_Merge

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

func (*TransferAuthorization) XXX_Size

func (m *TransferAuthorization) XXX_Size() int

func (*TransferAuthorization) XXX_Unmarshal

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

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Transfer

func (*UnimplementedMsgServer) UpdateParams

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) DenomHash

func (*UnimplementedQueryServer) EscrowAddress

func (*UnimplementedQueryServer) Params

func (*UnimplementedQueryServer) TotalEscrowForDenom

type UnimplementedQueryV2Server

type UnimplementedQueryV2Server struct {
}

UnimplementedQueryV2Server can be embedded to have forward compatible implementations.

func (*UnimplementedQueryV2Server) Denom

func (*UnimplementedQueryV2Server) Denoms

Jump to

Keyboard shortcuts

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