types

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2021 License: MIT Imports: 32 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-"
)
View Source 
const DefaultTimePerBlock = 30 * time.Second

DefaultTimePerBlock is the default value for maximum expected time per block (in nanoseconds).

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    = "connection_open_init"
	EventTypeConnectionOpenTry     = "connection_open_try"
	EventTypeConnectionOpenAck     = "connection_open_ack"
	EventTypeConnectionOpenConfirm = "connection_open_confirm"

	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 KeyMaxExpectedTimePerBlock = []byte("MaxExpectedTimePerBlock")

KeyMaxExpectedTimePerBlock is store's key for MaxExpectedTimePerBlock parameter

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 ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable type declaration for parameters

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 */
	Params                 Params `protobuf:"bytes,4,opt,name=params,proto3" json:"params"`
}

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, params Params,
) 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) GetParams 

func (m *GenesisState) GetParams() Params

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 string,
) *MsgConnectionOpenAck

NewMsgConnectionOpenAck creates a new MsgConnectionOpenAck instance

func (*MsgConnectionOpenAck) Descriptor 

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

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

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

func (*MsgConnectionOpenAck) String 

func (m *MsgConnectionOpenAck) String() string

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 (m *MsgConnectionOpenAckResponse) String() 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 string,
) *MsgConnectionOpenConfirm

NewMsgConnectionOpenConfirm creates a new MsgConnectionOpenConfirm instance

func (*MsgConnectionOpenConfirm) Descriptor 

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

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

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

func (*MsgConnectionOpenConfirm) String 

func (m *MsgConnectionOpenConfirm) String() string

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 (m *MsgConnectionOpenConfirmResponse) Reset()

func (*MsgConnectionOpenConfirmResponse) Size 

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

func (*MsgConnectionOpenConfirmResponse) String 

func (m *MsgConnectionOpenConfirmResponse) String() 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 (m *MsgConnectionOpenConfirmResponse) XXX_Merge(src proto.Message)

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 string,
) *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) 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) Size 

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

func (*MsgConnectionOpenInit) String 

func (m *MsgConnectionOpenInit) String() string

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 (m *MsgConnectionOpenInitResponse) String() 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 string,
) *MsgConnectionOpenTry

NewMsgConnectionOpenTry creates a new MsgConnectionOpenTry instance

func (*MsgConnectionOpenTry) Descriptor 

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

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

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

func (*MsgConnectionOpenTry) String 

func (m *MsgConnectionOpenTry) String() string

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 (m *MsgConnectionOpenTryResponse) String() 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 Params 

type Params struct {
	// maximum expected time per block (in nanoseconds), used to enforce block delay. This parameter should reflect the
	// largest amount of time that the chain might reasonably take to produce the next block under normal operating
	// conditions. A safe choice is 3-5x the expected time per block.
	MaxExpectedTimePerBlock uint64 `` /* 172-byte string literal not displayed */
}

Params defines the set of Connection parameters.

func DefaultParams 

func DefaultParams() Params

DefaultParams is the default parameter configuration for the ibc connection module

func NewParams 

func NewParams(timePerBlock uint64) Params

NewParams creates a new parameter configuration for the ibc connection module

func (*Params) Descriptor 

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

func (*Params) GetMaxExpectedTimePerBlock 

func (m *Params) GetMaxExpectedTimePerBlock() uint64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs implements params.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate ensures MaxExpectedTimePerBlock is non-zero

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

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 (m *QueryClientConnectionsRequest) String() 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 (m *QueryClientConnectionsResponse) String() 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 (m *QueryConnectionClientStateRequest) Reset()

func (*QueryConnectionClientStateRequest) Size 

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

func (*QueryConnectionClientStateRequest) String 

func (m *QueryConnectionClientStateRequest) String() 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 (m *QueryConnectionClientStateRequest) XXX_Merge(src proto.Message)

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 (m *QueryConnectionClientStateResponse) Reset()

func (*QueryConnectionClientStateResponse) Size 

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

func (*QueryConnectionClientStateResponse) String 

func (m *QueryConnectionClientStateResponse) String() 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 (m *QueryConnectionClientStateResponse) XXX_Merge(src proto.Message)

func (*QueryConnectionClientStateResponse) XXX_Size 

func (m *QueryConnectionClientStateResponse) XXX_Size() int

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 (m *QueryConnectionConsensusStateRequest) Reset()

func (*QueryConnectionConsensusStateRequest) Size 

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

func (*QueryConnectionConsensusStateRequest) String 

func (m *QueryConnectionConsensusStateRequest) String() 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 (m *QueryConnectionConsensusStateRequest) XXX_Merge(src proto.Message)

func (*QueryConnectionConsensusStateRequest) XXX_Size 

func (m *QueryConnectionConsensusStateRequest) XXX_Size() int

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 (m *QueryConnectionConsensusStateResponse) GetClientId() string

func (*QueryConnectionConsensusStateResponse) GetConsensusState 

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

func (*QueryConnectionConsensusStateResponse) GetProof 

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

func (*QueryConnectionConsensusStateResponse) GetProofHeight 

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

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 (m *QueryConnectionConsensusStateResponse) Reset()

func (*QueryConnectionConsensusStateResponse) Size 

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

func (*QueryConnectionConsensusStateResponse) String 

func (m *QueryConnectionConsensusStateResponse) String() 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 (m *QueryConnectionConsensusStateResponse) XXX_Merge(src proto.Message)

func (*QueryConnectionConsensusStateResponse) XXX_Size 

func (m *QueryConnectionConsensusStateResponse) XXX_Size() int

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) ConnectionOpenAck(ctx context.Context, req *MsgConnectionOpenAck) (*MsgConnectionOpenAckResponse, error)

func (*UnimplementedMsgServer) ConnectionOpenConfirm 

func (*UnimplementedMsgServer) ConnectionOpenConfirm(ctx context.Context, req *MsgConnectionOpenConfirm) (*MsgConnectionOpenConfirmResponse, error)

func (*UnimplementedMsgServer) ConnectionOpenInit 

func (*UnimplementedMsgServer) ConnectionOpenInit(ctx context.Context, req *MsgConnectionOpenInit) (*MsgConnectionOpenInitResponse, error)

func (*UnimplementedMsgServer) ConnectionOpenTry 

func (*UnimplementedMsgServer) ConnectionOpenTry(ctx context.Context, req *MsgConnectionOpenTry) (*MsgConnectionOpenTryResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ClientConnections 

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

func (*UnimplementedQueryServer) Connection 

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

func (*UnimplementedQueryServer) ConnectionClientState 

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

func (*UnimplementedQueryServer) ConnectionConsensusState 

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

func (*UnimplementedQueryServer) Connections 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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