Versions in this module Expand all Collapse all v16 v16.0.0 Oct 15, 2023 Changes in this version + const AttributeKeyChainId + const AttributeKeyConnectionId + const AttributeKeyHeight + const AttributeKeyParams + const AttributeKeyQueryId + const AttributeKeyRequest + const AttributeKeyType + const AttributeValueCategory + const AttributeValueQuery + const BANK_STORE_QUERY_WITH_PROOF + const ModuleName + const QuerierRoute + const RouterKey + const STAKING_STORE_QUERY_WITH_PROOF + const StoreKey + const TypeMsgSubmitQueryResponse + var ErrAlreadyFulfilled = errors.New("query already fulfilled") + var ErrFailedToRetryQuery = errors.New("failed to retry query") + var ErrICQCallbackNotFound = errors.New("icq callback id not found") + var ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMessages = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") + var ErrInvalidConsensusState = errors.New("invalid consensus state") + var ErrInvalidICQProof = errors.New("icq query response failed") + var ErrInvalidICQRequest = errors.New("invalid interchain query request") + 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 KeyQueryCounter = []byte + var ModuleCdc = codec.NewAminoCodec(amino) + var TimeoutPolicy_name = map[int32]string + var TimeoutPolicy_value = map[string]int32 + 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 RegisterQueryServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error + func RegisterQueryServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error + func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer) + 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 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 + CallbackData []byte + CallbackId string + CallbackModule string + ChainId string + ConnectionId string + Id string + QueryType string + RequestData []byte + RequestSent bool + SubmissionHeight uint64 + TimeoutDuration time.Duration + TimeoutPolicy TimeoutPolicy + TimeoutTimestamp uint64 + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) GetCallbackData() []byte + func (m *Query) GetCallbackId() string + func (m *Query) GetCallbackModule() string + func (m *Query) GetChainId() string + func (m *Query) GetConnectionId() string + func (m *Query) GetId() string + func (m *Query) GetQueryType() string + func (m *Query) GetRequestData() []byte + func (m *Query) GetRequestSent() bool + func (m *Query) GetSubmissionHeight() uint64 + func (m *Query) GetTimeoutDuration() time.Duration + func (m *Query) GetTimeoutPolicy() TimeoutPolicy + func (m *Query) GetTimeoutTimestamp() 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 + func (q Query) Description() string + func (q Query) HasTimedOut(currentBlockTime time.Time) bool + type QueryCallbacks interface + AddICQCallback func(id string, fn interface{}) QueryCallbacks + CallICQCallback func(ctx sdk.Context, id string, args []byte, query Query) error + HasICQCallback func(id string) bool + RegisterICQCallbacks func() QueryCallbacks + type QueryPendingQueriesRequest struct + func (*QueryPendingQueriesRequest) Descriptor() ([]byte, []int) + func (*QueryPendingQueriesRequest) ProtoMessage() + func (m *QueryPendingQueriesRequest) Marshal() (dAtA []byte, err error) + func (m *QueryPendingQueriesRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryPendingQueriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryPendingQueriesRequest) Reset() + func (m *QueryPendingQueriesRequest) Size() (n int) + func (m *QueryPendingQueriesRequest) String() string + func (m *QueryPendingQueriesRequest) Unmarshal(dAtA []byte) error + func (m *QueryPendingQueriesRequest) XXX_DiscardUnknown() + func (m *QueryPendingQueriesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryPendingQueriesRequest) XXX_Merge(src proto.Message) + func (m *QueryPendingQueriesRequest) XXX_Size() int + func (m *QueryPendingQueriesRequest) XXX_Unmarshal(b []byte) error + type QueryPendingQueriesResponse struct + PendingQueries []Query + func (*QueryPendingQueriesResponse) Descriptor() ([]byte, []int) + func (*QueryPendingQueriesResponse) ProtoMessage() + func (m *QueryPendingQueriesResponse) GetPendingQueries() []Query + func (m *QueryPendingQueriesResponse) Marshal() (dAtA []byte, err error) + func (m *QueryPendingQueriesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryPendingQueriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryPendingQueriesResponse) Reset() + func (m *QueryPendingQueriesResponse) Size() (n int) + func (m *QueryPendingQueriesResponse) String() string + func (m *QueryPendingQueriesResponse) Unmarshal(dAtA []byte) error + func (m *QueryPendingQueriesResponse) XXX_DiscardUnknown() + func (m *QueryPendingQueriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryPendingQueriesResponse) XXX_Merge(src proto.Message) + func (m *QueryPendingQueriesResponse) XXX_Size() int + func (m *QueryPendingQueriesResponse) XXX_Unmarshal(b []byte) error + type QueryServiceClient interface + PendingQueries func(ctx context.Context, in *QueryPendingQueriesRequest, opts ...grpc.CallOption) (*QueryPendingQueriesResponse, error) + func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient + type QueryServiceServer interface + PendingQueries func(context.Context, *QueryPendingQueriesRequest) (*QueryPendingQueriesResponse, error) + type TimeoutPolicy int32 + const TimeoutPolicy_EXECUTE_QUERY_CALLBACK + const TimeoutPolicy_REJECT_QUERY_RESPONSE + const TimeoutPolicy_RETRY_QUERY_REQUEST + func (TimeoutPolicy) EnumDescriptor() ([]byte, []int) + func (x TimeoutPolicy) String() string + type UnimplementedMsgServer struct + func (*UnimplementedMsgServer) SubmitQueryResponse(ctx context.Context, req *MsgSubmitQueryResponse) (*MsgSubmitQueryResponseResponse, error) + type UnimplementedQueryServiceServer struct + func (*UnimplementedQueryServiceServer) PendingQueries(ctx context.Context, req *QueryPendingQueriesRequest) (*QueryPendingQueriesResponse, error) v16.0.0-testnet Dec 12, 2023 Other modules containing this package github.com/Stride-Labs/stride github.com/Stride-Labs/stride/v10 github.com/Stride-Labs/stride/v11 github.com/Stride-Labs/stride/v12 github.com/Stride-Labs/stride/v13 github.com/Stride-Labs/stride/v14 github.com/Stride-Labs/stride/v15 github.com/Stride-Labs/stride/v17 github.com/Stride-Labs/stride/v18 github.com/Stride-Labs/stride/v19 github.com/Stride-Labs/stride/v20 github.com/Stride-Labs/stride/v21 github.com/Stride-Labs/stride/v22 github.com/Stride-Labs/stride/v23 github.com/Stride-Labs/stride/v24 github.com/Stride-Labs/stride/v3 github.com/Stride-Labs/stride/v4 github.com/Stride-Labs/stride/v5 github.com/Stride-Labs/stride/v6 github.com/Stride-Labs/stride/v7 github.com/Stride-Labs/stride/v8 github.com/Stride-Labs/stride/v9