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 (*Fee) GetRecvFee

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 (*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 (*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 (*MsgRegisterCounterpartyPayeeResponse) Size

func (*MsgRegisterCounterpartyPayeeResponse) 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 (*MsgRegisterCounterpartyPayeeResponse) XXX_Size

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 (*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 (*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 (*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 (*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 (*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 (*QueryFeeEnabledChannelsResponse) Size

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

func (*QueryFeeEnabledChannelsResponse) 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 (*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 (*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 (*QueryIncentivizedPacketResponse) Size

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

func (*QueryIncentivizedPacketResponse) 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 (*QueryIncentivizedPacketsForChannelRequest) GetPagination

func (*QueryIncentivizedPacketsForChannelRequest) GetPortId

func (*QueryIncentivizedPacketsForChannelRequest) GetQueryHeight

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

func (*QueryIncentivizedPacketsForChannelRequest) Size

func (*QueryIncentivizedPacketsForChannelRequest) String

func (*QueryIncentivizedPacketsForChannelRequest) Unmarshal

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 (*QueryIncentivizedPacketsForChannelRequest) XXX_Size

func (*QueryIncentivizedPacketsForChannelRequest) XXX_Unmarshal

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

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

func (*QueryIncentivizedPacketsForChannelResponse) Size

func (*QueryIncentivizedPacketsForChannelResponse) String

func (*QueryIncentivizedPacketsForChannelResponse) Unmarshal

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 (*QueryIncentivizedPacketsForChannelResponse) XXX_Size

func (*QueryIncentivizedPacketsForChannelResponse) XXX_Unmarshal

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 (*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 (*QueryIncentivizedPacketsRequest) Size

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

func (*QueryIncentivizedPacketsRequest) 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 (*QueryIncentivizedPacketsResponse) Size

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

func (*QueryIncentivizedPacketsResponse) 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 (*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 (*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 (*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 (*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 (*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 (*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) PayPacketFeeAsync

func (*UnimplementedMsgServer) RegisterCounterpartyPayee

func (*UnimplementedMsgServer) RegisterPayee

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) CounterpartyPayee

func (*UnimplementedQueryServer) FeeEnabledChannel

func (*UnimplementedQueryServer) FeeEnabledChannels

func (*UnimplementedQueryServer) IncentivizedPacket

func (*UnimplementedQueryServer) IncentivizedPackets

func (*UnimplementedQueryServer) Payee

func (*UnimplementedQueryServer) TotalAckFees

func (*UnimplementedQueryServer) TotalRecvFees

func (*UnimplementedQueryServer) TotalTimeoutFees

Jump to

Keyboard shortcuts

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