cosmos-sdk: github.com/cosmos/cosmos-sdk/x/ibc/03-connection/types Index | Files

package types

import "github.com/cosmos/cosmos-sdk/x/ibc/03-connection/types"

Index

Package Files

codec.go connection.go connection.pb.go errors.go events.go expected_keepers.go genesis.go genesis.pb.go keys.go msgs.go query.go query.pb.go version.go

Constants

const (
    AttributeKeyConnectionID             = "connection_id"
    AttributeKeyClientID                 = "client_id"
    AttributeKeyCounterpartyClientID     = "counterparty_client_id"
    AttributeKeyCounterpartyConnectionID = "counterparty_connection_id"
)

IBC connection events

const (
    // SubModuleName defines the IBC connection name
    SubModuleName = "connection"

    // StoreKey is the store key string for IBC connections
    StoreKey = SubModuleName

    // RouterKey is the message route for IBC connections
    RouterKey = SubModuleName

    // QuerierRoute is the querier route for IBC connections
    QuerierRoute = SubModuleName
)

Variables

var (
    ErrInvalidLengthConnection        = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowConnection          = fmt.Errorf("proto: integer overflow")
    ErrUnexpectedEndOfGroupConnection = fmt.Errorf("proto: unexpected end of group")
)
var (
    ErrConnectionExists              = sdkerrors.Register(SubModuleName, 2, "connection already exists")
    ErrConnectionNotFound            = sdkerrors.Register(SubModuleName, 3, "connection not found")
    ErrClientConnectionPathsNotFound = sdkerrors.Register(SubModuleName, 4, "light client connection paths not found")
    ErrConnectionPath                = sdkerrors.Register(SubModuleName, 5, "connection path is not associated to the given light client")
    ErrInvalidConnectionState        = sdkerrors.Register(SubModuleName, 6, "invalid connection state")
    ErrInvalidCounterparty           = sdkerrors.Register(SubModuleName, 7, "invalid counterparty connection")
    ErrInvalidConnection             = sdkerrors.Register(SubModuleName, 8, "invalid connection")
    ErrInvalidVersion                = sdkerrors.Register(SubModuleName, 9, "invalid connection version")
    ErrVersionNegotiationFailed      = sdkerrors.Register(SubModuleName, 10, "connection version negotiation failed")
)

IBC connection sentinel errors

var (
    EventTypeConnectionOpenInit    = MsgConnectionOpenInit{}.Type()
    EventTypeConnectionOpenTry     = MsgConnectionOpenTry{}.Type()
    EventTypeConnectionOpenAck     = MsgConnectionOpenAck{}.Type()
    EventTypeConnectionOpenConfirm = MsgConnectionOpenConfirm{}.Type()

    AttributeValueCategory = fmt.Sprintf("%s_%s", host.ModuleName, SubModuleName)
)

IBC connection events vars

var (
    ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
    ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
var (
    ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
    ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
var (
    // DefaultIBCVersion represents the latest supported version of IBC used
    // in connection version negotiation. The current version supports only
    // ORDERED and UNORDERED channels and requires at least one channel type
    // to be agreed upon.
    DefaultIBCVersion = NewVersion(DefaultIBCVersionIdentifier, []string{"ORDER_ORDERED", "ORDER_UNORDERED"})

    // DefaultIBCVersionIdentifier is the IBC v1.0.0 protocol version identifier
    DefaultIBCVersionIdentifier = "1"
)
var State_name = map[int32]string{
    0:  "STATE_UNINITIALIZED_UNSPECIFIED",
    1:  "STATE_INIT",
    2:  "STATE_TRYOPEN",
    3:  "STATE_OPEN",
}
var State_value = map[string]int32{
    "STATE_UNINITIALIZED_UNSPECIFIED": 0,
    "STATE_INIT":                      1,
    "STATE_TRYOPEN":                   2,
    "STATE_OPEN":                      3,
}
var (
    // SubModuleCdc references the global x/ibc/03-connection 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/03-connectionl and
    // defined at the application level.
    SubModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
)

func EncodeVersions Uses

func EncodeVersions(versions []Version) ([]string, error)

EncodeVersions iterates over the provided versions and marshals each into proto encoded strings. This represents the stored value of the version in the connection end as well as the value passed over the wire.

func GetCompatibleEncodedVersions Uses

func GetCompatibleEncodedVersions() []string

GetCompatibleEncodedVersions returns the return value from GetCompatibleVersions as a proto encoded string.

func GetFeatureSetIntersection Uses

func GetFeatureSetIntersection(sourceFeatureSet, counterpartyFeatureSet []string) (featureSet []string)

GetFeatureSetIntersection returns the intersections of source feature set and the counterparty feature set. This is done by iterating over all the features in the source version and seeing if they exist in the feature set for the counterparty version.

func PickVersion Uses

func PickVersion(encodedCounterpartyVersions []string) (string, error)

PickVersion iterates over the descending ordered set of compatible IBC versions and selects the first version with a version identifier that is supported by the counterparty. The returned version contains a feature set with the intersection of the features supported by the source and counterparty chains. If the feature set intersection is nil and this is not allowed for the chosen version identifier then the search for a compatible version continues. This function is called in the ConnOpenTry handshake procedure.

func RegisterInterfaces Uses

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the ibc interfaces submodule implementations to protobuf Any.

func RegisterQueryServer Uses

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateVersion Uses

func ValidateVersion(encodedVersion string) error

ValidateVersion does basic validation of the version identifier and features. It unmarshals the version string into a Version object.

func VerifySupportedFeature Uses

func VerifySupportedFeature(encodedVersion, feature string) bool

VerifySupportedFeature takes in a version and feature string and returns true if the feature is supported by the version and false otherwise.

type ClientKeeper Uses

type ClientKeeper interface {
    GetClientState(ctx sdk.Context, clientID string) (clientexported.ClientState, bool)
    GetClientConsensusState(ctx sdk.Context, clientID string, height uint64) (clientexported.ConsensusState, bool)
    GetSelfConsensusState(ctx sdk.Context, height uint64) (clientexported.ConsensusState, bool)
    IterateClients(ctx sdk.Context, cb func(string, clientexported.ClientState) bool)
    ClientStore(ctx sdk.Context, clientID string) sdk.KVStore
}

ClientKeeper expected account IBC client keeper

type ClientPaths Uses

type ClientPaths struct {
    // list of connection paths
    Paths []string `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
}

ClientPaths define all the connection paths for a client state.

func (*ClientPaths) Descriptor Uses

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

func (*ClientPaths) GetPaths Uses

func (m *ClientPaths) GetPaths() []string

func (*ClientPaths) Marshal Uses

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

func (*ClientPaths) MarshalTo Uses

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

func (*ClientPaths) MarshalToSizedBuffer Uses

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

func (*ClientPaths) ProtoMessage Uses

func (*ClientPaths) ProtoMessage()

func (*ClientPaths) Reset Uses

func (m *ClientPaths) Reset()

func (*ClientPaths) Size Uses

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

func (*ClientPaths) String Uses

func (m *ClientPaths) String() string

func (*ClientPaths) Unmarshal Uses

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

func (*ClientPaths) XXX_DiscardUnknown Uses

func (m *ClientPaths) XXX_DiscardUnknown()

func (*ClientPaths) XXX_Marshal Uses

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

func (*ClientPaths) XXX_Merge Uses

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

func (*ClientPaths) XXX_Size Uses

func (m *ClientPaths) XXX_Size() int

func (*ClientPaths) XXX_Unmarshal Uses

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

type ConnectionEnd Uses

type ConnectionEnd struct {
    // client associated with this connection.
    ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" yaml:"client_id"`
    // IBC version which can be utilised to determine encodings or protocols for
    // channels or packets utilising this connection
    Versions []string `protobuf:"bytes,2,rep,name=versions,proto3" json:"versions,omitempty"`
    // current state of the connection end.
    State State `protobuf:"varint,3,opt,name=state,proto3,enum=ibc.connection.State" json:"state,omitempty"`
    // counterparty chain associated with this connection.
    Counterparty Counterparty `protobuf:"bytes,4,opt,name=counterparty,proto3" json:"counterparty"`
}

ConnectionEnd defines a stateful object on a chain connected to another separate one. NOTE: there must only be 2 defined ConnectionEnds to establish a connection between two chains.

func NewConnectionEnd Uses

func NewConnectionEnd(state State, clientID string, counterparty Counterparty, versions []string) ConnectionEnd

NewConnectionEnd creates a new ConnectionEnd instance.

func (*ConnectionEnd) Descriptor Uses

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

func (ConnectionEnd) GetClientID Uses

func (c ConnectionEnd) GetClientID() string

GetClientID implements the Connection interface

func (ConnectionEnd) GetCounterparty Uses

func (c ConnectionEnd) GetCounterparty() exported.CounterpartyI

GetCounterparty implements the Connection interface

func (ConnectionEnd) GetState Uses

func (c ConnectionEnd) GetState() int32

GetState implements the Connection interface

func (ConnectionEnd) GetVersions Uses

func (c ConnectionEnd) GetVersions() []string

GetVersions implements the Connection interface

func (*ConnectionEnd) Marshal Uses

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

func (*ConnectionEnd) MarshalTo Uses

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

func (*ConnectionEnd) MarshalToSizedBuffer Uses

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

func (*ConnectionEnd) ProtoMessage Uses

func (*ConnectionEnd) ProtoMessage()

func (*ConnectionEnd) Reset Uses

func (m *ConnectionEnd) Reset()

func (*ConnectionEnd) Size Uses

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

func (*ConnectionEnd) String Uses

func (m *ConnectionEnd) String() string

func (*ConnectionEnd) Unmarshal Uses

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

func (ConnectionEnd) ValidateBasic Uses

func (c ConnectionEnd) ValidateBasic() error

ValidateBasic implements the Connection interface. NOTE: the protocol supports that the connection and client IDs match the counterparty's.

func (*ConnectionEnd) XXX_DiscardUnknown Uses

func (m *ConnectionEnd) XXX_DiscardUnknown()

func (*ConnectionEnd) XXX_Marshal Uses

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

func (*ConnectionEnd) XXX_Merge Uses

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

func (*ConnectionEnd) XXX_Size Uses

func (m *ConnectionEnd) XXX_Size() int

func (*ConnectionEnd) XXX_Unmarshal Uses

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

type ConnectionPaths Uses

type ConnectionPaths struct {
    // client state unique identifier
    ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" yaml:"client_id"`
    // list of connection paths
    Paths []string `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"`
}

ConnectionPaths define all the connection paths for a given client state.

func NewConnectionPaths Uses

func NewConnectionPaths(id string, paths []string) ConnectionPaths

NewConnectionPaths creates a ConnectionPaths instance.

func (*ConnectionPaths) Descriptor Uses

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

func (*ConnectionPaths) GetClientID Uses

func (m *ConnectionPaths) GetClientID() string

func (*ConnectionPaths) GetPaths Uses

func (m *ConnectionPaths) GetPaths() []string

func (*ConnectionPaths) Marshal Uses

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

func (*ConnectionPaths) MarshalTo Uses

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

func (*ConnectionPaths) MarshalToSizedBuffer Uses

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

func (*ConnectionPaths) ProtoMessage Uses

func (*ConnectionPaths) ProtoMessage()

func (*ConnectionPaths) Reset Uses

func (m *ConnectionPaths) Reset()

func (*ConnectionPaths) Size Uses

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

func (*ConnectionPaths) String Uses

func (m *ConnectionPaths) String() string

func (*ConnectionPaths) Unmarshal Uses

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

func (*ConnectionPaths) XXX_DiscardUnknown Uses

func (m *ConnectionPaths) XXX_DiscardUnknown()

func (*ConnectionPaths) XXX_Marshal Uses

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

func (*ConnectionPaths) XXX_Merge Uses

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

func (*ConnectionPaths) XXX_Size Uses

func (m *ConnectionPaths) XXX_Size() int

func (*ConnectionPaths) XXX_Unmarshal Uses

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

type Counterparty Uses

type Counterparty struct {
    // identifies the client on the counterparty chain associated with a given
    // connection.
    ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" yaml:"client_id"`
    // identifies the connection end on the counterparty chain associated with a
    // given connection.
    ConnectionID string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" yaml:"connection_id"`
    // commitment merkle prefix of the counterparty chain
    Prefix types.MerklePrefix `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix"`
}

Counterparty defines the counterparty chain associated with a connection end.

func NewCounterparty Uses

func NewCounterparty(clientID, connectionID string, prefix commitmenttypes.MerklePrefix) Counterparty

NewCounterparty creates a new Counterparty instance.

func (*Counterparty) Descriptor Uses

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

func (Counterparty) GetClientID Uses

func (c Counterparty) GetClientID() string

GetClientID implements the CounterpartyI interface

func (Counterparty) GetConnectionID Uses

func (c Counterparty) GetConnectionID() string

GetConnectionID implements the CounterpartyI interface

func (Counterparty) GetPrefix Uses

func (c Counterparty) GetPrefix() commitmentexported.Prefix

GetPrefix implements the CounterpartyI interface

func (*Counterparty) Marshal Uses

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

func (*Counterparty) MarshalTo Uses

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

func (*Counterparty) MarshalToSizedBuffer Uses

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

func (*Counterparty) ProtoMessage Uses

func (*Counterparty) ProtoMessage()

func (*Counterparty) Reset Uses

func (m *Counterparty) Reset()

func (*Counterparty) Size Uses

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

func (*Counterparty) String Uses

func (m *Counterparty) String() string

func (*Counterparty) Unmarshal Uses

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

func (Counterparty) ValidateBasic Uses

func (c Counterparty) ValidateBasic() error

ValidateBasic performs a basic validation check of the identifiers and prefix

func (*Counterparty) XXX_DiscardUnknown Uses

func (m *Counterparty) XXX_DiscardUnknown()

func (*Counterparty) XXX_Marshal Uses

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

func (*Counterparty) XXX_Merge Uses

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

func (*Counterparty) XXX_Size Uses

func (m *Counterparty) XXX_Size() int

func (*Counterparty) XXX_Unmarshal Uses

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

type GenesisState Uses

type GenesisState struct {
    Connections           []IdentifiedConnection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections"`
    ClientConnectionPaths []ConnectionPaths      `protobuf:"bytes,2,rep,name=client_connection_paths,json=clientConnectionPaths,proto3" json:"client_connection_paths" yaml:"client_connection_paths"`
}

GenesisState defines the ibc connection submodule's genesis state.

func DefaultGenesisState Uses

func DefaultGenesisState() GenesisState

DefaultGenesisState returns the ibc connection submodule's default genesis state.

func NewGenesisState Uses

func NewGenesisState(
    connections []IdentifiedConnection, connPaths []ConnectionPaths,
) GenesisState

NewGenesisState creates a GenesisState instance.

func (*GenesisState) Descriptor Uses

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

func (*GenesisState) GetClientConnectionPaths Uses

func (m *GenesisState) GetClientConnectionPaths() []ConnectionPaths

func (*GenesisState) GetConnections Uses

func (m *GenesisState) GetConnections() []IdentifiedConnection

func (*GenesisState) Marshal Uses

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

func (*GenesisState) MarshalTo Uses

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

func (*GenesisState) MarshalToSizedBuffer Uses

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

func (*GenesisState) ProtoMessage Uses

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset Uses

func (m *GenesisState) Reset()

func (*GenesisState) Size Uses

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

func (*GenesisState) String Uses

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal Uses

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

func (GenesisState) Validate Uses

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown Uses

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal Uses

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

func (*GenesisState) XXX_Merge Uses

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

func (*GenesisState) XXX_Size Uses

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal Uses

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

type IdentifiedConnection Uses

type IdentifiedConnection struct {
    // connection identifier.
    ID  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
    // client associated with this connection.
    ClientID string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" yaml:"client_id"`
    // IBC version which can be utilised to determine encodings or protocols for
    // channels or packets utilising this connection
    Versions []string `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty"`
    // current state of the connection end.
    State State `protobuf:"varint,4,opt,name=state,proto3,enum=ibc.connection.State" json:"state,omitempty"`
    // counterparty chain associated with this connection.
    Counterparty Counterparty `protobuf:"bytes,5,opt,name=counterparty,proto3" json:"counterparty"`
}

IdentifiedConnection defines a connection with additional connection identifier field.

func NewIdentifiedConnection Uses

func NewIdentifiedConnection(connectionID string, conn ConnectionEnd) IdentifiedConnection

NewIdentifiedConnection creates a new IdentifiedConnection instance

func (*IdentifiedConnection) Descriptor Uses

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

func (*IdentifiedConnection) Marshal Uses

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

func (*IdentifiedConnection) MarshalTo Uses

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

func (*IdentifiedConnection) MarshalToSizedBuffer Uses

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

func (*IdentifiedConnection) ProtoMessage Uses

func (*IdentifiedConnection) ProtoMessage()

func (*IdentifiedConnection) Reset Uses

func (m *IdentifiedConnection) Reset()

func (*IdentifiedConnection) Size Uses

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

func (*IdentifiedConnection) String Uses

func (m *IdentifiedConnection) String() string

func (*IdentifiedConnection) Unmarshal Uses

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

func (IdentifiedConnection) ValidateBasic Uses

func (ic IdentifiedConnection) ValidateBasic() error

ValidateBasic performs a basic validation of the connection identifier and connection fields.

func (*IdentifiedConnection) XXX_DiscardUnknown Uses

func (m *IdentifiedConnection) XXX_DiscardUnknown()

func (*IdentifiedConnection) XXX_Marshal Uses

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

func (*IdentifiedConnection) XXX_Merge Uses

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

func (*IdentifiedConnection) XXX_Size Uses

func (m *IdentifiedConnection) XXX_Size() int

func (*IdentifiedConnection) XXX_Unmarshal Uses

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

type MsgConnectionOpenAck Uses

type MsgConnectionOpenAck struct {
    ConnectionID string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" yaml:"connection_id"`
    Version      string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
    // proof of the initialization the connection on Chain B: `UNITIALIZED ->
    // TRYOPEN`
    ProofTry    []byte `protobuf:"bytes,3,opt,name=proof_try,json=proofTry,proto3" json:"proof_try,omitempty" yaml:"proof_try"`
    ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"`
    // proof of client consensus state
    ProofConsensus  []byte                                        `protobuf:"bytes,5,opt,name=proof_consensus,json=proofConsensus,proto3" json:"proof_consensus,omitempty" yaml:"proof_consensus"`
    ConsensusHeight uint64                                        `protobuf:"varint,6,opt,name=consensus_height,json=consensusHeight,proto3" json:"consensus_height,omitempty" yaml:"consensus_height"`
    Signer          github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,7,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

MsgConnectionOpenAck defines a msg sent by a Relayer to Chain A to acknowledge the change of connection state to TRYOPEN on Chain B.

func NewMsgConnectionOpenAck Uses

func NewMsgConnectionOpenAck(
    connectionID string, proofTry, proofConsensus []byte,
    proofHeight, consensusHeight uint64, version string,
    signer sdk.AccAddress,
) *MsgConnectionOpenAck

NewMsgConnectionOpenAck creates a new MsgConnectionOpenAck instance

func (*MsgConnectionOpenAck) Descriptor Uses

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

func (*MsgConnectionOpenAck) GetConnectionID Uses

func (m *MsgConnectionOpenAck) GetConnectionID() string

func (*MsgConnectionOpenAck) GetConsensusHeight Uses

func (m *MsgConnectionOpenAck) GetConsensusHeight() uint64

func (*MsgConnectionOpenAck) GetProofConsensus Uses

func (m *MsgConnectionOpenAck) GetProofConsensus() []byte

func (*MsgConnectionOpenAck) GetProofHeight Uses

func (m *MsgConnectionOpenAck) GetProofHeight() uint64

func (*MsgConnectionOpenAck) GetProofTry Uses

func (m *MsgConnectionOpenAck) GetProofTry() []byte

func (MsgConnectionOpenAck) GetSignBytes Uses

func (msg MsgConnectionOpenAck) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (*MsgConnectionOpenAck) GetSigner Uses

func (m *MsgConnectionOpenAck) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgConnectionOpenAck) GetSigners Uses

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

GetSigners implements sdk.Msg

func (*MsgConnectionOpenAck) GetVersion Uses

func (m *MsgConnectionOpenAck) GetVersion() string

func (*MsgConnectionOpenAck) Marshal Uses

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

func (*MsgConnectionOpenAck) MarshalTo Uses

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

func (*MsgConnectionOpenAck) MarshalToSizedBuffer Uses

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

func (*MsgConnectionOpenAck) ProtoMessage Uses

func (*MsgConnectionOpenAck) ProtoMessage()

func (*MsgConnectionOpenAck) Reset Uses

func (m *MsgConnectionOpenAck) Reset()

func (MsgConnectionOpenAck) Route Uses

func (msg MsgConnectionOpenAck) Route() string

Route implements sdk.Msg

func (*MsgConnectionOpenAck) Size Uses

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

func (*MsgConnectionOpenAck) String Uses

func (m *MsgConnectionOpenAck) String() string

func (MsgConnectionOpenAck) Type Uses

func (msg MsgConnectionOpenAck) Type() string

Type implements sdk.Msg

func (*MsgConnectionOpenAck) Unmarshal Uses

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

func (MsgConnectionOpenAck) ValidateBasic Uses

func (msg MsgConnectionOpenAck) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgConnectionOpenAck) XXX_DiscardUnknown Uses

func (m *MsgConnectionOpenAck) XXX_DiscardUnknown()

func (*MsgConnectionOpenAck) XXX_Marshal Uses

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

func (*MsgConnectionOpenAck) XXX_Merge Uses

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

func (*MsgConnectionOpenAck) XXX_Size Uses

func (m *MsgConnectionOpenAck) XXX_Size() int

func (*MsgConnectionOpenAck) XXX_Unmarshal Uses

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

type MsgConnectionOpenConfirm Uses

type MsgConnectionOpenConfirm struct {
    ConnectionID string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" yaml:"connection_id"`
    // proof for the change of the connection state on Chain A: `INIT -> OPEN`
    ProofAck    []byte                                        `protobuf:"bytes,2,opt,name=proof_ack,json=proofAck,proto3" json:"proof_ack,omitempty" yaml:"proof_ack"`
    ProofHeight uint64                                        `protobuf:"varint,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"`
    Signer      github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

MsgConnectionOpenConfirm defines a msg sent by a Relayer to Chain B to acknowledge the change of connection state to OPEN on Chain A.

func NewMsgConnectionOpenConfirm Uses

func NewMsgConnectionOpenConfirm(
    connectionID string, proofAck []byte, proofHeight uint64,
    signer sdk.AccAddress,
) *MsgConnectionOpenConfirm

NewMsgConnectionOpenConfirm creates a new MsgConnectionOpenConfirm instance

func (*MsgConnectionOpenConfirm) Descriptor Uses

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

func (*MsgConnectionOpenConfirm) GetConnectionID Uses

func (m *MsgConnectionOpenConfirm) GetConnectionID() string

func (*MsgConnectionOpenConfirm) GetProofAck Uses

func (m *MsgConnectionOpenConfirm) GetProofAck() []byte

func (*MsgConnectionOpenConfirm) GetProofHeight Uses

func (m *MsgConnectionOpenConfirm) GetProofHeight() uint64

func (MsgConnectionOpenConfirm) GetSignBytes Uses

func (msg MsgConnectionOpenConfirm) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (*MsgConnectionOpenConfirm) GetSigner Uses

func (m *MsgConnectionOpenConfirm) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgConnectionOpenConfirm) GetSigners Uses

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

GetSigners implements sdk.Msg

func (*MsgConnectionOpenConfirm) Marshal Uses

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

func (*MsgConnectionOpenConfirm) MarshalTo Uses

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

func (*MsgConnectionOpenConfirm) MarshalToSizedBuffer Uses

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

func (*MsgConnectionOpenConfirm) ProtoMessage Uses

func (*MsgConnectionOpenConfirm) ProtoMessage()

func (*MsgConnectionOpenConfirm) Reset Uses

func (m *MsgConnectionOpenConfirm) Reset()

func (MsgConnectionOpenConfirm) Route Uses

func (msg MsgConnectionOpenConfirm) Route() string

Route implements sdk.Msg

func (*MsgConnectionOpenConfirm) Size Uses

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

func (*MsgConnectionOpenConfirm) String Uses

func (m *MsgConnectionOpenConfirm) String() string

func (MsgConnectionOpenConfirm) Type Uses

func (msg MsgConnectionOpenConfirm) Type() string

Type implements sdk.Msg

func (*MsgConnectionOpenConfirm) Unmarshal Uses

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

func (MsgConnectionOpenConfirm) ValidateBasic Uses

func (msg MsgConnectionOpenConfirm) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgConnectionOpenConfirm) XXX_DiscardUnknown Uses

func (m *MsgConnectionOpenConfirm) XXX_DiscardUnknown()

func (*MsgConnectionOpenConfirm) XXX_Marshal Uses

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

func (*MsgConnectionOpenConfirm) XXX_Merge Uses

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

func (*MsgConnectionOpenConfirm) XXX_Size Uses

func (m *MsgConnectionOpenConfirm) XXX_Size() int

func (*MsgConnectionOpenConfirm) XXX_Unmarshal Uses

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

type MsgConnectionOpenInit Uses

type MsgConnectionOpenInit struct {
    ClientID     string                                        `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" yaml:"client_id"`
    ConnectionID string                                        `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" yaml:"connection_id"`
    Counterparty Counterparty                                  `protobuf:"bytes,3,opt,name=counterparty,proto3" json:"counterparty"`
    Signer       github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

MsgConnectionOpenInit defines the msg sent by an account on Chain A to initialize a connection with Chain B.

func NewMsgConnectionOpenInit Uses

func NewMsgConnectionOpenInit(
    connectionID, clientID, counterpartyConnectionID,
    counterpartyClientID string, counterpartyPrefix commitmenttypes.MerklePrefix,
    signer sdk.AccAddress,
) *MsgConnectionOpenInit

NewMsgConnectionOpenInit creates a new MsgConnectionOpenInit instance

func (*MsgConnectionOpenInit) Descriptor Uses

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

func (*MsgConnectionOpenInit) GetClientID Uses

func (m *MsgConnectionOpenInit) GetClientID() string

func (*MsgConnectionOpenInit) GetConnectionID Uses

func (m *MsgConnectionOpenInit) GetConnectionID() string

func (*MsgConnectionOpenInit) GetCounterparty Uses

func (m *MsgConnectionOpenInit) GetCounterparty() Counterparty

func (MsgConnectionOpenInit) GetSignBytes Uses

func (msg MsgConnectionOpenInit) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (*MsgConnectionOpenInit) GetSigner Uses

func (m *MsgConnectionOpenInit) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgConnectionOpenInit) GetSigners Uses

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

GetSigners implements sdk.Msg

func (*MsgConnectionOpenInit) Marshal Uses

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

func (*MsgConnectionOpenInit) MarshalTo Uses

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

func (*MsgConnectionOpenInit) MarshalToSizedBuffer Uses

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

func (*MsgConnectionOpenInit) ProtoMessage Uses

func (*MsgConnectionOpenInit) ProtoMessage()

func (*MsgConnectionOpenInit) Reset Uses

func (m *MsgConnectionOpenInit) Reset()

func (MsgConnectionOpenInit) Route Uses

func (msg MsgConnectionOpenInit) Route() string

Route implements sdk.Msg

func (*MsgConnectionOpenInit) Size Uses

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

func (*MsgConnectionOpenInit) String Uses

func (m *MsgConnectionOpenInit) String() string

func (MsgConnectionOpenInit) Type Uses

func (msg MsgConnectionOpenInit) Type() string

Type implements sdk.Msg

func (*MsgConnectionOpenInit) Unmarshal Uses

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

func (MsgConnectionOpenInit) ValidateBasic Uses

func (msg MsgConnectionOpenInit) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgConnectionOpenInit) XXX_DiscardUnknown Uses

func (m *MsgConnectionOpenInit) XXX_DiscardUnknown()

func (*MsgConnectionOpenInit) XXX_Marshal Uses

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

func (*MsgConnectionOpenInit) XXX_Merge Uses

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

func (*MsgConnectionOpenInit) XXX_Size Uses

func (m *MsgConnectionOpenInit) XXX_Size() int

func (*MsgConnectionOpenInit) XXX_Unmarshal Uses

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

type MsgConnectionOpenTry Uses

type MsgConnectionOpenTry struct {
    ClientID             string       `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" yaml:"client_id"`
    ConnectionID         string       `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" yaml:"connection_id"`
    Counterparty         Counterparty `protobuf:"bytes,3,opt,name=counterparty,proto3" json:"counterparty"`
    CounterpartyVersions []string     `protobuf:"bytes,4,rep,name=counterparty_versions,json=counterpartyVersions,proto3" json:"counterparty_versions,omitempty" yaml:"counterparty_versions"`
    // proof of the initialization the connection on Chain A: `UNITIALIZED ->
    // INIT`
    ProofInit   []byte `protobuf:"bytes,5,opt,name=proof_init,json=proofInit,proto3" json:"proof_init,omitempty" yaml:"proof_init"`
    ProofHeight uint64 `protobuf:"varint,6,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty"`
    // proof of client consensus state
    ProofConsensus  []byte                                        `protobuf:"bytes,7,opt,name=proof_consensus,json=proofConsensus,proto3" json:"proof_consensus,omitempty" yaml:"proof_consensus"`
    ConsensusHeight uint64                                        `protobuf:"varint,8,opt,name=consensus_height,json=consensusHeight,proto3" json:"consensus_height,omitempty" yaml:"consensus_height"`
    Signer          github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,9,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"`
}

MsgConnectionOpenTry defines a msg sent by a Relayer to try to open a connection on Chain B.

func NewMsgConnectionOpenTry Uses

func NewMsgConnectionOpenTry(
    connectionID, clientID, counterpartyConnectionID,
    counterpartyClientID string, counterpartyPrefix commitmenttypes.MerklePrefix,
    counterpartyVersions []string, proofInit, proofConsensus []byte,
    proofHeight, consensusHeight uint64, signer sdk.AccAddress,
) *MsgConnectionOpenTry

NewMsgConnectionOpenTry creates a new MsgConnectionOpenTry instance

func (*MsgConnectionOpenTry) Descriptor Uses

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

func (*MsgConnectionOpenTry) GetClientID Uses

func (m *MsgConnectionOpenTry) GetClientID() string

func (*MsgConnectionOpenTry) GetConnectionID Uses

func (m *MsgConnectionOpenTry) GetConnectionID() string

func (*MsgConnectionOpenTry) GetConsensusHeight Uses

func (m *MsgConnectionOpenTry) GetConsensusHeight() uint64

func (*MsgConnectionOpenTry) GetCounterparty Uses

func (m *MsgConnectionOpenTry) GetCounterparty() Counterparty

func (*MsgConnectionOpenTry) GetCounterpartyVersions Uses

func (m *MsgConnectionOpenTry) GetCounterpartyVersions() []string

func (*MsgConnectionOpenTry) GetProofConsensus Uses

func (m *MsgConnectionOpenTry) GetProofConsensus() []byte

func (*MsgConnectionOpenTry) GetProofHeight Uses

func (m *MsgConnectionOpenTry) GetProofHeight() uint64

func (*MsgConnectionOpenTry) GetProofInit Uses

func (m *MsgConnectionOpenTry) GetProofInit() []byte

func (MsgConnectionOpenTry) GetSignBytes Uses

func (msg MsgConnectionOpenTry) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (*MsgConnectionOpenTry) GetSigner Uses

func (m *MsgConnectionOpenTry) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress

func (MsgConnectionOpenTry) GetSigners Uses

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

GetSigners implements sdk.Msg

func (*MsgConnectionOpenTry) Marshal Uses

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

func (*MsgConnectionOpenTry) MarshalTo Uses

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

func (*MsgConnectionOpenTry) MarshalToSizedBuffer Uses

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

func (*MsgConnectionOpenTry) ProtoMessage Uses

func (*MsgConnectionOpenTry) ProtoMessage()

func (*MsgConnectionOpenTry) Reset Uses

func (m *MsgConnectionOpenTry) Reset()

func (MsgConnectionOpenTry) Route Uses

func (msg MsgConnectionOpenTry) Route() string

Route implements sdk.Msg

func (*MsgConnectionOpenTry) Size Uses

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

func (*MsgConnectionOpenTry) String Uses

func (m *MsgConnectionOpenTry) String() string

func (MsgConnectionOpenTry) Type Uses

func (msg MsgConnectionOpenTry) Type() string

Type implements sdk.Msg

func (*MsgConnectionOpenTry) Unmarshal Uses

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

func (MsgConnectionOpenTry) ValidateBasic Uses

func (msg MsgConnectionOpenTry) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgConnectionOpenTry) XXX_DiscardUnknown Uses

func (m *MsgConnectionOpenTry) XXX_DiscardUnknown()

func (*MsgConnectionOpenTry) XXX_Marshal Uses

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

func (*MsgConnectionOpenTry) XXX_Merge Uses

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

func (*MsgConnectionOpenTry) XXX_Size Uses

func (m *MsgConnectionOpenTry) XXX_Size() int

func (*MsgConnectionOpenTry) XXX_Unmarshal Uses

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

type QueryClient Uses

type QueryClient interface {
    // Connection queries an IBC connection end.
    Connection(ctx context.Context, in *QueryConnectionRequest, opts ...grpc.CallOption) (*QueryConnectionResponse, error)
    // Connections queries all the IBC connections of a chain.
    Connections(ctx context.Context, in *QueryConnectionsRequest, opts ...grpc.CallOption) (*QueryConnectionsResponse, error)
    // ClientConnections queries the connection paths associated with a client
    // state.
    ClientConnections(ctx context.Context, in *QueryClientConnectionsRequest, opts ...grpc.CallOption) (*QueryClientConnectionsResponse, error)
    // ConnectionClientState queries the client state associated with the
    // connection
    ConnectionClientState(ctx context.Context, in *QueryConnectionClientStateRequest, opts ...grpc.CallOption) (*QueryConnectionClientStateResponse, error)
    // ConnectionConsensusState queries the consensus state associated with the
    // connection
    ConnectionConsensusState(ctx context.Context, in *QueryConnectionConsensusStateRequest, opts ...grpc.CallOption) (*QueryConnectionConsensusStateResponse, 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 Uses

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryClientConnectionsRequest Uses

type QueryClientConnectionsRequest struct {
    // client identifier associated with a connection
    ClientID string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
}

QueryClientConnectionsRequest is the request type for the Query/ClientConnections RPC method

func NewQueryClientConnectionsRequest Uses

func NewQueryClientConnectionsRequest(clientID string) *QueryClientConnectionsRequest

NewQueryClientConnectionsRequest creates a new QueryClientConnectionsRequest instance

func (*QueryClientConnectionsRequest) Descriptor Uses

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

func (*QueryClientConnectionsRequest) GetClientID Uses

func (m *QueryClientConnectionsRequest) GetClientID() string

func (*QueryClientConnectionsRequest) Marshal Uses

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

func (*QueryClientConnectionsRequest) MarshalTo Uses

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

func (*QueryClientConnectionsRequest) MarshalToSizedBuffer Uses

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

func (*QueryClientConnectionsRequest) ProtoMessage Uses

func (*QueryClientConnectionsRequest) ProtoMessage()

func (*QueryClientConnectionsRequest) Reset Uses

func (m *QueryClientConnectionsRequest) Reset()

func (*QueryClientConnectionsRequest) Size Uses

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

func (*QueryClientConnectionsRequest) String Uses

func (m *QueryClientConnectionsRequest) String() string

func (*QueryClientConnectionsRequest) Unmarshal Uses

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

func (*QueryClientConnectionsRequest) XXX_DiscardUnknown Uses

func (m *QueryClientConnectionsRequest) XXX_DiscardUnknown()

func (*QueryClientConnectionsRequest) XXX_Marshal Uses

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

func (*QueryClientConnectionsRequest) XXX_Merge Uses

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

func (*QueryClientConnectionsRequest) XXX_Size Uses

func (m *QueryClientConnectionsRequest) XXX_Size() int

func (*QueryClientConnectionsRequest) XXX_Unmarshal Uses

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

type QueryClientConnectionsResponse Uses

type QueryClientConnectionsResponse struct {
    // slice of all the connection paths associated with a client.
    ConnectionPaths []string `protobuf:"bytes,1,rep,name=connection_paths,json=connectionPaths,proto3" json:"connection_paths,omitempty"`
    // merkle proof of existence
    Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
    // merkle proof path
    ProofPath string `protobuf:"bytes,3,opt,name=proof_path,json=proofPath,proto3" json:"proof_path,omitempty"`
    // height at which the proof was generated
    ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty"`
}

QueryClientConnectionsResponse is the response type for the Query/ClientConnections RPC method

func NewQueryClientConnectionsResponse Uses

func NewQueryClientConnectionsResponse(
    clientID string, connectionPaths []string, proof []byte, height int64,
) *QueryClientConnectionsResponse

NewQueryClientConnectionsResponse creates a new ConnectionPaths instance

func (*QueryClientConnectionsResponse) Descriptor Uses

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

func (*QueryClientConnectionsResponse) GetConnectionPaths Uses

func (m *QueryClientConnectionsResponse) GetConnectionPaths() []string

func (*QueryClientConnectionsResponse) GetProof Uses

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

func (*QueryClientConnectionsResponse) GetProofHeight Uses

func (m *QueryClientConnectionsResponse) GetProofHeight() uint64

func (*QueryClientConnectionsResponse) GetProofPath Uses

func (m *QueryClientConnectionsResponse) GetProofPath() string

func (*QueryClientConnectionsResponse) Marshal Uses

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

func (*QueryClientConnectionsResponse) MarshalTo Uses

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

func (*QueryClientConnectionsResponse) MarshalToSizedBuffer Uses

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

func (*QueryClientConnectionsResponse) ProtoMessage Uses

func (*QueryClientConnectionsResponse) ProtoMessage()

func (*QueryClientConnectionsResponse) Reset Uses

func (m *QueryClientConnectionsResponse) Reset()

func (*QueryClientConnectionsResponse) Size Uses

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

func (*QueryClientConnectionsResponse) String Uses

func (m *QueryClientConnectionsResponse) String() string

func (*QueryClientConnectionsResponse) Unmarshal Uses

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

func (*QueryClientConnectionsResponse) XXX_DiscardUnknown Uses

func (m *QueryClientConnectionsResponse) XXX_DiscardUnknown()

func (*QueryClientConnectionsResponse) XXX_Marshal Uses

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

func (*QueryClientConnectionsResponse) XXX_Merge Uses

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

func (*QueryClientConnectionsResponse) XXX_Size Uses

func (m *QueryClientConnectionsResponse) XXX_Size() int

func (*QueryClientConnectionsResponse) XXX_Unmarshal Uses

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

type QueryConnectionClientStateRequest Uses

type QueryConnectionClientStateRequest struct {
    // connection identifier
    ConnectionID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"connection_id"`
}

QueryConnectionClientStateRequest is the request type for the Query/ConnectionClientState RPC method

func (*QueryConnectionClientStateRequest) Descriptor Uses

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

func (*QueryConnectionClientStateRequest) GetConnectionID Uses

func (m *QueryConnectionClientStateRequest) GetConnectionID() string

func (*QueryConnectionClientStateRequest) Marshal Uses

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

func (*QueryConnectionClientStateRequest) MarshalTo Uses

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

func (*QueryConnectionClientStateRequest) MarshalToSizedBuffer Uses

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

func (*QueryConnectionClientStateRequest) ProtoMessage Uses

func (*QueryConnectionClientStateRequest) ProtoMessage()

func (*QueryConnectionClientStateRequest) Reset Uses

func (m *QueryConnectionClientStateRequest) Reset()

func (*QueryConnectionClientStateRequest) Size Uses

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

func (*QueryConnectionClientStateRequest) String Uses

func (m *QueryConnectionClientStateRequest) String() string

func (*QueryConnectionClientStateRequest) Unmarshal Uses

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

func (*QueryConnectionClientStateRequest) XXX_DiscardUnknown Uses

func (m *QueryConnectionClientStateRequest) XXX_DiscardUnknown()

func (*QueryConnectionClientStateRequest) XXX_Marshal Uses

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

func (*QueryConnectionClientStateRequest) XXX_Merge Uses

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

func (*QueryConnectionClientStateRequest) XXX_Size Uses

func (m *QueryConnectionClientStateRequest) XXX_Size() int

func (*QueryConnectionClientStateRequest) XXX_Unmarshal Uses

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

type QueryConnectionClientStateResponse Uses

type QueryConnectionClientStateResponse struct {
    // client state associated with the channel
    IdentifiedClientState *types.IdentifiedClientState `protobuf:"bytes,1,opt,name=identified_client_state,json=identifiedClientState,proto3" json:"identified_client_state,omitempty"`
    // merkle proof of existence
    Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
    // merkle proof path
    ProofPath string `protobuf:"bytes,3,opt,name=proof_path,json=proofPath,proto3" json:"proof_path,omitempty"`
    // height at which the proof was retrieved
    ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty"`
}

QueryConnectionClientStateResponse is the response type for the Query/ConnectionClientState RPC method

func NewQueryConnectionClientStateResponse Uses

func NewQueryConnectionClientStateResponse(identifiedClientState clienttypes.IdentifiedClientState, proof []byte, height int64) *QueryConnectionClientStateResponse

NewQueryConnectionClientStateResponse creates a newQueryConnectionClientStateResponse instance

func (*QueryConnectionClientStateResponse) Descriptor Uses

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

func (*QueryConnectionClientStateResponse) GetIdentifiedClientState Uses

func (m *QueryConnectionClientStateResponse) GetIdentifiedClientState() *types.IdentifiedClientState

func (*QueryConnectionClientStateResponse) GetProof Uses

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

func (*QueryConnectionClientStateResponse) GetProofHeight Uses

func (m *QueryConnectionClientStateResponse) GetProofHeight() uint64

func (*QueryConnectionClientStateResponse) GetProofPath Uses

func (m *QueryConnectionClientStateResponse) GetProofPath() string

func (*QueryConnectionClientStateResponse) Marshal Uses

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

func (*QueryConnectionClientStateResponse) MarshalTo Uses

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

func (*QueryConnectionClientStateResponse) MarshalToSizedBuffer Uses

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

func (*QueryConnectionClientStateResponse) ProtoMessage Uses

func (*QueryConnectionClientStateResponse) ProtoMessage()

func (*QueryConnectionClientStateResponse) Reset Uses

func (m *QueryConnectionClientStateResponse) Reset()

func (*QueryConnectionClientStateResponse) Size Uses

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

func (*QueryConnectionClientStateResponse) String Uses

func (m *QueryConnectionClientStateResponse) String() string

func (*QueryConnectionClientStateResponse) Unmarshal Uses

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

func (*QueryConnectionClientStateResponse) XXX_DiscardUnknown Uses

func (m *QueryConnectionClientStateResponse) XXX_DiscardUnknown()

func (*QueryConnectionClientStateResponse) XXX_Marshal Uses

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

func (*QueryConnectionClientStateResponse) XXX_Merge Uses

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

func (*QueryConnectionClientStateResponse) XXX_Size Uses

func (m *QueryConnectionClientStateResponse) XXX_Size() int

func (*QueryConnectionClientStateResponse) XXX_Unmarshal Uses

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

type QueryConnectionConsensusStateRequest Uses

type QueryConnectionConsensusStateRequest struct {
    // connection identifier
    ConnectionID string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" yaml:"connection_id"`
    Height       uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
}

QueryConnectionConsensusStateRequest is the request type for the Query/ConnectionConsensusState RPC method

func (*QueryConnectionConsensusStateRequest) Descriptor Uses

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

func (*QueryConnectionConsensusStateRequest) GetConnectionID Uses

func (m *QueryConnectionConsensusStateRequest) GetConnectionID() string

func (*QueryConnectionConsensusStateRequest) GetHeight Uses

func (m *QueryConnectionConsensusStateRequest) GetHeight() uint64

func (*QueryConnectionConsensusStateRequest) Marshal Uses

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

func (*QueryConnectionConsensusStateRequest) MarshalTo Uses

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

func (*QueryConnectionConsensusStateRequest) MarshalToSizedBuffer Uses

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

func (*QueryConnectionConsensusStateRequest) ProtoMessage Uses

func (*QueryConnectionConsensusStateRequest) ProtoMessage()

func (*QueryConnectionConsensusStateRequest) Reset Uses

func (m *QueryConnectionConsensusStateRequest) Reset()

func (*QueryConnectionConsensusStateRequest) Size Uses

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

func (*QueryConnectionConsensusStateRequest) String Uses

func (m *QueryConnectionConsensusStateRequest) String() string

func (*QueryConnectionConsensusStateRequest) Unmarshal Uses

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

func (*QueryConnectionConsensusStateRequest) XXX_DiscardUnknown Uses

func (m *QueryConnectionConsensusStateRequest) XXX_DiscardUnknown()

func (*QueryConnectionConsensusStateRequest) XXX_Marshal Uses

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

func (*QueryConnectionConsensusStateRequest) XXX_Merge Uses

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

func (*QueryConnectionConsensusStateRequest) XXX_Size Uses

func (m *QueryConnectionConsensusStateRequest) XXX_Size() int

func (*QueryConnectionConsensusStateRequest) XXX_Unmarshal Uses

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

type QueryConnectionConsensusStateResponse Uses

type QueryConnectionConsensusStateResponse struct {
    // consensus state associated with the channel
    ConsensusState *types1.Any `protobuf:"bytes,1,opt,name=consensus_state,json=consensusState,proto3" json:"consensus_state,omitempty"`
    // client ID associated with the consensus state
    ClientID string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
    // merkle proof of existence
    Proof []byte `protobuf:"bytes,3,opt,name=proof,proto3" json:"proof,omitempty"`
    // merkle proof path
    ProofPath string `protobuf:"bytes,4,opt,name=proof_path,json=proofPath,proto3" json:"proof_path,omitempty"`
    // height at which the proof was retrieved
    ProofHeight uint64 `protobuf:"varint,5,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty"`
}

QueryConnectionConsensusStateResponse is the response type for the Query/ConnectionConsensusState RPC method

func NewQueryConnectionConsensusStateResponse Uses

func NewQueryConnectionConsensusStateResponse(clientID string, anyConsensusState *codectypes.Any, consensusStateHeight uint64, proof []byte, height int64) *QueryConnectionConsensusStateResponse

NewQueryConnectionConsensusStateResponse creates a newQueryConnectionConsensusStateResponse instance

func (*QueryConnectionConsensusStateResponse) Descriptor Uses

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

func (*QueryConnectionConsensusStateResponse) GetClientID Uses

func (m *QueryConnectionConsensusStateResponse) GetClientID() string

func (*QueryConnectionConsensusStateResponse) GetConsensusState Uses

func (m *QueryConnectionConsensusStateResponse) GetConsensusState() *types1.Any

func (*QueryConnectionConsensusStateResponse) GetProof Uses

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

func (*QueryConnectionConsensusStateResponse) GetProofHeight Uses

func (m *QueryConnectionConsensusStateResponse) GetProofHeight() uint64

func (*QueryConnectionConsensusStateResponse) GetProofPath Uses

func (m *QueryConnectionConsensusStateResponse) GetProofPath() string

func (*QueryConnectionConsensusStateResponse) Marshal Uses

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

func (*QueryConnectionConsensusStateResponse) MarshalTo Uses

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

func (*QueryConnectionConsensusStateResponse) MarshalToSizedBuffer Uses

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

func (*QueryConnectionConsensusStateResponse) ProtoMessage Uses

func (*QueryConnectionConsensusStateResponse) ProtoMessage()

func (*QueryConnectionConsensusStateResponse) Reset Uses

func (m *QueryConnectionConsensusStateResponse) Reset()

func (*QueryConnectionConsensusStateResponse) Size Uses

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

func (*QueryConnectionConsensusStateResponse) String Uses

func (m *QueryConnectionConsensusStateResponse) String() string

func (*QueryConnectionConsensusStateResponse) Unmarshal Uses

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

func (*QueryConnectionConsensusStateResponse) XXX_DiscardUnknown Uses

func (m *QueryConnectionConsensusStateResponse) XXX_DiscardUnknown()

func (*QueryConnectionConsensusStateResponse) XXX_Marshal Uses

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

func (*QueryConnectionConsensusStateResponse) XXX_Merge Uses

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

func (*QueryConnectionConsensusStateResponse) XXX_Size Uses

func (m *QueryConnectionConsensusStateResponse) XXX_Size() int

func (*QueryConnectionConsensusStateResponse) XXX_Unmarshal Uses

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

type QueryConnectionRequest Uses

type QueryConnectionRequest struct {
    // connection unique identifier
    ConnectionID string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
}

QueryConnectionRequest is the request type for the Query/Connection RPC method

func (*QueryConnectionRequest) Descriptor Uses

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

func (*QueryConnectionRequest) GetConnectionID Uses

func (m *QueryConnectionRequest) GetConnectionID() string

func (*QueryConnectionRequest) Marshal Uses

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

func (*QueryConnectionRequest) MarshalTo Uses

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

func (*QueryConnectionRequest) MarshalToSizedBuffer Uses

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

func (*QueryConnectionRequest) ProtoMessage Uses

func (*QueryConnectionRequest) ProtoMessage()

func (*QueryConnectionRequest) Reset Uses

func (m *QueryConnectionRequest) Reset()

func (*QueryConnectionRequest) Size Uses

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

func (*QueryConnectionRequest) String Uses

func (m *QueryConnectionRequest) String() string

func (*QueryConnectionRequest) Unmarshal Uses

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

func (*QueryConnectionRequest) XXX_DiscardUnknown Uses

func (m *QueryConnectionRequest) XXX_DiscardUnknown()

func (*QueryConnectionRequest) XXX_Marshal Uses

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

func (*QueryConnectionRequest) XXX_Merge Uses

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

func (*QueryConnectionRequest) XXX_Size Uses

func (m *QueryConnectionRequest) XXX_Size() int

func (*QueryConnectionRequest) XXX_Unmarshal Uses

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

type QueryConnectionResponse Uses

type QueryConnectionResponse struct {
    // connection associated with the request identifier
    Connection *ConnectionEnd `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
    // merkle proof of existence
    Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
    // merkle proof path
    ProofPath string `protobuf:"bytes,3,opt,name=proof_path,json=proofPath,proto3" json:"proof_path,omitempty"`
    // height at which the proof was retrieved
    ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty"`
}

QueryConnectionResponse is the response type for the Query/Connection RPC method. Besides the connection end, it includes a proof and the height from which the proof was retrieved.

func NewQueryConnectionResponse Uses

func NewQueryConnectionResponse(
    connectionID string, connection ConnectionEnd, proof []byte, height int64,
) *QueryConnectionResponse

NewQueryConnectionResponse creates a new QueryConnectionResponse instance

func (*QueryConnectionResponse) Descriptor Uses

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

func (*QueryConnectionResponse) GetConnection Uses

func (m *QueryConnectionResponse) GetConnection() *ConnectionEnd

func (*QueryConnectionResponse) GetProof Uses

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

func (*QueryConnectionResponse) GetProofHeight Uses

func (m *QueryConnectionResponse) GetProofHeight() uint64

func (*QueryConnectionResponse) GetProofPath Uses

func (m *QueryConnectionResponse) GetProofPath() string

func (*QueryConnectionResponse) Marshal Uses

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

func (*QueryConnectionResponse) MarshalTo Uses

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

func (*QueryConnectionResponse) MarshalToSizedBuffer Uses

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

func (*QueryConnectionResponse) ProtoMessage Uses

func (*QueryConnectionResponse) ProtoMessage()

func (*QueryConnectionResponse) Reset Uses

func (m *QueryConnectionResponse) Reset()

func (*QueryConnectionResponse) Size Uses

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

func (*QueryConnectionResponse) String Uses

func (m *QueryConnectionResponse) String() string

func (*QueryConnectionResponse) Unmarshal Uses

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

func (*QueryConnectionResponse) XXX_DiscardUnknown Uses

func (m *QueryConnectionResponse) XXX_DiscardUnknown()

func (*QueryConnectionResponse) XXX_Marshal Uses

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

func (*QueryConnectionResponse) XXX_Merge Uses

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

func (*QueryConnectionResponse) XXX_Size Uses

func (m *QueryConnectionResponse) XXX_Size() int

func (*QueryConnectionResponse) XXX_Unmarshal Uses

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

type QueryConnectionsRequest Uses

type QueryConnectionsRequest struct {
    Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryConnectionsRequest is the request type for the Query/Connections RPC method

func (*QueryConnectionsRequest) Descriptor Uses

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

func (*QueryConnectionsRequest) GetPagination Uses

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

func (*QueryConnectionsRequest) Marshal Uses

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

func (*QueryConnectionsRequest) MarshalTo Uses

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

func (*QueryConnectionsRequest) MarshalToSizedBuffer Uses

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

func (*QueryConnectionsRequest) ProtoMessage Uses

func (*QueryConnectionsRequest) ProtoMessage()

func (*QueryConnectionsRequest) Reset Uses

func (m *QueryConnectionsRequest) Reset()

func (*QueryConnectionsRequest) Size Uses

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

func (*QueryConnectionsRequest) String Uses

func (m *QueryConnectionsRequest) String() string

func (*QueryConnectionsRequest) Unmarshal Uses

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

func (*QueryConnectionsRequest) XXX_DiscardUnknown Uses

func (m *QueryConnectionsRequest) XXX_DiscardUnknown()

func (*QueryConnectionsRequest) XXX_Marshal Uses

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

func (*QueryConnectionsRequest) XXX_Merge Uses

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

func (*QueryConnectionsRequest) XXX_Size Uses

func (m *QueryConnectionsRequest) XXX_Size() int

func (*QueryConnectionsRequest) XXX_Unmarshal Uses

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

type QueryConnectionsResponse Uses

type QueryConnectionsResponse struct {
    // list of stored connections of the chain.
    Connections []*IdentifiedConnection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
    // pagination response
    Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
    // query block height
    Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
}

QueryConnectionsResponse is the response type for the Query/Connections RPC method.

func (*QueryConnectionsResponse) Descriptor Uses

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

func (*QueryConnectionsResponse) GetConnections Uses

func (m *QueryConnectionsResponse) GetConnections() []*IdentifiedConnection

func (*QueryConnectionsResponse) GetHeight Uses

func (m *QueryConnectionsResponse) GetHeight() int64

func (*QueryConnectionsResponse) GetPagination Uses

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

func (*QueryConnectionsResponse) Marshal Uses

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

func (*QueryConnectionsResponse) MarshalTo Uses

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

func (*QueryConnectionsResponse) MarshalToSizedBuffer Uses

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

func (*QueryConnectionsResponse) ProtoMessage Uses

func (*QueryConnectionsResponse) ProtoMessage()

func (*QueryConnectionsResponse) Reset Uses

func (m *QueryConnectionsResponse) Reset()

func (*QueryConnectionsResponse) Size Uses

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

func (*QueryConnectionsResponse) String Uses

func (m *QueryConnectionsResponse) String() string

func (*QueryConnectionsResponse) Unmarshal Uses

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

func (*QueryConnectionsResponse) XXX_DiscardUnknown Uses

func (m *QueryConnectionsResponse) XXX_DiscardUnknown()

func (*QueryConnectionsResponse) XXX_Marshal Uses

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

func (*QueryConnectionsResponse) XXX_Merge Uses

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

func (*QueryConnectionsResponse) XXX_Size Uses

func (m *QueryConnectionsResponse) XXX_Size() int

func (*QueryConnectionsResponse) XXX_Unmarshal Uses

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

type QueryServer Uses

type QueryServer interface {
    // Connection queries an IBC connection end.
    Connection(context.Context, *QueryConnectionRequest) (*QueryConnectionResponse, error)
    // Connections queries all the IBC connections of a chain.
    Connections(context.Context, *QueryConnectionsRequest) (*QueryConnectionsResponse, error)
    // ClientConnections queries the connection paths associated with a client
    // state.
    ClientConnections(context.Context, *QueryClientConnectionsRequest) (*QueryClientConnectionsResponse, error)
    // ConnectionClientState queries the client state associated with the
    // connection
    ConnectionClientState(context.Context, *QueryConnectionClientStateRequest) (*QueryConnectionClientStateResponse, error)
    // ConnectionConsensusState queries the consensus state associated with the
    // connection
    ConnectionConsensusState(context.Context, *QueryConnectionConsensusStateRequest) (*QueryConnectionConsensusStateResponse, error)
}

QueryServer is the server API for Query service.

type State Uses

type State int32

State defines if a connection is in one of the following states: INIT, TRYOPEN, OPEN or UNINITIALIZED.

const (
    // Default State
    UNINITIALIZED State = 0
    // A connection end has just started the opening handshake.
    INIT State = 1
    // A connection end has acknowledged the handshake step on the counterparty
    // chain.
    TRYOPEN State = 2
    // A connection end has completed the handshake.
    OPEN State = 3
)

func (State) EnumDescriptor Uses

func (State) EnumDescriptor() ([]byte, []int)

func (State) String Uses

func (x State) String() string

type UnimplementedQueryServer Uses

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ClientConnections Uses

func (*UnimplementedQueryServer) ClientConnections(ctx context.Context, req *QueryClientConnectionsRequest) (*QueryClientConnectionsResponse, error)

func (*UnimplementedQueryServer) Connection Uses

func (*UnimplementedQueryServer) Connection(ctx context.Context, req *QueryConnectionRequest) (*QueryConnectionResponse, error)

func (*UnimplementedQueryServer) ConnectionClientState Uses

func (*UnimplementedQueryServer) ConnectionClientState(ctx context.Context, req *QueryConnectionClientStateRequest) (*QueryConnectionClientStateResponse, error)

func (*UnimplementedQueryServer) ConnectionConsensusState Uses

func (*UnimplementedQueryServer) ConnectionConsensusState(ctx context.Context, req *QueryConnectionConsensusStateRequest) (*QueryConnectionConsensusStateResponse, error)

func (*UnimplementedQueryServer) Connections Uses

func (*UnimplementedQueryServer) Connections(ctx context.Context, req *QueryConnectionsRequest) (*QueryConnectionsResponse, error)

type Version Uses

type Version struct {
    // unique version identifier
    Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
    // list of features compatible with the specified identifier
    Features []string `protobuf:"bytes,2,rep,name=features,proto3" json:"features,omitempty"`
}

Version defines the versioning scheme used to negotiate the IBC verison in the connection handshake.

func DecodeVersion Uses

func DecodeVersion(encodedVersion string) (Version, error)

DecodeVersion unmarshals a proto encoded version into a Version struct.

func DecodeVersions Uses

func DecodeVersions(encodedVersions []string) ([]Version, error)

DecodeVersions returns the supplied list of proto encoded version strings as unmarshalled Version structs.

func FindSupportedVersion Uses

func FindSupportedVersion(version Version, supportedVersions []Version) (Version, bool)

FindSupportedVersion returns the version with a matching version identifier if it exists. The returned boolean is true if the version is found and false otherwise.

func GetCompatibleVersions Uses

func GetCompatibleVersions() []Version

GetCompatibleVersions returns a descending ordered set of compatible IBC versions for the caller chain's connection end. The latest supported version should be first element and the set should descend to the oldest supported version.

func NewVersion Uses

func NewVersion(identifier string, features []string) Version

NewVersion returns a new instance of Version.

func (*Version) Descriptor Uses

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

func (Version) Encode Uses

func (version Version) Encode() (string, error)

Encode proto encodes the version and returns the bytes as a string.

func (Version) GetFeatures Uses

func (version Version) GetFeatures() []string

GetFeatures implements the VersionI interface

func (Version) GetIdentifier Uses

func (version Version) GetIdentifier() string

GetIdentifier implements the VersionI interface

func (*Version) Marshal Uses

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

func (*Version) MarshalTo Uses

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

func (*Version) MarshalToSizedBuffer Uses

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

func (*Version) ProtoMessage Uses

func (*Version) ProtoMessage()

func (*Version) Reset Uses

func (m *Version) Reset()

func (*Version) Size Uses

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

func (*Version) String Uses

func (m *Version) String() string

func (*Version) Unmarshal Uses

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

func (Version) VerifyProposedVersion Uses

func (version Version) VerifyProposedVersion(proposedVersion Version) error

VerifyProposedVersion verifies that the entire feature set in the proposed version is supported by this chain. If the feature set is empty it verifies that this is allowed for the specified version identifier.

func (*Version) XXX_DiscardUnknown Uses

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal Uses

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

func (*Version) XXX_Merge Uses

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

func (*Version) XXX_Size Uses

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal Uses

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

Package types imports 23 packages (graph) and is imported by 16 packages. Updated 2020-08-13. Refresh now. Tools for package owners.