Documentation
¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func FindSupportedVersion(version exported.Version, supportedVersions []exported.Version) (exported.Version, bool)
- func FormatConnectionIdentifier(sequence uint64) string
- func GetCompatibleVersions() []exported.Version
- func GetFeatureSetIntersection(sourceFeatureSet, counterpartyFeatureSet []string) (featureSet []string)
- func IsSupportedVersion(proposedVersion *Version) bool
- func IsSupportedVersionV4(supportedVersions []exported.Version, proposedVersion *Version) bool
- func IsValidConnectionID(connectionID string) bool
- func ParseConnectionSequence(connectionID string) (uint64, error)
- func ProtoVersionsToExported(versions []*Version) []exported.Version
- func RegisterInterfaces(registry codectypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- func ValidateVersion(version *Version) error
- func VerifySupportedFeature(version exported.Version, feature string) bool
- type ClientKeeper
- type ClientPaths
- func (*ClientPaths) Descriptor() ([]byte, []int)
- func (m *ClientPaths) GetPaths() []string
- func (m *ClientPaths) Marshal() (dAtA []byte, err error)
- func (m *ClientPaths) MarshalTo(dAtA []byte) (int, error)
- func (m *ClientPaths) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClientPaths) ProtoMessage()
- func (m *ClientPaths) Reset()
- func (m *ClientPaths) Size() (n int)
- func (m *ClientPaths) String() string
- func (m *ClientPaths) Unmarshal(dAtA []byte) error
- func (m *ClientPaths) XXX_DiscardUnknown()
- func (m *ClientPaths) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientPaths) XXX_Merge(src proto.Message)
- func (m *ClientPaths) XXX_Size() int
- func (m *ClientPaths) XXX_Unmarshal(b []byte) error
- type ConnectionEnd
- func (*ConnectionEnd) Descriptor() ([]byte, []int)
- func (c ConnectionEnd) GetClientID() string
- func (c ConnectionEnd) GetCounterparty() exported.CounterpartyConnectionI
- func (c ConnectionEnd) GetDelayPeriod() uint64
- func (c ConnectionEnd) GetState() int32
- func (c ConnectionEnd) GetVersions() []exported.Version
- func (m *ConnectionEnd) Marshal() (dAtA []byte, err error)
- func (m *ConnectionEnd) MarshalTo(dAtA []byte) (int, error)
- func (m *ConnectionEnd) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConnectionEnd) ProtoMessage()
- func (m *ConnectionEnd) Reset()
- func (m *ConnectionEnd) Size() (n int)
- func (m *ConnectionEnd) String() string
- func (m *ConnectionEnd) Unmarshal(dAtA []byte) error
- func (c ConnectionEnd) ValidateBasic() error
- func (m *ConnectionEnd) XXX_DiscardUnknown()
- func (m *ConnectionEnd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectionEnd) XXX_Merge(src proto.Message)
- func (m *ConnectionEnd) XXX_Size() int
- func (m *ConnectionEnd) XXX_Unmarshal(b []byte) error
- type ConnectionPaths
- func (*ConnectionPaths) Descriptor() ([]byte, []int)
- func (m *ConnectionPaths) GetClientId() string
- func (m *ConnectionPaths) GetPaths() []string
- func (m *ConnectionPaths) Marshal() (dAtA []byte, err error)
- func (m *ConnectionPaths) MarshalTo(dAtA []byte) (int, error)
- func (m *ConnectionPaths) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConnectionPaths) ProtoMessage()
- func (m *ConnectionPaths) Reset()
- func (m *ConnectionPaths) Size() (n int)
- func (m *ConnectionPaths) String() string
- func (m *ConnectionPaths) Unmarshal(dAtA []byte) error
- func (m *ConnectionPaths) XXX_DiscardUnknown()
- func (m *ConnectionPaths) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnectionPaths) XXX_Merge(src proto.Message)
- func (m *ConnectionPaths) XXX_Size() int
- func (m *ConnectionPaths) XXX_Unmarshal(b []byte) error
- type Counterparty
- func (*Counterparty) Descriptor() ([]byte, []int)
- func (c Counterparty) GetClientID() string
- func (c Counterparty) GetConnectionID() string
- func (c Counterparty) GetPrefix() exported.Prefix
- func (m *Counterparty) Marshal() (dAtA []byte, err error)
- func (m *Counterparty) MarshalTo(dAtA []byte) (int, error)
- func (m *Counterparty) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Counterparty) ProtoMessage()
- func (m *Counterparty) Reset()
- func (m *Counterparty) Size() (n int)
- func (m *Counterparty) String() string
- func (m *Counterparty) Unmarshal(dAtA []byte) error
- func (c Counterparty) ValidateBasic() error
- func (m *Counterparty) XXX_DiscardUnknown()
- func (m *Counterparty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Counterparty) XXX_Merge(src proto.Message)
- func (m *Counterparty) XXX_Size() int
- func (m *Counterparty) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetClientConnectionPaths() []ConnectionPaths
- func (m *GenesisState) GetConnections() []IdentifiedConnection
- func (m *GenesisState) GetNextConnectionSequence() uint64
- func (m *GenesisState) GetParams() Params
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type IdentifiedConnection
- func (*IdentifiedConnection) Descriptor() ([]byte, []int)
- func (m *IdentifiedConnection) Marshal() (dAtA []byte, err error)
- func (m *IdentifiedConnection) MarshalTo(dAtA []byte) (int, error)
- func (m *IdentifiedConnection) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdentifiedConnection) ProtoMessage()
- func (m *IdentifiedConnection) Reset()
- func (m *IdentifiedConnection) Size() (n int)
- func (m *IdentifiedConnection) String() string
- func (m *IdentifiedConnection) Unmarshal(dAtA []byte) error
- func (ic IdentifiedConnection) ValidateBasic() error
- func (m *IdentifiedConnection) XXX_DiscardUnknown()
- func (m *IdentifiedConnection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdentifiedConnection) XXX_Merge(src proto.Message)
- func (m *IdentifiedConnection) XXX_Size() int
- func (m *IdentifiedConnection) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgConnectionOpenAck
- func (*MsgConnectionOpenAck) Descriptor() ([]byte, []int)
- func (msg MsgConnectionOpenAck) GetSignBytes() []byte
- func (msg MsgConnectionOpenAck) GetSigners() []sdk.AccAddress
- func (m *MsgConnectionOpenAck) Marshal() (dAtA []byte, err error)
- func (m *MsgConnectionOpenAck) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgConnectionOpenAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgConnectionOpenAck) ProtoMessage()
- func (m *MsgConnectionOpenAck) Reset()
- func (msg MsgConnectionOpenAck) Route() string
- func (m *MsgConnectionOpenAck) Size() (n int)
- func (m *MsgConnectionOpenAck) String() string
- func (msg MsgConnectionOpenAck) Type() string
- func (m *MsgConnectionOpenAck) Unmarshal(dAtA []byte) error
- func (msg MsgConnectionOpenAck) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
- func (msg MsgConnectionOpenAck) ValidateBasic() error
- func (m *MsgConnectionOpenAck) XXX_DiscardUnknown()
- func (m *MsgConnectionOpenAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgConnectionOpenAck) XXX_Merge(src proto.Message)
- func (m *MsgConnectionOpenAck) XXX_Size() int
- func (m *MsgConnectionOpenAck) XXX_Unmarshal(b []byte) error
- type MsgConnectionOpenAckResponse
- func (*MsgConnectionOpenAckResponse) Descriptor() ([]byte, []int)
- func (m *MsgConnectionOpenAckResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgConnectionOpenAckResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgConnectionOpenAckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgConnectionOpenAckResponse) ProtoMessage()
- func (m *MsgConnectionOpenAckResponse) Reset()
- func (m *MsgConnectionOpenAckResponse) Size() (n int)
- func (m *MsgConnectionOpenAckResponse) String() string
- func (m *MsgConnectionOpenAckResponse) Unmarshal(dAtA []byte) error
- func (m *MsgConnectionOpenAckResponse) XXX_DiscardUnknown()
- func (m *MsgConnectionOpenAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgConnectionOpenAckResponse) XXX_Merge(src proto.Message)
- func (m *MsgConnectionOpenAckResponse) XXX_Size() int
- func (m *MsgConnectionOpenAckResponse) XXX_Unmarshal(b []byte) error
- type MsgConnectionOpenConfirm
- func (*MsgConnectionOpenConfirm) Descriptor() ([]byte, []int)
- func (msg MsgConnectionOpenConfirm) GetSignBytes() []byte
- func (msg MsgConnectionOpenConfirm) GetSigners() []sdk.AccAddress
- func (m *MsgConnectionOpenConfirm) Marshal() (dAtA []byte, err error)
- func (m *MsgConnectionOpenConfirm) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgConnectionOpenConfirm) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgConnectionOpenConfirm) ProtoMessage()
- func (m *MsgConnectionOpenConfirm) Reset()
- func (msg MsgConnectionOpenConfirm) Route() string
- func (m *MsgConnectionOpenConfirm) Size() (n int)
- func (m *MsgConnectionOpenConfirm) String() string
- func (msg MsgConnectionOpenConfirm) Type() string
- func (m *MsgConnectionOpenConfirm) Unmarshal(dAtA []byte) error
- func (msg MsgConnectionOpenConfirm) ValidateBasic() error
- func (m *MsgConnectionOpenConfirm) XXX_DiscardUnknown()
- func (m *MsgConnectionOpenConfirm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgConnectionOpenConfirm) XXX_Merge(src proto.Message)
- func (m *MsgConnectionOpenConfirm) XXX_Size() int
- func (m *MsgConnectionOpenConfirm) XXX_Unmarshal(b []byte) error
- type MsgConnectionOpenConfirmResponse
- func (*MsgConnectionOpenConfirmResponse) Descriptor() ([]byte, []int)
- func (m *MsgConnectionOpenConfirmResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgConnectionOpenConfirmResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgConnectionOpenConfirmResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgConnectionOpenConfirmResponse) ProtoMessage()
- func (m *MsgConnectionOpenConfirmResponse) Reset()
- func (m *MsgConnectionOpenConfirmResponse) Size() (n int)
- func (m *MsgConnectionOpenConfirmResponse) String() string
- func (m *MsgConnectionOpenConfirmResponse) Unmarshal(dAtA []byte) error
- func (m *MsgConnectionOpenConfirmResponse) XXX_DiscardUnknown()
- func (m *MsgConnectionOpenConfirmResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgConnectionOpenConfirmResponse) XXX_Merge(src proto.Message)
- func (m *MsgConnectionOpenConfirmResponse) XXX_Size() int
- func (m *MsgConnectionOpenConfirmResponse) XXX_Unmarshal(b []byte) error
- type MsgConnectionOpenInit
- func (*MsgConnectionOpenInit) Descriptor() ([]byte, []int)
- func (msg MsgConnectionOpenInit) GetSignBytes() []byte
- func (msg MsgConnectionOpenInit) GetSigners() []sdk.AccAddress
- func (m *MsgConnectionOpenInit) Marshal() (dAtA []byte, err error)
- func (m *MsgConnectionOpenInit) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgConnectionOpenInit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgConnectionOpenInit) ProtoMessage()
- func (m *MsgConnectionOpenInit) Reset()
- func (msg MsgConnectionOpenInit) Route() string
- func (m *MsgConnectionOpenInit) Size() (n int)
- func (m *MsgConnectionOpenInit) String() string
- func (msg MsgConnectionOpenInit) Type() string
- func (m *MsgConnectionOpenInit) Unmarshal(dAtA []byte) error
- func (msg MsgConnectionOpenInit) ValidateBasic() error
- func (m *MsgConnectionOpenInit) XXX_DiscardUnknown()
- func (m *MsgConnectionOpenInit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgConnectionOpenInit) XXX_Merge(src proto.Message)
- func (m *MsgConnectionOpenInit) XXX_Size() int
- func (m *MsgConnectionOpenInit) XXX_Unmarshal(b []byte) error
- type MsgConnectionOpenInitResponse
- func (*MsgConnectionOpenInitResponse) Descriptor() ([]byte, []int)
- func (m *MsgConnectionOpenInitResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgConnectionOpenInitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgConnectionOpenInitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgConnectionOpenInitResponse) ProtoMessage()
- func (m *MsgConnectionOpenInitResponse) Reset()
- func (m *MsgConnectionOpenInitResponse) Size() (n int)
- func (m *MsgConnectionOpenInitResponse) String() string
- func (m *MsgConnectionOpenInitResponse) Unmarshal(dAtA []byte) error
- func (m *MsgConnectionOpenInitResponse) XXX_DiscardUnknown()
- func (m *MsgConnectionOpenInitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgConnectionOpenInitResponse) XXX_Merge(src proto.Message)
- func (m *MsgConnectionOpenInitResponse) XXX_Size() int
- func (m *MsgConnectionOpenInitResponse) XXX_Unmarshal(b []byte) error
- type MsgConnectionOpenTry
- func (*MsgConnectionOpenTry) Descriptor() ([]byte, []int)
- func (msg MsgConnectionOpenTry) GetSignBytes() []byte
- func (msg MsgConnectionOpenTry) GetSigners() []sdk.AccAddress
- func (m *MsgConnectionOpenTry) Marshal() (dAtA []byte, err error)
- func (m *MsgConnectionOpenTry) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgConnectionOpenTry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgConnectionOpenTry) ProtoMessage()
- func (m *MsgConnectionOpenTry) Reset()
- func (msg MsgConnectionOpenTry) Route() string
- func (m *MsgConnectionOpenTry) Size() (n int)
- func (m *MsgConnectionOpenTry) String() string
- func (msg MsgConnectionOpenTry) Type() string
- func (m *MsgConnectionOpenTry) Unmarshal(dAtA []byte) error
- func (msg MsgConnectionOpenTry) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
- func (msg MsgConnectionOpenTry) ValidateBasic() error
- func (m *MsgConnectionOpenTry) XXX_DiscardUnknown()
- func (m *MsgConnectionOpenTry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgConnectionOpenTry) XXX_Merge(src proto.Message)
- func (m *MsgConnectionOpenTry) XXX_Size() int
- func (m *MsgConnectionOpenTry) XXX_Unmarshal(b []byte) error
- type MsgConnectionOpenTryResponse
- func (*MsgConnectionOpenTryResponse) Descriptor() ([]byte, []int)
- func (m *MsgConnectionOpenTryResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgConnectionOpenTryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgConnectionOpenTryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgConnectionOpenTryResponse) ProtoMessage()
- func (m *MsgConnectionOpenTryResponse) Reset()
- func (m *MsgConnectionOpenTryResponse) Size() (n int)
- func (m *MsgConnectionOpenTryResponse) String() string
- func (m *MsgConnectionOpenTryResponse) Unmarshal(dAtA []byte) error
- func (m *MsgConnectionOpenTryResponse) XXX_DiscardUnknown()
- func (m *MsgConnectionOpenTryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgConnectionOpenTryResponse) XXX_Merge(src proto.Message)
- func (m *MsgConnectionOpenTryResponse) XXX_Size() int
- func (m *MsgConnectionOpenTryResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (m *Params) GetMaxExpectedTimePerBlock() uint64
- func (m *Params) Marshal() (dAtA []byte, err error)
- func (m *Params) MarshalTo(dAtA []byte) (int, error)
- func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (m *Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (p Params) Validate() error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryClientConnectionsRequest
- func (*QueryClientConnectionsRequest) Descriptor() ([]byte, []int)
- func (m *QueryClientConnectionsRequest) GetClientId() string
- func (m *QueryClientConnectionsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryClientConnectionsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryClientConnectionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryClientConnectionsRequest) ProtoMessage()
- func (m *QueryClientConnectionsRequest) Reset()
- func (m *QueryClientConnectionsRequest) Size() (n int)
- func (m *QueryClientConnectionsRequest) String() string
- func (m *QueryClientConnectionsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryClientConnectionsRequest) XXX_DiscardUnknown()
- func (m *QueryClientConnectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryClientConnectionsRequest) XXX_Merge(src proto.Message)
- func (m *QueryClientConnectionsRequest) XXX_Size() int
- func (m *QueryClientConnectionsRequest) XXX_Unmarshal(b []byte) error
- type QueryClientConnectionsResponse
- func (*QueryClientConnectionsResponse) Descriptor() ([]byte, []int)
- func (m *QueryClientConnectionsResponse) GetConnectionPaths() []string
- func (m *QueryClientConnectionsResponse) GetProof() []byte
- func (m *QueryClientConnectionsResponse) GetProofHeight() types.Height
- func (m *QueryClientConnectionsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryClientConnectionsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryClientConnectionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryClientConnectionsResponse) ProtoMessage()
- func (m *QueryClientConnectionsResponse) Reset()
- func (m *QueryClientConnectionsResponse) Size() (n int)
- func (m *QueryClientConnectionsResponse) String() string
- func (m *QueryClientConnectionsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryClientConnectionsResponse) XXX_DiscardUnknown()
- func (m *QueryClientConnectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryClientConnectionsResponse) XXX_Merge(src proto.Message)
- func (m *QueryClientConnectionsResponse) XXX_Size() int
- func (m *QueryClientConnectionsResponse) XXX_Unmarshal(b []byte) error
- type QueryConnectionClientStateRequest
- func (*QueryConnectionClientStateRequest) Descriptor() ([]byte, []int)
- func (m *QueryConnectionClientStateRequest) GetConnectionId() string
- func (m *QueryConnectionClientStateRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionClientStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionClientStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionClientStateRequest) ProtoMessage()
- func (m *QueryConnectionClientStateRequest) Reset()
- func (m *QueryConnectionClientStateRequest) Size() (n int)
- func (m *QueryConnectionClientStateRequest) String() string
- func (m *QueryConnectionClientStateRequest) Unmarshal(dAtA []byte) error
- func (m *QueryConnectionClientStateRequest) XXX_DiscardUnknown()
- func (m *QueryConnectionClientStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionClientStateRequest) XXX_Merge(src proto.Message)
- func (m *QueryConnectionClientStateRequest) XXX_Size() int
- func (m *QueryConnectionClientStateRequest) XXX_Unmarshal(b []byte) error
- type QueryConnectionClientStateResponse
- func (*QueryConnectionClientStateResponse) Descriptor() ([]byte, []int)
- func (m *QueryConnectionClientStateResponse) GetIdentifiedClientState() *types.IdentifiedClientState
- func (m *QueryConnectionClientStateResponse) GetProof() []byte
- func (m *QueryConnectionClientStateResponse) GetProofHeight() types.Height
- func (m *QueryConnectionClientStateResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionClientStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionClientStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionClientStateResponse) ProtoMessage()
- func (m *QueryConnectionClientStateResponse) Reset()
- func (m *QueryConnectionClientStateResponse) Size() (n int)
- func (m *QueryConnectionClientStateResponse) String() string
- func (m *QueryConnectionClientStateResponse) Unmarshal(dAtA []byte) error
- func (qccsr QueryConnectionClientStateResponse) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
- func (m *QueryConnectionClientStateResponse) XXX_DiscardUnknown()
- func (m *QueryConnectionClientStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionClientStateResponse) XXX_Merge(src proto.Message)
- func (m *QueryConnectionClientStateResponse) XXX_Size() int
- func (m *QueryConnectionClientStateResponse) XXX_Unmarshal(b []byte) error
- type QueryConnectionConsensusStateRequest
- func (*QueryConnectionConsensusStateRequest) Descriptor() ([]byte, []int)
- func (m *QueryConnectionConsensusStateRequest) GetConnectionId() string
- func (m *QueryConnectionConsensusStateRequest) GetRevisionHeight() uint64
- func (m *QueryConnectionConsensusStateRequest) GetRevisionNumber() uint64
- func (m *QueryConnectionConsensusStateRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionConsensusStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionConsensusStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionConsensusStateRequest) ProtoMessage()
- func (m *QueryConnectionConsensusStateRequest) Reset()
- func (m *QueryConnectionConsensusStateRequest) Size() (n int)
- func (m *QueryConnectionConsensusStateRequest) String() string
- func (m *QueryConnectionConsensusStateRequest) Unmarshal(dAtA []byte) error
- func (m *QueryConnectionConsensusStateRequest) XXX_DiscardUnknown()
- func (m *QueryConnectionConsensusStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionConsensusStateRequest) XXX_Merge(src proto.Message)
- func (m *QueryConnectionConsensusStateRequest) XXX_Size() int
- func (m *QueryConnectionConsensusStateRequest) XXX_Unmarshal(b []byte) error
- type QueryConnectionConsensusStateResponse
- func (*QueryConnectionConsensusStateResponse) Descriptor() ([]byte, []int)
- func (m *QueryConnectionConsensusStateResponse) GetClientId() string
- func (m *QueryConnectionConsensusStateResponse) GetConsensusState() *types1.Any
- func (m *QueryConnectionConsensusStateResponse) GetProof() []byte
- func (m *QueryConnectionConsensusStateResponse) GetProofHeight() types.Height
- func (m *QueryConnectionConsensusStateResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionConsensusStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionConsensusStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionConsensusStateResponse) ProtoMessage()
- func (m *QueryConnectionConsensusStateResponse) Reset()
- func (m *QueryConnectionConsensusStateResponse) Size() (n int)
- func (m *QueryConnectionConsensusStateResponse) String() string
- func (m *QueryConnectionConsensusStateResponse) Unmarshal(dAtA []byte) error
- func (qccsr QueryConnectionConsensusStateResponse) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
- func (m *QueryConnectionConsensusStateResponse) XXX_DiscardUnknown()
- func (m *QueryConnectionConsensusStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionConsensusStateResponse) XXX_Merge(src proto.Message)
- func (m *QueryConnectionConsensusStateResponse) XXX_Size() int
- func (m *QueryConnectionConsensusStateResponse) XXX_Unmarshal(b []byte) error
- type QueryConnectionRequest
- func (*QueryConnectionRequest) Descriptor() ([]byte, []int)
- func (m *QueryConnectionRequest) GetConnectionId() string
- func (m *QueryConnectionRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionRequest) ProtoMessage()
- func (m *QueryConnectionRequest) Reset()
- func (m *QueryConnectionRequest) Size() (n int)
- func (m *QueryConnectionRequest) String() string
- func (m *QueryConnectionRequest) Unmarshal(dAtA []byte) error
- func (m *QueryConnectionRequest) XXX_DiscardUnknown()
- func (m *QueryConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionRequest) XXX_Merge(src proto.Message)
- func (m *QueryConnectionRequest) XXX_Size() int
- func (m *QueryConnectionRequest) XXX_Unmarshal(b []byte) error
- type QueryConnectionResponse
- func (*QueryConnectionResponse) Descriptor() ([]byte, []int)
- func (m *QueryConnectionResponse) GetConnection() *ConnectionEnd
- func (m *QueryConnectionResponse) GetProof() []byte
- func (m *QueryConnectionResponse) GetProofHeight() types.Height
- func (m *QueryConnectionResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionResponse) ProtoMessage()
- func (m *QueryConnectionResponse) Reset()
- func (m *QueryConnectionResponse) Size() (n int)
- func (m *QueryConnectionResponse) String() string
- func (m *QueryConnectionResponse) Unmarshal(dAtA []byte) error
- func (m *QueryConnectionResponse) XXX_DiscardUnknown()
- func (m *QueryConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionResponse) XXX_Merge(src proto.Message)
- func (m *QueryConnectionResponse) XXX_Size() int
- func (m *QueryConnectionResponse) XXX_Unmarshal(b []byte) error
- type QueryConnectionsRequest
- func (*QueryConnectionsRequest) Descriptor() ([]byte, []int)
- func (m *QueryConnectionsRequest) GetPagination() *query.PageRequest
- func (m *QueryConnectionsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionsRequest) ProtoMessage()
- func (m *QueryConnectionsRequest) Reset()
- func (m *QueryConnectionsRequest) Size() (n int)
- func (m *QueryConnectionsRequest) String() string
- func (m *QueryConnectionsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryConnectionsRequest) XXX_DiscardUnknown()
- func (m *QueryConnectionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionsRequest) XXX_Merge(src proto.Message)
- func (m *QueryConnectionsRequest) XXX_Size() int
- func (m *QueryConnectionsRequest) XXX_Unmarshal(b []byte) error
- type QueryConnectionsResponse
- func (*QueryConnectionsResponse) Descriptor() ([]byte, []int)
- func (m *QueryConnectionsResponse) GetConnections() []*IdentifiedConnection
- func (m *QueryConnectionsResponse) GetHeight() types.Height
- func (m *QueryConnectionsResponse) GetPagination() *query.PageResponse
- func (m *QueryConnectionsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionsResponse) ProtoMessage()
- func (m *QueryConnectionsResponse) Reset()
- func (m *QueryConnectionsResponse) Size() (n int)
- func (m *QueryConnectionsResponse) String() string
- func (m *QueryConnectionsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryConnectionsResponse) XXX_DiscardUnknown()
- func (m *QueryConnectionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionsResponse) XXX_Merge(src proto.Message)
- func (m *QueryConnectionsResponse) XXX_Size() int
- func (m *QueryConnectionsResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type State
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) ConnectionOpenAck(ctx context.Context, req *MsgConnectionOpenAck) (*MsgConnectionOpenAckResponse, error)
- func (*UnimplementedMsgServer) ConnectionOpenConfirm(ctx context.Context, req *MsgConnectionOpenConfirm) (*MsgConnectionOpenConfirmResponse, error)
- func (*UnimplementedMsgServer) ConnectionOpenInit(ctx context.Context, req *MsgConnectionOpenInit) (*MsgConnectionOpenInitResponse, error)
- func (*UnimplementedMsgServer) ConnectionOpenTry(ctx context.Context, req *MsgConnectionOpenTry) (*MsgConnectionOpenTryResponse, error)
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) ClientConnections(ctx context.Context, req *QueryClientConnectionsRequest) (*QueryClientConnectionsResponse, error)
- func (*UnimplementedQueryServer) Connection(ctx context.Context, req *QueryConnectionRequest) (*QueryConnectionResponse, error)
- func (*UnimplementedQueryServer) ConnectionClientState(ctx context.Context, req *QueryConnectionClientStateRequest) (*QueryConnectionClientStateResponse, error)
- func (*UnimplementedQueryServer) ConnectionConsensusState(ctx context.Context, req *QueryConnectionConsensusStateRequest) (*QueryConnectionConsensusStateResponse, error)
- func (*UnimplementedQueryServer) Connections(ctx context.Context, req *QueryConnectionsRequest) (*QueryConnectionsResponse, error)
- type Version
- func (*Version) Descriptor() ([]byte, []int)
- func (version Version) GetFeatures() []string
- func (version Version) GetIdentifier() string
- func (m *Version) Marshal() (dAtA []byte, err error)
- func (m *Version) MarshalTo(dAtA []byte) (int, error)
- func (m *Version) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Version) ProtoMessage()
- func (m *Version) Reset()
- func (m *Version) Size() (n int)
- func (m *Version) String() string
- func (m *Version) Unmarshal(dAtA []byte) error
- func (version Version) VerifyProposedVersion(proposedVersion exported.Version) error
- func (m *Version) XXX_DiscardUnknown()
- func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Version) XXX_Merge(src proto.Message)
- func (m *Version) XXX_Size() int
- func (m *Version) XXX_Unmarshal(b []byte) error
Constants ¶
const ( AttributeKeyConnectionID = "connection_id" AttributeKeyClientID = "client_id" AttributeKeyCounterpartyClientID = "counterparty_client_id" AttributeKeyCounterpartyConnectionID = "counterparty_connection_id" )
IBC connection events
const ( // SubModuleName defines the IBC connection name SubModuleName = "connection" // StoreKey is the store key string for IBC connections StoreKey = SubModuleName // RouterKey is the message route for IBC connections RouterKey = SubModuleName // QuerierRoute is the querier route for IBC connections QuerierRoute = SubModuleName // 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-" )
const DefaultTimePerBlock = 30 * time.Second
DefaultTimePerBlock is the default value for maximum expected time per block (in nanoseconds).
Variables ¶
var ( ErrInvalidLengthConnection = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowConnection = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupConnection = fmt.Errorf("proto: unexpected end of group") )
var ( ErrConnectionExists = sdkerrors.Register(SubModuleName, 2, "connection already exists") ErrConnectionNotFound = sdkerrors.Register(SubModuleName, 3, "connection not found") ErrClientConnectionPathsNotFound = sdkerrors.Register(SubModuleName, 4, "light client connection paths not found") ErrConnectionPath = sdkerrors.Register(SubModuleName, 5, "connection path is not associated to the given light client") ErrInvalidConnectionState = sdkerrors.Register(SubModuleName, 6, "invalid connection state") ErrInvalidCounterparty = sdkerrors.Register(SubModuleName, 7, "invalid counterparty connection") ErrInvalidConnection = sdkerrors.Register(SubModuleName, 8, "invalid connection") ErrInvalidVersion = sdkerrors.Register(SubModuleName, 9, "invalid connection version") ErrVersionNegotiationFailed = sdkerrors.Register(SubModuleName, 10, "connection version negotiation failed") ErrInvalidConnectionIdentifier = sdkerrors.Register(SubModuleName, 11, "invalid connection identifier") )
IBC connection sentinel errors
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
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var ( // DefaultIBCVersion represents the latest supported version of IBC used // in connection version negotiation. The current version supports only // ORDERED and UNORDERED channels and requires at least one channel type // to be agreed upon. DefaultIBCVersion = NewVersion(DefaultIBCVersionIdentifier, []string{"ORDER_ORDERED", "ORDER_UNORDERED"}) // DefaultIBCVersionIdentifier is the IBC v1.0.0 protocol version identifier DefaultIBCVersionIdentifier = "1" )
var 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}
var KeyMaxExpectedTimePerBlock = []byte("MaxExpectedTimePerBlock")
KeyMaxExpectedTimePerBlock is store's key for MaxExpectedTimePerBlock parameter
var State_name = map[int32]string{
0: "STATE_UNINITIALIZED_UNSPECIFIED",
1: "STATE_INIT",
2: "STATE_TRYOPEN",
3: "STATE_OPEN",
}
var State_value = map[string]int32{
"STATE_UNINITIALIZED_UNSPECIFIED": 0,
"STATE_INIT": 1,
"STATE_TRYOPEN": 2,
"STATE_OPEN": 3,
}
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 ¶
FormatConnectionIdentifier returns the connection identifier with the sequence appended. This is a SDK specific format not enforced by IBC protocol.
func GetCompatibleVersions ¶
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 ¶
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 IsSupportedVersionV4 ¶ added in v1.6.7
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 ¶
IsValidConnectionID checks if the connection identifier is valid and can be parsed to the connection identifier format.
func ParseConnectionSequence ¶
ParseConnectionSequence parses the connection sequence from the connection identifier.
func ProtoVersionsToExported ¶
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 RegisterQueryHandler ¶
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 ¶
ValidateVersion does basic validation of the version identifier and features. It unmarshals the version string into a Version object.
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) GetSelfConsensusStateV4(ctx sdk.Context, height exported.Height) (exported.ConsensusState, error) 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) 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) 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) 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) 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) 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) 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 (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) 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 (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) 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 (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) 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 (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 (*Params) Descriptor ¶
func (*Params) GetMaxExpectedTimePerBlock ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ParamSetPairs ¶
func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
ParamSetPairs implements params.ParamSet
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
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.
func (State) EnumDescriptor ¶
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 ¶
ExportedVersionsToProto casts a slice of the Version interface to a slice of the Version proto definition.
func NewVersion ¶
NewVersion returns a new instance of Version.
func PickVersion ¶
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) GetFeatures ¶
GetFeatures implements the VersionI interface
func (Version) GetIdentifier ¶
GetIdentifier implements the VersionI interface
func (*Version) MarshalToSizedBuffer ¶
func (*Version) ProtoMessage ¶
func (*Version) ProtoMessage()
func (Version) VerifyProposedVersion ¶
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()