types

package
v6.3.1 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: MIT Imports: 30 Imported by: 20

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeIncentivizedPacket        = "incentivized_ibc_packet"
	EventTypeRegisterPayee             = "register_payee"
	EventTypeRegisterCounterpartyPayee = "register_counterparty_payee"

	AttributeKeyRecvFee           = "recv_fee"
	AttributeKeyAckFee            = "ack_fee"
	AttributeKeyTimeoutFee        = "timeout_fee"
	AttributeKeyChannelID         = "channel_id"
	AttributeKeyRelayer           = "relayer"
	AttributeKeyPayee             = "payee"
	AttributeKeyCounterpartyPayee = "counterparty_payee"
)

29-fee events

View Source 
const (
	// ModuleName defines the 29-fee name
	ModuleName = "feeibc"

	// StoreKey is the store key string for IBC fee module
	StoreKey = ModuleName

	// RouterKey is the message route for IBC fee module
	RouterKey = ModuleName

	// QuerierRoute is the querier route for IBC fee module
	QuerierRoute = ModuleName

	Version = "ics29-1"

	// FeeEnabledPrefix is the key prefix for storing fee enabled flag
	FeeEnabledKeyPrefix = "feeEnabled"

	// PayeeKeyPrefix is the key prefix for the fee payee address stored in state
	PayeeKeyPrefix = "payee"

	// CounterpartyPayeeKeyPrefix is the key prefix for the counterparty payee address mapping
	CounterpartyPayeeKeyPrefix = "counterpartyPayee"

	// FeesInEscrowPrefix is the key prefix for fee in escrow mapping
	FeesInEscrowPrefix = "feesInEscrow"

	// ForwardRelayerPrefix is the key prefix for forward relayer addresses stored in state for async acknowledgements
	ForwardRelayerPrefix = "forwardRelayer"
)
View Source 
const (
	TypeMsgPayPacketFee      = "payPacketFee"
	TypeMsgPayPacketFeeAsync = "payPacketFeeAsync"
)

msg types

Variables

View Source 
var (
	ErrInvalidLengthAck        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAck          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAck = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (

	// 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.
	ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())

	// AminoCdc is a amino codec created to support amino json compatible msgs.
	AminoCdc = codec.NewAminoCodec(amino)
)
View Source 
var (
	ErrInvalidVersion                = sdkerrors.Register(ModuleName, 2, "invalid ICS29 middleware version")
	ErrRefundAccNotFound             = sdkerrors.Register(ModuleName, 3, "no account found for given refund address")
	ErrBalanceNotFound               = sdkerrors.Register(ModuleName, 4, "balance not found for given account address")
	ErrFeeNotFound                   = sdkerrors.Register(ModuleName, 5, "there is no fee escrowed for the given packetID")
	ErrRelayersNotEmpty              = sdkerrors.Register(ModuleName, 6, "relayers must not be set. This feature is not supported")
	ErrCounterpartyPayeeEmpty        = sdkerrors.Register(ModuleName, 7, "counterparty payee must not be empty")
	ErrForwardRelayerAddressNotFound = sdkerrors.Register(ModuleName, 8, "forward relayer address not found")
	ErrFeeNotEnabled                 = sdkerrors.Register(ModuleName, 9, "fee module is not enabled for this channel. If this error occurs after channel setup, fee module may not be enabled")
	ErrRelayerNotFoundForAsyncAck    = sdkerrors.Register(ModuleName, 10, "relayer address must be stored for async WriteAcknowledgement")
	ErrFeeModuleLocked               = sdkerrors.Register(ModuleName, 11, "the fee module is currently locked, a severe bug has been detected")
)

29-fee sentinel errors

View Source 
var (
	ErrInvalidLengthFee        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFee          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFee = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthMetadata        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMetadata          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMetadata = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)

Functions

func KeyCounterpartyPayee 

func KeyCounterpartyPayee(address, channelID string) []byte

KeyCounterpartyPayee returns the key for relayer address -> counterparty payee address mapping

func KeyFeeEnabled 

func KeyFeeEnabled(portID, channelID string) []byte

KeyFeeEnabled returns the key that stores a flag to determine if fee logic should be enabled for the given port and channel identifiers.

func KeyFeesInEscrow 

func KeyFeesInEscrow(packetID channeltypes.PacketId) []byte

KeyFeesInEscrow returns the key for escrowed fees

func KeyFeesInEscrowChannelPrefix 

func KeyFeesInEscrowChannelPrefix(portID, channelID string) []byte

KeyFeesInEscrowChannelPrefix returns the key prefix for escrowed fees on the given channel

func KeyLocked 

func KeyLocked() []byte

KeyLocked returns the key used to lock and unlock the fee module. This key is used in the presence of a severe bug.

func KeyPayee 

func KeyPayee(relayerAddr, channelID string) []byte

KeyPayee returns the key for relayer address -> payee address mapping

func KeyRelayerAddressForAsyncAck 

func KeyRelayerAddressForAsyncAck(packetID channeltypes.PacketId) []byte

KeyRelayerAddressForAsyncAck returns the key for packetID -> forwardAddress mapping

func ParseKeyCounterpartyPayee 

func ParseKeyCounterpartyPayee(key string) (address string, channelID string, error error)

ParseKeyCounterpartyPayee returns the registered relayer address and channelID used to store the counterparty payee address

func ParseKeyFeeEnabled 

func ParseKeyFeeEnabled(key string) (portID, channelID string, err error)

ParseKeyFeeEnabled parses the key used to indicate if the fee logic should be enabled for the given port and channel identifiers.

func ParseKeyFeesInEscrow 

func ParseKeyFeesInEscrow(key string) (channeltypes.PacketId, error)

ParseKeyFeesInEscrow parses the key used to store fees in escrow and returns the packet id

func ParseKeyPayeeAddress 

func ParseKeyPayeeAddress(key string) (relayerAddr, channelID string, err error)

ParseKeyPayeeAddress returns the registered relayer addresss and channelID used to the store the fee payee address

func ParseKeyRelayerAddressForAsyncAck 

func ParseKeyRelayerAddressForAsyncAck(key string) (channeltypes.PacketId, error)

ParseKeyRelayerAddressForAsyncAck parses the key used to store the forward relayer address and returns the packetID

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the 29-fee module interfaces to protobuf Any.

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/ibc 29-fee 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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	GetModuleAddress(name string) sdk.AccAddress
	GetAccount(sdk.Context, sdk.AccAddress) types.AccountI
}

AccountKeeper defines the contract required for account APIs.

type BankKeeper 

type BankKeeper interface {
	HasBalance(ctx sdk.Context, addr sdk.AccAddress, amt sdk.Coin) bool
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	BlockedAddr(sdk.AccAddress) bool
	IsSendEnabledCoins(ctx sdk.Context, coins ...sdk.Coin) error
}

BankKeeper defines the expected bank keeper

type ChannelKeeper 

type ChannelKeeper interface {
	GetChannel(ctx sdk.Context, srcPort, srcChan string) (channel channeltypes.Channel, found bool)
	GetPacketCommitment(ctx sdk.Context, portID, channelID string, sequence uint64) []byte
	GetNextSequenceSend(ctx sdk.Context, portID, channelID string) (uint64, bool)
}

ChannelKeeper defines the expected IBC channel keeper

type Fee 

type Fee struct {
	// the packet receive fee
	RecvFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 142-byte string literal not displayed */
	// the packet acknowledgement fee
	AckFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 138-byte string literal not displayed */
	// the packet timeout fee
	TimeoutFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 154-byte string literal not displayed */
}

Fee defines the ICS29 receive, acknowledgement and timeout fees

func NewFee 

func NewFee(recvFee, ackFee, timeoutFee sdk.Coins) Fee

NewFee creates and returns a new Fee struct encapsulating the receive, acknowledgement and timeout fees as sdk.Coins

func (*Fee) Descriptor 

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

func (*Fee) GetAckFee 

func (m *Fee) GetAckFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*Fee) GetRecvFee 

func (m *Fee) GetRecvFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*Fee) GetTimeoutFee 

func (m *Fee) GetTimeoutFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*Fee) Marshal 

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

func (*Fee) MarshalTo 

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

func (*Fee) MarshalToSizedBuffer 

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

func (*Fee) ProtoMessage 

func (*Fee) ProtoMessage()

func (*Fee) Reset 

func (m *Fee) Reset()

func (*Fee) Size 

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

func (*Fee) String 

func (m *Fee) String() string

func (Fee) Total 

func (f Fee) Total() sdk.Coins

Total returns the total amount for a given Fee

func (*Fee) Unmarshal 

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

func (Fee) Validate 

func (f Fee) Validate() error

Validate asserts that each Fee is valid and all three Fees are not empty or zero

func (*Fee) XXX_DiscardUnknown 

func (m *Fee) XXX_DiscardUnknown()

func (*Fee) XXX_Marshal 

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

func (*Fee) XXX_Merge 

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

func (*Fee) XXX_Size 

func (m *Fee) XXX_Size() int

func (*Fee) XXX_Unmarshal 

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

type FeeEnabledChannel 

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

FeeEnabledChannel contains the PortID & ChannelID for a fee enabled channel

func (*FeeEnabledChannel) Descriptor 

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

func (*FeeEnabledChannel) GetChannelId 

func (m *FeeEnabledChannel) GetChannelId() string

func (*FeeEnabledChannel) GetPortId 

func (m *FeeEnabledChannel) GetPortId() string

func (*FeeEnabledChannel) Marshal 

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

func (*FeeEnabledChannel) MarshalTo 

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

func (*FeeEnabledChannel) MarshalToSizedBuffer 

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

func (*FeeEnabledChannel) ProtoMessage 

func (*FeeEnabledChannel) ProtoMessage()

func (*FeeEnabledChannel) Reset 

func (m *FeeEnabledChannel) Reset()

func (*FeeEnabledChannel) Size 

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

func (*FeeEnabledChannel) String 

func (m *FeeEnabledChannel) String() string

func (*FeeEnabledChannel) Unmarshal 

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

func (*FeeEnabledChannel) XXX_DiscardUnknown 

func (m *FeeEnabledChannel) XXX_DiscardUnknown()

func (*FeeEnabledChannel) XXX_Marshal 

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

func (*FeeEnabledChannel) XXX_Merge 

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

func (*FeeEnabledChannel) XXX_Size 

func (m *FeeEnabledChannel) XXX_Size() int

func (*FeeEnabledChannel) XXX_Unmarshal 

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

type ForwardRelayerAddress 

type ForwardRelayerAddress struct {
	// the forward relayer address
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// unique packet identifer comprised of the channel ID, port ID and sequence
	PacketId types.PacketId `protobuf:"bytes,2,opt,name=packet_id,json=packetId,proto3" json:"packet_id" yaml:"packet_id"`
}

ForwardRelayerAddress contains the forward relayer address and PacketId used for async acknowledgements

func (*ForwardRelayerAddress) Descriptor 

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

func (*ForwardRelayerAddress) GetAddress 

func (m *ForwardRelayerAddress) GetAddress() string

func (*ForwardRelayerAddress) GetPacketId 

func (m *ForwardRelayerAddress) GetPacketId() types.PacketId

func (*ForwardRelayerAddress) Marshal 

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

func (*ForwardRelayerAddress) MarshalTo 

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

func (*ForwardRelayerAddress) MarshalToSizedBuffer 

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

func (*ForwardRelayerAddress) ProtoMessage 

func (*ForwardRelayerAddress) ProtoMessage()

func (*ForwardRelayerAddress) Reset 

func (m *ForwardRelayerAddress) Reset()

func (*ForwardRelayerAddress) Size 

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

func (*ForwardRelayerAddress) String 

func (m *ForwardRelayerAddress) String() string

func (*ForwardRelayerAddress) Unmarshal 

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

func (*ForwardRelayerAddress) XXX_DiscardUnknown 

func (m *ForwardRelayerAddress) XXX_DiscardUnknown()

func (*ForwardRelayerAddress) XXX_Marshal 

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

func (*ForwardRelayerAddress) XXX_Merge 

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

func (*ForwardRelayerAddress) XXX_Size 

func (m *ForwardRelayerAddress) XXX_Size() int

func (*ForwardRelayerAddress) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// list of identified packet fees
	IdentifiedFees []IdentifiedPacketFees `protobuf:"bytes,1,rep,name=identified_fees,json=identifiedFees,proto3" json:"identified_fees" yaml:"identified_fees"`
	// list of fee enabled channels
	FeeEnabledChannels []FeeEnabledChannel `` /* 135-byte string literal not displayed */
	// list of registered payees
	RegisteredPayees []RegisteredPayee `protobuf:"bytes,3,rep,name=registered_payees,json=registeredPayees,proto3" json:"registered_payees" yaml:"registered_payees"`
	// list of registered counterparty payees
	RegisteredCounterpartyPayees []RegisteredCounterpartyPayee `` /* 175-byte string literal not displayed */
	// list of forward relayer addresses
	ForwardRelayers []ForwardRelayerAddress `protobuf:"bytes,5,rep,name=forward_relayers,json=forwardRelayers,proto3" json:"forward_relayers" yaml:"forward_relayers"`
}

GenesisState defines the ICS29 fee middleware genesis state

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns a default instance of the 29-fee GenesisState.

func NewGenesisState 

func NewGenesisState(
	identifiedFees []IdentifiedPacketFees,
	feeEnabledChannels []FeeEnabledChannel,
	registeredPayees []RegisteredPayee,
	registeredCounterpartyPayees []RegisteredCounterpartyPayee,
	forwardRelayers []ForwardRelayerAddress,
) *GenesisState

NewGenesisState creates a 29-fee GenesisState instance.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetFeeEnabledChannels 

func (m *GenesisState) GetFeeEnabledChannels() []FeeEnabledChannel

func (*GenesisState) GetForwardRelayers 

func (m *GenesisState) GetForwardRelayers() []ForwardRelayerAddress

func (*GenesisState) GetIdentifiedFees 

func (m *GenesisState) GetIdentifiedFees() []IdentifiedPacketFees

func (*GenesisState) GetRegisteredCounterpartyPayees 

func (m *GenesisState) GetRegisteredCounterpartyPayees() []RegisteredCounterpartyPayee

func (*GenesisState) GetRegisteredPayees 

func (m *GenesisState) GetRegisteredPayees() []RegisteredPayee

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 IdentifiedPacketFees 

type IdentifiedPacketFees struct {
	// unique packet identifier comprised of the channel ID, port ID and sequence
	PacketId types1.PacketId `protobuf:"bytes,1,opt,name=packet_id,json=packetId,proto3" json:"packet_id" yaml:"packet_id"`
	// list of packet fees
	PacketFees []PacketFee `protobuf:"bytes,2,rep,name=packet_fees,json=packetFees,proto3" json:"packet_fees" yaml:"packet_fees"`
}

IdentifiedPacketFees contains a list of type PacketFee and associated PacketId

func NewIdentifiedPacketFees 

func NewIdentifiedPacketFees(packetID channeltypes.PacketId, packetFees []PacketFee) IdentifiedPacketFees

NewIdentifiedPacketFees creates and returns a new IdentifiedPacketFees struct containing a packet ID and packet fees

func (*IdentifiedPacketFees) Descriptor 

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

func (*IdentifiedPacketFees) GetPacketFees 

func (m *IdentifiedPacketFees) GetPacketFees() []PacketFee

func (*IdentifiedPacketFees) GetPacketId 

func (m *IdentifiedPacketFees) GetPacketId() types1.PacketId

func (*IdentifiedPacketFees) Marshal 

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

func (*IdentifiedPacketFees) MarshalTo 

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

func (*IdentifiedPacketFees) MarshalToSizedBuffer 

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

func (*IdentifiedPacketFees) ProtoMessage 

func (*IdentifiedPacketFees) ProtoMessage()

func (*IdentifiedPacketFees) Reset 

func (m *IdentifiedPacketFees) Reset()

func (*IdentifiedPacketFees) Size 

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

func (*IdentifiedPacketFees) String 

func (m *IdentifiedPacketFees) String() string

func (*IdentifiedPacketFees) Unmarshal 

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

func (*IdentifiedPacketFees) XXX_DiscardUnknown 

func (m *IdentifiedPacketFees) XXX_DiscardUnknown()

func (*IdentifiedPacketFees) XXX_Marshal 

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

func (*IdentifiedPacketFees) XXX_Merge 

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

func (*IdentifiedPacketFees) XXX_Size 

func (m *IdentifiedPacketFees) XXX_Size() int

func (*IdentifiedPacketFees) XXX_Unmarshal 

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

type IncentivizedAcknowledgement 

type IncentivizedAcknowledgement struct {
	// the underlying app acknowledgement bytes
	AppAcknowledgement []byte `` /* 142-byte string literal not displayed */
	// the relayer address which submits the recv packet message
	ForwardRelayerAddress string `` /* 157-byte string literal not displayed */
	// success flag of the base application callback
	UnderlyingAppSuccess bool `` /* 155-byte string literal not displayed */
}

IncentivizedAcknowledgement is the acknowledgement format to be used by applications wrapped in the fee middleware

func NewIncentivizedAcknowledgement 

func NewIncentivizedAcknowledgement(relayer string, ack []byte, success bool) IncentivizedAcknowledgement

NewIncentivizedAcknowledgement creates a new instance of IncentivizedAcknowledgement

func (IncentivizedAcknowledgement) Acknowledgement 

func (ack IncentivizedAcknowledgement) Acknowledgement() []byte

Acknowledgement implements the Acknowledgement interface. It returns the acknowledgement serialised using JSON.

func (*IncentivizedAcknowledgement) Descriptor 

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

func (*IncentivizedAcknowledgement) GetAppAcknowledgement 

func (m *IncentivizedAcknowledgement) GetAppAcknowledgement() []byte

func (*IncentivizedAcknowledgement) GetForwardRelayerAddress 

func (m *IncentivizedAcknowledgement) GetForwardRelayerAddress() string

func (*IncentivizedAcknowledgement) GetUnderlyingAppSuccess 

func (m *IncentivizedAcknowledgement) GetUnderlyingAppSuccess() bool

func (*IncentivizedAcknowledgement) Marshal 

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

func (*IncentivizedAcknowledgement) MarshalTo 

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

func (*IncentivizedAcknowledgement) MarshalToSizedBuffer 

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

func (*IncentivizedAcknowledgement) ProtoMessage 

func (*IncentivizedAcknowledgement) ProtoMessage()

func (*IncentivizedAcknowledgement) Reset 

func (m *IncentivizedAcknowledgement) Reset()

func (*IncentivizedAcknowledgement) Size 

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

func (*IncentivizedAcknowledgement) String 

func (m *IncentivizedAcknowledgement) String() string

func (IncentivizedAcknowledgement) Success 

func (ack IncentivizedAcknowledgement) Success() bool

Success implements the Acknowledgement interface. The acknowledgement is considered successful if the forward relayer address is empty. Otherwise it is considered a failed acknowledgement.

func (*IncentivizedAcknowledgement) Unmarshal 

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

func (*IncentivizedAcknowledgement) XXX_DiscardUnknown 

func (m *IncentivizedAcknowledgement) XXX_DiscardUnknown()

func (*IncentivizedAcknowledgement) XXX_Marshal 

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

func (*IncentivizedAcknowledgement) XXX_Merge 

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

func (*IncentivizedAcknowledgement) XXX_Size 

func (m *IncentivizedAcknowledgement) XXX_Size() int

func (*IncentivizedAcknowledgement) XXX_Unmarshal 

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

type Metadata 

type Metadata struct {
	// fee_version defines the ICS29 fee version
	FeeVersion string `protobuf:"bytes,1,opt,name=fee_version,json=feeVersion,proto3" json:"fee_version,omitempty" yaml:"fee_version"`
	// app_version defines the underlying application version, which may or may not be a JSON encoded bytestring
	AppVersion string `protobuf:"bytes,2,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty" yaml:"app_version"`
}

Metadata defines the ICS29 channel specific metadata encoded into the channel version bytestring See ICS004: https://github.com/cosmos/ibc/tree/master/spec/core/ics-004-channel-and-packet-semantics#Versioning

func (*Metadata) Descriptor 

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

func (*Metadata) GetAppVersion 

func (m *Metadata) GetAppVersion() string

func (*Metadata) GetFeeVersion 

func (m *Metadata) GetFeeVersion() string

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) MarshalToSizedBuffer 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

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

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// RegisterPayee defines a rpc handler method for MsgRegisterPayee
	// RegisterPayee is called by the relayer on each channelEnd and allows them to set an optional
	// payee to which reverse and timeout relayer packet fees will be paid out. The payee should be registered on
	// the source chain from which packets originate as this is where fee distribution takes place. This function may be
	// called more than once by a relayer, in which case, the latest payee is always used.
	RegisterPayee(ctx context.Context, in *MsgRegisterPayee, opts ...grpc.CallOption) (*MsgRegisterPayeeResponse, error)
	// RegisterCounterpartyPayee defines a rpc handler method for MsgRegisterCounterpartyPayee
	// RegisterCounterpartyPayee is called by the relayer on each channelEnd and allows them to specify the counterparty
	// payee address before relaying. This ensures they will be properly compensated for forward relaying since
	// the destination chain must include the registered counterparty payee address in the acknowledgement. This function
	// may be called more than once by a relayer, in which case, the latest counterparty payee address is always used.
	RegisterCounterpartyPayee(ctx context.Context, in *MsgRegisterCounterpartyPayee, opts ...grpc.CallOption) (*MsgRegisterCounterpartyPayeeResponse, error)
	// PayPacketFee defines a rpc handler method for MsgPayPacketFee
	// PayPacketFee is an open callback that may be called by any module/user that wishes to escrow funds in order to
	// incentivize the relaying of the packet at the next sequence
	// NOTE: This method is intended to be used within a multi msg transaction, where the subsequent msg that follows
	// initiates the lifecycle of the incentivized packet
	PayPacketFee(ctx context.Context, in *MsgPayPacketFee, opts ...grpc.CallOption) (*MsgPayPacketFeeResponse, error)
	// PayPacketFeeAsync defines a rpc handler method for MsgPayPacketFeeAsync
	// PayPacketFeeAsync is an open callback that may be called by any module/user that wishes to escrow funds in order to
	// incentivize the relaying of a known packet (i.e. at a particular sequence)
	PayPacketFeeAsync(ctx context.Context, in *MsgPayPacketFeeAsync, opts ...grpc.CallOption) (*MsgPayPacketFeeAsyncResponse, 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 MsgPayPacketFee 

type MsgPayPacketFee struct {
	// fee encapsulates the recv, ack and timeout fees associated with an IBC packet
	Fee Fee `protobuf:"bytes,1,opt,name=fee,proto3" json:"fee"`
	// the source port unique identifier
	SourcePortId string `protobuf:"bytes,2,opt,name=source_port_id,json=sourcePortId,proto3" json:"source_port_id,omitempty" yaml:"source_port_id"`
	// the source channel unique identifer
	SourceChannelId string `` /* 133-byte string literal not displayed */
	// account address to refund fee if necessary
	Signer string `protobuf:"bytes,4,opt,name=signer,proto3" json:"signer,omitempty"`
	// optional list of relayers permitted to the receive packet fees
	Relayers []string `protobuf:"bytes,5,rep,name=relayers,proto3" json:"relayers,omitempty"`
}

MsgPayPacketFee defines the request type for the PayPacketFee rpc This Msg can be used to pay for a packet at the next sequence send & should be combined with the Msg that will be paid for

func NewMsgPayPacketFee 

func NewMsgPayPacketFee(fee Fee, sourcePortID, sourceChannelID, signer string, relayers []string) *MsgPayPacketFee

NewMsgPayPacketFee creates a new instance of MsgPayPacketFee

func (*MsgPayPacketFee) Descriptor 

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

func (MsgPayPacketFee) GetSignBytes 

func (msg MsgPayPacketFee) GetSignBytes() []byte

GetSignBytes implements sdk.Msg.

func (MsgPayPacketFee) GetSigners 

func (msg MsgPayPacketFee) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgPayPacketFee) Marshal 

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

func (*MsgPayPacketFee) MarshalTo 

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

func (*MsgPayPacketFee) MarshalToSizedBuffer 

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

func (*MsgPayPacketFee) ProtoMessage 

func (*MsgPayPacketFee) ProtoMessage()

func (*MsgPayPacketFee) Reset 

func (m *MsgPayPacketFee) Reset()

func (MsgPayPacketFee) Route 

func (msg MsgPayPacketFee) Route() string

Route implements sdk.Msg

func (*MsgPayPacketFee) Size 

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

func (*MsgPayPacketFee) String 

func (m *MsgPayPacketFee) String() string

func (MsgPayPacketFee) Type 

func (msg MsgPayPacketFee) Type() string

Type implements sdk.Msg

func (*MsgPayPacketFee) Unmarshal 

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

func (MsgPayPacketFee) ValidateBasic 

func (msg MsgPayPacketFee) ValidateBasic() error

ValidateBasic performs a basic check of the MsgPayPacketFee fields

func (*MsgPayPacketFee) XXX_DiscardUnknown 

func (m *MsgPayPacketFee) XXX_DiscardUnknown()

func (*MsgPayPacketFee) XXX_Marshal 

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

func (*MsgPayPacketFee) XXX_Merge 

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

func (*MsgPayPacketFee) XXX_Size 

func (m *MsgPayPacketFee) XXX_Size() int

func (*MsgPayPacketFee) XXX_Unmarshal 

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

type MsgPayPacketFeeAsync 

type MsgPayPacketFeeAsync struct {
	// unique packet identifier comprised of the channel ID, port ID and sequence
	PacketId types.PacketId `protobuf:"bytes,1,opt,name=packet_id,json=packetId,proto3" json:"packet_id" yaml:"packet_id"`
	// the packet fee associated with a particular IBC packet
	PacketFee PacketFee `protobuf:"bytes,2,opt,name=packet_fee,json=packetFee,proto3" json:"packet_fee" yaml:"packet_fee"`
}

MsgPayPacketFeeAsync defines the request type for the PayPacketFeeAsync rpc This Msg can be used to pay for a packet at a specified sequence (instead of the next sequence send)

func NewMsgPayPacketFeeAsync 

func NewMsgPayPacketFeeAsync(packetID channeltypes.PacketId, packetFee PacketFee) *MsgPayPacketFeeAsync

NewMsgPayPacketAsync creates a new instance of MsgPayPacketFee

func (*MsgPayPacketFeeAsync) Descriptor 

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

func (MsgPayPacketFeeAsync) GetSignBytes 

func (msg MsgPayPacketFeeAsync) GetSignBytes() []byte

GetSignBytes implements sdk.Msg.

func (MsgPayPacketFeeAsync) GetSigners 

func (msg MsgPayPacketFeeAsync) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg The signer of the fee message must be the refund address

func (*MsgPayPacketFeeAsync) Marshal 

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

func (*MsgPayPacketFeeAsync) MarshalTo 

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

func (*MsgPayPacketFeeAsync) MarshalToSizedBuffer 

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

func (*MsgPayPacketFeeAsync) ProtoMessage 

func (*MsgPayPacketFeeAsync) ProtoMessage()

func (*MsgPayPacketFeeAsync) Reset 

func (m *MsgPayPacketFeeAsync) Reset()

func (MsgPayPacketFeeAsync) Route 

func (msg MsgPayPacketFeeAsync) Route() string

Route implements sdk.Msg

func (*MsgPayPacketFeeAsync) Size 

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

func (*MsgPayPacketFeeAsync) String 

func (m *MsgPayPacketFeeAsync) String() string

func (MsgPayPacketFeeAsync) Type 

func (msg MsgPayPacketFeeAsync) Type() string

Type implements sdk.Msg

func (*MsgPayPacketFeeAsync) Unmarshal 

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

func (MsgPayPacketFeeAsync) ValidateBasic 

func (msg MsgPayPacketFeeAsync) ValidateBasic() error

ValidateBasic performs a basic check of the MsgPayPacketFeeAsync fields

func (*MsgPayPacketFeeAsync) XXX_DiscardUnknown 

func (m *MsgPayPacketFeeAsync) XXX_DiscardUnknown()

func (*MsgPayPacketFeeAsync) XXX_Marshal 

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

func (*MsgPayPacketFeeAsync) XXX_Merge 

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

func (*MsgPayPacketFeeAsync) XXX_Size 

func (m *MsgPayPacketFeeAsync) XXX_Size() int

func (*MsgPayPacketFeeAsync) XXX_Unmarshal 

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

type MsgPayPacketFeeAsyncResponse 

type MsgPayPacketFeeAsyncResponse struct {
}

MsgPayPacketFeeAsyncResponse defines the response type for the PayPacketFeeAsync rpc

func (*MsgPayPacketFeeAsyncResponse) Descriptor 

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

func (*MsgPayPacketFeeAsyncResponse) Marshal 

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

func (*MsgPayPacketFeeAsyncResponse) MarshalTo 

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

func (*MsgPayPacketFeeAsyncResponse) MarshalToSizedBuffer 

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

func (*MsgPayPacketFeeAsyncResponse) ProtoMessage 

func (*MsgPayPacketFeeAsyncResponse) ProtoMessage()

func (*MsgPayPacketFeeAsyncResponse) Reset 

func (m *MsgPayPacketFeeAsyncResponse) Reset()

func (*MsgPayPacketFeeAsyncResponse) Size 

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

func (*MsgPayPacketFeeAsyncResponse) String 

func (m *MsgPayPacketFeeAsyncResponse) String() string

func (*MsgPayPacketFeeAsyncResponse) Unmarshal 

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

func (*MsgPayPacketFeeAsyncResponse) XXX_DiscardUnknown 

func (m *MsgPayPacketFeeAsyncResponse) XXX_DiscardUnknown()

func (*MsgPayPacketFeeAsyncResponse) XXX_Marshal 

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

func (*MsgPayPacketFeeAsyncResponse) XXX_Merge 

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

func (*MsgPayPacketFeeAsyncResponse) XXX_Size 

func (m *MsgPayPacketFeeAsyncResponse) XXX_Size() int

func (*MsgPayPacketFeeAsyncResponse) XXX_Unmarshal 

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

type MsgPayPacketFeeResponse 

type MsgPayPacketFeeResponse struct {
}

MsgPayPacketFeeResponse defines the response type for the PayPacketFee rpc

func (*MsgPayPacketFeeResponse) Descriptor 

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

func (*MsgPayPacketFeeResponse) Marshal 

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

func (*MsgPayPacketFeeResponse) MarshalTo 

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

func (*MsgPayPacketFeeResponse) MarshalToSizedBuffer 

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

func (*MsgPayPacketFeeResponse) ProtoMessage 

func (*MsgPayPacketFeeResponse) ProtoMessage()

func (*MsgPayPacketFeeResponse) Reset 

func (m *MsgPayPacketFeeResponse) Reset()

func (*MsgPayPacketFeeResponse) Size 

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

func (*MsgPayPacketFeeResponse) String 

func (m *MsgPayPacketFeeResponse) String() string

func (*MsgPayPacketFeeResponse) Unmarshal 

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

func (*MsgPayPacketFeeResponse) XXX_DiscardUnknown 

func (m *MsgPayPacketFeeResponse) XXX_DiscardUnknown()

func (*MsgPayPacketFeeResponse) XXX_Marshal 

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

func (*MsgPayPacketFeeResponse) XXX_Merge 

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

func (*MsgPayPacketFeeResponse) XXX_Size 

func (m *MsgPayPacketFeeResponse) XXX_Size() int

func (*MsgPayPacketFeeResponse) XXX_Unmarshal 

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

type MsgRegisterCounterpartyPayee 

type MsgRegisterCounterpartyPayee struct {
	// unique port identifier
	PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"`
	// unique channel identifier
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"`
	// the relayer address
	Relayer string `protobuf:"bytes,3,opt,name=relayer,proto3" json:"relayer,omitempty"`
	// the counterparty payee address
	CounterpartyPayee string `` /* 138-byte string literal not displayed */
}

MsgRegisterCounterpartyPayee defines the request type for the RegisterCounterpartyPayee rpc

func NewMsgRegisterCounterpartyPayee 

func NewMsgRegisterCounterpartyPayee(portID, channelID, relayerAddr, counterpartyPayeeAddr string) *MsgRegisterCounterpartyPayee

NewMsgRegisterCounterpartyPayee creates a new instance of MsgRegisterCounterpartyPayee

func (*MsgRegisterCounterpartyPayee) Descriptor 

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

func (MsgRegisterCounterpartyPayee) GetSigners 

func (msg MsgRegisterCounterpartyPayee) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgRegisterCounterpartyPayee) Marshal 

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

func (*MsgRegisterCounterpartyPayee) MarshalTo 

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

func (*MsgRegisterCounterpartyPayee) MarshalToSizedBuffer 

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

func (*MsgRegisterCounterpartyPayee) ProtoMessage 

func (*MsgRegisterCounterpartyPayee) ProtoMessage()

func (*MsgRegisterCounterpartyPayee) Reset 

func (m *MsgRegisterCounterpartyPayee) Reset()

func (*MsgRegisterCounterpartyPayee) Size 

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

func (*MsgRegisterCounterpartyPayee) String 

func (m *MsgRegisterCounterpartyPayee) String() string

func (*MsgRegisterCounterpartyPayee) Unmarshal 

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

func (MsgRegisterCounterpartyPayee) ValidateBasic 

func (msg MsgRegisterCounterpartyPayee) ValidateBasic() error

ValidateBasic performs a basic check of the MsgRegisterCounterpartyAddress fields

func (*MsgRegisterCounterpartyPayee) XXX_DiscardUnknown 

func (m *MsgRegisterCounterpartyPayee) XXX_DiscardUnknown()

func (*MsgRegisterCounterpartyPayee) XXX_Marshal 

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

func (*MsgRegisterCounterpartyPayee) XXX_Merge 

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

func (*MsgRegisterCounterpartyPayee) XXX_Size 

func (m *MsgRegisterCounterpartyPayee) XXX_Size() int

func (*MsgRegisterCounterpartyPayee) XXX_Unmarshal 

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

type MsgRegisterCounterpartyPayeeResponse 

type MsgRegisterCounterpartyPayeeResponse struct {
}

MsgRegisterCounterpartyPayeeResponse defines the response type for the RegisterCounterpartyPayee rpc

func (*MsgRegisterCounterpartyPayeeResponse) Descriptor 

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

func (*MsgRegisterCounterpartyPayeeResponse) Marshal 

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

func (*MsgRegisterCounterpartyPayeeResponse) MarshalTo 

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

func (*MsgRegisterCounterpartyPayeeResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterCounterpartyPayeeResponse) ProtoMessage 

func (*MsgRegisterCounterpartyPayeeResponse) ProtoMessage()

func (*MsgRegisterCounterpartyPayeeResponse) Reset 

func (m *MsgRegisterCounterpartyPayeeResponse) Reset()

func (*MsgRegisterCounterpartyPayeeResponse) Size 

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

func (*MsgRegisterCounterpartyPayeeResponse) String 

func (m *MsgRegisterCounterpartyPayeeResponse) String() string

func (*MsgRegisterCounterpartyPayeeResponse) Unmarshal 

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

func (*MsgRegisterCounterpartyPayeeResponse) XXX_DiscardUnknown 

func (m *MsgRegisterCounterpartyPayeeResponse) XXX_DiscardUnknown()

func (*MsgRegisterCounterpartyPayeeResponse) XXX_Marshal 

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

func (*MsgRegisterCounterpartyPayeeResponse) XXX_Merge 

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

func (*MsgRegisterCounterpartyPayeeResponse) XXX_Size 

func (m *MsgRegisterCounterpartyPayeeResponse) XXX_Size() int

func (*MsgRegisterCounterpartyPayeeResponse) XXX_Unmarshal 

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

type MsgRegisterPayee 

type MsgRegisterPayee struct {
	// unique port identifier
	PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"`
	// unique channel identifier
	ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"`
	// the relayer address
	Relayer string `protobuf:"bytes,3,opt,name=relayer,proto3" json:"relayer,omitempty"`
	// the payee address
	Payee string `protobuf:"bytes,4,opt,name=payee,proto3" json:"payee,omitempty"`
}

MsgRegisterPayee defines the request type for the RegisterPayee rpc

func NewMsgRegisterPayee 

func NewMsgRegisterPayee(portID, channelID, relayerAddr, payeeAddr string) *MsgRegisterPayee

NewMsgRegisterPayee creates a new instance of MsgRegisterPayee

func (*MsgRegisterPayee) Descriptor 

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

func (MsgRegisterPayee) GetSigners 

func (msg MsgRegisterPayee) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgRegisterPayee) Marshal 

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

func (*MsgRegisterPayee) MarshalTo 

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

func (*MsgRegisterPayee) MarshalToSizedBuffer 

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

func (*MsgRegisterPayee) ProtoMessage 

func (*MsgRegisterPayee) ProtoMessage()

func (*MsgRegisterPayee) Reset 

func (m *MsgRegisterPayee) Reset()

func (*MsgRegisterPayee) Size 

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

func (*MsgRegisterPayee) String 

func (m *MsgRegisterPayee) String() string

func (*MsgRegisterPayee) Unmarshal 

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

func (MsgRegisterPayee) ValidateBasic 

func (msg MsgRegisterPayee) ValidateBasic() error

ValidateBasic implements sdk.Msg and performs basic stateless validation

func (*MsgRegisterPayee) XXX_DiscardUnknown 

func (m *MsgRegisterPayee) XXX_DiscardUnknown()

func (*MsgRegisterPayee) XXX_Marshal 

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

func (*MsgRegisterPayee) XXX_Merge 

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

func (*MsgRegisterPayee) XXX_Size 

func (m *MsgRegisterPayee) XXX_Size() int

func (*MsgRegisterPayee) XXX_Unmarshal 

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

type MsgRegisterPayeeResponse 

type MsgRegisterPayeeResponse struct {
}

MsgRegisterPayeeResponse defines the response type for the RegisterPayee rpc

func (*MsgRegisterPayeeResponse) Descriptor 

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

func (*MsgRegisterPayeeResponse) Marshal 

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

func (*MsgRegisterPayeeResponse) MarshalTo 

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

func (*MsgRegisterPayeeResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterPayeeResponse) ProtoMessage 

func (*MsgRegisterPayeeResponse) ProtoMessage()

func (*MsgRegisterPayeeResponse) Reset 

func (m *MsgRegisterPayeeResponse) Reset()

func (*MsgRegisterPayeeResponse) Size 

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

func (*MsgRegisterPayeeResponse) String 

func (m *MsgRegisterPayeeResponse) String() string

func (*MsgRegisterPayeeResponse) Unmarshal 

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

func (*MsgRegisterPayeeResponse) XXX_DiscardUnknown 

func (m *MsgRegisterPayeeResponse) XXX_DiscardUnknown()

func (*MsgRegisterPayeeResponse) XXX_Marshal 

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

func (*MsgRegisterPayeeResponse) XXX_Merge 

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

func (*MsgRegisterPayeeResponse) XXX_Size 

func (m *MsgRegisterPayeeResponse) XXX_Size() int

func (*MsgRegisterPayeeResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// RegisterPayee defines a rpc handler method for MsgRegisterPayee
	// RegisterPayee is called by the relayer on each channelEnd and allows them to set an optional
	// payee to which reverse and timeout relayer packet fees will be paid out. The payee should be registered on
	// the source chain from which packets originate as this is where fee distribution takes place. This function may be
	// called more than once by a relayer, in which case, the latest payee is always used.
	RegisterPayee(context.Context, *MsgRegisterPayee) (*MsgRegisterPayeeResponse, error)
	// RegisterCounterpartyPayee defines a rpc handler method for MsgRegisterCounterpartyPayee
	// RegisterCounterpartyPayee is called by the relayer on each channelEnd and allows them to specify the counterparty
	// payee address before relaying. This ensures they will be properly compensated for forward relaying since
	// the destination chain must include the registered counterparty payee address in the acknowledgement. This function
	// may be called more than once by a relayer, in which case, the latest counterparty payee address is always used.
	RegisterCounterpartyPayee(context.Context, *MsgRegisterCounterpartyPayee) (*MsgRegisterCounterpartyPayeeResponse, error)
	// PayPacketFee defines a rpc handler method for MsgPayPacketFee
	// PayPacketFee is an open callback that may be called by any module/user that wishes to escrow funds in order to
	// incentivize the relaying of the packet at the next sequence
	// NOTE: This method is intended to be used within a multi msg transaction, where the subsequent msg that follows
	// initiates the lifecycle of the incentivized packet
	PayPacketFee(context.Context, *MsgPayPacketFee) (*MsgPayPacketFeeResponse, error)
	// PayPacketFeeAsync defines a rpc handler method for MsgPayPacketFeeAsync
	// PayPacketFeeAsync is an open callback that may be called by any module/user that wishes to escrow funds in order to
	// incentivize the relaying of a known packet (i.e. at a particular sequence)
	PayPacketFeeAsync(context.Context, *MsgPayPacketFeeAsync) (*MsgPayPacketFeeAsyncResponse, error)
}

MsgServer is the server API for Msg service.

type PacketFee 

type PacketFee struct {
	// fee encapsulates the recv, ack and timeout fees associated with an IBC packet
	Fee Fee `protobuf:"bytes,1,opt,name=fee,proto3" json:"fee"`
	// the refund address for unspent fees
	RefundAddress string `protobuf:"bytes,2,opt,name=refund_address,json=refundAddress,proto3" json:"refund_address,omitempty" yaml:"refund_address"`
	// optional list of relayers permitted to receive fees
	Relayers []string `protobuf:"bytes,3,rep,name=relayers,proto3" json:"relayers,omitempty"`
}

PacketFee contains ICS29 relayer fees, refund address and optional list of permitted relayers

func NewPacketFee 

func NewPacketFee(fee Fee, refundAddr string, relayers []string) PacketFee

NewPacketFee creates and returns a new PacketFee struct including the incentivization fees, refund address and relayers

func (*PacketFee) Descriptor 

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

func (*PacketFee) GetFee 

func (m *PacketFee) GetFee() Fee

func (*PacketFee) GetRefundAddress 

func (m *PacketFee) GetRefundAddress() string

func (*PacketFee) GetRelayers 

func (m *PacketFee) GetRelayers() []string

func (*PacketFee) Marshal 

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

func (*PacketFee) MarshalTo 

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

func (*PacketFee) MarshalToSizedBuffer 

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

func (*PacketFee) ProtoMessage 

func (*PacketFee) ProtoMessage()

func (*PacketFee) Reset 

func (m *PacketFee) Reset()

func (*PacketFee) Size 

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

func (*PacketFee) String 

func (m *PacketFee) String() string

func (*PacketFee) Unmarshal 

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

func (PacketFee) Validate 

func (p PacketFee) Validate() error

Validate performs basic stateless validation of the associated PacketFee

func (*PacketFee) XXX_DiscardUnknown 

func (m *PacketFee) XXX_DiscardUnknown()

func (*PacketFee) XXX_Marshal 

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

func (*PacketFee) XXX_Merge 

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

func (*PacketFee) XXX_Size 

func (m *PacketFee) XXX_Size() int

func (*PacketFee) XXX_Unmarshal 

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

type PacketFees 

type PacketFees struct {
	// list of packet fees
	PacketFees []PacketFee `protobuf:"bytes,1,rep,name=packet_fees,json=packetFees,proto3" json:"packet_fees" yaml:"packet_fees"`
}

PacketFees contains a list of type PacketFee

func NewPacketFees 

func NewPacketFees(packetFees []PacketFee) PacketFees

NewPacketFees creates and returns a new PacketFees struct including a list of type PacketFee

func (*PacketFees) Descriptor 

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

func (*PacketFees) GetPacketFees 

func (m *PacketFees) GetPacketFees() []PacketFee

func (*PacketFees) Marshal 

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

func (*PacketFees) MarshalTo 

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

func (*PacketFees) MarshalToSizedBuffer 

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

func (*PacketFees) ProtoMessage 

func (*PacketFees) ProtoMessage()

func (*PacketFees) Reset 

func (m *PacketFees) Reset()

func (*PacketFees) Size 

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

func (*PacketFees) String 

func (m *PacketFees) String() string

func (*PacketFees) Unmarshal 

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

func (*PacketFees) XXX_DiscardUnknown 

func (m *PacketFees) XXX_DiscardUnknown()

func (*PacketFees) XXX_Marshal 

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

func (*PacketFees) XXX_Merge 

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

func (*PacketFees) XXX_Size 

func (m *PacketFees) XXX_Size() int

func (*PacketFees) XXX_Unmarshal 

func (m *PacketFees) 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 {
	// IncentivizedPackets returns all incentivized packets and their associated fees
	IncentivizedPackets(ctx context.Context, in *QueryIncentivizedPacketsRequest, opts ...grpc.CallOption) (*QueryIncentivizedPacketsResponse, error)
	// IncentivizedPacket returns all packet fees for a packet given its identifier
	IncentivizedPacket(ctx context.Context, in *QueryIncentivizedPacketRequest, opts ...grpc.CallOption) (*QueryIncentivizedPacketResponse, error)
	// Gets all incentivized packets for a specific channel
	IncentivizedPacketsForChannel(ctx context.Context, in *QueryIncentivizedPacketsForChannelRequest, opts ...grpc.CallOption) (*QueryIncentivizedPacketsForChannelResponse, error)
	// TotalRecvFees returns the total receive fees for a packet given its identifier
	TotalRecvFees(ctx context.Context, in *QueryTotalRecvFeesRequest, opts ...grpc.CallOption) (*QueryTotalRecvFeesResponse, error)
	// TotalAckFees returns the total acknowledgement fees for a packet given its identifier
	TotalAckFees(ctx context.Context, in *QueryTotalAckFeesRequest, opts ...grpc.CallOption) (*QueryTotalAckFeesResponse, error)
	// TotalTimeoutFees returns the total timeout fees for a packet given its identifier
	TotalTimeoutFees(ctx context.Context, in *QueryTotalTimeoutFeesRequest, opts ...grpc.CallOption) (*QueryTotalTimeoutFeesResponse, error)
	// Payee returns the registered payee address for a specific channel given the relayer address
	Payee(ctx context.Context, in *QueryPayeeRequest, opts ...grpc.CallOption) (*QueryPayeeResponse, error)
	// CounterpartyPayee returns the registered counterparty payee for forward relaying
	CounterpartyPayee(ctx context.Context, in *QueryCounterpartyPayeeRequest, opts ...grpc.CallOption) (*QueryCounterpartyPayeeResponse, error)
	// FeeEnabledChannels returns a list of all fee enabled channels
	FeeEnabledChannels(ctx context.Context, in *QueryFeeEnabledChannelsRequest, opts ...grpc.CallOption) (*QueryFeeEnabledChannelsResponse, error)
	// FeeEnabledChannel returns true if the provided port and channel identifiers belong to a fee enabled channel
	FeeEnabledChannel(ctx context.Context, in *QueryFeeEnabledChannelRequest, opts ...grpc.CallOption) (*QueryFeeEnabledChannelResponse, 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 QueryCounterpartyPayeeRequest 

type QueryCounterpartyPayeeRequest struct {
	// unique channel identifier
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"`
	// the relayer address to which the counterparty is registered
	Relayer string `protobuf:"bytes,2,opt,name=relayer,proto3" json:"relayer,omitempty"`
}

QueryCounterpartyPayeeRequest defines the request type for the CounterpartyPayee rpc

func (*QueryCounterpartyPayeeRequest) Descriptor 

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

func (*QueryCounterpartyPayeeRequest) GetChannelId 

func (m *QueryCounterpartyPayeeRequest) GetChannelId() string

func (*QueryCounterpartyPayeeRequest) GetRelayer 

func (m *QueryCounterpartyPayeeRequest) GetRelayer() string

func (*QueryCounterpartyPayeeRequest) Marshal 

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

func (*QueryCounterpartyPayeeRequest) MarshalTo 

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

func (*QueryCounterpartyPayeeRequest) MarshalToSizedBuffer 

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

func (*QueryCounterpartyPayeeRequest) ProtoMessage 

func (*QueryCounterpartyPayeeRequest) ProtoMessage()

func (*QueryCounterpartyPayeeRequest) Reset 

func (m *QueryCounterpartyPayeeRequest) Reset()

func (*QueryCounterpartyPayeeRequest) Size 

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

func (*QueryCounterpartyPayeeRequest) String 

func (m *QueryCounterpartyPayeeRequest) String() string

func (*QueryCounterpartyPayeeRequest) Unmarshal 

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

func (*QueryCounterpartyPayeeRequest) XXX_DiscardUnknown 

func (m *QueryCounterpartyPayeeRequest) XXX_DiscardUnknown()

func (*QueryCounterpartyPayeeRequest) XXX_Marshal 

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

func (*QueryCounterpartyPayeeRequest) XXX_Merge 

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

func (*QueryCounterpartyPayeeRequest) XXX_Size 

func (m *QueryCounterpartyPayeeRequest) XXX_Size() int

func (*QueryCounterpartyPayeeRequest) XXX_Unmarshal 

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

type QueryCounterpartyPayeeResponse 

type QueryCounterpartyPayeeResponse struct {
	// the counterparty payee address used to compensate forward relaying
	CounterpartyPayee string `` /* 138-byte string literal not displayed */
}

QueryCounterpartyPayeeResponse defines the response type for the CounterpartyPayee rpc

func (*QueryCounterpartyPayeeResponse) Descriptor 

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

func (*QueryCounterpartyPayeeResponse) GetCounterpartyPayee 

func (m *QueryCounterpartyPayeeResponse) GetCounterpartyPayee() string

func (*QueryCounterpartyPayeeResponse) Marshal 

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

func (*QueryCounterpartyPayeeResponse) MarshalTo 

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

func (*QueryCounterpartyPayeeResponse) MarshalToSizedBuffer 

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

func (*QueryCounterpartyPayeeResponse) ProtoMessage 

func (*QueryCounterpartyPayeeResponse) ProtoMessage()

func (*QueryCounterpartyPayeeResponse) Reset 

func (m *QueryCounterpartyPayeeResponse) Reset()

func (*QueryCounterpartyPayeeResponse) Size 

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

func (*QueryCounterpartyPayeeResponse) String 

func (m *QueryCounterpartyPayeeResponse) String() string

func (*QueryCounterpartyPayeeResponse) Unmarshal 

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

func (*QueryCounterpartyPayeeResponse) XXX_DiscardUnknown 

func (m *QueryCounterpartyPayeeResponse) XXX_DiscardUnknown()

func (*QueryCounterpartyPayeeResponse) XXX_Marshal 

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

func (*QueryCounterpartyPayeeResponse) XXX_Merge 

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

func (*QueryCounterpartyPayeeResponse) XXX_Size 

func (m *QueryCounterpartyPayeeResponse) XXX_Size() int

func (*QueryCounterpartyPayeeResponse) XXX_Unmarshal 

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

type QueryFeeEnabledChannelRequest 

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

QueryFeeEnabledChannelRequest defines the request type for the FeeEnabledChannel rpc

func (*QueryFeeEnabledChannelRequest) Descriptor 

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

func (*QueryFeeEnabledChannelRequest) GetChannelId 

func (m *QueryFeeEnabledChannelRequest) GetChannelId() string

func (*QueryFeeEnabledChannelRequest) GetPortId 

func (m *QueryFeeEnabledChannelRequest) GetPortId() string

func (*QueryFeeEnabledChannelRequest) Marshal 

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

func (*QueryFeeEnabledChannelRequest) MarshalTo 

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

func (*QueryFeeEnabledChannelRequest) MarshalToSizedBuffer 

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

func (*QueryFeeEnabledChannelRequest) ProtoMessage 

func (*QueryFeeEnabledChannelRequest) ProtoMessage()

func (*QueryFeeEnabledChannelRequest) Reset 

func (m *QueryFeeEnabledChannelRequest) Reset()

func (*QueryFeeEnabledChannelRequest) Size 

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

func (*QueryFeeEnabledChannelRequest) String 

func (m *QueryFeeEnabledChannelRequest) String() string

func (*QueryFeeEnabledChannelRequest) Unmarshal 

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

func (*QueryFeeEnabledChannelRequest) XXX_DiscardUnknown 

func (m *QueryFeeEnabledChannelRequest) XXX_DiscardUnknown()

func (*QueryFeeEnabledChannelRequest) XXX_Marshal 

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

func (*QueryFeeEnabledChannelRequest) XXX_Merge 

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

func (*QueryFeeEnabledChannelRequest) XXX_Size 

func (m *QueryFeeEnabledChannelRequest) XXX_Size() int

func (*QueryFeeEnabledChannelRequest) XXX_Unmarshal 

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

type QueryFeeEnabledChannelResponse 

type QueryFeeEnabledChannelResponse struct {
	// boolean flag representing the fee enabled channel status
	FeeEnabled bool `protobuf:"varint,1,opt,name=fee_enabled,json=feeEnabled,proto3" json:"fee_enabled,omitempty" yaml:"fee_enabled"`
}

QueryFeeEnabledChannelResponse defines the response type for the FeeEnabledChannel rpc

func (*QueryFeeEnabledChannelResponse) Descriptor 

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

func (*QueryFeeEnabledChannelResponse) GetFeeEnabled 

func (m *QueryFeeEnabledChannelResponse) GetFeeEnabled() bool

func (*QueryFeeEnabledChannelResponse) Marshal 

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

func (*QueryFeeEnabledChannelResponse) MarshalTo 

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

func (*QueryFeeEnabledChannelResponse) MarshalToSizedBuffer 

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

func (*QueryFeeEnabledChannelResponse) ProtoMessage 

func (*QueryFeeEnabledChannelResponse) ProtoMessage()

func (*QueryFeeEnabledChannelResponse) Reset 

func (m *QueryFeeEnabledChannelResponse) Reset()

func (*QueryFeeEnabledChannelResponse) Size 

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

func (*QueryFeeEnabledChannelResponse) String 

func (m *QueryFeeEnabledChannelResponse) String() string

func (*QueryFeeEnabledChannelResponse) Unmarshal 

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

func (*QueryFeeEnabledChannelResponse) XXX_DiscardUnknown 

func (m *QueryFeeEnabledChannelResponse) XXX_DiscardUnknown()

func (*QueryFeeEnabledChannelResponse) XXX_Marshal 

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

func (*QueryFeeEnabledChannelResponse) XXX_Merge 

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

func (*QueryFeeEnabledChannelResponse) XXX_Size 

func (m *QueryFeeEnabledChannelResponse) XXX_Size() int

func (*QueryFeeEnabledChannelResponse) XXX_Unmarshal 

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

type QueryFeeEnabledChannelsRequest 

type QueryFeeEnabledChannelsRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// block height at which to query
	QueryHeight uint64 `protobuf:"varint,2,opt,name=query_height,json=queryHeight,proto3" json:"query_height,omitempty"`
}

QueryFeeEnabledChannelsRequest defines the request type for the FeeEnabledChannels rpc

func (*QueryFeeEnabledChannelsRequest) Descriptor 

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

func (*QueryFeeEnabledChannelsRequest) GetPagination 

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

func (*QueryFeeEnabledChannelsRequest) GetQueryHeight 

func (m *QueryFeeEnabledChannelsRequest) GetQueryHeight() uint64

func (*QueryFeeEnabledChannelsRequest) Marshal 

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

func (*QueryFeeEnabledChannelsRequest) MarshalTo 

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

func (*QueryFeeEnabledChannelsRequest) MarshalToSizedBuffer 

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

func (*QueryFeeEnabledChannelsRequest) ProtoMessage 

func (*QueryFeeEnabledChannelsRequest) ProtoMessage()

func (*QueryFeeEnabledChannelsRequest) Reset 

func (m *QueryFeeEnabledChannelsRequest) Reset()

func (*QueryFeeEnabledChannelsRequest) Size 

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

func (*QueryFeeEnabledChannelsRequest) String 

func (m *QueryFeeEnabledChannelsRequest) String() string

func (*QueryFeeEnabledChannelsRequest) Unmarshal 

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

func (*QueryFeeEnabledChannelsRequest) XXX_DiscardUnknown 

func (m *QueryFeeEnabledChannelsRequest) XXX_DiscardUnknown()

func (*QueryFeeEnabledChannelsRequest) XXX_Marshal 

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

func (*QueryFeeEnabledChannelsRequest) XXX_Merge 

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

func (*QueryFeeEnabledChannelsRequest) XXX_Size 

func (m *QueryFeeEnabledChannelsRequest) XXX_Size() int

func (*QueryFeeEnabledChannelsRequest) XXX_Unmarshal 

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

type QueryFeeEnabledChannelsResponse 

type QueryFeeEnabledChannelsResponse struct {
	// list of fee enabled channels
	FeeEnabledChannels []FeeEnabledChannel `` /* 135-byte string literal not displayed */
}

QueryFeeEnabledChannelsResponse defines the response type for the FeeEnabledChannels rpc

func (*QueryFeeEnabledChannelsResponse) Descriptor 

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

func (*QueryFeeEnabledChannelsResponse) GetFeeEnabledChannels 

func (m *QueryFeeEnabledChannelsResponse) GetFeeEnabledChannels() []FeeEnabledChannel

func (*QueryFeeEnabledChannelsResponse) Marshal 

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

func (*QueryFeeEnabledChannelsResponse) MarshalTo 

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

func (*QueryFeeEnabledChannelsResponse) MarshalToSizedBuffer 

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

func (*QueryFeeEnabledChannelsResponse) ProtoMessage 

func (*QueryFeeEnabledChannelsResponse) ProtoMessage()

func (*QueryFeeEnabledChannelsResponse) Reset 

func (m *QueryFeeEnabledChannelsResponse) Reset()

func (*QueryFeeEnabledChannelsResponse) Size 

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

func (*QueryFeeEnabledChannelsResponse) String 

func (m *QueryFeeEnabledChannelsResponse) String() string

func (*QueryFeeEnabledChannelsResponse) Unmarshal 

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

func (*QueryFeeEnabledChannelsResponse) XXX_DiscardUnknown 

func (m *QueryFeeEnabledChannelsResponse) XXX_DiscardUnknown()

func (*QueryFeeEnabledChannelsResponse) XXX_Marshal 

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

func (*QueryFeeEnabledChannelsResponse) XXX_Merge 

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

func (*QueryFeeEnabledChannelsResponse) XXX_Size 

func (m *QueryFeeEnabledChannelsResponse) XXX_Size() int

func (*QueryFeeEnabledChannelsResponse) XXX_Unmarshal 

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

type QueryIncentivizedPacketRequest 

type QueryIncentivizedPacketRequest struct {
	// unique packet identifier comprised of channel ID, port ID and sequence
	PacketId types.PacketId `protobuf:"bytes,1,opt,name=packet_id,json=packetId,proto3" json:"packet_id"`
	// block height at which to query
	QueryHeight uint64 `protobuf:"varint,2,opt,name=query_height,json=queryHeight,proto3" json:"query_height,omitempty"`
}

QueryIncentivizedPacketRequest defines the request type for the IncentivizedPacket rpc

func (*QueryIncentivizedPacketRequest) Descriptor 

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

func (*QueryIncentivizedPacketRequest) GetPacketId 

func (m *QueryIncentivizedPacketRequest) GetPacketId() types.PacketId

func (*QueryIncentivizedPacketRequest) GetQueryHeight 

func (m *QueryIncentivizedPacketRequest) GetQueryHeight() uint64

func (*QueryIncentivizedPacketRequest) Marshal 

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

func (*QueryIncentivizedPacketRequest) MarshalTo 

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

func (*QueryIncentivizedPacketRequest) MarshalToSizedBuffer 

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

func (*QueryIncentivizedPacketRequest) ProtoMessage 

func (*QueryIncentivizedPacketRequest) ProtoMessage()

func (*QueryIncentivizedPacketRequest) Reset 

func (m *QueryIncentivizedPacketRequest) Reset()

func (*QueryIncentivizedPacketRequest) Size 

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

func (*QueryIncentivizedPacketRequest) String 

func (m *QueryIncentivizedPacketRequest) String() string

func (*QueryIncentivizedPacketRequest) Unmarshal 

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

func (*QueryIncentivizedPacketRequest) XXX_DiscardUnknown 

func (m *QueryIncentivizedPacketRequest) XXX_DiscardUnknown()

func (*QueryIncentivizedPacketRequest) XXX_Marshal 

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

func (*QueryIncentivizedPacketRequest) XXX_Merge 

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

func (*QueryIncentivizedPacketRequest) XXX_Size 

func (m *QueryIncentivizedPacketRequest) XXX_Size() int

func (*QueryIncentivizedPacketRequest) XXX_Unmarshal 

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

type QueryIncentivizedPacketResponse 

type QueryIncentivizedPacketResponse struct {
	// the identified fees for the incentivized packet
	IncentivizedPacket IdentifiedPacketFees `protobuf:"bytes,1,opt,name=incentivized_packet,json=incentivizedPacket,proto3" json:"incentivized_packet"`
}

QueryIncentivizedPacketsResponse defines the response type for the IncentivizedPacket rpc

func (*QueryIncentivizedPacketResponse) Descriptor 

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

func (*QueryIncentivizedPacketResponse) GetIncentivizedPacket 

func (m *QueryIncentivizedPacketResponse) GetIncentivizedPacket() IdentifiedPacketFees

func (*QueryIncentivizedPacketResponse) Marshal 

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

func (*QueryIncentivizedPacketResponse) MarshalTo 

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

func (*QueryIncentivizedPacketResponse) MarshalToSizedBuffer 

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

func (*QueryIncentivizedPacketResponse) ProtoMessage 

func (*QueryIncentivizedPacketResponse) ProtoMessage()

func (*QueryIncentivizedPacketResponse) Reset 

func (m *QueryIncentivizedPacketResponse) Reset()

func (*QueryIncentivizedPacketResponse) Size 

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

func (*QueryIncentivizedPacketResponse) String 

func (m *QueryIncentivizedPacketResponse) String() string

func (*QueryIncentivizedPacketResponse) Unmarshal 

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

func (*QueryIncentivizedPacketResponse) XXX_DiscardUnknown 

func (m *QueryIncentivizedPacketResponse) XXX_DiscardUnknown()

func (*QueryIncentivizedPacketResponse) XXX_Marshal 

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

func (*QueryIncentivizedPacketResponse) XXX_Merge 

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

func (*QueryIncentivizedPacketResponse) XXX_Size 

func (m *QueryIncentivizedPacketResponse) XXX_Size() int

func (*QueryIncentivizedPacketResponse) XXX_Unmarshal 

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

type QueryIncentivizedPacketsForChannelRequest 

type QueryIncentivizedPacketsForChannelRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	PortId     string             `protobuf:"bytes,2,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
	ChannelId  string             `protobuf:"bytes,3,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	// Height to query at
	QueryHeight uint64 `protobuf:"varint,4,opt,name=query_height,json=queryHeight,proto3" json:"query_height,omitempty"`
}

QueryIncentivizedPacketsForChannelRequest defines the request type for querying for all incentivized packets for a specific channel

func (*QueryIncentivizedPacketsForChannelRequest) Descriptor 

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

func (*QueryIncentivizedPacketsForChannelRequest) GetChannelId 

func (m *QueryIncentivizedPacketsForChannelRequest) GetChannelId() string

func (*QueryIncentivizedPacketsForChannelRequest) GetPagination 

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

func (*QueryIncentivizedPacketsForChannelRequest) GetPortId 

func (m *QueryIncentivizedPacketsForChannelRequest) GetPortId() string

func (*QueryIncentivizedPacketsForChannelRequest) GetQueryHeight 

func (m *QueryIncentivizedPacketsForChannelRequest) GetQueryHeight() uint64

func (*QueryIncentivizedPacketsForChannelRequest) Marshal 

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

func (*QueryIncentivizedPacketsForChannelRequest) MarshalTo 

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

func (*QueryIncentivizedPacketsForChannelRequest) MarshalToSizedBuffer 

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

func (*QueryIncentivizedPacketsForChannelRequest) ProtoMessage 

func (*QueryIncentivizedPacketsForChannelRequest) ProtoMessage()

func (*QueryIncentivizedPacketsForChannelRequest) Reset 

func (m *QueryIncentivizedPacketsForChannelRequest) Reset()

func (*QueryIncentivizedPacketsForChannelRequest) Size 

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

func (*QueryIncentivizedPacketsForChannelRequest) String 

func (m *QueryIncentivizedPacketsForChannelRequest) String() string

func (*QueryIncentivizedPacketsForChannelRequest) Unmarshal 

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

func (*QueryIncentivizedPacketsForChannelRequest) XXX_DiscardUnknown 

func (m *QueryIncentivizedPacketsForChannelRequest) XXX_DiscardUnknown()

func (*QueryIncentivizedPacketsForChannelRequest) XXX_Marshal 

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

func (*QueryIncentivizedPacketsForChannelRequest) XXX_Merge 

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

func (*QueryIncentivizedPacketsForChannelRequest) XXX_Size 

func (m *QueryIncentivizedPacketsForChannelRequest) XXX_Size() int

func (*QueryIncentivizedPacketsForChannelRequest) XXX_Unmarshal 

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

type QueryIncentivizedPacketsForChannelResponse 

type QueryIncentivizedPacketsForChannelResponse struct {
	// Map of all incentivized_packets
	IncentivizedPackets []*IdentifiedPacketFees `protobuf:"bytes,1,rep,name=incentivized_packets,json=incentivizedPackets,proto3" json:"incentivized_packets,omitempty"`
}

QueryIncentivizedPacketsResponse defines the response type for the incentivized packets RPC

func (*QueryIncentivizedPacketsForChannelResponse) Descriptor 

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

func (*QueryIncentivizedPacketsForChannelResponse) GetIncentivizedPackets 

func (m *QueryIncentivizedPacketsForChannelResponse) GetIncentivizedPackets() []*IdentifiedPacketFees

func (*QueryIncentivizedPacketsForChannelResponse) Marshal 

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

func (*QueryIncentivizedPacketsForChannelResponse) MarshalTo 

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

func (*QueryIncentivizedPacketsForChannelResponse) MarshalToSizedBuffer 

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

func (*QueryIncentivizedPacketsForChannelResponse) ProtoMessage 

func (*QueryIncentivizedPacketsForChannelResponse) ProtoMessage()

func (*QueryIncentivizedPacketsForChannelResponse) Reset 

func (m *QueryIncentivizedPacketsForChannelResponse) Reset()

func (*QueryIncentivizedPacketsForChannelResponse) Size 

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

func (*QueryIncentivizedPacketsForChannelResponse) String 

func (m *QueryIncentivizedPacketsForChannelResponse) String() string

func (*QueryIncentivizedPacketsForChannelResponse) Unmarshal 

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

func (*QueryIncentivizedPacketsForChannelResponse) XXX_DiscardUnknown 

func (m *QueryIncentivizedPacketsForChannelResponse) XXX_DiscardUnknown()

func (*QueryIncentivizedPacketsForChannelResponse) XXX_Marshal 

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

func (*QueryIncentivizedPacketsForChannelResponse) XXX_Merge 

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

func (*QueryIncentivizedPacketsForChannelResponse) XXX_Size 

func (m *QueryIncentivizedPacketsForChannelResponse) XXX_Size() int

func (*QueryIncentivizedPacketsForChannelResponse) XXX_Unmarshal 

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

type QueryIncentivizedPacketsRequest 

type QueryIncentivizedPacketsRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// block height at which to query
	QueryHeight uint64 `protobuf:"varint,2,opt,name=query_height,json=queryHeight,proto3" json:"query_height,omitempty"`
}

QueryIncentivizedPacketsRequest defines the request type for the IncentivizedPackets rpc

func (*QueryIncentivizedPacketsRequest) Descriptor 

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

func (*QueryIncentivizedPacketsRequest) GetPagination 

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

func (*QueryIncentivizedPacketsRequest) GetQueryHeight 

func (m *QueryIncentivizedPacketsRequest) GetQueryHeight() uint64

func (*QueryIncentivizedPacketsRequest) Marshal 

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

func (*QueryIncentivizedPacketsRequest) MarshalTo 

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

func (*QueryIncentivizedPacketsRequest) MarshalToSizedBuffer 

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

func (*QueryIncentivizedPacketsRequest) ProtoMessage 

func (*QueryIncentivizedPacketsRequest) ProtoMessage()

func (*QueryIncentivizedPacketsRequest) Reset 

func (m *QueryIncentivizedPacketsRequest) Reset()

func (*QueryIncentivizedPacketsRequest) Size 

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

func (*QueryIncentivizedPacketsRequest) String 

func (m *QueryIncentivizedPacketsRequest) String() string

func (*QueryIncentivizedPacketsRequest) Unmarshal 

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

func (*QueryIncentivizedPacketsRequest) XXX_DiscardUnknown 

func (m *QueryIncentivizedPacketsRequest) XXX_DiscardUnknown()

func (*QueryIncentivizedPacketsRequest) XXX_Marshal 

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

func (*QueryIncentivizedPacketsRequest) XXX_Merge 

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

func (*QueryIncentivizedPacketsRequest) XXX_Size 

func (m *QueryIncentivizedPacketsRequest) XXX_Size() int

func (*QueryIncentivizedPacketsRequest) XXX_Unmarshal 

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

type QueryIncentivizedPacketsResponse 

type QueryIncentivizedPacketsResponse struct {
	// list of identified fees for incentivized packets
	IncentivizedPackets []IdentifiedPacketFees `protobuf:"bytes,1,rep,name=incentivized_packets,json=incentivizedPackets,proto3" json:"incentivized_packets"`
}

QueryIncentivizedPacketsResponse defines the response type for the IncentivizedPackets rpc

func (*QueryIncentivizedPacketsResponse) Descriptor 

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

func (*QueryIncentivizedPacketsResponse) GetIncentivizedPackets 

func (m *QueryIncentivizedPacketsResponse) GetIncentivizedPackets() []IdentifiedPacketFees

func (*QueryIncentivizedPacketsResponse) Marshal 

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

func (*QueryIncentivizedPacketsResponse) MarshalTo 

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

func (*QueryIncentivizedPacketsResponse) MarshalToSizedBuffer 

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

func (*QueryIncentivizedPacketsResponse) ProtoMessage 

func (*QueryIncentivizedPacketsResponse) ProtoMessage()

func (*QueryIncentivizedPacketsResponse) Reset 

func (m *QueryIncentivizedPacketsResponse) Reset()

func (*QueryIncentivizedPacketsResponse) Size 

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

func (*QueryIncentivizedPacketsResponse) String 

func (m *QueryIncentivizedPacketsResponse) String() string

func (*QueryIncentivizedPacketsResponse) Unmarshal 

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

func (*QueryIncentivizedPacketsResponse) XXX_DiscardUnknown 

func (m *QueryIncentivizedPacketsResponse) XXX_DiscardUnknown()

func (*QueryIncentivizedPacketsResponse) XXX_Marshal 

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

func (*QueryIncentivizedPacketsResponse) XXX_Merge 

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

func (*QueryIncentivizedPacketsResponse) XXX_Size 

func (m *QueryIncentivizedPacketsResponse) XXX_Size() int

func (*QueryIncentivizedPacketsResponse) XXX_Unmarshal 

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

type QueryPayeeRequest 

type QueryPayeeRequest struct {
	// unique channel identifier
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"`
	// the relayer address to which the distribution address is registered
	Relayer string `protobuf:"bytes,2,opt,name=relayer,proto3" json:"relayer,omitempty"`
}

QueryPayeeRequest defines the request type for the Payee rpc

func (*QueryPayeeRequest) Descriptor 

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

func (*QueryPayeeRequest) GetChannelId 

func (m *QueryPayeeRequest) GetChannelId() string

func (*QueryPayeeRequest) GetRelayer 

func (m *QueryPayeeRequest) GetRelayer() string

func (*QueryPayeeRequest) Marshal 

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

func (*QueryPayeeRequest) MarshalTo 

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

func (*QueryPayeeRequest) MarshalToSizedBuffer 

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

func (*QueryPayeeRequest) ProtoMessage 

func (*QueryPayeeRequest) ProtoMessage()

func (*QueryPayeeRequest) Reset 

func (m *QueryPayeeRequest) Reset()

func (*QueryPayeeRequest) Size 

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

func (*QueryPayeeRequest) String 

func (m *QueryPayeeRequest) String() string

func (*QueryPayeeRequest) Unmarshal 

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

func (*QueryPayeeRequest) XXX_DiscardUnknown 

func (m *QueryPayeeRequest) XXX_DiscardUnknown()

func (*QueryPayeeRequest) XXX_Marshal 

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

func (*QueryPayeeRequest) XXX_Merge 

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

func (*QueryPayeeRequest) XXX_Size 

func (m *QueryPayeeRequest) XXX_Size() int

func (*QueryPayeeRequest) XXX_Unmarshal 

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

type QueryPayeeResponse 

type QueryPayeeResponse struct {
	// the payee address to which packet fees are paid out
	PayeeAddress string `protobuf:"bytes,1,opt,name=payee_address,json=payeeAddress,proto3" json:"payee_address,omitempty" yaml:"payee_address"`
}

QueryPayeeResponse defines the response type for the Payee rpc

func (*QueryPayeeResponse) Descriptor 

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

func (*QueryPayeeResponse) GetPayeeAddress 

func (m *QueryPayeeResponse) GetPayeeAddress() string

func (*QueryPayeeResponse) Marshal 

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

func (*QueryPayeeResponse) MarshalTo 

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

func (*QueryPayeeResponse) MarshalToSizedBuffer 

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

func (*QueryPayeeResponse) ProtoMessage 

func (*QueryPayeeResponse) ProtoMessage()

func (*QueryPayeeResponse) Reset 

func (m *QueryPayeeResponse) Reset()

func (*QueryPayeeResponse) Size 

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

func (*QueryPayeeResponse) String 

func (m *QueryPayeeResponse) String() string

func (*QueryPayeeResponse) Unmarshal 

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

func (*QueryPayeeResponse) XXX_DiscardUnknown 

func (m *QueryPayeeResponse) XXX_DiscardUnknown()

func (*QueryPayeeResponse) XXX_Marshal 

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

func (*QueryPayeeResponse) XXX_Merge 

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

func (*QueryPayeeResponse) XXX_Size 

func (m *QueryPayeeResponse) XXX_Size() int

func (*QueryPayeeResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// IncentivizedPackets returns all incentivized packets and their associated fees
	IncentivizedPackets(context.Context, *QueryIncentivizedPacketsRequest) (*QueryIncentivizedPacketsResponse, error)
	// IncentivizedPacket returns all packet fees for a packet given its identifier
	IncentivizedPacket(context.Context, *QueryIncentivizedPacketRequest) (*QueryIncentivizedPacketResponse, error)
	// Gets all incentivized packets for a specific channel
	IncentivizedPacketsForChannel(context.Context, *QueryIncentivizedPacketsForChannelRequest) (*QueryIncentivizedPacketsForChannelResponse, error)
	// TotalRecvFees returns the total receive fees for a packet given its identifier
	TotalRecvFees(context.Context, *QueryTotalRecvFeesRequest) (*QueryTotalRecvFeesResponse, error)
	// TotalAckFees returns the total acknowledgement fees for a packet given its identifier
	TotalAckFees(context.Context, *QueryTotalAckFeesRequest) (*QueryTotalAckFeesResponse, error)
	// TotalTimeoutFees returns the total timeout fees for a packet given its identifier
	TotalTimeoutFees(context.Context, *QueryTotalTimeoutFeesRequest) (*QueryTotalTimeoutFeesResponse, error)
	// Payee returns the registered payee address for a specific channel given the relayer address
	Payee(context.Context, *QueryPayeeRequest) (*QueryPayeeResponse, error)
	// CounterpartyPayee returns the registered counterparty payee for forward relaying
	CounterpartyPayee(context.Context, *QueryCounterpartyPayeeRequest) (*QueryCounterpartyPayeeResponse, error)
	// FeeEnabledChannels returns a list of all fee enabled channels
	FeeEnabledChannels(context.Context, *QueryFeeEnabledChannelsRequest) (*QueryFeeEnabledChannelsResponse, error)
	// FeeEnabledChannel returns true if the provided port and channel identifiers belong to a fee enabled channel
	FeeEnabledChannel(context.Context, *QueryFeeEnabledChannelRequest) (*QueryFeeEnabledChannelResponse, error)
}

QueryServer is the server API for Query service.

type QueryTotalAckFeesRequest 

type QueryTotalAckFeesRequest struct {
	// the packet identifier for the associated fees
	PacketId types.PacketId `protobuf:"bytes,1,opt,name=packet_id,json=packetId,proto3" json:"packet_id"`
}

QueryTotalAckFeesRequest defines the request type for the TotalAckFees rpc

func (*QueryTotalAckFeesRequest) Descriptor 

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

func (*QueryTotalAckFeesRequest) GetPacketId 

func (m *QueryTotalAckFeesRequest) GetPacketId() types.PacketId

func (*QueryTotalAckFeesRequest) Marshal 

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

func (*QueryTotalAckFeesRequest) MarshalTo 

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

func (*QueryTotalAckFeesRequest) MarshalToSizedBuffer 

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

func (*QueryTotalAckFeesRequest) ProtoMessage 

func (*QueryTotalAckFeesRequest) ProtoMessage()

func (*QueryTotalAckFeesRequest) Reset 

func (m *QueryTotalAckFeesRequest) Reset()

func (*QueryTotalAckFeesRequest) Size 

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

func (*QueryTotalAckFeesRequest) String 

func (m *QueryTotalAckFeesRequest) String() string

func (*QueryTotalAckFeesRequest) Unmarshal 

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

func (*QueryTotalAckFeesRequest) XXX_DiscardUnknown 

func (m *QueryTotalAckFeesRequest) XXX_DiscardUnknown()

func (*QueryTotalAckFeesRequest) XXX_Marshal 

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

func (*QueryTotalAckFeesRequest) XXX_Merge 

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

func (*QueryTotalAckFeesRequest) XXX_Size 

func (m *QueryTotalAckFeesRequest) XXX_Size() int

func (*QueryTotalAckFeesRequest) XXX_Unmarshal 

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

type QueryTotalAckFeesResponse 

type QueryTotalAckFeesResponse struct {
	// the total packet acknowledgement fees
	AckFees github_com_cosmos_cosmos_sdk_types.Coins `` /* 142-byte string literal not displayed */
}

QueryTotalAckFeesResponse defines the response type for the TotalAckFees rpc

func (*QueryTotalAckFeesResponse) Descriptor 

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

func (*QueryTotalAckFeesResponse) GetAckFees 

func (m *QueryTotalAckFeesResponse) GetAckFees() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryTotalAckFeesResponse) Marshal 

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

func (*QueryTotalAckFeesResponse) MarshalTo 

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

func (*QueryTotalAckFeesResponse) MarshalToSizedBuffer 

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

func (*QueryTotalAckFeesResponse) ProtoMessage 

func (*QueryTotalAckFeesResponse) ProtoMessage()

func (*QueryTotalAckFeesResponse) Reset 

func (m *QueryTotalAckFeesResponse) Reset()

func (*QueryTotalAckFeesResponse) Size 

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

func (*QueryTotalAckFeesResponse) String 

func (m *QueryTotalAckFeesResponse) String() string

func (*QueryTotalAckFeesResponse) Unmarshal 

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

func (*QueryTotalAckFeesResponse) XXX_DiscardUnknown 

func (m *QueryTotalAckFeesResponse) XXX_DiscardUnknown()

func (*QueryTotalAckFeesResponse) XXX_Marshal 

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

func (*QueryTotalAckFeesResponse) XXX_Merge 

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

func (*QueryTotalAckFeesResponse) XXX_Size 

func (m *QueryTotalAckFeesResponse) XXX_Size() int

func (*QueryTotalAckFeesResponse) XXX_Unmarshal 

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

type QueryTotalRecvFeesRequest 

type QueryTotalRecvFeesRequest struct {
	// the packet identifier for the associated fees
	PacketId types.PacketId `protobuf:"bytes,1,opt,name=packet_id,json=packetId,proto3" json:"packet_id"`
}

QueryTotalRecvFeesRequest defines the request type for the TotalRecvFees rpc

func (*QueryTotalRecvFeesRequest) Descriptor 

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

func (*QueryTotalRecvFeesRequest) GetPacketId 

func (m *QueryTotalRecvFeesRequest) GetPacketId() types.PacketId

func (*QueryTotalRecvFeesRequest) Marshal 

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

func (*QueryTotalRecvFeesRequest) MarshalTo 

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

func (*QueryTotalRecvFeesRequest) MarshalToSizedBuffer 

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

func (*QueryTotalRecvFeesRequest) ProtoMessage 

func (*QueryTotalRecvFeesRequest) ProtoMessage()

func (*QueryTotalRecvFeesRequest) Reset 

func (m *QueryTotalRecvFeesRequest) Reset()

func (*QueryTotalRecvFeesRequest) Size 

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

func (*QueryTotalRecvFeesRequest) String 

func (m *QueryTotalRecvFeesRequest) String() string

func (*QueryTotalRecvFeesRequest) Unmarshal 

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

func (*QueryTotalRecvFeesRequest) XXX_DiscardUnknown 

func (m *QueryTotalRecvFeesRequest) XXX_DiscardUnknown()

func (*QueryTotalRecvFeesRequest) XXX_Marshal 

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

func (*QueryTotalRecvFeesRequest) XXX_Merge 

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

func (*QueryTotalRecvFeesRequest) XXX_Size 

func (m *QueryTotalRecvFeesRequest) XXX_Size() int

func (*QueryTotalRecvFeesRequest) XXX_Unmarshal 

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

type QueryTotalRecvFeesResponse 

type QueryTotalRecvFeesResponse struct {
	// the total packet receive fees
	RecvFees github_com_cosmos_cosmos_sdk_types.Coins `` /* 146-byte string literal not displayed */
}

QueryTotalRecvFeesResponse defines the response type for the TotalRecvFees rpc

func (*QueryTotalRecvFeesResponse) Descriptor 

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

func (*QueryTotalRecvFeesResponse) GetRecvFees 

func (m *QueryTotalRecvFeesResponse) GetRecvFees() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryTotalRecvFeesResponse) Marshal 

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

func (*QueryTotalRecvFeesResponse) MarshalTo 

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

func (*QueryTotalRecvFeesResponse) MarshalToSizedBuffer 

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

func (*QueryTotalRecvFeesResponse) ProtoMessage 

func (*QueryTotalRecvFeesResponse) ProtoMessage()

func (*QueryTotalRecvFeesResponse) Reset 

func (m *QueryTotalRecvFeesResponse) Reset()

func (*QueryTotalRecvFeesResponse) Size 

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

func (*QueryTotalRecvFeesResponse) String 

func (m *QueryTotalRecvFeesResponse) String() string

func (*QueryTotalRecvFeesResponse) Unmarshal 

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

func (*QueryTotalRecvFeesResponse) XXX_DiscardUnknown 

func (m *QueryTotalRecvFeesResponse) XXX_DiscardUnknown()

func (*QueryTotalRecvFeesResponse) XXX_Marshal 

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

func (*QueryTotalRecvFeesResponse) XXX_Merge 

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

func (*QueryTotalRecvFeesResponse) XXX_Size 

func (m *QueryTotalRecvFeesResponse) XXX_Size() int

func (*QueryTotalRecvFeesResponse) XXX_Unmarshal 

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

type QueryTotalTimeoutFeesRequest 

type QueryTotalTimeoutFeesRequest struct {
	// the packet identifier for the associated fees
	PacketId types.PacketId `protobuf:"bytes,1,opt,name=packet_id,json=packetId,proto3" json:"packet_id"`
}

QueryTotalTimeoutFeesRequest defines the request type for the TotalTimeoutFees rpc

func (*QueryTotalTimeoutFeesRequest) Descriptor 

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

func (*QueryTotalTimeoutFeesRequest) GetPacketId 

func (m *QueryTotalTimeoutFeesRequest) GetPacketId() types.PacketId

func (*QueryTotalTimeoutFeesRequest) Marshal 

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

func (*QueryTotalTimeoutFeesRequest) MarshalTo 

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

func (*QueryTotalTimeoutFeesRequest) MarshalToSizedBuffer 

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

func (*QueryTotalTimeoutFeesRequest) ProtoMessage 

func (*QueryTotalTimeoutFeesRequest) ProtoMessage()

func (*QueryTotalTimeoutFeesRequest) Reset 

func (m *QueryTotalTimeoutFeesRequest) Reset()

func (*QueryTotalTimeoutFeesRequest) Size 

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

func (*QueryTotalTimeoutFeesRequest) String 

func (m *QueryTotalTimeoutFeesRequest) String() string

func (*QueryTotalTimeoutFeesRequest) Unmarshal 

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

func (*QueryTotalTimeoutFeesRequest) XXX_DiscardUnknown 

func (m *QueryTotalTimeoutFeesRequest) XXX_DiscardUnknown()

func (*QueryTotalTimeoutFeesRequest) XXX_Marshal 

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

func (*QueryTotalTimeoutFeesRequest) XXX_Merge 

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

func (*QueryTotalTimeoutFeesRequest) XXX_Size 

func (m *QueryTotalTimeoutFeesRequest) XXX_Size() int

func (*QueryTotalTimeoutFeesRequest) XXX_Unmarshal 

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

type QueryTotalTimeoutFeesResponse 

type QueryTotalTimeoutFeesResponse struct {
	// the total packet timeout fees
	TimeoutFees github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
}

QueryTotalTimeoutFeesResponse defines the response type for the TotalTimeoutFees rpc

func (*QueryTotalTimeoutFeesResponse) Descriptor 

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

func (*QueryTotalTimeoutFeesResponse) GetTimeoutFees 

func (m *QueryTotalTimeoutFeesResponse) GetTimeoutFees() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryTotalTimeoutFeesResponse) Marshal 

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

func (*QueryTotalTimeoutFeesResponse) MarshalTo 

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

func (*QueryTotalTimeoutFeesResponse) MarshalToSizedBuffer 

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

func (*QueryTotalTimeoutFeesResponse) ProtoMessage 

func (*QueryTotalTimeoutFeesResponse) ProtoMessage()

func (*QueryTotalTimeoutFeesResponse) Reset 

func (m *QueryTotalTimeoutFeesResponse) Reset()

func (*QueryTotalTimeoutFeesResponse) Size 

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

func (*QueryTotalTimeoutFeesResponse) String 

func (m *QueryTotalTimeoutFeesResponse) String() string

func (*QueryTotalTimeoutFeesResponse) Unmarshal 

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

func (*QueryTotalTimeoutFeesResponse) XXX_DiscardUnknown 

func (m *QueryTotalTimeoutFeesResponse) XXX_DiscardUnknown()

func (*QueryTotalTimeoutFeesResponse) XXX_Marshal 

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

func (*QueryTotalTimeoutFeesResponse) XXX_Merge 

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

func (*QueryTotalTimeoutFeesResponse) XXX_Size 

func (m *QueryTotalTimeoutFeesResponse) XXX_Size() int

func (*QueryTotalTimeoutFeesResponse) XXX_Unmarshal 

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

type RegisteredCounterpartyPayee 

type RegisteredCounterpartyPayee struct {
	// unique channel identifier
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"`
	// the relayer address
	Relayer string `protobuf:"bytes,2,opt,name=relayer,proto3" json:"relayer,omitempty"`
	// the counterparty payee address
	CounterpartyPayee string `` /* 138-byte string literal not displayed */
}

RegisteredCounterpartyPayee contains the relayer address and counterparty payee address for a specific channel (used for recv fee distribution)

func (*RegisteredCounterpartyPayee) Descriptor 

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

func (*RegisteredCounterpartyPayee) GetChannelId 

func (m *RegisteredCounterpartyPayee) GetChannelId() string

func (*RegisteredCounterpartyPayee) GetCounterpartyPayee 

func (m *RegisteredCounterpartyPayee) GetCounterpartyPayee() string

func (*RegisteredCounterpartyPayee) GetRelayer 

func (m *RegisteredCounterpartyPayee) GetRelayer() string

func (*RegisteredCounterpartyPayee) Marshal 

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

func (*RegisteredCounterpartyPayee) MarshalTo 

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

func (*RegisteredCounterpartyPayee) MarshalToSizedBuffer 

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

func (*RegisteredCounterpartyPayee) ProtoMessage 

func (*RegisteredCounterpartyPayee) ProtoMessage()

func (*RegisteredCounterpartyPayee) Reset 

func (m *RegisteredCounterpartyPayee) Reset()

func (*RegisteredCounterpartyPayee) Size 

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

func (*RegisteredCounterpartyPayee) String 

func (m *RegisteredCounterpartyPayee) String() string

func (*RegisteredCounterpartyPayee) Unmarshal 

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

func (*RegisteredCounterpartyPayee) XXX_DiscardUnknown 

func (m *RegisteredCounterpartyPayee) XXX_DiscardUnknown()

func (*RegisteredCounterpartyPayee) XXX_Marshal 

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

func (*RegisteredCounterpartyPayee) XXX_Merge 

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

func (*RegisteredCounterpartyPayee) XXX_Size 

func (m *RegisteredCounterpartyPayee) XXX_Size() int

func (*RegisteredCounterpartyPayee) XXX_Unmarshal 

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

type RegisteredPayee 

type RegisteredPayee struct {
	// unique channel identifier
	ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"`
	// the relayer address
	Relayer string `protobuf:"bytes,2,opt,name=relayer,proto3" json:"relayer,omitempty"`
	// the payee address
	Payee string `protobuf:"bytes,3,opt,name=payee,proto3" json:"payee,omitempty"`
}

RegisteredPayee contains the relayer address and payee address for a specific channel

func (*RegisteredPayee) Descriptor 

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

func (*RegisteredPayee) GetChannelId 

func (m *RegisteredPayee) GetChannelId() string

func (*RegisteredPayee) GetPayee 

func (m *RegisteredPayee) GetPayee() string

func (*RegisteredPayee) GetRelayer 

func (m *RegisteredPayee) GetRelayer() string

func (*RegisteredPayee) Marshal 

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

func (*RegisteredPayee) MarshalTo 

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

func (*RegisteredPayee) MarshalToSizedBuffer 

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

func (*RegisteredPayee) ProtoMessage 

func (*RegisteredPayee) ProtoMessage()

func (*RegisteredPayee) Reset 

func (m *RegisteredPayee) Reset()

func (*RegisteredPayee) Size 

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

func (*RegisteredPayee) String 

func (m *RegisteredPayee) String() string

func (*RegisteredPayee) Unmarshal 

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

func (*RegisteredPayee) XXX_DiscardUnknown 

func (m *RegisteredPayee) XXX_DiscardUnknown()

func (*RegisteredPayee) XXX_Marshal 

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

func (*RegisteredPayee) XXX_Merge 

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

func (*RegisteredPayee) XXX_Size 

func (m *RegisteredPayee) XXX_Size() int

func (*RegisteredPayee) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) PayPacketFee 

func (*UnimplementedMsgServer) PayPacketFee(ctx context.Context, req *MsgPayPacketFee) (*MsgPayPacketFeeResponse, error)

func (*UnimplementedMsgServer) PayPacketFeeAsync 

func (*UnimplementedMsgServer) PayPacketFeeAsync(ctx context.Context, req *MsgPayPacketFeeAsync) (*MsgPayPacketFeeAsyncResponse, error)

func (*UnimplementedMsgServer) RegisterCounterpartyPayee 

func (*UnimplementedMsgServer) RegisterCounterpartyPayee(ctx context.Context, req *MsgRegisterCounterpartyPayee) (*MsgRegisterCounterpartyPayeeResponse, error)

func (*UnimplementedMsgServer) RegisterPayee 

func (*UnimplementedMsgServer) RegisterPayee(ctx context.Context, req *MsgRegisterPayee) (*MsgRegisterPayeeResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) CounterpartyPayee 

func (*UnimplementedQueryServer) CounterpartyPayee(ctx context.Context, req *QueryCounterpartyPayeeRequest) (*QueryCounterpartyPayeeResponse, error)

func (*UnimplementedQueryServer) FeeEnabledChannel 

func (*UnimplementedQueryServer) FeeEnabledChannel(ctx context.Context, req *QueryFeeEnabledChannelRequest) (*QueryFeeEnabledChannelResponse, error)

func (*UnimplementedQueryServer) FeeEnabledChannels 

func (*UnimplementedQueryServer) FeeEnabledChannels(ctx context.Context, req *QueryFeeEnabledChannelsRequest) (*QueryFeeEnabledChannelsResponse, error)

func (*UnimplementedQueryServer) IncentivizedPacket 

func (*UnimplementedQueryServer) IncentivizedPacket(ctx context.Context, req *QueryIncentivizedPacketRequest) (*QueryIncentivizedPacketResponse, error)

func (*UnimplementedQueryServer) IncentivizedPackets 

func (*UnimplementedQueryServer) IncentivizedPackets(ctx context.Context, req *QueryIncentivizedPacketsRequest) (*QueryIncentivizedPacketsResponse, error)

func (*UnimplementedQueryServer) IncentivizedPacketsForChannel 

func (*UnimplementedQueryServer) IncentivizedPacketsForChannel(ctx context.Context, req *QueryIncentivizedPacketsForChannelRequest) (*QueryIncentivizedPacketsForChannelResponse, error)

func (*UnimplementedQueryServer) Payee 

func (*UnimplementedQueryServer) Payee(ctx context.Context, req *QueryPayeeRequest) (*QueryPayeeResponse, error)

func (*UnimplementedQueryServer) TotalAckFees 

func (*UnimplementedQueryServer) TotalAckFees(ctx context.Context, req *QueryTotalAckFeesRequest) (*QueryTotalAckFeesResponse, error)

func (*UnimplementedQueryServer) TotalRecvFees 

func (*UnimplementedQueryServer) TotalRecvFees(ctx context.Context, req *QueryTotalRecvFeesRequest) (*QueryTotalRecvFeesResponse, error)

func (*UnimplementedQueryServer) TotalTimeoutFees 

func (*UnimplementedQueryServer) TotalTimeoutFees(ctx context.Context, req *QueryTotalTimeoutFeesRequest) (*QueryTotalTimeoutFeesResponse, 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.