Versions in this module Expand all Collapse all v0 v0.1.17 Jun 13, 2023 Changes in this version + const AttributeKeyChainID + const AttributeKeyConnectionID + const AttributeKeyHeight + const AttributeKeyParams + const AttributeKeyQueryID + const AttributeKeyRequest + const AttributeKeyType + const AttributeValueCategory + const AttributeValueQuery + const ModuleName + const QuerierRoute + const RouterKey + const StoreKey + const TypeMsgSubmitQueryResponse + var ErrAlreadyFulfilled = errors.New("query already fulfilled") + var ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMessages = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthMessages = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrSucceededNoDelete = errors.New("query succeeded; do not not execute default behavior") + var ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupMessages = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") + var KeyPrefixData = []byte + var KeyPrefixQuery = []byte + var ModuleCdc = codec.NewAminoCodec(amino) + func KeyPrefix(p string) []byte + func RegisterInterfaces(registry types.InterfaceRegistry) + func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino) + func RegisterMsgHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error + func RegisterMsgHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error + func RegisterMsgServer(s grpc1.Server, srv MsgServer) + func RegisterQuerySrvrHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterQuerySrvrHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QuerySrvrClient) error + func RegisterQuerySrvrHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterQuerySrvrHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QuerySrvrServer) error + func RegisterQuerySrvrServer(s grpc1.Server, srv QuerySrvrServer) + type DataPoint struct + Id string + LocalHeight github_com_cosmos_cosmos_sdk_types.Int + RemoteHeight github_com_cosmos_cosmos_sdk_types.Int + Value []byte + func (*DataPoint) Descriptor() ([]byte, []int) + func (*DataPoint) ProtoMessage() + func (m *DataPoint) GetId() string + func (m *DataPoint) GetValue() []byte + func (m *DataPoint) Marshal() (dAtA []byte, err error) + func (m *DataPoint) MarshalTo(dAtA []byte) (int, error) + func (m *DataPoint) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DataPoint) Reset() + func (m *DataPoint) Size() (n int) + func (m *DataPoint) String() string + func (m *DataPoint) Unmarshal(dAtA []byte) error + func (m *DataPoint) XXX_DiscardUnknown() + func (m *DataPoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataPoint) XXX_Merge(src proto.Message) + func (m *DataPoint) XXX_Size() int + func (m *DataPoint) XXX_Unmarshal(b []byte) error + type GenesisState struct + Queries []Query + func DefaultGenesis() *GenesisState + func NewGenesisState(queries []Query) *GenesisState + func (*GenesisState) Descriptor() ([]byte, []int) + func (*GenesisState) ProtoMessage() + func (gs GenesisState) Validate() error + func (m *GenesisState) GetQueries() []Query + 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 (m *GenesisState) Reset() + func (m *GenesisState) Size() (n int) + func (m *GenesisState) String() string + func (m *GenesisState) Unmarshal(dAtA []byte) 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 GetTxWithProofResponse struct + Header *types2.Header + Proof *types1.TxProof + Tx *tx.Tx + TxResponse *types.TxResponse + func (*GetTxWithProofResponse) Descriptor() ([]byte, []int) + func (*GetTxWithProofResponse) ProtoMessage() + func (m *GetTxWithProofResponse) GetHeader() *types2.Header + func (m *GetTxWithProofResponse) GetProof() *types1.TxProof + func (m *GetTxWithProofResponse) GetTx() *tx.Tx + func (m *GetTxWithProofResponse) GetTxResponse() *types.TxResponse + func (m *GetTxWithProofResponse) Marshal() (dAtA []byte, err error) + func (m *GetTxWithProofResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetTxWithProofResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetTxWithProofResponse) Reset() + func (m *GetTxWithProofResponse) Size() (n int) + func (m *GetTxWithProofResponse) String() string + func (m *GetTxWithProofResponse) Unmarshal(dAtA []byte) error + func (m *GetTxWithProofResponse) XXX_DiscardUnknown() + func (m *GetTxWithProofResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetTxWithProofResponse) XXX_Merge(src proto.Message) + func (m *GetTxWithProofResponse) XXX_Size() int + func (m *GetTxWithProofResponse) XXX_Unmarshal(b []byte) error + type MsgClient interface + SubmitQueryResponse func(ctx context.Context, in *MsgSubmitQueryResponse, opts ...grpc.CallOption) (*MsgSubmitQueryResponseResponse, error) + func NewMsgClient(cc grpc1.ClientConn) MsgClient + type MsgServer interface + SubmitQueryResponse func(context.Context, *MsgSubmitQueryResponse) (*MsgSubmitQueryResponseResponse, error) + type MsgSubmitQueryResponse struct + ChainId string + FromAddress string + Height int64 + ProofOps *crypto.ProofOps + QueryId string + Result []byte + func (*MsgSubmitQueryResponse) Descriptor() ([]byte, []int) + func (*MsgSubmitQueryResponse) ProtoMessage() + func (m *MsgSubmitQueryResponse) Marshal() (dAtA []byte, err error) + func (m *MsgSubmitQueryResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgSubmitQueryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgSubmitQueryResponse) Reset() + func (m *MsgSubmitQueryResponse) Size() (n int) + func (m *MsgSubmitQueryResponse) String() string + func (m *MsgSubmitQueryResponse) Unmarshal(dAtA []byte) error + func (m *MsgSubmitQueryResponse) XXX_DiscardUnknown() + func (m *MsgSubmitQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgSubmitQueryResponse) XXX_Merge(src proto.Message) + func (m *MsgSubmitQueryResponse) XXX_Size() int + func (m *MsgSubmitQueryResponse) XXX_Unmarshal(b []byte) error + func (msg MsgSubmitQueryResponse) GetSignBytes() []byte + func (msg MsgSubmitQueryResponse) GetSigners() []sdk.AccAddress + func (msg MsgSubmitQueryResponse) Route() string + func (msg MsgSubmitQueryResponse) Type() string + func (msg MsgSubmitQueryResponse) ValidateBasic() error + type MsgSubmitQueryResponseResponse struct + func (*MsgSubmitQueryResponseResponse) Descriptor() ([]byte, []int) + func (*MsgSubmitQueryResponseResponse) ProtoMessage() + func (m *MsgSubmitQueryResponseResponse) Marshal() (dAtA []byte, err error) + func (m *MsgSubmitQueryResponseResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgSubmitQueryResponseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgSubmitQueryResponseResponse) Reset() + func (m *MsgSubmitQueryResponseResponse) Size() (n int) + func (m *MsgSubmitQueryResponseResponse) String() string + func (m *MsgSubmitQueryResponseResponse) Unmarshal(dAtA []byte) error + func (m *MsgSubmitQueryResponseResponse) XXX_DiscardUnknown() + func (m *MsgSubmitQueryResponseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgSubmitQueryResponseResponse) XXX_Merge(src proto.Message) + func (m *MsgSubmitQueryResponseResponse) XXX_Size() int + func (m *MsgSubmitQueryResponseResponse) XXX_Unmarshal(b []byte) error + type Query struct + CallbackId string + ChainId string + ConnectionId string + Id string + LastEmission github_com_cosmos_cosmos_sdk_types.Int + LastHeight github_com_cosmos_cosmos_sdk_types.Int + Period github_com_cosmos_cosmos_sdk_types.Int + QueryType string + Request []byte + Ttl uint64 + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) GetCallbackId() string + func (m *Query) GetChainId() string + func (m *Query) GetConnectionId() string + func (m *Query) GetId() string + func (m *Query) GetQueryType() string + func (m *Query) GetRequest() []byte + func (m *Query) GetTtl() uint64 + func (m *Query) Marshal() (dAtA []byte, err error) + func (m *Query) MarshalTo(dAtA []byte) (int, error) + func (m *Query) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Query) Reset() + func (m *Query) Size() (n int) + func (m *Query) String() string + func (m *Query) Unmarshal(dAtA []byte) error + func (m *Query) XXX_DiscardUnknown() + func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Query) XXX_Merge(src proto.Message) + func (m *Query) XXX_Size() int + func (m *Query) XXX_Unmarshal(b []byte) error + type QueryCallbacks interface + AddCallback func(id string, fn interface{}) QueryCallbacks + Call func(ctx sdk.Context, id string, args []byte, query Query) error + Has func(id string) bool + RegisterCallbacks func() QueryCallbacks + type QueryRequestsRequest struct + ChainId string + Pagination *query.PageRequest + func (*QueryRequestsRequest) Descriptor() ([]byte, []int) + func (*QueryRequestsRequest) ProtoMessage() + func (m *QueryRequestsRequest) GetChainId() string + func (m *QueryRequestsRequest) GetPagination() *query.PageRequest + func (m *QueryRequestsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryRequestsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestsRequest) Reset() + func (m *QueryRequestsRequest) Size() (n int) + func (m *QueryRequestsRequest) String() string + func (m *QueryRequestsRequest) Unmarshal(dAtA []byte) error + func (m *QueryRequestsRequest) XXX_DiscardUnknown() + func (m *QueryRequestsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestsRequest) XXX_Merge(src proto.Message) + func (m *QueryRequestsRequest) XXX_Size() int + func (m *QueryRequestsRequest) XXX_Unmarshal(b []byte) error + type QueryRequestsResponse struct + Pagination *query.PageResponse + Queries []Query + func (*QueryRequestsResponse) Descriptor() ([]byte, []int) + func (*QueryRequestsResponse) ProtoMessage() + func (m *QueryRequestsResponse) GetPagination() *query.PageResponse + func (m *QueryRequestsResponse) GetQueries() []Query + func (m *QueryRequestsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryRequestsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryRequestsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryRequestsResponse) Reset() + func (m *QueryRequestsResponse) Size() (n int) + func (m *QueryRequestsResponse) String() string + func (m *QueryRequestsResponse) Unmarshal(dAtA []byte) error + func (m *QueryRequestsResponse) XXX_DiscardUnknown() + func (m *QueryRequestsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryRequestsResponse) XXX_Merge(src proto.Message) + func (m *QueryRequestsResponse) XXX_Size() int + func (m *QueryRequestsResponse) XXX_Unmarshal(b []byte) error + type QuerySrvrClient interface + Queries func(ctx context.Context, in *QueryRequestsRequest, opts ...grpc.CallOption) (*QueryRequestsResponse, error) + func NewQuerySrvrClient(cc grpc1.ClientConn) QuerySrvrClient + type QuerySrvrServer interface + Queries func(context.Context, *QueryRequestsRequest) (*QueryRequestsResponse, error) + type UnimplementedMsgServer struct + func (*UnimplementedMsgServer) SubmitQueryResponse(ctx context.Context, req *MsgSubmitQueryResponse) (*MsgSubmitQueryResponseResponse, error) + type UnimplementedQuerySrvrServer struct + func (*UnimplementedQuerySrvrServer) Queries(ctx context.Context, req *QueryRequestsRequest) (*QueryRequestsResponse, error)