types

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2022 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// SubModuleName defines the XIBC packets name
	SubModuleName = "packet"
)

Variables

View Source 
var (
	ErrInvalidPacket            = sdkerrors.Register(moduleName, 2, "invalid packet")
	ErrInvalidAcknowledgement   = sdkerrors.Register(moduleName, 3, "invalid acknowledgement")
	ErrPacketCommitmentNotFound = sdkerrors.Register(moduleName, 4, "packet commitment not found")
	ErrAcknowledgementExists    = sdkerrors.Register(moduleName, 5, "packet acknowledgement already exists")
	ErrWritingEthTxData         = sdkerrors.Register(moduleName, 6, "writing ethereum tx data error")
	ErrScChainEqualToDestChain  = sdkerrors.Register(moduleName, 7, "source chain equals to destination chain")
	ErrRelayerNotFound          = sdkerrors.Register(moduleName, 8, "relayer not found")
	ErrInvalidRelayer           = sdkerrors.Register(moduleName, 9, "invalid relayer")
	ErrInvalidSequence          = sdkerrors.Register(moduleName, 10, "invalid sequence")
	ErrInvalidSrcChain          = sdkerrors.Register(moduleName, 11, "invalid source chain")
	ErrInvalidDestChain         = sdkerrors.Register(moduleName, 12, "invalid destination chain")
	ErrInvalidRelayChain        = sdkerrors.Register(moduleName, 13, "invalid relay chain")
)

XIBC packet sentinel errors

View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = 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 (
	ErrInvalidLengthPacket        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPacket          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPacket = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// ModuleAddress is the native module address for EVM
	// 0x7426aFC489D0eeF99a0B438DEF226aD139F75235
	ModuleAddress common.Address
)
View Source 
var ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
View Source 
var SubModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
View Source 
var (
	TupleAckData abi.Type
)

Functions

func CommitAcknowledgement 

func CommitAcknowledgement(data []byte) []byte

CommitAcknowledgement returns the hash of commitment bytes

func CommitPacket 

func CommitPacket(packet exported.PacketI) []byte

CommitPacket returns the packet commitment bytes. The commitment consists of: sha256_hash(timeout_timestamp + timeout_height.RevisionNumber + timeout_height.RevisionHeight + sha256_hash(port + data)) from a given packet. This results in a fixed length preimage. NOTE: sdk.Uint64ToBigEndian sets the uint64 to a slice of length 8.

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the xibc packet submodule interfaces to protobuf Any

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
	GetSequence(sdk.Context, sdk.AccAddress) (uint64, error)
	GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI
}

AccountKeeper defines the expected account keeper

type Acknowledgement 

type Acknowledgement struct {
	// the execution results of the packet data list
	Results [][]byte `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// error message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// relayer address
	Relayer string `protobuf:"bytes,3,opt,name=relayer,proto3" json:"relayer,omitempty"`
}

Acknowledgement is the recommended acknowledgement format to be used by app-specific protocols.

func NewErrorAcknowledgement 

func NewErrorAcknowledgement(message string, relayer string) Acknowledgement

NewErrorAcknowledgement returns a new instance of Acknowledgement using an Acknowledgement_Error type in the Response field.

func NewResultAcknowledgement 

func NewResultAcknowledgement(results [][]byte, relayer string) Acknowledgement

NewResultAcknowledgement returns a new instance of Acknowledgement using an Acknowledgement_Result type in the Response field.

func (*Acknowledgement) DecodeBytes 

func (ack *Acknowledgement) DecodeBytes(bz []byte) error

func (*Acknowledgement) Descriptor 

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

func (Acknowledgement) GetBytes 

func (ack Acknowledgement) GetBytes() ([]byte, error)

GetBytes is a helper for serialising acknowledgements

func (*Acknowledgement) GetMessage 

func (m *Acknowledgement) GetMessage() string

func (*Acknowledgement) GetRelayer 

func (m *Acknowledgement) GetRelayer() string

func (*Acknowledgement) GetResults 

func (m *Acknowledgement) GetResults() [][]byte

func (*Acknowledgement) Marshal 

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

func (*Acknowledgement) MarshalTo 

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

func (*Acknowledgement) MarshalToSizedBuffer 

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

func (*Acknowledgement) ProtoMessage 

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) Reset 

func (m *Acknowledgement) Reset()

func (*Acknowledgement) Size 

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

func (*Acknowledgement) String 

func (m *Acknowledgement) String() string

func (*Acknowledgement) Unmarshal 

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

func (*Acknowledgement) XXX_DiscardUnknown 

func (m *Acknowledgement) XXX_DiscardUnknown()

func (*Acknowledgement) XXX_Marshal 

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

func (*Acknowledgement) XXX_Merge 

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

func (*Acknowledgement) XXX_Size 

func (m *Acknowledgement) XXX_Size() int

func (*Acknowledgement) XXX_Unmarshal 

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

type ClientKeeper 

type ClientKeeper interface {
	GetClientState(ctx sdk.Context, chainName string) (exported.ClientState, bool)
	GetClientConsensusState(ctx sdk.Context, chainName string, height exported.Height) (exported.ConsensusState, bool)
	ClientStore(ctx sdk.Context, chainName string) sdk.KVStore
	GetChainName(ctx sdk.Context) string
	GetRelayerAddressOnOtherChain(ctx sdk.Context, chainName string, address string) (string, bool)
}

ClientKeeper expected account XIBC client keeper

type EVMKeeper 

type EVMKeeper interface {
	ChainID() *big.Int
	GetNonce(ctx sdk.Context, addr common.Address) uint64
	ApplyMessage(ctx sdk.Context, msg core.Message, tracer vm.EVMLogger, commit bool) (*types.MsgEthereumTxResponse, error)
	EthereumTx(goCtx context.Context, msg *types.MsgEthereumTx) (*types.MsgEthereumTxResponse, error)
	EstimateGas(c context.Context, req *types.EthCallRequest) (*types.EstimateGasResponse, error)
}

EVMKeeper defines the expected EVM keeper interface used on xibc-transfer

type EventAcknowledgePacket 

type EventAcknowledgePacket struct {
	Sequence   string   `protobuf:"bytes,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	SrcChain   string   `protobuf:"bytes,2,opt,name=src_chain,json=srcChain,proto3" json:"src_chain,omitempty"`
	DstChain   string   `protobuf:"bytes,3,opt,name=dst_chain,json=dstChain,proto3" json:"dst_chain,omitempty"`
	RelayChain string   `protobuf:"bytes,4,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty"`
	Ports      []string `protobuf:"bytes,5,rep,name=ports,proto3" json:"ports,omitempty"`
	DataList   [][]byte `protobuf:"bytes,6,rep,name=data_list,json=dataList,proto3" json:"data_list,omitempty"`
	Ack        []byte   `protobuf:"bytes,7,opt,name=ack,proto3" json:"ack,omitempty"`
}

EventAcknowledgePacket is emitted on acknowledgement packet

func (*EventAcknowledgePacket) Descriptor 

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

func (*EventAcknowledgePacket) GetAck 

func (m *EventAcknowledgePacket) GetAck() []byte

func (*EventAcknowledgePacket) GetDataList 

func (m *EventAcknowledgePacket) GetDataList() [][]byte

func (*EventAcknowledgePacket) GetDstChain 

func (m *EventAcknowledgePacket) GetDstChain() string

func (*EventAcknowledgePacket) GetPorts 

func (m *EventAcknowledgePacket) GetPorts() []string

func (*EventAcknowledgePacket) GetRelayChain 

func (m *EventAcknowledgePacket) GetRelayChain() string

func (*EventAcknowledgePacket) GetSequence 

func (m *EventAcknowledgePacket) GetSequence() string

func (*EventAcknowledgePacket) GetSrcChain 

func (m *EventAcknowledgePacket) GetSrcChain() string

func (*EventAcknowledgePacket) Marshal 

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

func (*EventAcknowledgePacket) MarshalTo 

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

func (*EventAcknowledgePacket) MarshalToSizedBuffer 

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

func (*EventAcknowledgePacket) ProtoMessage 

func (*EventAcknowledgePacket) ProtoMessage()

func (*EventAcknowledgePacket) Reset 

func (m *EventAcknowledgePacket) Reset()

func (*EventAcknowledgePacket) Size 

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

func (*EventAcknowledgePacket) String 

func (m *EventAcknowledgePacket) String() string

func (*EventAcknowledgePacket) Unmarshal 

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

func (*EventAcknowledgePacket) XXX_DiscardUnknown 

func (m *EventAcknowledgePacket) XXX_DiscardUnknown()

func (*EventAcknowledgePacket) XXX_Marshal 

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

func (*EventAcknowledgePacket) XXX_Merge 

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

func (*EventAcknowledgePacket) XXX_Size 

func (m *EventAcknowledgePacket) XXX_Size() int

func (*EventAcknowledgePacket) XXX_Unmarshal 

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

type EventRecvPacket 

type EventRecvPacket struct {
	Sequence   string   `protobuf:"bytes,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	SrcChain   string   `protobuf:"bytes,2,opt,name=src_chain,json=srcChain,proto3" json:"src_chain,omitempty"`
	DstChain   string   `protobuf:"bytes,3,opt,name=dst_chain,json=dstChain,proto3" json:"dst_chain,omitempty"`
	RelayChain string   `protobuf:"bytes,4,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty"`
	Ports      []string `protobuf:"bytes,5,rep,name=ports,proto3" json:"ports,omitempty"`
	DataList   [][]byte `protobuf:"bytes,6,rep,name=data_list,json=dataList,proto3" json:"data_list,omitempty"`
}

EventRecvPacket is emitted on receive packet

func (*EventRecvPacket) Descriptor 

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

func (*EventRecvPacket) GetDataList 

func (m *EventRecvPacket) GetDataList() [][]byte

func (*EventRecvPacket) GetDstChain 

func (m *EventRecvPacket) GetDstChain() string

func (*EventRecvPacket) GetPorts 

func (m *EventRecvPacket) GetPorts() []string

func (*EventRecvPacket) GetRelayChain 

func (m *EventRecvPacket) GetRelayChain() string

func (*EventRecvPacket) GetSequence 

func (m *EventRecvPacket) GetSequence() string

func (*EventRecvPacket) GetSrcChain 

func (m *EventRecvPacket) GetSrcChain() string

func (*EventRecvPacket) Marshal 

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

func (*EventRecvPacket) MarshalTo 

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

func (*EventRecvPacket) MarshalToSizedBuffer 

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

func (*EventRecvPacket) ProtoMessage 

func (*EventRecvPacket) ProtoMessage()

func (*EventRecvPacket) Reset 

func (m *EventRecvPacket) Reset()

func (*EventRecvPacket) Size 

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

func (*EventRecvPacket) String 

func (m *EventRecvPacket) String() string

func (*EventRecvPacket) Unmarshal 

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

func (*EventRecvPacket) XXX_DiscardUnknown 

func (m *EventRecvPacket) XXX_DiscardUnknown()

func (*EventRecvPacket) XXX_Marshal 

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

func (*EventRecvPacket) XXX_Merge 

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

func (*EventRecvPacket) XXX_Size 

func (m *EventRecvPacket) XXX_Size() int

func (*EventRecvPacket) XXX_Unmarshal 

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

type EventSendPacket 

type EventSendPacket struct {
	Sequence   string   `protobuf:"bytes,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	SrcChain   string   `protobuf:"bytes,2,opt,name=src_chain,json=srcChain,proto3" json:"src_chain,omitempty"`
	DstChain   string   `protobuf:"bytes,3,opt,name=dst_chain,json=dstChain,proto3" json:"dst_chain,omitempty"`
	RelayChain string   `protobuf:"bytes,4,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty"`
	Ports      []string `protobuf:"bytes,5,rep,name=ports,proto3" json:"ports,omitempty"`
	DataList   [][]byte `protobuf:"bytes,6,rep,name=data_list,json=dataList,proto3" json:"data_list,omitempty"`
}

EventSendPacket is emitted on send packet

func (*EventSendPacket) Descriptor 

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

func (*EventSendPacket) GetDataList 

func (m *EventSendPacket) GetDataList() [][]byte

func (*EventSendPacket) GetDstChain 

func (m *EventSendPacket) GetDstChain() string

func (*EventSendPacket) GetPorts 

func (m *EventSendPacket) GetPorts() []string

func (*EventSendPacket) GetRelayChain 

func (m *EventSendPacket) GetRelayChain() string

func (*EventSendPacket) GetSequence 

func (m *EventSendPacket) GetSequence() string

func (*EventSendPacket) GetSrcChain 

func (m *EventSendPacket) GetSrcChain() string

func (*EventSendPacket) Marshal 

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

func (*EventSendPacket) MarshalTo 

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

func (*EventSendPacket) MarshalToSizedBuffer 

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

func (*EventSendPacket) ProtoMessage 

func (*EventSendPacket) ProtoMessage()

func (*EventSendPacket) Reset 

func (m *EventSendPacket) Reset()

func (*EventSendPacket) Size 

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

func (*EventSendPacket) String 

func (m *EventSendPacket) String() string

func (*EventSendPacket) Unmarshal 

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

func (*EventSendPacket) XXX_DiscardUnknown 

func (m *EventSendPacket) XXX_DiscardUnknown()

func (*EventSendPacket) XXX_Marshal 

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

func (*EventSendPacket) XXX_Merge 

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

func (*EventSendPacket) XXX_Size 

func (m *EventSendPacket) XXX_Size() int

func (*EventSendPacket) XXX_Unmarshal 

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

type EventWriteAck 

type EventWriteAck struct {
	Sequence   string   `protobuf:"bytes,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	SrcChain   string   `protobuf:"bytes,2,opt,name=src_chain,json=srcChain,proto3" json:"src_chain,omitempty"`
	DstChain   string   `protobuf:"bytes,3,opt,name=dst_chain,json=dstChain,proto3" json:"dst_chain,omitempty"`
	RelayChain string   `protobuf:"bytes,4,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty"`
	Ports      []string `protobuf:"bytes,5,rep,name=ports,proto3" json:"ports,omitempty"`
	DataList   [][]byte `protobuf:"bytes,6,rep,name=data_list,json=dataList,proto3" json:"data_list,omitempty"`
	Ack        []byte   `protobuf:"bytes,7,opt,name=ack,proto3" json:"ack,omitempty"`
}

EventWriteAck is emitted on receive packet

func (*EventWriteAck) Descriptor 

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

func (*EventWriteAck) GetAck 

func (m *EventWriteAck) GetAck() []byte

func (*EventWriteAck) GetDataList 

func (m *EventWriteAck) GetDataList() [][]byte

func (*EventWriteAck) GetDstChain 

func (m *EventWriteAck) GetDstChain() string

func (*EventWriteAck) GetPorts 

func (m *EventWriteAck) GetPorts() []string

func (*EventWriteAck) GetRelayChain 

func (m *EventWriteAck) GetRelayChain() string

func (*EventWriteAck) GetSequence 

func (m *EventWriteAck) GetSequence() string

func (*EventWriteAck) GetSrcChain 

func (m *EventWriteAck) GetSrcChain() string

func (*EventWriteAck) Marshal 

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

func (*EventWriteAck) MarshalTo 

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

func (*EventWriteAck) MarshalToSizedBuffer 

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

func (*EventWriteAck) ProtoMessage 

func (*EventWriteAck) ProtoMessage()

func (*EventWriteAck) Reset 

func (m *EventWriteAck) Reset()

func (*EventWriteAck) Size 

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

func (*EventWriteAck) String 

func (m *EventWriteAck) String() string

func (*EventWriteAck) Unmarshal 

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

func (*EventWriteAck) XXX_DiscardUnknown 

func (m *EventWriteAck) XXX_DiscardUnknown()

func (*EventWriteAck) XXX_Marshal 

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

func (*EventWriteAck) XXX_Merge 

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

func (*EventWriteAck) XXX_Size 

func (m *EventWriteAck) XXX_Size() int

func (*EventWriteAck) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Acknowledgements []PacketState    `protobuf:"bytes,1,rep,name=acknowledgements,proto3" json:"acknowledgements"`
	Commitments      []PacketState    `protobuf:"bytes,2,rep,name=commitments,proto3" json:"commitments"`
	Receipts         []PacketState    `protobuf:"bytes,3,rep,name=receipts,proto3" json:"receipts"`
	SendSequences    []PacketSequence `protobuf:"bytes,4,rep,name=send_sequences,json=sendSequences,proto3" json:"send_sequences" yaml:"send_sequences"`
	RecvSequences    []PacketSequence `protobuf:"bytes,5,rep,name=recv_sequences,json=recvSequences,proto3" json:"recv_sequences" yaml:"recv_sequences"`
	AckSequences     []PacketSequence `protobuf:"bytes,6,rep,name=ack_sequences,json=ackSequences,proto3" json:"ack_sequences" yaml:"ack_sequences"`
}

GenesisState defines the xibc channel submodule's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() GenesisState

DefaultGenesisState returns the xibc packet submodule's default genesis state.

func NewGenesisState 

func NewGenesisState(
	acks, commitments, receipts []PacketState,
	sendSeqs, recvSeqs, ackSeqs []PacketSequence,
) GenesisState

NewGenesisState creates a GenesisState instance.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetAckSequences 

func (m *GenesisState) GetAckSequences() []PacketSequence

func (*GenesisState) GetAcknowledgements 

func (m *GenesisState) GetAcknowledgements() []PacketState

func (*GenesisState) GetCommitments 

func (m *GenesisState) GetCommitments() []PacketState

func (*GenesisState) GetReceipts 

func (m *GenesisState) GetReceipts() []PacketState

func (*GenesisState) GetRecvSequences 

func (m *GenesisState) GetRecvSequences() []PacketSequence

func (*GenesisState) GetSendSequences 

func (m *GenesisState) GetSendSequences() []PacketSequence

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 MsgAcknowledgement 

type MsgAcknowledgement struct {
	Packet          Packet       `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"`
	Acknowledgement []byte       `protobuf:"bytes,2,opt,name=acknowledgement,proto3" json:"acknowledgement,omitempty"`
	ProofAcked      []byte       `protobuf:"bytes,3,opt,name=proof_acked,json=proofAcked,proto3" json:"proof_acked,omitempty" yaml:"proof_acked"`
	ProofHeight     types.Height `protobuf:"bytes,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"`
	Signer          string       `protobuf:"bytes,5,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgAcknowledgement receives incoming XIBC acknowledgement

func NewMsgAcknowledgement 

func NewMsgAcknowledgement(
	packet Packet,
	ack []byte,
	proofAcked []byte,
	proofHeight clienttypes.Height,
	signer sdk.AccAddress,
) *MsgAcknowledgement

NewMsgAcknowledgement constructs a new MsgAcknowledgement nolint:interfacer

func (*MsgAcknowledgement) Descriptor 

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

func (MsgAcknowledgement) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgAcknowledgement) Marshal 

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

func (*MsgAcknowledgement) MarshalTo 

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

func (*MsgAcknowledgement) MarshalToSizedBuffer 

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

func (*MsgAcknowledgement) ProtoMessage 

func (*MsgAcknowledgement) ProtoMessage()

func (*MsgAcknowledgement) Reset 

func (m *MsgAcknowledgement) Reset()

func (*MsgAcknowledgement) Size 

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

func (*MsgAcknowledgement) String 

func (m *MsgAcknowledgement) String() string

func (*MsgAcknowledgement) Unmarshal 

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

func (MsgAcknowledgement) ValidateBasic 

func (msg MsgAcknowledgement) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAcknowledgement) XXX_DiscardUnknown 

func (m *MsgAcknowledgement) XXX_DiscardUnknown()

func (*MsgAcknowledgement) XXX_Marshal 

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

func (*MsgAcknowledgement) XXX_Merge 

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

func (*MsgAcknowledgement) XXX_Size 

func (m *MsgAcknowledgement) XXX_Size() int

func (*MsgAcknowledgement) XXX_Unmarshal 

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

type MsgAcknowledgementResponse 

type MsgAcknowledgementResponse struct {
}

MsgAcknowledgementResponse defines the Msg/Acknowledgement response type.

func (*MsgAcknowledgementResponse) Descriptor 

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

func (*MsgAcknowledgementResponse) Marshal 

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

func (*MsgAcknowledgementResponse) MarshalTo 

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

func (*MsgAcknowledgementResponse) MarshalToSizedBuffer 

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

func (*MsgAcknowledgementResponse) ProtoMessage 

func (*MsgAcknowledgementResponse) ProtoMessage()

func (*MsgAcknowledgementResponse) Reset 

func (m *MsgAcknowledgementResponse) Reset()

func (*MsgAcknowledgementResponse) Size 

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

func (*MsgAcknowledgementResponse) String 

func (m *MsgAcknowledgementResponse) String() string

func (*MsgAcknowledgementResponse) Unmarshal 

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

func (*MsgAcknowledgementResponse) XXX_DiscardUnknown 

func (m *MsgAcknowledgementResponse) XXX_DiscardUnknown()

func (*MsgAcknowledgementResponse) XXX_Marshal 

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

func (*MsgAcknowledgementResponse) XXX_Merge 

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

func (*MsgAcknowledgementResponse) XXX_Size 

func (m *MsgAcknowledgementResponse) XXX_Size() int

func (*MsgAcknowledgementResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// RecvPacket defines a rpc handler method for MsgRecvPacket.
	RecvPacket(ctx context.Context, in *MsgRecvPacket, opts ...grpc.CallOption) (*MsgRecvPacketResponse, error)
	// Acknowledgement defines a rpc handler method for MsgAcknowledgement.
	Acknowledgement(ctx context.Context, in *MsgAcknowledgement, opts ...grpc.CallOption) (*MsgAcknowledgementResponse, 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 MsgRecvPacket 

type MsgRecvPacket struct {
	Packet          Packet       `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"`
	ProofCommitment []byte       `` /* 130-byte string literal not displayed */
	ProofHeight     types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"`
	Signer          string       `protobuf:"bytes,4,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgRecvPacket receives incoming XIBC packet

func NewMsgRecvPacket 

func NewMsgRecvPacket(
	packet Packet,
	proofCommitment []byte,
	proofHeight clienttypes.Height,
	signer sdk.AccAddress,
) *MsgRecvPacket

NewMsgRecvPacket constructs new MsgRecvPacket nolint:interfacer

func (*MsgRecvPacket) Descriptor 

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

func (MsgRecvPacket) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgRecvPacket) Marshal 

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

func (*MsgRecvPacket) MarshalTo 

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

func (*MsgRecvPacket) MarshalToSizedBuffer 

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

func (*MsgRecvPacket) ProtoMessage 

func (*MsgRecvPacket) ProtoMessage()

func (*MsgRecvPacket) Reset 

func (m *MsgRecvPacket) Reset()

func (*MsgRecvPacket) Size 

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

func (*MsgRecvPacket) String 

func (m *MsgRecvPacket) String() string

func (*MsgRecvPacket) Unmarshal 

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

func (MsgRecvPacket) ValidateBasic 

func (msg MsgRecvPacket) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgRecvPacket) XXX_DiscardUnknown 

func (m *MsgRecvPacket) XXX_DiscardUnknown()

func (*MsgRecvPacket) XXX_Marshal 

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

func (*MsgRecvPacket) XXX_Merge 

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

func (*MsgRecvPacket) XXX_Size 

func (m *MsgRecvPacket) XXX_Size() int

func (*MsgRecvPacket) XXX_Unmarshal 

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

type MsgRecvPacketResponse 

type MsgRecvPacketResponse struct {
}

MsgRecvPacketResponse defines the Msg/RecvPacket response type.

func (*MsgRecvPacketResponse) Descriptor 

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

func (*MsgRecvPacketResponse) Marshal 

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

func (*MsgRecvPacketResponse) MarshalTo 

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

func (*MsgRecvPacketResponse) MarshalToSizedBuffer 

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

func (*MsgRecvPacketResponse) ProtoMessage 

func (*MsgRecvPacketResponse) ProtoMessage()

func (*MsgRecvPacketResponse) Reset 

func (m *MsgRecvPacketResponse) Reset()

func (*MsgRecvPacketResponse) Size 

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

func (*MsgRecvPacketResponse) String 

func (m *MsgRecvPacketResponse) String() string

func (*MsgRecvPacketResponse) Unmarshal 

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

func (*MsgRecvPacketResponse) XXX_DiscardUnknown 

func (m *MsgRecvPacketResponse) XXX_DiscardUnknown()

func (*MsgRecvPacketResponse) XXX_Marshal 

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

func (*MsgRecvPacketResponse) XXX_Merge 

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

func (*MsgRecvPacketResponse) XXX_Size 

func (m *MsgRecvPacketResponse) XXX_Size() int

func (*MsgRecvPacketResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// RecvPacket defines a rpc handler method for MsgRecvPacket.
	RecvPacket(context.Context, *MsgRecvPacket) (*MsgRecvPacketResponse, error)
	// Acknowledgement defines a rpc handler method for MsgAcknowledgement.
	Acknowledgement(context.Context, *MsgAcknowledgement) (*MsgAcknowledgementResponse, error)
}

MsgServer is the server API for Msg service.

type Packet 

type Packet struct {
	// number corresponds to the order of sends and receives, where a Packet
	// with an earlier sequence number must be sent and received before a Packet
	// with a later sequence number.
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// identifies the chain id of the sending chain.
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"`
	// identifies the chain id of the receiving chain.
	DestinationChain string `` /* 133-byte string literal not displayed */
	// identifies the chain id of the relay chain.
	RelayChain string `protobuf:"bytes,4,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty" yaml:"relay_chain"`
	// identifies the ports on the sending chain and destination chain
	Ports []string `protobuf:"bytes,5,rep,name=ports,proto3" json:"ports,omitempty"`
	// actual opaque bytes transferred directly to the application module
	DataList [][]byte `protobuf:"bytes,6,rep,name=data_list,json=dataList,proto3" json:"data_list,omitempty"`
}

Packet defines a type that carries data across different chains through XIBC

func NewPacket 

func NewPacket(
	sequence uint64,
	sourceChain string,
	destinationChain string,
	relayChain string,
	ports []string,
	dataList [][]byte,
) Packet

NewPacket creates a new Packet instance. It panics if the provided packet data interface is not registered.

func (*Packet) Descriptor 

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

func (Packet) GetDataList 

func (p Packet) GetDataList() [][]byte

GetDataList implements PacketI interface

func (Packet) GetDestChain 

func (p Packet) GetDestChain() string

GetDestinationChain implements PacketI interface

func (Packet) GetPorts 

func (p Packet) GetPorts() []string

GetPorts implements PacketI interface

func (Packet) GetRelayChain 

func (p Packet) GetRelayChain() string

GetRelayChain implements PacketI interface

func (Packet) GetSequence 

func (p Packet) GetSequence() uint64

GetSequence implements PacketI interface

func (Packet) GetSourceChain 

func (p Packet) GetSourceChain() string

GetSourceChain implements PacketI interface

func (*Packet) Marshal 

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

func (*Packet) MarshalTo 

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

func (*Packet) MarshalToSizedBuffer 

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

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) Reset 

func (m *Packet) Reset()

func (*Packet) Size 

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

func (*Packet) String 

func (m *Packet) String() string

func (*Packet) Unmarshal 

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

func (Packet) ValidateBasic 

func (p Packet) ValidateBasic() error

ValidateBasic implements PacketI interface

func (*Packet) XXX_DiscardUnknown 

func (m *Packet) XXX_DiscardUnknown()

func (*Packet) XXX_Marshal 

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

func (*Packet) XXX_Merge 

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

func (*Packet) XXX_Size 

func (m *Packet) XXX_Size() int

func (*Packet) XXX_Unmarshal 

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

type PacketSequence 

type PacketSequence struct {
	SourceChain      string `protobuf:"bytes,1,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"`
	DestinationChain string `` /* 134-byte string literal not displayed */
	Sequence         uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

PacketSequence defines the genesis type necessary to retrieve and store next send and receive sequences.

func NewPacketSequence 

func NewPacketSequence(sourceChain, destinationChain string, seq uint64) PacketSequence

NewPacketSequence creates a new PacketSequences instance.

func (*PacketSequence) Descriptor 

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

func (*PacketSequence) GetDestinationChain 

func (m *PacketSequence) GetDestinationChain() string

func (*PacketSequence) GetSequence 

func (m *PacketSequence) GetSequence() uint64

func (*PacketSequence) GetSourceChain 

func (m *PacketSequence) GetSourceChain() string

func (*PacketSequence) Marshal 

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

func (*PacketSequence) MarshalTo 

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

func (*PacketSequence) MarshalToSizedBuffer 

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

func (*PacketSequence) ProtoMessage 

func (*PacketSequence) ProtoMessage()

func (*PacketSequence) Reset 

func (m *PacketSequence) Reset()

func (*PacketSequence) Size 

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

func (*PacketSequence) String 

func (m *PacketSequence) String() string

func (*PacketSequence) Unmarshal 

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

func (PacketSequence) Validate 

func (ps PacketSequence) Validate() error

Validate performs basic validation of fields returning an error upon any failure.

func (*PacketSequence) XXX_DiscardUnknown 

func (m *PacketSequence) XXX_DiscardUnknown()

func (*PacketSequence) XXX_Marshal 

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

func (*PacketSequence) XXX_Merge 

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

func (*PacketSequence) XXX_Size 

func (m *PacketSequence) XXX_Size() int

func (*PacketSequence) XXX_Unmarshal 

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

type PacketState 

type PacketState struct {
	// the sending chain identifier.
	SourceChain string `protobuf:"bytes,1,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"`
	// the receiving chain identifier.
	DestinationChain string `` /* 129-byte string literal not displayed */
	// packet sequence.
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// embedded data that represents packet state.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

PacketState defines the generic type necessary to retrieve and store packet commitments, acknowledgements, and receipts. Caller is responsible for knowing the context necessary to interpret this state as a commitment, acknowledgement, or a receipt.

func NewPacketState 

func NewPacketState(sourceChain, destinationChain string, seq uint64, data []byte) PacketState

NewPacketState creates a new PacketState instance.

func (*PacketState) Descriptor 

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

func (*PacketState) Marshal 

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

func (*PacketState) MarshalTo 

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

func (*PacketState) MarshalToSizedBuffer 

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

func (*PacketState) ProtoMessage 

func (*PacketState) ProtoMessage()

func (*PacketState) Reset 

func (m *PacketState) Reset()

func (*PacketState) Size 

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

func (*PacketState) String 

func (m *PacketState) String() string

func (*PacketState) Unmarshal 

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

func (PacketState) Validate 

func (pa PacketState) Validate() error

Validate performs basic validation of fields returning an error upon any failure.

func (*PacketState) XXX_DiscardUnknown 

func (m *PacketState) XXX_DiscardUnknown()

func (*PacketState) XXX_Marshal 

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

func (*PacketState) XXX_Merge 

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

func (*PacketState) XXX_Size 

func (m *PacketState) XXX_Size() int

func (*PacketState) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// PacketCommitment queries a stored packet commitment hash.
	PacketCommitment(ctx context.Context, in *QueryPacketCommitmentRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentResponse, error)
	// PacketCommitments returns all the packet commitments hashes associated
	PacketCommitments(ctx context.Context, in *QueryPacketCommitmentsRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentsResponse, error)
	// PacketReceipt queries if a given packet sequence has been received on the
	// queried chain
	PacketReceipt(ctx context.Context, in *QueryPacketReceiptRequest, opts ...grpc.CallOption) (*QueryPacketReceiptResponse, error)
	// PacketAcknowledgement queries a stored packet acknowledgement hash.
	PacketAcknowledgement(ctx context.Context, in *QueryPacketAcknowledgementRequest, opts ...grpc.CallOption) (*QueryPacketAcknowledgementResponse, error)
	// PacketAcknowledgements returns all the packet acknowledgements associated
	PacketAcknowledgements(ctx context.Context, in *QueryPacketAcknowledgementsRequest, opts ...grpc.CallOption) (*QueryPacketAcknowledgementsResponse, error)
	// UnreceivedPackets returns all the unreceived XIBC packets associated with
	// sequences.
	UnreceivedPackets(ctx context.Context, in *QueryUnreceivedPacketsRequest, opts ...grpc.CallOption) (*QueryUnreceivedPacketsResponse, error)
	// UnreceivedAcks returns all the unreceived XIBC acknowledgements associated
	// with sequences.
	UnreceivedAcks(ctx context.Context, in *QueryUnreceivedAcksRequest, opts ...grpc.CallOption) (*QueryUnreceivedAcksResponse, 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 QueryPacketAcknowledgementRequest 

type QueryPacketAcknowledgementRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// packet sequence
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

QueryPacketAcknowledgementRequest is the request type for the Query/PacketAcknowledgement RPC method

func (*QueryPacketAcknowledgementRequest) Descriptor 

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

func (*QueryPacketAcknowledgementRequest) GetDestChain 

func (m *QueryPacketAcknowledgementRequest) GetDestChain() string

func (*QueryPacketAcknowledgementRequest) GetSequence 

func (m *QueryPacketAcknowledgementRequest) GetSequence() uint64

func (*QueryPacketAcknowledgementRequest) GetSourceChain 

func (m *QueryPacketAcknowledgementRequest) GetSourceChain() string

func (*QueryPacketAcknowledgementRequest) Marshal 

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

func (*QueryPacketAcknowledgementRequest) MarshalTo 

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

func (*QueryPacketAcknowledgementRequest) MarshalToSizedBuffer 

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

func (*QueryPacketAcknowledgementRequest) ProtoMessage 

func (*QueryPacketAcknowledgementRequest) ProtoMessage()

func (*QueryPacketAcknowledgementRequest) Reset 

func (m *QueryPacketAcknowledgementRequest) Reset()

func (*QueryPacketAcknowledgementRequest) Size 

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

func (*QueryPacketAcknowledgementRequest) String 

func (m *QueryPacketAcknowledgementRequest) String() string

func (*QueryPacketAcknowledgementRequest) Unmarshal 

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

func (*QueryPacketAcknowledgementRequest) XXX_DiscardUnknown 

func (m *QueryPacketAcknowledgementRequest) XXX_DiscardUnknown()

func (*QueryPacketAcknowledgementRequest) XXX_Marshal 

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

func (*QueryPacketAcknowledgementRequest) XXX_Merge 

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

func (*QueryPacketAcknowledgementRequest) XXX_Size 

func (m *QueryPacketAcknowledgementRequest) XXX_Size() int

func (*QueryPacketAcknowledgementRequest) XXX_Unmarshal 

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

type QueryPacketAcknowledgementResponse 

type QueryPacketAcknowledgementResponse struct {
	// packet associated with the request fields
	Acknowledgement []byte `protobuf:"bytes,1,opt,name=acknowledgement,proto3" json:"acknowledgement,omitempty"`
	// merkle proof of existence
	Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
	// height at which the proof was retrieved
	ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

QueryPacketAcknowledgementResponse defines the client query response for a packet which also includes a proof and the height from which the proof was retrieved

func NewQueryPacketAcknowledgementResponse 

func NewQueryPacketAcknowledgementResponse(
	acknowledgement []byte, proof []byte, height clienttypes.Height,
) *QueryPacketAcknowledgementResponse

NewQueryPacketAcknowledgementResponse creates a new QueryPacketAcknowledgementResponse instance

func (*QueryPacketAcknowledgementResponse) Descriptor 

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

func (*QueryPacketAcknowledgementResponse) GetAcknowledgement 

func (m *QueryPacketAcknowledgementResponse) GetAcknowledgement() []byte

func (*QueryPacketAcknowledgementResponse) GetProof 

func (m *QueryPacketAcknowledgementResponse) GetProof() []byte

func (*QueryPacketAcknowledgementResponse) GetProofHeight 

func (m *QueryPacketAcknowledgementResponse) GetProofHeight() types.Height

func (*QueryPacketAcknowledgementResponse) Marshal 

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

func (*QueryPacketAcknowledgementResponse) MarshalTo 

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

func (*QueryPacketAcknowledgementResponse) MarshalToSizedBuffer 

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

func (*QueryPacketAcknowledgementResponse) ProtoMessage 

func (*QueryPacketAcknowledgementResponse) ProtoMessage()

func (*QueryPacketAcknowledgementResponse) Reset 

func (m *QueryPacketAcknowledgementResponse) Reset()

func (*QueryPacketAcknowledgementResponse) Size 

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

func (*QueryPacketAcknowledgementResponse) String 

func (m *QueryPacketAcknowledgementResponse) String() string

func (*QueryPacketAcknowledgementResponse) Unmarshal 

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

func (*QueryPacketAcknowledgementResponse) XXX_DiscardUnknown 

func (m *QueryPacketAcknowledgementResponse) XXX_DiscardUnknown()

func (*QueryPacketAcknowledgementResponse) XXX_Marshal 

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

func (*QueryPacketAcknowledgementResponse) XXX_Merge 

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

func (*QueryPacketAcknowledgementResponse) XXX_Size 

func (m *QueryPacketAcknowledgementResponse) XXX_Size() int

func (*QueryPacketAcknowledgementResponse) XXX_Unmarshal 

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

type QueryPacketAcknowledgementsRequest 

type QueryPacketAcknowledgementsRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// pagination request
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPacketAcknowledgementsRequest is the request type for the Query/QueryPacketCommitments RPC method

func (*QueryPacketAcknowledgementsRequest) Descriptor 

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

func (*QueryPacketAcknowledgementsRequest) GetDestChain 

func (m *QueryPacketAcknowledgementsRequest) GetDestChain() string

func (*QueryPacketAcknowledgementsRequest) GetPagination 

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

func (*QueryPacketAcknowledgementsRequest) GetSourceChain 

func (m *QueryPacketAcknowledgementsRequest) GetSourceChain() string

func (*QueryPacketAcknowledgementsRequest) Marshal 

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

func (*QueryPacketAcknowledgementsRequest) MarshalTo 

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

func (*QueryPacketAcknowledgementsRequest) MarshalToSizedBuffer 

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

func (*QueryPacketAcknowledgementsRequest) ProtoMessage 

func (*QueryPacketAcknowledgementsRequest) ProtoMessage()

func (*QueryPacketAcknowledgementsRequest) Reset 

func (m *QueryPacketAcknowledgementsRequest) Reset()

func (*QueryPacketAcknowledgementsRequest) Size 

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

func (*QueryPacketAcknowledgementsRequest) String 

func (m *QueryPacketAcknowledgementsRequest) String() string

func (*QueryPacketAcknowledgementsRequest) Unmarshal 

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

func (*QueryPacketAcknowledgementsRequest) XXX_DiscardUnknown 

func (m *QueryPacketAcknowledgementsRequest) XXX_DiscardUnknown()

func (*QueryPacketAcknowledgementsRequest) XXX_Marshal 

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

func (*QueryPacketAcknowledgementsRequest) XXX_Merge 

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

func (*QueryPacketAcknowledgementsRequest) XXX_Size 

func (m *QueryPacketAcknowledgementsRequest) XXX_Size() int

func (*QueryPacketAcknowledgementsRequest) XXX_Unmarshal 

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

type QueryPacketAcknowledgementsResponse 

type QueryPacketAcknowledgementsResponse struct {
	Acknowledgements []*PacketState `protobuf:"bytes,1,rep,name=acknowledgements,proto3" json:"acknowledgements,omitempty"`
	// pagination response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// query block height
	Height types.Height `protobuf:"bytes,3,opt,name=height,proto3" json:"height"`
}

QueryPacketAcknowledgemetsResponse is the request type for the Query/QueryPacketAcknowledgements RPC method

func (*QueryPacketAcknowledgementsResponse) Descriptor 

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

func (*QueryPacketAcknowledgementsResponse) GetAcknowledgements 

func (m *QueryPacketAcknowledgementsResponse) GetAcknowledgements() []*PacketState

func (*QueryPacketAcknowledgementsResponse) GetHeight 

func (m *QueryPacketAcknowledgementsResponse) GetHeight() types.Height

func (*QueryPacketAcknowledgementsResponse) GetPagination 

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

func (*QueryPacketAcknowledgementsResponse) Marshal 

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

func (*QueryPacketAcknowledgementsResponse) MarshalTo 

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

func (*QueryPacketAcknowledgementsResponse) MarshalToSizedBuffer 

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

func (*QueryPacketAcknowledgementsResponse) ProtoMessage 

func (*QueryPacketAcknowledgementsResponse) ProtoMessage()

func (*QueryPacketAcknowledgementsResponse) Reset 

func (m *QueryPacketAcknowledgementsResponse) Reset()

func (*QueryPacketAcknowledgementsResponse) Size 

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

func (*QueryPacketAcknowledgementsResponse) String 

func (m *QueryPacketAcknowledgementsResponse) String() string

func (*QueryPacketAcknowledgementsResponse) Unmarshal 

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

func (*QueryPacketAcknowledgementsResponse) XXX_DiscardUnknown 

func (m *QueryPacketAcknowledgementsResponse) XXX_DiscardUnknown()

func (*QueryPacketAcknowledgementsResponse) XXX_Marshal 

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

func (*QueryPacketAcknowledgementsResponse) XXX_Merge 

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

func (*QueryPacketAcknowledgementsResponse) XXX_Size 

func (m *QueryPacketAcknowledgementsResponse) XXX_Size() int

func (*QueryPacketAcknowledgementsResponse) XXX_Unmarshal 

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

type QueryPacketCommitmentRequest 

type QueryPacketCommitmentRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// packet sequence
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

QueryPacketCommitmentRequest is the request type for the QueryPacketCommitment RPC method

func (*QueryPacketCommitmentRequest) Descriptor 

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

func (*QueryPacketCommitmentRequest) GetDestChain 

func (m *QueryPacketCommitmentRequest) GetDestChain() string

func (*QueryPacketCommitmentRequest) GetSequence 

func (m *QueryPacketCommitmentRequest) GetSequence() uint64

func (*QueryPacketCommitmentRequest) GetSourceChain 

func (m *QueryPacketCommitmentRequest) GetSourceChain() string

func (*QueryPacketCommitmentRequest) Marshal 

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

func (*QueryPacketCommitmentRequest) MarshalTo 

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

func (*QueryPacketCommitmentRequest) MarshalToSizedBuffer 

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

func (*QueryPacketCommitmentRequest) ProtoMessage 

func (*QueryPacketCommitmentRequest) ProtoMessage()

func (*QueryPacketCommitmentRequest) Reset 

func (m *QueryPacketCommitmentRequest) Reset()

func (*QueryPacketCommitmentRequest) Size 

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

func (*QueryPacketCommitmentRequest) String 

func (m *QueryPacketCommitmentRequest) String() string

func (*QueryPacketCommitmentRequest) Unmarshal 

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

func (*QueryPacketCommitmentRequest) XXX_DiscardUnknown 

func (m *QueryPacketCommitmentRequest) XXX_DiscardUnknown()

func (*QueryPacketCommitmentRequest) XXX_Marshal 

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

func (*QueryPacketCommitmentRequest) XXX_Merge 

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

func (*QueryPacketCommitmentRequest) XXX_Size 

func (m *QueryPacketCommitmentRequest) XXX_Size() int

func (*QueryPacketCommitmentRequest) XXX_Unmarshal 

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

type QueryPacketCommitmentResponse 

type QueryPacketCommitmentResponse struct {
	// packet associated with the request fields
	Commitment []byte `protobuf:"bytes,1,opt,name=commitment,proto3" json:"commitment,omitempty"`
	// merkle proof of existence
	Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
	// height at which the proof was retrieved
	ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

QueryPacketCommitmentResponse defines the client query response for a packet which also includes a proof and the height from which the proof was retrieved

func NewQueryPacketCommitmentResponse 

func NewQueryPacketCommitmentResponse(
	commitment []byte, proof []byte, height clienttypes.Height,
) *QueryPacketCommitmentResponse

NewQueryPacketCommitmentResponse creates a new QueryPacketCommitmentResponse instance

func (*QueryPacketCommitmentResponse) Descriptor 

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

func (*QueryPacketCommitmentResponse) GetCommitment 

func (m *QueryPacketCommitmentResponse) GetCommitment() []byte

func (*QueryPacketCommitmentResponse) GetProof 

func (m *QueryPacketCommitmentResponse) GetProof() []byte

func (*QueryPacketCommitmentResponse) GetProofHeight 

func (m *QueryPacketCommitmentResponse) GetProofHeight() types.Height

func (*QueryPacketCommitmentResponse) Marshal 

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

func (*QueryPacketCommitmentResponse) MarshalTo 

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

func (*QueryPacketCommitmentResponse) MarshalToSizedBuffer 

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

func (*QueryPacketCommitmentResponse) ProtoMessage 

func (*QueryPacketCommitmentResponse) ProtoMessage()

func (*QueryPacketCommitmentResponse) Reset 

func (m *QueryPacketCommitmentResponse) Reset()

func (*QueryPacketCommitmentResponse) Size 

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

func (*QueryPacketCommitmentResponse) String 

func (m *QueryPacketCommitmentResponse) String() string

func (*QueryPacketCommitmentResponse) Unmarshal 

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

func (*QueryPacketCommitmentResponse) XXX_DiscardUnknown 

func (m *QueryPacketCommitmentResponse) XXX_DiscardUnknown()

func (*QueryPacketCommitmentResponse) XXX_Marshal 

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

func (*QueryPacketCommitmentResponse) XXX_Merge 

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

func (*QueryPacketCommitmentResponse) XXX_Size 

func (m *QueryPacketCommitmentResponse) XXX_Size() int

func (*QueryPacketCommitmentResponse) XXX_Unmarshal 

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

type QueryPacketCommitmentsRequest 

type QueryPacketCommitmentsRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// pagination request
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPacketCommitmentsRequest is the request type for the Query/QueryPacketCommitments RPC method

func (*QueryPacketCommitmentsRequest) Descriptor 

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

func (*QueryPacketCommitmentsRequest) GetDestChain 

func (m *QueryPacketCommitmentsRequest) GetDestChain() string

func (*QueryPacketCommitmentsRequest) GetPagination 

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

func (*QueryPacketCommitmentsRequest) GetSourceChain 

func (m *QueryPacketCommitmentsRequest) GetSourceChain() string

func (*QueryPacketCommitmentsRequest) Marshal 

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

func (*QueryPacketCommitmentsRequest) MarshalTo 

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

func (*QueryPacketCommitmentsRequest) MarshalToSizedBuffer 

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

func (*QueryPacketCommitmentsRequest) ProtoMessage 

func (*QueryPacketCommitmentsRequest) ProtoMessage()

func (*QueryPacketCommitmentsRequest) Reset 

func (m *QueryPacketCommitmentsRequest) Reset()

func (*QueryPacketCommitmentsRequest) Size 

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

func (*QueryPacketCommitmentsRequest) String 

func (m *QueryPacketCommitmentsRequest) String() string

func (*QueryPacketCommitmentsRequest) Unmarshal 

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

func (*QueryPacketCommitmentsRequest) XXX_DiscardUnknown 

func (m *QueryPacketCommitmentsRequest) XXX_DiscardUnknown()

func (*QueryPacketCommitmentsRequest) XXX_Marshal 

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

func (*QueryPacketCommitmentsRequest) XXX_Merge 

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

func (*QueryPacketCommitmentsRequest) XXX_Size 

func (m *QueryPacketCommitmentsRequest) XXX_Size() int

func (*QueryPacketCommitmentsRequest) XXX_Unmarshal 

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

type QueryPacketCommitmentsResponse 

type QueryPacketCommitmentsResponse struct {
	Commitments []*PacketState `protobuf:"bytes,1,rep,name=commitments,proto3" json:"commitments,omitempty"`
	// pagination response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// query block height
	Height types.Height `protobuf:"bytes,3,opt,name=height,proto3" json:"height"`
}

QueryPacketCommitmentsResponse is the request type for the Query/QueryPacketCommitments RPC method

func (*QueryPacketCommitmentsResponse) Descriptor 

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

func (*QueryPacketCommitmentsResponse) GetCommitments 

func (m *QueryPacketCommitmentsResponse) GetCommitments() []*PacketState

func (*QueryPacketCommitmentsResponse) GetHeight 

func (m *QueryPacketCommitmentsResponse) GetHeight() types.Height

func (*QueryPacketCommitmentsResponse) GetPagination 

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

func (*QueryPacketCommitmentsResponse) Marshal 

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

func (*QueryPacketCommitmentsResponse) MarshalTo 

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

func (*QueryPacketCommitmentsResponse) MarshalToSizedBuffer 

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

func (*QueryPacketCommitmentsResponse) ProtoMessage 

func (*QueryPacketCommitmentsResponse) ProtoMessage()

func (*QueryPacketCommitmentsResponse) Reset 

func (m *QueryPacketCommitmentsResponse) Reset()

func (*QueryPacketCommitmentsResponse) Size 

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

func (*QueryPacketCommitmentsResponse) String 

func (m *QueryPacketCommitmentsResponse) String() string

func (*QueryPacketCommitmentsResponse) Unmarshal 

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

func (*QueryPacketCommitmentsResponse) XXX_DiscardUnknown 

func (m *QueryPacketCommitmentsResponse) XXX_DiscardUnknown()

func (*QueryPacketCommitmentsResponse) XXX_Marshal 

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

func (*QueryPacketCommitmentsResponse) XXX_Merge 

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

func (*QueryPacketCommitmentsResponse) XXX_Size 

func (m *QueryPacketCommitmentsResponse) XXX_Size() int

func (*QueryPacketCommitmentsResponse) XXX_Unmarshal 

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

type QueryPacketReceiptRequest 

type QueryPacketReceiptRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// packet sequence
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

QueryPacketReceiptRequest is the request type for the Query/PacketReceipt RPC method

func (*QueryPacketReceiptRequest) Descriptor 

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

func (*QueryPacketReceiptRequest) GetDestChain 

func (m *QueryPacketReceiptRequest) GetDestChain() string

func (*QueryPacketReceiptRequest) GetSequence 

func (m *QueryPacketReceiptRequest) GetSequence() uint64

func (*QueryPacketReceiptRequest) GetSourceChain 

func (m *QueryPacketReceiptRequest) GetSourceChain() string

func (*QueryPacketReceiptRequest) Marshal 

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

func (*QueryPacketReceiptRequest) MarshalTo 

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

func (*QueryPacketReceiptRequest) MarshalToSizedBuffer 

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

func (*QueryPacketReceiptRequest) ProtoMessage 

func (*QueryPacketReceiptRequest) ProtoMessage()

func (*QueryPacketReceiptRequest) Reset 

func (m *QueryPacketReceiptRequest) Reset()

func (*QueryPacketReceiptRequest) Size 

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

func (*QueryPacketReceiptRequest) String 

func (m *QueryPacketReceiptRequest) String() string

func (*QueryPacketReceiptRequest) Unmarshal 

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

func (*QueryPacketReceiptRequest) XXX_DiscardUnknown 

func (m *QueryPacketReceiptRequest) XXX_DiscardUnknown()

func (*QueryPacketReceiptRequest) XXX_Marshal 

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

func (*QueryPacketReceiptRequest) XXX_Merge 

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

func (*QueryPacketReceiptRequest) XXX_Size 

func (m *QueryPacketReceiptRequest) XXX_Size() int

func (*QueryPacketReceiptRequest) XXX_Unmarshal 

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

type QueryPacketReceiptResponse 

type QueryPacketReceiptResponse struct {
	// success flag for if receipt exists
	Received bool `protobuf:"varint,1,opt,name=received,proto3" json:"received,omitempty"`
	// merkle proof of existence
	Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
	// height at which the proof was retrieved
	ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

QueryPacketReceiptResponse defines the client query response for a packet receipt which also includes a proof, and the height from which the proof was retrieved

func NewQueryPacketReceiptResponse 

func NewQueryPacketReceiptResponse(
	recvd bool, proof []byte, height clienttypes.Height,
) *QueryPacketReceiptResponse

NewQueryPacketReceiptResponse creates a new QueryPacketReceiptResponse instance

func (*QueryPacketReceiptResponse) Descriptor 

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

func (*QueryPacketReceiptResponse) GetProof 

func (m *QueryPacketReceiptResponse) GetProof() []byte

func (*QueryPacketReceiptResponse) GetProofHeight 

func (m *QueryPacketReceiptResponse) GetProofHeight() types.Height

func (*QueryPacketReceiptResponse) GetReceived 

func (m *QueryPacketReceiptResponse) GetReceived() bool

func (*QueryPacketReceiptResponse) Marshal 

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

func (*QueryPacketReceiptResponse) MarshalTo 

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

func (*QueryPacketReceiptResponse) MarshalToSizedBuffer 

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

func (*QueryPacketReceiptResponse) ProtoMessage 

func (*QueryPacketReceiptResponse) ProtoMessage()

func (*QueryPacketReceiptResponse) Reset 

func (m *QueryPacketReceiptResponse) Reset()

func (*QueryPacketReceiptResponse) Size 

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

func (*QueryPacketReceiptResponse) String 

func (m *QueryPacketReceiptResponse) String() string

func (*QueryPacketReceiptResponse) Unmarshal 

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

func (*QueryPacketReceiptResponse) XXX_DiscardUnknown 

func (m *QueryPacketReceiptResponse) XXX_DiscardUnknown()

func (*QueryPacketReceiptResponse) XXX_Marshal 

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

func (*QueryPacketReceiptResponse) XXX_Merge 

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

func (*QueryPacketReceiptResponse) XXX_Size 

func (m *QueryPacketReceiptResponse) XXX_Size() int

func (*QueryPacketReceiptResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// PacketCommitment queries a stored packet commitment hash.
	PacketCommitment(context.Context, *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)
	// PacketCommitments returns all the packet commitments hashes associated
	PacketCommitments(context.Context, *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)
	// PacketReceipt queries if a given packet sequence has been received on the
	// queried chain
	PacketReceipt(context.Context, *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error)
	// PacketAcknowledgement queries a stored packet acknowledgement hash.
	PacketAcknowledgement(context.Context, *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error)
	// PacketAcknowledgements returns all the packet acknowledgements associated
	PacketAcknowledgements(context.Context, *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error)
	// UnreceivedPackets returns all the unreceived XIBC packets associated with
	// sequences.
	UnreceivedPackets(context.Context, *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error)
	// UnreceivedAcks returns all the unreceived XIBC acknowledgements associated
	// with sequences.
	UnreceivedAcks(context.Context, *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error)
}

QueryServer is the server API for Query service.

type QueryUnreceivedAcksRequest 

type QueryUnreceivedAcksRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// list of acknowledgement sequences
	PacketAckSequences []uint64 `protobuf:"varint,3,rep,packed,name=packet_ack_sequences,json=packetAckSequences,proto3" json:"packet_ack_sequences,omitempty"`
}

QueryUnreceivedAcks is the request type for the Query/UnreceivedAcks RPC method

func (*QueryUnreceivedAcksRequest) Descriptor 

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

func (*QueryUnreceivedAcksRequest) GetDestChain 

func (m *QueryUnreceivedAcksRequest) GetDestChain() string

func (*QueryUnreceivedAcksRequest) GetPacketAckSequences 

func (m *QueryUnreceivedAcksRequest) GetPacketAckSequences() []uint64

func (*QueryUnreceivedAcksRequest) GetSourceChain 

func (m *QueryUnreceivedAcksRequest) GetSourceChain() string

func (*QueryUnreceivedAcksRequest) Marshal 

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

func (*QueryUnreceivedAcksRequest) MarshalTo 

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

func (*QueryUnreceivedAcksRequest) MarshalToSizedBuffer 

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

func (*QueryUnreceivedAcksRequest) ProtoMessage 

func (*QueryUnreceivedAcksRequest) ProtoMessage()

func (*QueryUnreceivedAcksRequest) Reset 

func (m *QueryUnreceivedAcksRequest) Reset()

func (*QueryUnreceivedAcksRequest) Size 

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

func (*QueryUnreceivedAcksRequest) String 

func (m *QueryUnreceivedAcksRequest) String() string

func (*QueryUnreceivedAcksRequest) Unmarshal 

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

func (*QueryUnreceivedAcksRequest) XXX_DiscardUnknown 

func (m *QueryUnreceivedAcksRequest) XXX_DiscardUnknown()

func (*QueryUnreceivedAcksRequest) XXX_Marshal 

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

func (*QueryUnreceivedAcksRequest) XXX_Merge 

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

func (*QueryUnreceivedAcksRequest) XXX_Size 

func (m *QueryUnreceivedAcksRequest) XXX_Size() int

func (*QueryUnreceivedAcksRequest) XXX_Unmarshal 

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

type QueryUnreceivedAcksResponse 

type QueryUnreceivedAcksResponse struct {
	// list of unreceived acknowledgement sequences
	Sequences []uint64 `protobuf:"varint,1,rep,packed,name=sequences,proto3" json:"sequences,omitempty"`
	// query block height
	Height types.Height `protobuf:"bytes,2,opt,name=height,proto3" json:"height"`
}

QueryUnreceivedAcksResponse is the response type for the Query/UnreceivedAcks RPC method

func (*QueryUnreceivedAcksResponse) Descriptor 

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

func (*QueryUnreceivedAcksResponse) GetHeight 

func (m *QueryUnreceivedAcksResponse) GetHeight() types.Height

func (*QueryUnreceivedAcksResponse) GetSequences 

func (m *QueryUnreceivedAcksResponse) GetSequences() []uint64

func (*QueryUnreceivedAcksResponse) Marshal 

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

func (*QueryUnreceivedAcksResponse) MarshalTo 

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

func (*QueryUnreceivedAcksResponse) MarshalToSizedBuffer 

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

func (*QueryUnreceivedAcksResponse) ProtoMessage 

func (*QueryUnreceivedAcksResponse) ProtoMessage()

func (*QueryUnreceivedAcksResponse) Reset 

func (m *QueryUnreceivedAcksResponse) Reset()

func (*QueryUnreceivedAcksResponse) Size 

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

func (*QueryUnreceivedAcksResponse) String 

func (m *QueryUnreceivedAcksResponse) String() string

func (*QueryUnreceivedAcksResponse) Unmarshal 

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

func (*QueryUnreceivedAcksResponse) XXX_DiscardUnknown 

func (m *QueryUnreceivedAcksResponse) XXX_DiscardUnknown()

func (*QueryUnreceivedAcksResponse) XXX_Marshal 

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

func (*QueryUnreceivedAcksResponse) XXX_Merge 

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

func (*QueryUnreceivedAcksResponse) XXX_Size 

func (m *QueryUnreceivedAcksResponse) XXX_Size() int

func (*QueryUnreceivedAcksResponse) XXX_Unmarshal 

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

type QueryUnreceivedPacketsRequest 

type QueryUnreceivedPacketsRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// list of packet sequences
	PacketCommitmentSequences []uint64 `` /* 146-byte string literal not displayed */
}

QueryUnreceivedPacketsRequest is the request type for the Query/UnreceivedPackets RPC method

func (*QueryUnreceivedPacketsRequest) Descriptor 

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

func (*QueryUnreceivedPacketsRequest) GetDestChain 

func (m *QueryUnreceivedPacketsRequest) GetDestChain() string

func (*QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences 

func (m *QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences() []uint64

func (*QueryUnreceivedPacketsRequest) GetSourceChain 

func (m *QueryUnreceivedPacketsRequest) GetSourceChain() string

func (*QueryUnreceivedPacketsRequest) Marshal 

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

func (*QueryUnreceivedPacketsRequest) MarshalTo 

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

func (*QueryUnreceivedPacketsRequest) MarshalToSizedBuffer 

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

func (*QueryUnreceivedPacketsRequest) ProtoMessage 

func (*QueryUnreceivedPacketsRequest) ProtoMessage()

func (*QueryUnreceivedPacketsRequest) Reset 

func (m *QueryUnreceivedPacketsRequest) Reset()

func (*QueryUnreceivedPacketsRequest) Size 

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

func (*QueryUnreceivedPacketsRequest) String 

func (m *QueryUnreceivedPacketsRequest) String() string

func (*QueryUnreceivedPacketsRequest) Unmarshal 

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

func (*QueryUnreceivedPacketsRequest) XXX_DiscardUnknown 

func (m *QueryUnreceivedPacketsRequest) XXX_DiscardUnknown()

func (*QueryUnreceivedPacketsRequest) XXX_Marshal 

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

func (*QueryUnreceivedPacketsRequest) XXX_Merge 

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

func (*QueryUnreceivedPacketsRequest) XXX_Size 

func (m *QueryUnreceivedPacketsRequest) XXX_Size() int

func (*QueryUnreceivedPacketsRequest) XXX_Unmarshal 

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

type QueryUnreceivedPacketsResponse 

type QueryUnreceivedPacketsResponse struct {
	// list of unreceived packet sequences
	Sequences []uint64 `protobuf:"varint,1,rep,packed,name=sequences,proto3" json:"sequences,omitempty"`
	// query block height
	Height types.Height `protobuf:"bytes,2,opt,name=height,proto3" json:"height"`
}

QueryUnreceivedPacketsResponse is the response type for the Query/UnreceivedPacketCommitments RPC method

func (*QueryUnreceivedPacketsResponse) Descriptor 

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

func (*QueryUnreceivedPacketsResponse) GetHeight 

func (m *QueryUnreceivedPacketsResponse) GetHeight() types.Height

func (*QueryUnreceivedPacketsResponse) GetSequences 

func (m *QueryUnreceivedPacketsResponse) GetSequences() []uint64

func (*QueryUnreceivedPacketsResponse) Marshal 

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

func (*QueryUnreceivedPacketsResponse) MarshalTo 

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

func (*QueryUnreceivedPacketsResponse) MarshalToSizedBuffer 

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

func (*QueryUnreceivedPacketsResponse) ProtoMessage 

func (*QueryUnreceivedPacketsResponse) ProtoMessage()

func (*QueryUnreceivedPacketsResponse) Reset 

func (m *QueryUnreceivedPacketsResponse) Reset()

func (*QueryUnreceivedPacketsResponse) Size 

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

func (*QueryUnreceivedPacketsResponse) String 

func (m *QueryUnreceivedPacketsResponse) String() string

func (*QueryUnreceivedPacketsResponse) Unmarshal 

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

func (*QueryUnreceivedPacketsResponse) XXX_DiscardUnknown 

func (m *QueryUnreceivedPacketsResponse) XXX_DiscardUnknown()

func (*QueryUnreceivedPacketsResponse) XXX_Marshal 

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

func (*QueryUnreceivedPacketsResponse) XXX_Merge 

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

func (*QueryUnreceivedPacketsResponse) XXX_Size 

func (m *QueryUnreceivedPacketsResponse) XXX_Size() int

func (*QueryUnreceivedPacketsResponse) XXX_Unmarshal 

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

type Result 

type Result struct {
	// the execution result
	Result []byte
	// error message
	Message string
}

Result is the execution result of packet data

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Acknowledgement 

func (*UnimplementedMsgServer) Acknowledgement(ctx context.Context, req *MsgAcknowledgement) (*MsgAcknowledgementResponse, error)

func (*UnimplementedMsgServer) RecvPacket 

func (*UnimplementedMsgServer) RecvPacket(ctx context.Context, req *MsgRecvPacket) (*MsgRecvPacketResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) PacketAcknowledgement 

func (*UnimplementedQueryServer) PacketAcknowledgement(ctx context.Context, req *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error)

func (*UnimplementedQueryServer) PacketAcknowledgements 

func (*UnimplementedQueryServer) PacketAcknowledgements(ctx context.Context, req *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error)

func (*UnimplementedQueryServer) PacketCommitment 

func (*UnimplementedQueryServer) PacketCommitment(ctx context.Context, req *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)

func (*UnimplementedQueryServer) PacketCommitments 

func (*UnimplementedQueryServer) PacketCommitments(ctx context.Context, req *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)

func (*UnimplementedQueryServer) PacketReceipt 

func (*UnimplementedQueryServer) PacketReceipt(ctx context.Context, req *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error)

func (*UnimplementedQueryServer) UnreceivedAcks 

func (*UnimplementedQueryServer) UnreceivedAcks(ctx context.Context, req *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error)

func (*UnimplementedQueryServer) UnreceivedPackets 

func (*UnimplementedQueryServer) UnreceivedPackets(ctx context.Context, req *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.