types

package
Version: v0.0.0-...-fbaf713 Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2021 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

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

IBC connection events

View Source
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

	// KeyNextConnectionSequence is the key used to store the next connection sequence in
	// the keeper.
	KeyNextConnectionSequence = "nextConnectionSequence"

	// ConnectionPrefix is the prefix used when creating a connection identifier
	ConnectionPrefix = "connection-"
)

Variables

View Source
var (
	ErrInvalidLengthConnection        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConnection          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupConnection = fmt.Errorf("proto: unexpected end of group")
)
View Source
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")
	ErrInvalidConnectionIdentifier   = sdkerrors.Register(SubModuleName, 11, "invalid connection identifier")
)

IBC connection sentinel errors

View Source
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

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 (
	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 (
	// 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"
)
View Source
var IsConnectionIDFormat = regexp.MustCompile(`^connection-[0-9]{1,20}$`).MatchString

IsConnectionIDFormat checks if a connectionID is in the format required on the SDK for parsing connection identifiers. The connection identifier must be in the form: `connection-{N}

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

Functions

func FindSupportedVersion

func FindSupportedVersion(version exported.Version, supportedVersions []exported.Version) (exported.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 FormatConnectionIdentifier

func FormatConnectionIdentifier(sequence uint64) string

FormatConnectionIdentifier returns the connection identifier with the sequence appended. This is a SDK specific format not enforced by IBC protocol.

func GetCompatibleVersions

func GetCompatibleVersions() []exported.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 GetFeatureSetIntersection

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 IsSupportedVersion

func IsSupportedVersion(proposedVersion *Version) bool

IsSupportedVersion returns true if the proposed version has a matching version identifier and its entire feature set is supported or the version identifier supports an empty feature set.

func IsValidConnectionID

func IsValidConnectionID(connectionID string) bool

IsValidConnectionID checks if the connection identifier is valid and can be parsed to the connection identifier format.

func ParseConnectionSequence

func ParseConnectionSequence(connectionID string) (uint64, error)

ParseConnectionSequence parses the connection sequence from the connection identifier.

func ProtoVersionsToExported

func ProtoVersionsToExported(versions []*Version) []exported.Version

ProtoVersionsToExported converts a slice of the Version proto definition to the Version interface.

func RegisterInterfaces

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the ibc interfaces submodule implementations 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)

func ValidateVersion

func ValidateVersion(version *Version) error

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

func VerifySupportedFeature

func VerifySupportedFeature(version exported.Version, 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.

Types

type ClientKeeper

type ClientKeeper interface {
	GetClientState(ctx sdk.Context, clientID string) (exported.ClientState, bool)
	GetClientConsensusState(ctx sdk.Context, clientID string, height exported.Height) (exported.ConsensusState, bool)
	GetSelfConsensusState(ctx sdk.Context, height exported.Height) (exported.ConsensusState, bool)
	ValidateSelfClient(ctx sdk.Context, clientState exported.ClientState) error
	IterateClients(ctx sdk.Context, cb func(string, exported.ClientState) bool)
	ClientStore(ctx sdk.Context, clientID string) sdk.KVStore
}

ClientKeeper expected account IBC client keeper

type ClientPaths

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

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

func (*ClientPaths) GetPaths

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

func (*ClientPaths) Marshal

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

func (*ClientPaths) MarshalTo

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

func (*ClientPaths) MarshalToSizedBuffer

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

func (*ClientPaths) ProtoMessage

func (*ClientPaths) ProtoMessage()

func (*ClientPaths) Reset

func (m *ClientPaths) Reset()

func (*ClientPaths) Size

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

func (*ClientPaths) String

func (m *ClientPaths) String() string

func (*ClientPaths) Unmarshal

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

func (*ClientPaths) XXX_DiscardUnknown

func (m *ClientPaths) XXX_DiscardUnknown()

func (*ClientPaths) XXX_Marshal

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

func (*ClientPaths) XXX_Merge

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

func (*ClientPaths) XXX_Size

func (m *ClientPaths) XXX_Size() int

func (*ClientPaths) XXX_Unmarshal

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

type ConnectionEnd

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 []*Version `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.core.connection.v1.State" json:"state,omitempty"`
	// counterparty chain associated with this connection.
	Counterparty Counterparty `protobuf:"bytes,4,opt,name=counterparty,proto3" json:"counterparty"`
	// delay period that must pass before a consensus state can be used for packet-verification
	// NOTE: delay period logic is only implemented by some clients.
	DelayPeriod uint64 `protobuf:"varint,5,opt,name=delay_period,json=delayPeriod,proto3" json:"delay_period,omitempty" yaml:"delay_period"`
}

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

func NewConnectionEnd(state State, clientID string, counterparty Counterparty, versions []*Version, delayPeriod uint64) ConnectionEnd

NewConnectionEnd creates a new ConnectionEnd instance.

func (*ConnectionEnd) Descriptor

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

func (ConnectionEnd) GetClientID

func (c ConnectionEnd) GetClientID() string

GetClientID implements the Connection interface

func (ConnectionEnd) GetCounterparty

func (c ConnectionEnd) GetCounterparty() exported.CounterpartyConnectionI

GetCounterparty implements the Connection interface

func (ConnectionEnd) GetDelayPeriod

func (c ConnectionEnd) GetDelayPeriod() uint64

GetDelayPeriod implements the Connection interface

func (ConnectionEnd) GetState

func (c ConnectionEnd) GetState() int32

GetState implements the Connection interface

func (ConnectionEnd) GetVersions

func (c ConnectionEnd) GetVersions() []exported.Version

GetVersions implements the Connection interface

func (*ConnectionEnd) Marshal

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

func (*ConnectionEnd) MarshalTo

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

func (*ConnectionEnd) MarshalToSizedBuffer

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

func (*ConnectionEnd) ProtoMessage

func (*ConnectionEnd) ProtoMessage()

func (*ConnectionEnd) Reset

func (m *ConnectionEnd) Reset()

func (*ConnectionEnd) Size

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

func (*ConnectionEnd) String

func (m *ConnectionEnd) String() string

func (*ConnectionEnd) Unmarshal

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

func (ConnectionEnd) ValidateBasic

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

func (m *ConnectionEnd) XXX_DiscardUnknown()

func (*ConnectionEnd) XXX_Marshal

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

func (*ConnectionEnd) XXX_Merge

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

func (*ConnectionEnd) XXX_Size

func (m *ConnectionEnd) XXX_Size() int

func (*ConnectionEnd) XXX_Unmarshal

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

type ConnectionPaths

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

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

NewConnectionPaths creates a ConnectionPaths instance.

func (*ConnectionPaths) Descriptor

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

func (*ConnectionPaths) GetClientId

func (m *ConnectionPaths) GetClientId() string

func (*ConnectionPaths) GetPaths

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

func (*ConnectionPaths) Marshal

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

func (*ConnectionPaths) MarshalTo

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

func (*ConnectionPaths) MarshalToSizedBuffer

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

func (*ConnectionPaths) ProtoMessage

func (*ConnectionPaths) ProtoMessage()

func (*ConnectionPaths) Reset

func (m *ConnectionPaths) Reset()

func (*ConnectionPaths) Size

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

func (*ConnectionPaths) String

func (m *ConnectionPaths) String() string

func (*ConnectionPaths) Unmarshal

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

func (*ConnectionPaths) XXX_DiscardUnknown

func (m *ConnectionPaths) XXX_DiscardUnknown()

func (*ConnectionPaths) XXX_Marshal

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

func (*ConnectionPaths) XXX_Merge

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

func (*ConnectionPaths) XXX_Size

func (m *ConnectionPaths) XXX_Size() int

func (*ConnectionPaths) XXX_Unmarshal

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

type Counterparty

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

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

NewCounterparty creates a new Counterparty instance.

func (*Counterparty) Descriptor

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

func (Counterparty) GetClientID

func (c Counterparty) GetClientID() string

GetClientID implements the CounterpartyConnectionI interface

func (Counterparty) GetConnectionID

func (c Counterparty) GetConnectionID() string

GetConnectionID implements the CounterpartyConnectionI interface

func (Counterparty) GetPrefix

func (c Counterparty) GetPrefix() exported.Prefix

GetPrefix implements the CounterpartyConnectionI interface

func (*Counterparty) Marshal

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

func (*Counterparty) MarshalTo

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

func (*Counterparty) MarshalToSizedBuffer

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

func (*Counterparty) ProtoMessage

func (*Counterparty) ProtoMessage()

func (*Counterparty) Reset

func (m *Counterparty) Reset()

func (*Counterparty) Size

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

func (*Counterparty) String

func (m *Counterparty) String() string

func (*Counterparty) Unmarshal

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

func (Counterparty) ValidateBasic

func (c Counterparty) ValidateBasic() error

ValidateBasic performs a basic validation check of the identifiers and prefix

func (*Counterparty) XXX_DiscardUnknown

func (m *Counterparty) XXX_DiscardUnknown()

func (*Counterparty) XXX_Marshal

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

func (*Counterparty) XXX_Merge

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

func (*Counterparty) XXX_Size

func (m *Counterparty) XXX_Size() int

func (*Counterparty) XXX_Unmarshal

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

type GenesisState

type GenesisState struct {
	Connections           []IdentifiedConnection `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections"`
	ClientConnectionPaths []ConnectionPaths      `` /* 147-byte string literal not displayed */
	// the sequence for the next generated connection identifier
	NextConnectionSequence uint64 `` /* 162-byte string literal not displayed */
}

GenesisState defines the ibc connection submodule's genesis state.

func DefaultGenesisState

func DefaultGenesisState() GenesisState

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

func NewGenesisState

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

NewGenesisState creates a GenesisState instance.

func (*GenesisState) Descriptor

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

func (*GenesisState) GetClientConnectionPaths

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

func (*GenesisState) GetConnections

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

func (*GenesisState) GetNextConnectionSequence

func (m *GenesisState) GetNextConnectionSequence() uint64

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 IdentifiedConnection

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 []*Version `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.core.connection.v1.State" json:"state,omitempty"`
	// counterparty chain associated with this connection.
	Counterparty Counterparty `protobuf:"bytes,5,opt,name=counterparty,proto3" json:"counterparty"`
	// delay period associated with this connection.
	DelayPeriod uint64 `protobuf:"varint,6,opt,name=delay_period,json=delayPeriod,proto3" json:"delay_period,omitempty" yaml:"delay_period"`
}

IdentifiedConnection defines a connection with additional connection identifier field.

func NewIdentifiedConnection

func NewIdentifiedConnection(connectionID string, conn ConnectionEnd) IdentifiedConnection

NewIdentifiedConnection creates a new IdentifiedConnection instance

func (*IdentifiedConnection) Descriptor

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

func (*IdentifiedConnection) Marshal

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

func (*IdentifiedConnection) MarshalTo

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

func (*IdentifiedConnection) MarshalToSizedBuffer

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

func (*IdentifiedConnection) ProtoMessage

func (*IdentifiedConnection) ProtoMessage()

func (*IdentifiedConnection) Reset

func (m *IdentifiedConnection) Reset()

func (*IdentifiedConnection) Size

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

func (*IdentifiedConnection) String

func (m *IdentifiedConnection) String() string

func (*IdentifiedConnection) Unmarshal

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

func (IdentifiedConnection) ValidateBasic

func (ic IdentifiedConnection) ValidateBasic() error

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

func (*IdentifiedConnection) XXX_DiscardUnknown

func (m *IdentifiedConnection) XXX_DiscardUnknown()

func (*IdentifiedConnection) XXX_Marshal

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

func (*IdentifiedConnection) XXX_Merge

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

func (*IdentifiedConnection) XXX_Size

func (m *IdentifiedConnection) XXX_Size() int

func (*IdentifiedConnection) XXX_Unmarshal

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

type MsgClient

type MsgClient interface {
	// ConnectionOpenInit defines a rpc handler method for MsgConnectionOpenInit.
	ConnectionOpenInit(ctx context.Context, in *MsgConnectionOpenInit, opts ...grpc.CallOption) (*MsgConnectionOpenInitResponse, error)
	// ConnectionOpenTry defines a rpc handler method for MsgConnectionOpenTry.
	ConnectionOpenTry(ctx context.Context, in *MsgConnectionOpenTry, opts ...grpc.CallOption) (*MsgConnectionOpenTryResponse, error)
	// ConnectionOpenAck defines a rpc handler method for MsgConnectionOpenAck.
	ConnectionOpenAck(ctx context.Context, in *MsgConnectionOpenAck, opts ...grpc.CallOption) (*MsgConnectionOpenAckResponse, error)
	// ConnectionOpenConfirm defines a rpc handler method for MsgConnectionOpenConfirm.
	ConnectionOpenConfirm(ctx context.Context, in *MsgConnectionOpenConfirm, opts ...grpc.CallOption) (*MsgConnectionOpenConfirmResponse, 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 MsgConnectionOpenAck

type MsgConnectionOpenAck struct {
	ConnectionId             string        `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" yaml:"connection_id"`
	CounterpartyConnectionId string        `` /* 169-byte string literal not displayed */
	Version                  *Version      `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	ClientState              *types.Any    `protobuf:"bytes,4,opt,name=client_state,json=clientState,proto3" json:"client_state,omitempty" yaml:"client_state"`
	ProofHeight              types1.Height `protobuf:"bytes,5,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"`
	// proof of the initialization the connection on Chain B: `UNITIALIZED ->
	// TRYOPEN`
	ProofTry []byte `protobuf:"bytes,6,opt,name=proof_try,json=proofTry,proto3" json:"proof_try,omitempty" yaml:"proof_try"`
	// proof of client state included in message
	ProofClient []byte `protobuf:"bytes,7,opt,name=proof_client,json=proofClient,proto3" json:"proof_client,omitempty" yaml:"proof_client"`
	// proof of client consensus state
	ProofConsensus  []byte        `` /* 126-byte string literal not displayed */
	ConsensusHeight types1.Height `protobuf:"bytes,9,opt,name=consensus_height,json=consensusHeight,proto3" json:"consensus_height" yaml:"consensus_height"`
	Signer          string        `protobuf:"bytes,10,opt,name=signer,proto3" 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

func NewMsgConnectionOpenAck(
	connectionID, counterpartyConnectionID string, counterpartyClient exported.ClientState,
	proofTry, proofClient, proofConsensus []byte,
	proofHeight, consensusHeight clienttypes.Height,
	version *Version,
	signer sdk.AccAddress,
) *MsgConnectionOpenAck

NewMsgConnectionOpenAck creates a new MsgConnectionOpenAck instance

func (*MsgConnectionOpenAck) Descriptor

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

func (MsgConnectionOpenAck) GetSignBytes

func (msg MsgConnectionOpenAck) GetSignBytes() []byte

GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which IBC does not support.

func (MsgConnectionOpenAck) GetSigners

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

GetSigners implements sdk.Msg

func (*MsgConnectionOpenAck) Marshal

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

func (*MsgConnectionOpenAck) MarshalTo

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

func (*MsgConnectionOpenAck) MarshalToSizedBuffer

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

func (*MsgConnectionOpenAck) ProtoMessage

func (*MsgConnectionOpenAck) ProtoMessage()

func (*MsgConnectionOpenAck) Reset

func (m *MsgConnectionOpenAck) Reset()

func (MsgConnectionOpenAck) Route

func (msg MsgConnectionOpenAck) Route() string

Route implements sdk.Msg

func (*MsgConnectionOpenAck) Size

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

func (*MsgConnectionOpenAck) String

func (m *MsgConnectionOpenAck) String() string

func (MsgConnectionOpenAck) Type

func (msg MsgConnectionOpenAck) Type() string

Type implements sdk.Msg

func (*MsgConnectionOpenAck) Unmarshal

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

func (MsgConnectionOpenAck) UnpackInterfaces

func (msg MsgConnectionOpenAck) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (MsgConnectionOpenAck) ValidateBasic

func (msg MsgConnectionOpenAck) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgConnectionOpenAck) XXX_DiscardUnknown

func (m *MsgConnectionOpenAck) XXX_DiscardUnknown()

func (*MsgConnectionOpenAck) XXX_Marshal

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

func (*MsgConnectionOpenAck) XXX_Merge

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

func (*MsgConnectionOpenAck) XXX_Size

func (m *MsgConnectionOpenAck) XXX_Size() int

func (*MsgConnectionOpenAck) XXX_Unmarshal

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

type MsgConnectionOpenAckResponse

type MsgConnectionOpenAckResponse struct {
}

MsgConnectionOpenAckResponse defines the Msg/ConnectionOpenAck response type.

func (*MsgConnectionOpenAckResponse) Descriptor

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

func (*MsgConnectionOpenAckResponse) Marshal

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

func (*MsgConnectionOpenAckResponse) MarshalTo

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

func (*MsgConnectionOpenAckResponse) MarshalToSizedBuffer

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

func (*MsgConnectionOpenAckResponse) ProtoMessage

func (*MsgConnectionOpenAckResponse) ProtoMessage()

func (*MsgConnectionOpenAckResponse) Reset

func (m *MsgConnectionOpenAckResponse) Reset()

func (*MsgConnectionOpenAckResponse) Size

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

func (*MsgConnectionOpenAckResponse) String

func (*MsgConnectionOpenAckResponse) Unmarshal

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

func (*MsgConnectionOpenAckResponse) XXX_DiscardUnknown

func (m *MsgConnectionOpenAckResponse) XXX_DiscardUnknown()

func (*MsgConnectionOpenAckResponse) XXX_Marshal

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

func (*MsgConnectionOpenAckResponse) XXX_Merge

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

func (*MsgConnectionOpenAckResponse) XXX_Size

func (m *MsgConnectionOpenAckResponse) XXX_Size() int

func (*MsgConnectionOpenAckResponse) XXX_Unmarshal

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

type MsgConnectionOpenConfirm

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 types1.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"`
}

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

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

NewMsgConnectionOpenConfirm creates a new MsgConnectionOpenConfirm instance

func (*MsgConnectionOpenConfirm) Descriptor

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

func (MsgConnectionOpenConfirm) GetSignBytes

func (msg MsgConnectionOpenConfirm) GetSignBytes() []byte

GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which IBC does not support.

func (MsgConnectionOpenConfirm) GetSigners

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

GetSigners implements sdk.Msg

func (*MsgConnectionOpenConfirm) Marshal

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

func (*MsgConnectionOpenConfirm) MarshalTo

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

func (*MsgConnectionOpenConfirm) MarshalToSizedBuffer

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

func (*MsgConnectionOpenConfirm) ProtoMessage

func (*MsgConnectionOpenConfirm) ProtoMessage()

func (*MsgConnectionOpenConfirm) Reset

func (m *MsgConnectionOpenConfirm) Reset()

func (MsgConnectionOpenConfirm) Route

func (msg MsgConnectionOpenConfirm) Route() string

Route implements sdk.Msg

func (*MsgConnectionOpenConfirm) Size

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

func (*MsgConnectionOpenConfirm) String

func (m *MsgConnectionOpenConfirm) String() string

func (MsgConnectionOpenConfirm) Type

func (msg MsgConnectionOpenConfirm) Type() string

Type implements sdk.Msg

func (*MsgConnectionOpenConfirm) Unmarshal

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

func (MsgConnectionOpenConfirm) ValidateBasic

func (msg MsgConnectionOpenConfirm) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgConnectionOpenConfirm) XXX_DiscardUnknown

func (m *MsgConnectionOpenConfirm) XXX_DiscardUnknown()

func (*MsgConnectionOpenConfirm) XXX_Marshal

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

func (*MsgConnectionOpenConfirm) XXX_Merge

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

func (*MsgConnectionOpenConfirm) XXX_Size

func (m *MsgConnectionOpenConfirm) XXX_Size() int

func (*MsgConnectionOpenConfirm) XXX_Unmarshal

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

type MsgConnectionOpenConfirmResponse

type MsgConnectionOpenConfirmResponse struct {
}

MsgConnectionOpenConfirmResponse defines the Msg/ConnectionOpenConfirm response type.

func (*MsgConnectionOpenConfirmResponse) Descriptor

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

func (*MsgConnectionOpenConfirmResponse) Marshal

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

func (*MsgConnectionOpenConfirmResponse) MarshalTo

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

func (*MsgConnectionOpenConfirmResponse) MarshalToSizedBuffer

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

func (*MsgConnectionOpenConfirmResponse) ProtoMessage

func (*MsgConnectionOpenConfirmResponse) ProtoMessage()

func (*MsgConnectionOpenConfirmResponse) Reset

func (*MsgConnectionOpenConfirmResponse) Size

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

func (*MsgConnectionOpenConfirmResponse) String

func (*MsgConnectionOpenConfirmResponse) Unmarshal

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

func (*MsgConnectionOpenConfirmResponse) XXX_DiscardUnknown

func (m *MsgConnectionOpenConfirmResponse) XXX_DiscardUnknown()

func (*MsgConnectionOpenConfirmResponse) XXX_Marshal

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

func (*MsgConnectionOpenConfirmResponse) XXX_Merge

func (*MsgConnectionOpenConfirmResponse) XXX_Size

func (m *MsgConnectionOpenConfirmResponse) XXX_Size() int

func (*MsgConnectionOpenConfirmResponse) XXX_Unmarshal

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

type MsgConnectionOpenInit

type MsgConnectionOpenInit struct {
	ClientId     string       `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" yaml:"client_id"`
	Counterparty Counterparty `protobuf:"bytes,2,opt,name=counterparty,proto3" json:"counterparty"`
	Version      *Version     `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	DelayPeriod  uint64       `protobuf:"varint,4,opt,name=delay_period,json=delayPeriod,proto3" json:"delay_period,omitempty" yaml:"delay_period"`
	Signer       string       `protobuf:"bytes,5,opt,name=signer,proto3" json:"signer,omitempty"`
}

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

func NewMsgConnectionOpenInit

func NewMsgConnectionOpenInit(
	clientID, counterpartyClientID string,
	counterpartyPrefix commitmenttypes.MerklePrefix,
	version *Version, delayPeriod uint64, signer sdk.AccAddress,
) *MsgConnectionOpenInit

NewMsgConnectionOpenInit creates a new MsgConnectionOpenInit instance. It sets the counterparty connection identifier to be empty.

func (*MsgConnectionOpenInit) Descriptor

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

func (MsgConnectionOpenInit) GetSignBytes

func (msg MsgConnectionOpenInit) GetSignBytes() []byte

GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which IBC does not support.

func (MsgConnectionOpenInit) GetSigners

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

GetSigners implements sdk.Msg

func (*MsgConnectionOpenInit) Marshal

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

func (*MsgConnectionOpenInit) MarshalTo

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

func (*MsgConnectionOpenInit) MarshalToSizedBuffer

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

func (*MsgConnectionOpenInit) ProtoMessage

func (*MsgConnectionOpenInit) ProtoMessage()

func (*MsgConnectionOpenInit) Reset

func (m *MsgConnectionOpenInit) Reset()

func (MsgConnectionOpenInit) Route

func (msg MsgConnectionOpenInit) Route() string

Route implements sdk.Msg

func (*MsgConnectionOpenInit) Size

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

func (*MsgConnectionOpenInit) String

func (m *MsgConnectionOpenInit) String() string

func (MsgConnectionOpenInit) Type

func (msg MsgConnectionOpenInit) Type() string

Type implements sdk.Msg

func (*MsgConnectionOpenInit) Unmarshal

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

func (MsgConnectionOpenInit) ValidateBasic

func (msg MsgConnectionOpenInit) ValidateBasic() error

ValidateBasic implements sdk.Msg.

func (*MsgConnectionOpenInit) XXX_DiscardUnknown

func (m *MsgConnectionOpenInit) XXX_DiscardUnknown()

func (*MsgConnectionOpenInit) XXX_Marshal

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

func (*MsgConnectionOpenInit) XXX_Merge

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

func (*MsgConnectionOpenInit) XXX_Size

func (m *MsgConnectionOpenInit) XXX_Size() int

func (*MsgConnectionOpenInit) XXX_Unmarshal

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

type MsgConnectionOpenInitResponse

type MsgConnectionOpenInitResponse struct {
}

MsgConnectionOpenInitResponse defines the Msg/ConnectionOpenInit response type.

func (*MsgConnectionOpenInitResponse) Descriptor

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

func (*MsgConnectionOpenInitResponse) Marshal

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

func (*MsgConnectionOpenInitResponse) MarshalTo

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

func (*MsgConnectionOpenInitResponse) MarshalToSizedBuffer

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

func (*MsgConnectionOpenInitResponse) ProtoMessage

func (*MsgConnectionOpenInitResponse) ProtoMessage()

func (*MsgConnectionOpenInitResponse) Reset

func (m *MsgConnectionOpenInitResponse) Reset()

func (*MsgConnectionOpenInitResponse) Size

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

func (*MsgConnectionOpenInitResponse) String

func (*MsgConnectionOpenInitResponse) Unmarshal

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

func (*MsgConnectionOpenInitResponse) XXX_DiscardUnknown

func (m *MsgConnectionOpenInitResponse) XXX_DiscardUnknown()

func (*MsgConnectionOpenInitResponse) XXX_Marshal

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

func (*MsgConnectionOpenInitResponse) XXX_Merge

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

func (*MsgConnectionOpenInitResponse) XXX_Size

func (m *MsgConnectionOpenInitResponse) XXX_Size() int

func (*MsgConnectionOpenInitResponse) XXX_Unmarshal

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

type MsgConnectionOpenTry

type MsgConnectionOpenTry struct {
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty" yaml:"client_id"`
	// in the case of crossing hello's, when both chains call OpenInit, we need the connection identifier
	// of the previous connection in state INIT
	PreviousConnectionId string        `` /* 153-byte string literal not displayed */
	ClientState          *types.Any    `protobuf:"bytes,3,opt,name=client_state,json=clientState,proto3" json:"client_state,omitempty" yaml:"client_state"`
	Counterparty         Counterparty  `protobuf:"bytes,4,opt,name=counterparty,proto3" json:"counterparty"`
	DelayPeriod          uint64        `protobuf:"varint,5,opt,name=delay_period,json=delayPeriod,proto3" json:"delay_period,omitempty" yaml:"delay_period"`
	CounterpartyVersions []*Version    `` /* 150-byte string literal not displayed */
	ProofHeight          types1.Height `protobuf:"bytes,7,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"`
	// proof of the initialization the connection on Chain A: `UNITIALIZED ->
	// INIT`
	ProofInit []byte `protobuf:"bytes,8,opt,name=proof_init,json=proofInit,proto3" json:"proof_init,omitempty" yaml:"proof_init"`
	// proof of client state included in message
	ProofClient []byte `protobuf:"bytes,9,opt,name=proof_client,json=proofClient,proto3" json:"proof_client,omitempty" yaml:"proof_client"`
	// proof of client consensus state
	ProofConsensus  []byte        `` /* 127-byte string literal not displayed */
	ConsensusHeight types1.Height `protobuf:"bytes,11,opt,name=consensus_height,json=consensusHeight,proto3" json:"consensus_height" yaml:"consensus_height"`
	Signer          string        `protobuf:"bytes,12,opt,name=signer,proto3" json:"signer,omitempty"`
}

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

func NewMsgConnectionOpenTry

func NewMsgConnectionOpenTry(
	previousConnectionID, clientID, counterpartyConnectionID,
	counterpartyClientID string, counterpartyClient exported.ClientState,
	counterpartyPrefix commitmenttypes.MerklePrefix,
	counterpartyVersions []*Version, delayPeriod uint64,
	proofInit, proofClient, proofConsensus []byte,
	proofHeight, consensusHeight clienttypes.Height, signer sdk.AccAddress,
) *MsgConnectionOpenTry

NewMsgConnectionOpenTry creates a new MsgConnectionOpenTry instance

func (*MsgConnectionOpenTry) Descriptor

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

func (MsgConnectionOpenTry) GetSignBytes

func (msg MsgConnectionOpenTry) GetSignBytes() []byte

GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which IBC does not support.

func (MsgConnectionOpenTry) GetSigners

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

GetSigners implements sdk.Msg

func (*MsgConnectionOpenTry) Marshal

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

func (*MsgConnectionOpenTry) MarshalTo

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

func (*MsgConnectionOpenTry) MarshalToSizedBuffer

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

func (*MsgConnectionOpenTry) ProtoMessage

func (*MsgConnectionOpenTry) ProtoMessage()

func (*MsgConnectionOpenTry) Reset

func (m *MsgConnectionOpenTry) Reset()

func (MsgConnectionOpenTry) Route

func (msg MsgConnectionOpenTry) Route() string

Route implements sdk.Msg

func (*MsgConnectionOpenTry) Size

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

func (*MsgConnectionOpenTry) String

func (m *MsgConnectionOpenTry) String() string

func (MsgConnectionOpenTry) Type

func (msg MsgConnectionOpenTry) Type() string

Type implements sdk.Msg

func (*MsgConnectionOpenTry) Unmarshal

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

func (MsgConnectionOpenTry) UnpackInterfaces

func (msg MsgConnectionOpenTry) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (MsgConnectionOpenTry) ValidateBasic

func (msg MsgConnectionOpenTry) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgConnectionOpenTry) XXX_DiscardUnknown

func (m *MsgConnectionOpenTry) XXX_DiscardUnknown()

func (*MsgConnectionOpenTry) XXX_Marshal

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

func (*MsgConnectionOpenTry) XXX_Merge

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

func (*MsgConnectionOpenTry) XXX_Size

func (m *MsgConnectionOpenTry) XXX_Size() int

func (*MsgConnectionOpenTry) XXX_Unmarshal

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

type MsgConnectionOpenTryResponse

type MsgConnectionOpenTryResponse struct {
}

MsgConnectionOpenTryResponse defines the Msg/ConnectionOpenTry response type.

func (*MsgConnectionOpenTryResponse) Descriptor

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

func (*MsgConnectionOpenTryResponse) Marshal

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

func (*MsgConnectionOpenTryResponse) MarshalTo

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

func (*MsgConnectionOpenTryResponse) MarshalToSizedBuffer

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

func (*MsgConnectionOpenTryResponse) ProtoMessage

func (*MsgConnectionOpenTryResponse) ProtoMessage()

func (*MsgConnectionOpenTryResponse) Reset

func (m *MsgConnectionOpenTryResponse) Reset()

func (*MsgConnectionOpenTryResponse) Size

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

func (*MsgConnectionOpenTryResponse) String

func (*MsgConnectionOpenTryResponse) Unmarshal

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

func (*MsgConnectionOpenTryResponse) XXX_DiscardUnknown

func (m *MsgConnectionOpenTryResponse) XXX_DiscardUnknown()

func (*MsgConnectionOpenTryResponse) XXX_Marshal

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

func (*MsgConnectionOpenTryResponse) XXX_Merge

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

func (*MsgConnectionOpenTryResponse) XXX_Size

func (m *MsgConnectionOpenTryResponse) XXX_Size() int

func (*MsgConnectionOpenTryResponse) XXX_Unmarshal

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

type MsgServer

type MsgServer interface {
	// ConnectionOpenInit defines a rpc handler method for MsgConnectionOpenInit.
	ConnectionOpenInit(context.Context, *MsgConnectionOpenInit) (*MsgConnectionOpenInitResponse, error)
	// ConnectionOpenTry defines a rpc handler method for MsgConnectionOpenTry.
	ConnectionOpenTry(context.Context, *MsgConnectionOpenTry) (*MsgConnectionOpenTryResponse, error)
	// ConnectionOpenAck defines a rpc handler method for MsgConnectionOpenAck.
	ConnectionOpenAck(context.Context, *MsgConnectionOpenAck) (*MsgConnectionOpenAckResponse, error)
	// ConnectionOpenConfirm defines a rpc handler method for MsgConnectionOpenConfirm.
	ConnectionOpenConfirm(context.Context, *MsgConnectionOpenConfirm) (*MsgConnectionOpenConfirmResponse, error)
}

MsgServer is the server API for Msg service.

type QueryClient

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

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryClientConnectionsRequest

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

func NewQueryClientConnectionsRequest(clientID string) *QueryClientConnectionsRequest

NewQueryClientConnectionsRequest creates a new QueryClientConnectionsRequest instance

func (*QueryClientConnectionsRequest) Descriptor

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

func (*QueryClientConnectionsRequest) GetClientId

func (m *QueryClientConnectionsRequest) GetClientId() string

func (*QueryClientConnectionsRequest) Marshal

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

func (*QueryClientConnectionsRequest) MarshalTo

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

func (*QueryClientConnectionsRequest) MarshalToSizedBuffer

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

func (*QueryClientConnectionsRequest) ProtoMessage

func (*QueryClientConnectionsRequest) ProtoMessage()

func (*QueryClientConnectionsRequest) Reset

func (m *QueryClientConnectionsRequest) Reset()

func (*QueryClientConnectionsRequest) Size

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

func (*QueryClientConnectionsRequest) String

func (*QueryClientConnectionsRequest) Unmarshal

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

func (*QueryClientConnectionsRequest) XXX_DiscardUnknown

func (m *QueryClientConnectionsRequest) XXX_DiscardUnknown()

func (*QueryClientConnectionsRequest) XXX_Marshal

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

func (*QueryClientConnectionsRequest) XXX_Merge

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

func (*QueryClientConnectionsRequest) XXX_Size

func (m *QueryClientConnectionsRequest) XXX_Size() int

func (*QueryClientConnectionsRequest) XXX_Unmarshal

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

type QueryClientConnectionsResponse

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"`
	// height at which the proof was generated
	ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

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

func NewQueryClientConnectionsResponse

func NewQueryClientConnectionsResponse(
	connectionPaths []string, proof []byte, height clienttypes.Height,
) *QueryClientConnectionsResponse

NewQueryClientConnectionsResponse creates a new ConnectionPaths instance

func (*QueryClientConnectionsResponse) Descriptor

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

func (*QueryClientConnectionsResponse) GetConnectionPaths

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

func (*QueryClientConnectionsResponse) GetProof

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

func (*QueryClientConnectionsResponse) GetProofHeight

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

func (*QueryClientConnectionsResponse) Marshal

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

func (*QueryClientConnectionsResponse) MarshalTo

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

func (*QueryClientConnectionsResponse) MarshalToSizedBuffer

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

func (*QueryClientConnectionsResponse) ProtoMessage

func (*QueryClientConnectionsResponse) ProtoMessage()

func (*QueryClientConnectionsResponse) Reset

func (m *QueryClientConnectionsResponse) Reset()

func (*QueryClientConnectionsResponse) Size

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

func (*QueryClientConnectionsResponse) String

func (*QueryClientConnectionsResponse) Unmarshal

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

func (*QueryClientConnectionsResponse) XXX_DiscardUnknown

func (m *QueryClientConnectionsResponse) XXX_DiscardUnknown()

func (*QueryClientConnectionsResponse) XXX_Marshal

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

func (*QueryClientConnectionsResponse) XXX_Merge

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

func (*QueryClientConnectionsResponse) XXX_Size

func (m *QueryClientConnectionsResponse) XXX_Size() int

func (*QueryClientConnectionsResponse) XXX_Unmarshal

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

type QueryConnectionClientStateRequest

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

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

func (*QueryConnectionClientStateRequest) Descriptor

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

func (*QueryConnectionClientStateRequest) GetConnectionId

func (m *QueryConnectionClientStateRequest) GetConnectionId() string

func (*QueryConnectionClientStateRequest) Marshal

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

func (*QueryConnectionClientStateRequest) MarshalTo

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

func (*QueryConnectionClientStateRequest) MarshalToSizedBuffer

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

func (*QueryConnectionClientStateRequest) ProtoMessage

func (*QueryConnectionClientStateRequest) ProtoMessage()

func (*QueryConnectionClientStateRequest) Reset

func (*QueryConnectionClientStateRequest) Size

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

func (*QueryConnectionClientStateRequest) String

func (*QueryConnectionClientStateRequest) Unmarshal

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

func (*QueryConnectionClientStateRequest) XXX_DiscardUnknown

func (m *QueryConnectionClientStateRequest) XXX_DiscardUnknown()

func (*QueryConnectionClientStateRequest) XXX_Marshal

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

func (*QueryConnectionClientStateRequest) XXX_Merge

func (*QueryConnectionClientStateRequest) XXX_Size

func (m *QueryConnectionClientStateRequest) XXX_Size() int

func (*QueryConnectionClientStateRequest) XXX_Unmarshal

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

type QueryConnectionClientStateResponse

type QueryConnectionClientStateResponse struct {
	// client state associated with the channel
	IdentifiedClientState *types.IdentifiedClientState `` /* 126-byte string literal not displayed */
	// 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"`
}

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

func NewQueryConnectionClientStateResponse

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

NewQueryConnectionClientStateResponse creates a newQueryConnectionClientStateResponse instance

func (*QueryConnectionClientStateResponse) Descriptor

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

func (*QueryConnectionClientStateResponse) GetIdentifiedClientState

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

func (*QueryConnectionClientStateResponse) GetProof

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

func (*QueryConnectionClientStateResponse) GetProofHeight

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

func (*QueryConnectionClientStateResponse) Marshal

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

func (*QueryConnectionClientStateResponse) MarshalTo

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

func (*QueryConnectionClientStateResponse) MarshalToSizedBuffer

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

func (*QueryConnectionClientStateResponse) ProtoMessage

func (*QueryConnectionClientStateResponse) ProtoMessage()

func (*QueryConnectionClientStateResponse) Reset

func (*QueryConnectionClientStateResponse) Size

func (*QueryConnectionClientStateResponse) String

func (*QueryConnectionClientStateResponse) Unmarshal

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

func (QueryConnectionClientStateResponse) UnpackInterfaces

func (qccsr QueryConnectionClientStateResponse) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMesssage.UnpackInterfaces

func (*QueryConnectionClientStateResponse) XXX_DiscardUnknown

func (m *QueryConnectionClientStateResponse) XXX_DiscardUnknown()

func (*QueryConnectionClientStateResponse) XXX_Marshal

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

func (*QueryConnectionClientStateResponse) XXX_Merge

func (*QueryConnectionClientStateResponse) XXX_Size

func (*QueryConnectionClientStateResponse) XXX_Unmarshal

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

type QueryConnectionConsensusStateRequest

type QueryConnectionConsensusStateRequest struct {
	// connection identifier
	ConnectionId   string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty" yaml:"connection_id"`
	RevisionNumber uint64 `protobuf:"varint,2,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"`
	RevisionHeight uint64 `protobuf:"varint,3,opt,name=revision_height,json=revisionHeight,proto3" json:"revision_height,omitempty"`
}

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

func (*QueryConnectionConsensusStateRequest) Descriptor

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

func (*QueryConnectionConsensusStateRequest) GetConnectionId

func (m *QueryConnectionConsensusStateRequest) GetConnectionId() string

func (*QueryConnectionConsensusStateRequest) GetRevisionHeight

func (m *QueryConnectionConsensusStateRequest) GetRevisionHeight() uint64

func (*QueryConnectionConsensusStateRequest) GetRevisionNumber

func (m *QueryConnectionConsensusStateRequest) GetRevisionNumber() uint64

func (*QueryConnectionConsensusStateRequest) Marshal

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

func (*QueryConnectionConsensusStateRequest) MarshalTo

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

func (*QueryConnectionConsensusStateRequest) MarshalToSizedBuffer

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

func (*QueryConnectionConsensusStateRequest) ProtoMessage

func (*QueryConnectionConsensusStateRequest) ProtoMessage()

func (*QueryConnectionConsensusStateRequest) Reset

func (*QueryConnectionConsensusStateRequest) Size

func (*QueryConnectionConsensusStateRequest) String

func (*QueryConnectionConsensusStateRequest) Unmarshal

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

func (*QueryConnectionConsensusStateRequest) XXX_DiscardUnknown

func (m *QueryConnectionConsensusStateRequest) XXX_DiscardUnknown()

func (*QueryConnectionConsensusStateRequest) XXX_Marshal

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

func (*QueryConnectionConsensusStateRequest) XXX_Merge

func (*QueryConnectionConsensusStateRequest) XXX_Size

func (*QueryConnectionConsensusStateRequest) XXX_Unmarshal

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

type QueryConnectionConsensusStateResponse

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"`
	// height at which the proof was retrieved
	ProofHeight types.Height `protobuf:"bytes,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

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

func NewQueryConnectionConsensusStateResponse

func NewQueryConnectionConsensusStateResponse(clientID string, anyConsensusState *codectypes.Any, consensusStateHeight exported.Height, proof []byte, height clienttypes.Height) *QueryConnectionConsensusStateResponse

NewQueryConnectionConsensusStateResponse creates a newQueryConnectionConsensusStateResponse instance

func (*QueryConnectionConsensusStateResponse) Descriptor

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

func (*QueryConnectionConsensusStateResponse) GetClientId

func (*QueryConnectionConsensusStateResponse) GetConsensusState

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

func (*QueryConnectionConsensusStateResponse) GetProof

func (*QueryConnectionConsensusStateResponse) GetProofHeight

func (*QueryConnectionConsensusStateResponse) Marshal

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

func (*QueryConnectionConsensusStateResponse) MarshalTo

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

func (*QueryConnectionConsensusStateResponse) MarshalToSizedBuffer

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

func (*QueryConnectionConsensusStateResponse) ProtoMessage

func (*QueryConnectionConsensusStateResponse) ProtoMessage()

func (*QueryConnectionConsensusStateResponse) Reset

func (*QueryConnectionConsensusStateResponse) Size

func (*QueryConnectionConsensusStateResponse) String

func (*QueryConnectionConsensusStateResponse) Unmarshal

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

func (QueryConnectionConsensusStateResponse) UnpackInterfaces

func (qccsr QueryConnectionConsensusStateResponse) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMesssage.UnpackInterfaces

func (*QueryConnectionConsensusStateResponse) XXX_DiscardUnknown

func (m *QueryConnectionConsensusStateResponse) XXX_DiscardUnknown()

func (*QueryConnectionConsensusStateResponse) XXX_Marshal

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

func (*QueryConnectionConsensusStateResponse) XXX_Merge

func (*QueryConnectionConsensusStateResponse) XXX_Size

func (*QueryConnectionConsensusStateResponse) XXX_Unmarshal

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

type QueryConnectionRequest

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

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

func (*QueryConnectionRequest) GetConnectionId

func (m *QueryConnectionRequest) GetConnectionId() string

func (*QueryConnectionRequest) Marshal

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

func (*QueryConnectionRequest) MarshalTo

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

func (*QueryConnectionRequest) MarshalToSizedBuffer

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

func (*QueryConnectionRequest) ProtoMessage

func (*QueryConnectionRequest) ProtoMessage()

func (*QueryConnectionRequest) Reset

func (m *QueryConnectionRequest) Reset()

func (*QueryConnectionRequest) Size

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

func (*QueryConnectionRequest) String

func (m *QueryConnectionRequest) String() string

func (*QueryConnectionRequest) Unmarshal

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

func (*QueryConnectionRequest) XXX_DiscardUnknown

func (m *QueryConnectionRequest) XXX_DiscardUnknown()

func (*QueryConnectionRequest) XXX_Marshal

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

func (*QueryConnectionRequest) XXX_Merge

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

func (*QueryConnectionRequest) XXX_Size

func (m *QueryConnectionRequest) XXX_Size() int

func (*QueryConnectionRequest) XXX_Unmarshal

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

type QueryConnectionResponse

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"`
	// height at which the proof was retrieved
	ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

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

func NewQueryConnectionResponse(
	connection ConnectionEnd, proof []byte, height clienttypes.Height,
) *QueryConnectionResponse

NewQueryConnectionResponse creates a new QueryConnectionResponse instance

func (*QueryConnectionResponse) Descriptor

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

func (*QueryConnectionResponse) GetConnection

func (m *QueryConnectionResponse) GetConnection() *ConnectionEnd

func (*QueryConnectionResponse) GetProof

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

func (*QueryConnectionResponse) GetProofHeight

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

func (*QueryConnectionResponse) Marshal

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

func (*QueryConnectionResponse) MarshalTo

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

func (*QueryConnectionResponse) MarshalToSizedBuffer

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

func (*QueryConnectionResponse) ProtoMessage

func (*QueryConnectionResponse) ProtoMessage()

func (*QueryConnectionResponse) Reset

func (m *QueryConnectionResponse) Reset()

func (*QueryConnectionResponse) Size

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

func (*QueryConnectionResponse) String

func (m *QueryConnectionResponse) String() string

func (*QueryConnectionResponse) Unmarshal

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

func (*QueryConnectionResponse) XXX_DiscardUnknown

func (m *QueryConnectionResponse) XXX_DiscardUnknown()

func (*QueryConnectionResponse) XXX_Marshal

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

func (*QueryConnectionResponse) XXX_Merge

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

func (*QueryConnectionResponse) XXX_Size

func (m *QueryConnectionResponse) XXX_Size() int

func (*QueryConnectionResponse) XXX_Unmarshal

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

type QueryConnectionsRequest

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

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

func (*QueryConnectionsRequest) GetPagination

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

func (*QueryConnectionsRequest) Marshal

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

func (*QueryConnectionsRequest) MarshalTo

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

func (*QueryConnectionsRequest) MarshalToSizedBuffer

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

func (*QueryConnectionsRequest) ProtoMessage

func (*QueryConnectionsRequest) ProtoMessage()

func (*QueryConnectionsRequest) Reset

func (m *QueryConnectionsRequest) Reset()

func (*QueryConnectionsRequest) Size

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

func (*QueryConnectionsRequest) String

func (m *QueryConnectionsRequest) String() string

func (*QueryConnectionsRequest) Unmarshal

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

func (*QueryConnectionsRequest) XXX_DiscardUnknown

func (m *QueryConnectionsRequest) XXX_DiscardUnknown()

func (*QueryConnectionsRequest) XXX_Marshal

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

func (*QueryConnectionsRequest) XXX_Merge

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

func (*QueryConnectionsRequest) XXX_Size

func (m *QueryConnectionsRequest) XXX_Size() int

func (*QueryConnectionsRequest) XXX_Unmarshal

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

type QueryConnectionsResponse

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 types.Height `protobuf:"bytes,3,opt,name=height,proto3" json:"height"`
}

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

func (*QueryConnectionsResponse) Descriptor

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

func (*QueryConnectionsResponse) GetConnections

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

func (*QueryConnectionsResponse) GetHeight

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

func (*QueryConnectionsResponse) GetPagination

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

func (*QueryConnectionsResponse) Marshal

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

func (*QueryConnectionsResponse) MarshalTo

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

func (*QueryConnectionsResponse) MarshalToSizedBuffer

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

func (*QueryConnectionsResponse) ProtoMessage

func (*QueryConnectionsResponse) ProtoMessage()

func (*QueryConnectionsResponse) Reset

func (m *QueryConnectionsResponse) Reset()

func (*QueryConnectionsResponse) Size

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

func (*QueryConnectionsResponse) String

func (m *QueryConnectionsResponse) String() string

func (*QueryConnectionsResponse) Unmarshal

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

func (*QueryConnectionsResponse) XXX_DiscardUnknown

func (m *QueryConnectionsResponse) XXX_DiscardUnknown()

func (*QueryConnectionsResponse) XXX_Marshal

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

func (*QueryConnectionsResponse) XXX_Merge

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

func (*QueryConnectionsResponse) XXX_Size

func (m *QueryConnectionsResponse) XXX_Size() int

func (*QueryConnectionsResponse) XXX_Unmarshal

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

type QueryServer

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

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

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

func (State) String

func (x State) String() string

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ConnectionOpenAck

func (*UnimplementedMsgServer) ConnectionOpenConfirm

func (*UnimplementedMsgServer) ConnectionOpenInit

func (*UnimplementedMsgServer) ConnectionOpenTry

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ClientConnections

func (*UnimplementedQueryServer) Connection

func (*UnimplementedQueryServer) Connections

type Version

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 ExportedVersionsToProto

func ExportedVersionsToProto(exportedVersions []exported.Version) []*Version

ExportedVersionsToProto casts a slice of the Version interface to a slice of the Version proto definition.

func NewVersion

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

NewVersion returns a new instance of Version.

func PickVersion

func PickVersion(supportedVersions, counterpartyVersions []exported.Version) (*Version, 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.

CONTRACT: PickVersion must only provide a version that is in the intersection of the supported versions and the counterparty versions.

func (*Version) Descriptor

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

func (Version) GetFeatures

func (version Version) GetFeatures() []string

GetFeatures implements the VersionI interface

func (Version) GetIdentifier

func (version Version) GetIdentifier() string

GetIdentifier implements the VersionI interface

func (*Version) Marshal

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

func (*Version) MarshalTo

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

func (*Version) MarshalToSizedBuffer

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

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) Reset

func (m *Version) Reset()

func (*Version) Size

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

func (*Version) String

func (m *Version) String() string

func (*Version) Unmarshal

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

func (Version) VerifyProposedVersion

func (version Version) VerifyProposedVersion(proposedVersion exported.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

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal

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

func (*Version) XXX_Merge

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

func (*Version) XXX_Size

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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