types

package
v0.0.0-...-af3b207 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2023 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName defines the module name
	ModuleName = "interchainqueries"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_interchainqueries"
)
View Source 
const (
	// EventTypeFuryaMessage defines the event type used by the Interchain Queries module events.
	EventTypeFuryaMessage = "furya"

	// AttributeKeyQueryID represents the key for event attribute delivering the query ID of a
	// registered interchain query.
	AttributeKeyQueryID = "query_id"

	// AttributeKeyOwner represents the key for event attribute delivering the address of the
	// registrator of an interchain query.
	AttributeKeyOwner = "owner"

	// AttributeKeyConnectionID represents the key for event attribute delivering the connection ID
	// of an interchain query.
	AttributeKeyConnectionID = "connection_id"

	// AttributeKeyQueryType represents the key for event attribute delivering the query type
	// identifier (e.g. 'kv' or 'tx')
	AttributeKeyQueryType = "type"

	// AttributeKeyKVQuery represents the keys of the storage we want to get from remote chain for event attribute delivering the keys
	// of an interchain query.
	AttributeKeyKVQuery = "kv_key"

	// AttributeTransactionsFilterQuery represents the transactions filter for event attribute delivering the filter
	// of an interchain query.
	AttributeTransactionsFilterQuery = "tx_filter"

	// AttributeValueCategory represents the value for the 'module' event attribute.
	AttributeValueCategory = ModuleName

	// AttributeValueQueryUpdated represents the value for the 'action' event attribute.
	AttributeValueQueryUpdated = "query_updated"

	// AttributeValueQueryRemoved represents the value for the 'action' event attribute.
	AttributeValueQueryRemoved = "query_removed"
)
View Source 
const (
	MaxKVQueryKeysCount = 32
)

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrInvalidQueryID             = sdkerrors.Register(ModuleName, 1100, "invalid query id")
	ErrEmptyResult                = sdkerrors.Register(ModuleName, 1101, "empty result")
	ErrInvalidClientID            = sdkerrors.Register(ModuleName, 1102, "invalid client id")
	ErrInvalidUpdatePeriod        = sdkerrors.Register(ModuleName, 1103, "invalid update period")
	ErrInvalidConnectionID        = sdkerrors.Register(ModuleName, 1104, "invalid connection id")
	ErrInvalidQueryType           = sdkerrors.Register(ModuleName, 1105, "invalid query type")
	ErrInvalidTransactionsFilter  = sdkerrors.Register(ModuleName, 1106, "invalid transactions filter")
	ErrInvalidSubmittedResult     = sdkerrors.Register(ModuleName, 1107, "invalid result")
	ErrProtoMarshal               = sdkerrors.Register(ModuleName, 1108, "failed to marshal protobuf bytes")
	ErrProtoUnmarshal             = sdkerrors.Register(ModuleName, 1109, "failed to unmarshal protobuf bytes")
	ErrInvalidType                = sdkerrors.Register(ModuleName, 1110, "invalid type")
	ErrInternal                   = sdkerrors.Register(ModuleName, 1111, "internal error")
	ErrInvalidProof               = sdkerrors.Register(ModuleName, 1112, "merkle proof is invalid")
	ErrInvalidHeader              = sdkerrors.Register(ModuleName, 1113, "header is invalid")
	ErrInvalidHeight              = sdkerrors.Register(ModuleName, 1114, "height is invalid")
	ErrNoQueryResult              = sdkerrors.Register(ModuleName, 1115, "no query result")
	ErrNotContract                = sdkerrors.Register(ModuleName, 1116, "not a contract")
	ErrEmptyKeys                  = sdkerrors.Register(ModuleName, 1117, "keys are empty")
	ErrEmptyKeyPath               = sdkerrors.Register(ModuleName, 1118, "key path is empty")
	ErrEmptyKeyID                 = sdkerrors.Register(ModuleName, 1119, "key id is empty")
	ErrTooManyKVQueryKeys         = sdkerrors.Register(ModuleName, 1120, "too many keys")
	ErrUnexpectedQueryTypeGenesis = sdkerrors.Register(ModuleName, 1121, "unexpected query type")
)

x/interchainqueries module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// RegisteredQueryKey is the store key for queries registered in the module.
	RegisteredQueryKey = []byte{prefixRegisteredQuery}
	// RegisteredQueryResultKey is the store key for KV query results.
	RegisteredQueryResultKey = []byte{prefixRegisteredQueryResult}
	// SubmittedTxKey is the store key for submitted transaction hashes.
	SubmittedTxKey = []byte{prefixSubmittedTx}
	// TxQueryToRemoveKey is the store key for TX queries marked to be removed.
	TxQueryToRemoveKey = []byte{prefixTxQueryToRemove}
	// LastRegisteredQueryIDKey is the store key for last registered query ID.
	LastRegisteredQueryIDKey = []byte{0x64}
)
View Source 
var (
	KeyQuerySubmitTimeout                = []byte("QuerySubmitTimeout")
	DefaultQuerySubmitTimeout            = uint64(1036800) // One month, with block_time = 2.5s
	KeyQueryDeposit                      = []byte("QueryDeposit")
	DefaultQueryDeposit        sdk.Coins = sdk.NewCoins(sdk.NewCoin(params.DefaultDenom, sdk.NewInt(int64(1_000_000))))
	KeyTxQueryRemovalLimit               = []byte("TxQueryRemovalLimit")
	DefaultTxQueryRemovalLimit           = uint64(10_000)
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)

Functions

func GetRegisteredQueryByIDKey 

func GetRegisteredQueryByIDKey(id uint64) []byte

GetRegisteredQueryByIDKey builds a store key to access a registered query by query ID.

func GetRegisteredQueryResultByIDKey 

func GetRegisteredQueryResultByIDKey(id uint64) []byte

GetRegisteredQueryResultByIDKey builds a store key to access a KV query result by query ID.

func GetSubmittedTransactionIDForQueryKey 

func GetSubmittedTransactionIDForQueryKey(queryID uint64, txHash []byte) []byte

GetSubmittedTransactionIDForQueryKey builds a store key to access a submitted transaction hash by query ID and hash.

func GetSubmittedTransactionIDForQueryKeyPrefix 

func GetSubmittedTransactionIDForQueryKeyPrefix(queryID uint64) []byte

GetSubmittedTransactionIDForQueryKeyPrefix builds a store key prefix to access TX query hashes by ID.

func GetTxQueryToRemoveByIDKey 

func GetTxQueryToRemoveByIDKey(id uint64) []byte

GetTxQueryToRemoveByIDKey builds a store key to access a TX query marked to be removed.

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateTransactionsFilter 

func ValidateTransactionsFilter(s string) error

ValidateTransactionsFilter checks if the passed string is a valid TransactionsFilter value.

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) types.AccountI
}

AccountKeeper defines the expected account keeper used for simulations (noalias)

type BankKeeper 

type BankKeeper interface {
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type Block 

type Block struct {
	// We need to know block X+1 to verify response of transaction for block X
	// since LastResultsHash is root hash of all results from the txs from the
	// previous block
	NextBlockHeader *types.Any `protobuf:"bytes,1,opt,name=next_block_header,json=nextBlockHeader,proto3" json:"next_block_header,omitempty"`
	// We need to know block X to verify inclusion of transaction for block X
	Header *types.Any `protobuf:"bytes,2,opt,name=header,proto3" json:"header,omitempty"`
	Tx     *TxValue   `protobuf:"bytes,3,opt,name=tx,proto3" json:"tx,omitempty"`
}

func (*Block) Descriptor 

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

func (*Block) GetHeader 

func (m *Block) GetHeader() *types.Any

func (*Block) GetNextBlockHeader 

func (m *Block) GetNextBlockHeader() *types.Any

func (*Block) GetTx 

func (m *Block) GetTx() *TxValue

func (*Block) Marshal 

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

func (*Block) MarshalTo 

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

func (*Block) MarshalToSizedBuffer 

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

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) Size 

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

func (*Block) String 

func (m *Block) String() string

func (*Block) Unmarshal 

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

func (*Block) XXX_DiscardUnknown 

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal 

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

func (*Block) XXX_Merge 

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

func (*Block) XXX_Size 

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal 

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

type ContractManagerKeeper 

type ContractManagerKeeper interface {
	HasContractInfo(ctx sdk.Context, contractAddress sdk.AccAddress) bool
	SudoResponse(ctx sdk.Context, senderAddress sdk.AccAddress, request channeltypes.Packet, msg []byte) ([]byte, error)
	SudoError(ctx sdk.Context, senderAddress sdk.AccAddress, request channeltypes.Packet, details string) ([]byte, error)
	SudoTimeout(ctx sdk.Context, senderAddress sdk.AccAddress, request channeltypes.Packet) ([]byte, error)
	SudoKVQueryResult(ctx sdk.Context, contractAddress sdk.AccAddress, queryID uint64) ([]byte, error)
	SudoTxQueryResult(ctx sdk.Context, contractAddress sdk.AccAddress, queryID uint64, height ibcclienttypes.Height, data []byte) ([]byte, error)
}

type GenesisState 

type GenesisState struct {
	Params            Params             `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	RegisteredQueries []*RegisteredQuery `protobuf:"bytes,2,rep,name=registered_queries,json=registeredQueries,proto3" json:"registered_queries,omitempty"`
}

GenesisState defines the interchainqueries module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetRegisteredQueries 

func (m *GenesisState) GetRegisteredQueries() []*RegisteredQuery

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type HeaderVerifier 

type HeaderVerifier interface {
	VerifyHeaders(ctx sdk.Context, cleintkeeper clientkeeper.Keeper, clientID string, header, nextHeader exported.Header) error
	UnpackHeader(any *codectypes.Any) (exported.Header, error)
}

type InterchainQueryType 

type InterchainQueryType string
const (
	InterchainQueryTypeKV InterchainQueryType = "kv"
	InterchainQueryTypeTX InterchainQueryType = "tx"
)

func (InterchainQueryType) IsKV 

func (icqt InterchainQueryType) IsKV() bool

func (InterchainQueryType) IsTX 

func (icqt InterchainQueryType) IsTX() bool

func (InterchainQueryType) IsValid 

func (icqt InterchainQueryType) IsValid() bool

type KVKey 

type KVKey struct {
	// Path (storage prefix) to the storage where you want to read value by key
	// (usually name of cosmos-sdk module: 'staking', 'bank', etc.)
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Key you want to read from the storage
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
}

func (*KVKey) Descriptor 

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

func (*KVKey) GetKey 

func (m *KVKey) GetKey() []byte

func (*KVKey) GetPath 

func (m *KVKey) GetPath() string

func (*KVKey) Marshal 

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

func (*KVKey) MarshalTo 

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

func (*KVKey) MarshalToSizedBuffer 

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

func (*KVKey) ProtoMessage 

func (*KVKey) ProtoMessage()

func (*KVKey) Reset 

func (m *KVKey) Reset()

func (*KVKey) Size 

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

func (*KVKey) String 

func (m *KVKey) String() string

func (KVKey) ToString 

func (kv KVKey) ToString() string

func (*KVKey) Unmarshal 

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

func (*KVKey) XXX_DiscardUnknown 

func (m *KVKey) XXX_DiscardUnknown()

func (*KVKey) XXX_Marshal 

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

func (*KVKey) XXX_Merge 

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

func (*KVKey) XXX_Size 

func (m *KVKey) XXX_Size() int

func (*KVKey) XXX_Unmarshal 

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

type KVKeys 

type KVKeys []*KVKey

func (KVKeys) String 

func (keys KVKeys) String() string

type MsgClient 

type MsgClient interface {
	RegisterInterchainQuery(ctx context.Context, in *MsgRegisterInterchainQuery, opts ...grpc.CallOption) (*MsgRegisterInterchainQueryResponse, error)
	SubmitQueryResult(ctx context.Context, in *MsgSubmitQueryResult, opts ...grpc.CallOption) (*MsgSubmitQueryResultResponse, error)
	RemoveInterchainQuery(ctx context.Context, in *MsgRemoveInterchainQueryRequest, opts ...grpc.CallOption) (*MsgRemoveInterchainQueryResponse, error)
	UpdateInterchainQuery(ctx context.Context, in *MsgUpdateInterchainQueryRequest, opts ...grpc.CallOption) (*MsgUpdateInterchainQueryResponse, 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 MsgRegisterInterchainQuery 

type MsgRegisterInterchainQuery struct {
	// defines a query type: `kv` or `tx` now
	QueryType string `protobuf:"bytes,1,opt,name=query_type,json=queryType,proto3" json:"query_type,omitempty"`
	// is used to define KV-storage keys for which we want to get values from
	// remote chain
	Keys []*KVKey `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// is used to define a filter for transaction search ICQ
	TransactionsFilter string `protobuf:"bytes,3,opt,name=transactions_filter,json=transactionsFilter,proto3" json:"transactions_filter,omitempty"`
	// is IBC connection ID for getting ConsensusState to verify proofs
	ConnectionId string `protobuf:"bytes,4,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// is used to specify how often (in furya blocks) the query must be updated
	UpdatePeriod uint64 `protobuf:"varint,5,opt,name=update_period,json=updatePeriod,proto3" json:"update_period,omitempty"`
	// is the signer of the message
	Sender string `protobuf:"bytes,6,opt,name=sender,proto3" json:"sender,omitempty"`
}

func (*MsgRegisterInterchainQuery) Descriptor 

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

func (*MsgRegisterInterchainQuery) GetConnectionId 

func (m *MsgRegisterInterchainQuery) GetConnectionId() string

func (*MsgRegisterInterchainQuery) GetKeys 

func (m *MsgRegisterInterchainQuery) GetKeys() []*KVKey

func (*MsgRegisterInterchainQuery) GetQueryType 

func (m *MsgRegisterInterchainQuery) GetQueryType() string

func (*MsgRegisterInterchainQuery) GetSender 

func (m *MsgRegisterInterchainQuery) GetSender() string

func (MsgRegisterInterchainQuery) GetSignBytes 

func (msg MsgRegisterInterchainQuery) GetSignBytes() []byte

func (MsgRegisterInterchainQuery) GetSigners 

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

func (*MsgRegisterInterchainQuery) GetTransactionsFilter 

func (m *MsgRegisterInterchainQuery) GetTransactionsFilter() string

func (*MsgRegisterInterchainQuery) GetUpdatePeriod 

func (m *MsgRegisterInterchainQuery) GetUpdatePeriod() uint64

func (*MsgRegisterInterchainQuery) Marshal 

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

func (*MsgRegisterInterchainQuery) MarshalTo 

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

func (*MsgRegisterInterchainQuery) MarshalToSizedBuffer 

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

func (*MsgRegisterInterchainQuery) ProtoMessage 

func (*MsgRegisterInterchainQuery) ProtoMessage()

func (*MsgRegisterInterchainQuery) Reset 

func (m *MsgRegisterInterchainQuery) Reset()

func (MsgRegisterInterchainQuery) Route 

func (msg MsgRegisterInterchainQuery) Route() string

func (*MsgRegisterInterchainQuery) Size 

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

func (*MsgRegisterInterchainQuery) String 

func (m *MsgRegisterInterchainQuery) String() string

func (MsgRegisterInterchainQuery) Type 

func (msg MsgRegisterInterchainQuery) Type() string

func (*MsgRegisterInterchainQuery) Unmarshal 

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

func (MsgRegisterInterchainQuery) ValidateBasic 

func (msg MsgRegisterInterchainQuery) ValidateBasic() error

func (*MsgRegisterInterchainQuery) XXX_DiscardUnknown 

func (m *MsgRegisterInterchainQuery) XXX_DiscardUnknown()

func (*MsgRegisterInterchainQuery) XXX_Marshal 

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

func (*MsgRegisterInterchainQuery) XXX_Merge 

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

func (*MsgRegisterInterchainQuery) XXX_Size 

func (m *MsgRegisterInterchainQuery) XXX_Size() int

func (*MsgRegisterInterchainQuery) XXX_Unmarshal 

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

type MsgRegisterInterchainQueryResponse 

type MsgRegisterInterchainQueryResponse struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*MsgRegisterInterchainQueryResponse) Descriptor 

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

func (*MsgRegisterInterchainQueryResponse) GetId 

func (m *MsgRegisterInterchainQueryResponse) GetId() uint64

func (*MsgRegisterInterchainQueryResponse) Marshal 

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

func (*MsgRegisterInterchainQueryResponse) MarshalTo 

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

func (*MsgRegisterInterchainQueryResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterInterchainQueryResponse) ProtoMessage 

func (*MsgRegisterInterchainQueryResponse) ProtoMessage()

func (*MsgRegisterInterchainQueryResponse) Reset 

func (m *MsgRegisterInterchainQueryResponse) Reset()

func (*MsgRegisterInterchainQueryResponse) Size 

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

func (*MsgRegisterInterchainQueryResponse) String 

func (m *MsgRegisterInterchainQueryResponse) String() string

func (*MsgRegisterInterchainQueryResponse) Unmarshal 

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

func (*MsgRegisterInterchainQueryResponse) XXX_DiscardUnknown 

func (m *MsgRegisterInterchainQueryResponse) XXX_DiscardUnknown()

func (*MsgRegisterInterchainQueryResponse) XXX_Marshal 

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

func (*MsgRegisterInterchainQueryResponse) XXX_Merge 

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

func (*MsgRegisterInterchainQueryResponse) XXX_Size 

func (m *MsgRegisterInterchainQueryResponse) XXX_Size() int

func (*MsgRegisterInterchainQueryResponse) XXX_Unmarshal 

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

type MsgRemoveInterchainQueryRequest 

type MsgRemoveInterchainQueryRequest struct {
	QueryId uint64 `protobuf:"varint,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	Sender  string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
}

func NewMsgRemoveInterchainQuery 

func NewMsgRemoveInterchainQuery(sender string, queryID uint64) MsgRemoveInterchainQueryRequest

func (*MsgRemoveInterchainQueryRequest) Descriptor 

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

func (*MsgRemoveInterchainQueryRequest) GetQueryId 

func (m *MsgRemoveInterchainQueryRequest) GetQueryId() uint64

func (*MsgRemoveInterchainQueryRequest) GetSender 

func (m *MsgRemoveInterchainQueryRequest) GetSender() string

func (MsgRemoveInterchainQueryRequest) GetSignBytes 

func (msg MsgRemoveInterchainQueryRequest) GetSignBytes() []byte

func (MsgRemoveInterchainQueryRequest) GetSigners 

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

func (*MsgRemoveInterchainQueryRequest) Marshal 

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

func (*MsgRemoveInterchainQueryRequest) MarshalTo 

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

func (*MsgRemoveInterchainQueryRequest) MarshalToSizedBuffer 

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

func (*MsgRemoveInterchainQueryRequest) ProtoMessage 

func (*MsgRemoveInterchainQueryRequest) ProtoMessage()

func (*MsgRemoveInterchainQueryRequest) Reset 

func (m *MsgRemoveInterchainQueryRequest) Reset()

func (MsgRemoveInterchainQueryRequest) Route 

func (msg MsgRemoveInterchainQueryRequest) Route() string

func (*MsgRemoveInterchainQueryRequest) Size 

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

func (*MsgRemoveInterchainQueryRequest) String 

func (m *MsgRemoveInterchainQueryRequest) String() string

func (MsgRemoveInterchainQueryRequest) Type 

func (msg MsgRemoveInterchainQueryRequest) Type() string

func (*MsgRemoveInterchainQueryRequest) Unmarshal 

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

func (MsgRemoveInterchainQueryRequest) ValidateBasic 

func (msg MsgRemoveInterchainQueryRequest) ValidateBasic() error

func (*MsgRemoveInterchainQueryRequest) XXX_DiscardUnknown 

func (m *MsgRemoveInterchainQueryRequest) XXX_DiscardUnknown()

func (*MsgRemoveInterchainQueryRequest) XXX_Marshal 

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

func (*MsgRemoveInterchainQueryRequest) XXX_Merge 

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

func (*MsgRemoveInterchainQueryRequest) XXX_Size 

func (m *MsgRemoveInterchainQueryRequest) XXX_Size() int

func (*MsgRemoveInterchainQueryRequest) XXX_Unmarshal 

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

type MsgRemoveInterchainQueryResponse 

type MsgRemoveInterchainQueryResponse struct {
}

func (*MsgRemoveInterchainQueryResponse) Descriptor 

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

func (*MsgRemoveInterchainQueryResponse) Marshal 

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

func (*MsgRemoveInterchainQueryResponse) MarshalTo 

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

func (*MsgRemoveInterchainQueryResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveInterchainQueryResponse) ProtoMessage 

func (*MsgRemoveInterchainQueryResponse) ProtoMessage()

func (*MsgRemoveInterchainQueryResponse) Reset 

func (m *MsgRemoveInterchainQueryResponse) Reset()

func (*MsgRemoveInterchainQueryResponse) Size 

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

func (*MsgRemoveInterchainQueryResponse) String 

func (m *MsgRemoveInterchainQueryResponse) String() string

func (*MsgRemoveInterchainQueryResponse) Unmarshal 

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

func (*MsgRemoveInterchainQueryResponse) XXX_DiscardUnknown 

func (m *MsgRemoveInterchainQueryResponse) XXX_DiscardUnknown()

func (*MsgRemoveInterchainQueryResponse) XXX_Marshal 

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

func (*MsgRemoveInterchainQueryResponse) XXX_Merge 

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

func (*MsgRemoveInterchainQueryResponse) XXX_Size 

func (m *MsgRemoveInterchainQueryResponse) XXX_Size() int

func (*MsgRemoveInterchainQueryResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	RegisterInterchainQuery(context.Context, *MsgRegisterInterchainQuery) (*MsgRegisterInterchainQueryResponse, error)
	SubmitQueryResult(context.Context, *MsgSubmitQueryResult) (*MsgSubmitQueryResultResponse, error)
	RemoveInterchainQuery(context.Context, *MsgRemoveInterchainQueryRequest) (*MsgRemoveInterchainQueryResponse, error)
	UpdateInterchainQuery(context.Context, *MsgUpdateInterchainQueryRequest) (*MsgUpdateInterchainQueryResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSubmitQueryResult 

type MsgSubmitQueryResult struct {
	QueryId uint64 `protobuf:"varint,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	Sender  string `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// is the IBC client ID for an IBC connection between Furya chain and target
	// chain (where the result was obtained from)
	ClientId string       `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Result   *QueryResult `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
}

func (*MsgSubmitQueryResult) Descriptor 

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

func (*MsgSubmitQueryResult) GetClientId 

func (m *MsgSubmitQueryResult) GetClientId() string

func (*MsgSubmitQueryResult) GetQueryId 

func (m *MsgSubmitQueryResult) GetQueryId() uint64

func (*MsgSubmitQueryResult) GetResult 

func (m *MsgSubmitQueryResult) GetResult() *QueryResult

func (*MsgSubmitQueryResult) GetSender 

func (m *MsgSubmitQueryResult) GetSender() string

func (MsgSubmitQueryResult) GetSignBytes 

func (msg MsgSubmitQueryResult) GetSignBytes() []byte

func (MsgSubmitQueryResult) GetSigners 

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

func (*MsgSubmitQueryResult) Marshal 

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

func (*MsgSubmitQueryResult) MarshalTo 

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

func (*MsgSubmitQueryResult) MarshalToSizedBuffer 

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

func (*MsgSubmitQueryResult) ProtoMessage 

func (*MsgSubmitQueryResult) ProtoMessage()

func (*MsgSubmitQueryResult) Reset 

func (m *MsgSubmitQueryResult) Reset()

func (MsgSubmitQueryResult) Route 

func (msg MsgSubmitQueryResult) Route() string

func (*MsgSubmitQueryResult) Size 

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

func (*MsgSubmitQueryResult) String 

func (m *MsgSubmitQueryResult) String() string

func (MsgSubmitQueryResult) Type 

func (msg MsgSubmitQueryResult) Type() string

func (*MsgSubmitQueryResult) Unmarshal 

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

func (MsgSubmitQueryResult) UnpackInterfaces 

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

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (MsgSubmitQueryResult) ValidateBasic 

func (msg MsgSubmitQueryResult) ValidateBasic() error

func (*MsgSubmitQueryResult) XXX_DiscardUnknown 

func (m *MsgSubmitQueryResult) XXX_DiscardUnknown()

func (*MsgSubmitQueryResult) XXX_Marshal 

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

func (*MsgSubmitQueryResult) XXX_Merge 

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

func (*MsgSubmitQueryResult) XXX_Size 

func (m *MsgSubmitQueryResult) XXX_Size() int

func (*MsgSubmitQueryResult) XXX_Unmarshal 

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

type MsgSubmitQueryResultResponse 

type MsgSubmitQueryResultResponse struct {
}

func (*MsgSubmitQueryResultResponse) Descriptor 

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

func (*MsgSubmitQueryResultResponse) Marshal 

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

func (*MsgSubmitQueryResultResponse) MarshalTo 

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

func (*MsgSubmitQueryResultResponse) MarshalToSizedBuffer 

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

func (*MsgSubmitQueryResultResponse) ProtoMessage 

func (*MsgSubmitQueryResultResponse) ProtoMessage()

func (*MsgSubmitQueryResultResponse) Reset 

func (m *MsgSubmitQueryResultResponse) Reset()

func (*MsgSubmitQueryResultResponse) Size 

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

func (*MsgSubmitQueryResultResponse) String 

func (m *MsgSubmitQueryResultResponse) String() string

func (*MsgSubmitQueryResultResponse) Unmarshal 

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

func (*MsgSubmitQueryResultResponse) XXX_DiscardUnknown 

func (m *MsgSubmitQueryResultResponse) XXX_DiscardUnknown()

func (*MsgSubmitQueryResultResponse) XXX_Marshal 

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

func (*MsgSubmitQueryResultResponse) XXX_Merge 

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

func (*MsgSubmitQueryResultResponse) XXX_Size 

func (m *MsgSubmitQueryResultResponse) XXX_Size() int

func (*MsgSubmitQueryResultResponse) XXX_Unmarshal 

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

type MsgUpdateInterchainQueryRequest 

type MsgUpdateInterchainQueryRequest struct {
	QueryId               uint64   `protobuf:"varint,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	NewKeys               []*KVKey `protobuf:"bytes,2,rep,name=new_keys,json=newKeys,proto3" json:"new_keys,omitempty"`
	NewUpdatePeriod       uint64   `protobuf:"varint,3,opt,name=new_update_period,json=newUpdatePeriod,proto3" json:"new_update_period,omitempty"`
	NewTransactionsFilter string   `` /* 126-byte string literal not displayed */
	Sender                string   `protobuf:"bytes,5,opt,name=sender,proto3" json:"sender,omitempty"`
}

func (*MsgUpdateInterchainQueryRequest) Descriptor 

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

func (*MsgUpdateInterchainQueryRequest) GetNewKeys 

func (m *MsgUpdateInterchainQueryRequest) GetNewKeys() []*KVKey

func (*MsgUpdateInterchainQueryRequest) GetNewTransactionsFilter 

func (m *MsgUpdateInterchainQueryRequest) GetNewTransactionsFilter() string

func (*MsgUpdateInterchainQueryRequest) GetNewUpdatePeriod 

func (m *MsgUpdateInterchainQueryRequest) GetNewUpdatePeriod() uint64

func (*MsgUpdateInterchainQueryRequest) GetQueryId 

func (m *MsgUpdateInterchainQueryRequest) GetQueryId() uint64

func (*MsgUpdateInterchainQueryRequest) GetSender 

func (m *MsgUpdateInterchainQueryRequest) GetSender() string

func (MsgUpdateInterchainQueryRequest) GetSignBytes 

func (msg MsgUpdateInterchainQueryRequest) GetSignBytes() []byte

func (MsgUpdateInterchainQueryRequest) GetSigners 

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

func (*MsgUpdateInterchainQueryRequest) Marshal 

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

func (*MsgUpdateInterchainQueryRequest) MarshalTo 

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

func (*MsgUpdateInterchainQueryRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateInterchainQueryRequest) ProtoMessage 

func (*MsgUpdateInterchainQueryRequest) ProtoMessage()

func (*MsgUpdateInterchainQueryRequest) Reset 

func (m *MsgUpdateInterchainQueryRequest) Reset()

func (*MsgUpdateInterchainQueryRequest) Size 

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

func (*MsgUpdateInterchainQueryRequest) String 

func (m *MsgUpdateInterchainQueryRequest) String() string

func (*MsgUpdateInterchainQueryRequest) Unmarshal 

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

func (MsgUpdateInterchainQueryRequest) ValidateBasic 

func (msg MsgUpdateInterchainQueryRequest) ValidateBasic() error

func (*MsgUpdateInterchainQueryRequest) XXX_DiscardUnknown 

func (m *MsgUpdateInterchainQueryRequest) XXX_DiscardUnknown()

func (*MsgUpdateInterchainQueryRequest) XXX_Marshal 

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

func (*MsgUpdateInterchainQueryRequest) XXX_Merge 

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

func (*MsgUpdateInterchainQueryRequest) XXX_Size 

func (m *MsgUpdateInterchainQueryRequest) XXX_Size() int

func (*MsgUpdateInterchainQueryRequest) XXX_Unmarshal 

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

type MsgUpdateInterchainQueryResponse 

type MsgUpdateInterchainQueryResponse struct {
}

func (*MsgUpdateInterchainQueryResponse) Descriptor 

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

func (*MsgUpdateInterchainQueryResponse) Marshal 

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

func (*MsgUpdateInterchainQueryResponse) MarshalTo 

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

func (*MsgUpdateInterchainQueryResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateInterchainQueryResponse) ProtoMessage 

func (*MsgUpdateInterchainQueryResponse) ProtoMessage()

func (*MsgUpdateInterchainQueryResponse) Reset 

func (m *MsgUpdateInterchainQueryResponse) Reset()

func (*MsgUpdateInterchainQueryResponse) Size 

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

func (*MsgUpdateInterchainQueryResponse) String 

func (m *MsgUpdateInterchainQueryResponse) String() string

func (*MsgUpdateInterchainQueryResponse) Unmarshal 

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

func (*MsgUpdateInterchainQueryResponse) XXX_DiscardUnknown 

func (m *MsgUpdateInterchainQueryResponse) XXX_DiscardUnknown()

func (*MsgUpdateInterchainQueryResponse) XXX_Marshal 

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

func (*MsgUpdateInterchainQueryResponse) XXX_Merge 

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

func (*MsgUpdateInterchainQueryResponse) XXX_Size 

func (m *MsgUpdateInterchainQueryResponse) XXX_Size() int

func (*MsgUpdateInterchainQueryResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// Defines amount of blocks required before query becomes available for
	// removal by anybody
	QuerySubmitTimeout uint64 `protobuf:"varint,1,opt,name=query_submit_timeout,json=querySubmitTimeout,proto3" json:"query_submit_timeout,omitempty"`
	// Amount of coins deposited for the query.
	QueryDeposit github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	// Amount of tx hashes to be removed during a single EndBlock. Can vary to
	// balance between network cleaning speed and EndBlock duration. A zero value
	// means no limit.
	TxQueryRemovalLimit uint64 `protobuf:"varint,3,opt,name=tx_query_removal_limit,json=txQueryRemovalLimit,proto3" json:"tx_query_removal_limit,omitempty"`
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(querySubmitTimeout uint64, queryDeposit sdk.Coins, txQueryRemovalLimit uint64) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetQueryDeposit 

func (m *Params) GetQueryDeposit() github_com_cosmos_cosmos_sdk_types.Coins

func (*Params) GetQuerySubmitTimeout 

func (m *Params) GetQuerySubmitTimeout() uint64

func (*Params) GetTxQueryRemovalLimit 

func (m *Params) GetTxQueryRemovalLimit() uint64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs get the params.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Parameters queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	RegisteredQueries(ctx context.Context, in *QueryRegisteredQueriesRequest, opts ...grpc.CallOption) (*QueryRegisteredQueriesResponse, error)
	RegisteredQuery(ctx context.Context, in *QueryRegisteredQueryRequest, opts ...grpc.CallOption) (*QueryRegisteredQueryResponse, error)
	QueryResult(ctx context.Context, in *QueryRegisteredQueryResultRequest, opts ...grpc.CallOption) (*QueryRegisteredQueryResultResponse, error)
	LastRemoteHeight(ctx context.Context, in *QueryLastRemoteHeight, opts ...grpc.CallOption) (*QueryLastRemoteHeightResponse, 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 QueryLastRemoteHeight 

type QueryLastRemoteHeight struct {
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
}

func (*QueryLastRemoteHeight) Descriptor 

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

func (*QueryLastRemoteHeight) GetConnectionId 

func (m *QueryLastRemoteHeight) GetConnectionId() string

func (*QueryLastRemoteHeight) Marshal 

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

func (*QueryLastRemoteHeight) MarshalTo 

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

func (*QueryLastRemoteHeight) MarshalToSizedBuffer 

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

func (*QueryLastRemoteHeight) ProtoMessage 

func (*QueryLastRemoteHeight) ProtoMessage()

func (*QueryLastRemoteHeight) Reset 

func (m *QueryLastRemoteHeight) Reset()

func (*QueryLastRemoteHeight) Size 

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

func (*QueryLastRemoteHeight) String 

func (m *QueryLastRemoteHeight) String() string

func (*QueryLastRemoteHeight) Unmarshal 

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

func (*QueryLastRemoteHeight) XXX_DiscardUnknown 

func (m *QueryLastRemoteHeight) XXX_DiscardUnknown()

func (*QueryLastRemoteHeight) XXX_Marshal 

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

func (*QueryLastRemoteHeight) XXX_Merge 

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

func (*QueryLastRemoteHeight) XXX_Size 

func (m *QueryLastRemoteHeight) XXX_Size() int

func (*QueryLastRemoteHeight) XXX_Unmarshal 

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

type QueryLastRemoteHeightResponse 

type QueryLastRemoteHeightResponse struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
}

func (*QueryLastRemoteHeightResponse) Descriptor 

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

func (*QueryLastRemoteHeightResponse) GetHeight 

func (m *QueryLastRemoteHeightResponse) GetHeight() uint64

func (*QueryLastRemoteHeightResponse) Marshal 

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

func (*QueryLastRemoteHeightResponse) MarshalTo 

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

func (*QueryLastRemoteHeightResponse) MarshalToSizedBuffer 

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

func (*QueryLastRemoteHeightResponse) ProtoMessage 

func (*QueryLastRemoteHeightResponse) ProtoMessage()

func (*QueryLastRemoteHeightResponse) Reset 

func (m *QueryLastRemoteHeightResponse) Reset()

func (*QueryLastRemoteHeightResponse) Size 

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

func (*QueryLastRemoteHeightResponse) String 

func (m *QueryLastRemoteHeightResponse) String() string

func (*QueryLastRemoteHeightResponse) Unmarshal 

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

func (*QueryLastRemoteHeightResponse) XXX_DiscardUnknown 

func (m *QueryLastRemoteHeightResponse) XXX_DiscardUnknown()

func (*QueryLastRemoteHeightResponse) XXX_Marshal 

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

func (*QueryLastRemoteHeightResponse) XXX_Merge 

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

func (*QueryLastRemoteHeightResponse) XXX_Size 

func (m *QueryLastRemoteHeightResponse) XXX_Size() int

func (*QueryLastRemoteHeightResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryRegisteredQueriesRequest 

type QueryRegisteredQueriesRequest struct {
	Owners       []string           `protobuf:"bytes,1,rep,name=owners,proto3" json:"owners,omitempty"`
	ConnectionId string             `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	Pagination   *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryRegisteredQueriesRequest) Descriptor 

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

func (*QueryRegisteredQueriesRequest) GetConnectionId 

func (m *QueryRegisteredQueriesRequest) GetConnectionId() string

func (*QueryRegisteredQueriesRequest) GetOwners 

func (m *QueryRegisteredQueriesRequest) GetOwners() []string

func (*QueryRegisteredQueriesRequest) GetPagination 

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

func (*QueryRegisteredQueriesRequest) Marshal 

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

func (*QueryRegisteredQueriesRequest) MarshalTo 

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

func (*QueryRegisteredQueriesRequest) MarshalToSizedBuffer 

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

func (*QueryRegisteredQueriesRequest) ProtoMessage 

func (*QueryRegisteredQueriesRequest) ProtoMessage()

func (*QueryRegisteredQueriesRequest) Reset 

func (m *QueryRegisteredQueriesRequest) Reset()

func (*QueryRegisteredQueriesRequest) Size 

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

func (*QueryRegisteredQueriesRequest) String 

func (m *QueryRegisteredQueriesRequest) String() string

func (*QueryRegisteredQueriesRequest) Unmarshal 

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

func (*QueryRegisteredQueriesRequest) XXX_DiscardUnknown 

func (m *QueryRegisteredQueriesRequest) XXX_DiscardUnknown()

func (*QueryRegisteredQueriesRequest) XXX_Marshal 

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

func (*QueryRegisteredQueriesRequest) XXX_Merge 

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

func (*QueryRegisteredQueriesRequest) XXX_Size 

func (m *QueryRegisteredQueriesRequest) XXX_Size() int

func (*QueryRegisteredQueriesRequest) XXX_Unmarshal 

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

type QueryRegisteredQueriesResponse 

type QueryRegisteredQueriesResponse struct {
	RegisteredQueries []RegisteredQuery `protobuf:"bytes,1,rep,name=registered_queries,json=registeredQueries,proto3" json:"registered_queries"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryRegisteredQueriesResponse) Descriptor 

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

func (*QueryRegisteredQueriesResponse) GetPagination 

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

func (*QueryRegisteredQueriesResponse) GetRegisteredQueries 

func (m *QueryRegisteredQueriesResponse) GetRegisteredQueries() []RegisteredQuery

func (*QueryRegisteredQueriesResponse) Marshal 

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

func (*QueryRegisteredQueriesResponse) MarshalTo 

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

func (*QueryRegisteredQueriesResponse) MarshalToSizedBuffer 

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

func (*QueryRegisteredQueriesResponse) ProtoMessage 

func (*QueryRegisteredQueriesResponse) ProtoMessage()

func (*QueryRegisteredQueriesResponse) Reset 

func (m *QueryRegisteredQueriesResponse) Reset()

func (*QueryRegisteredQueriesResponse) Size 

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

func (*QueryRegisteredQueriesResponse) String 

func (m *QueryRegisteredQueriesResponse) String() string

func (*QueryRegisteredQueriesResponse) Unmarshal 

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

func (*QueryRegisteredQueriesResponse) XXX_DiscardUnknown 

func (m *QueryRegisteredQueriesResponse) XXX_DiscardUnknown()

func (*QueryRegisteredQueriesResponse) XXX_Marshal 

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

func (*QueryRegisteredQueriesResponse) XXX_Merge 

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

func (*QueryRegisteredQueriesResponse) XXX_Size 

func (m *QueryRegisteredQueriesResponse) XXX_Size() int

func (*QueryRegisteredQueriesResponse) XXX_Unmarshal 

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

type QueryRegisteredQueryRequest 

type QueryRegisteredQueryRequest struct {
	QueryId uint64 `protobuf:"varint,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
}

func (*QueryRegisteredQueryRequest) Descriptor 

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

func (*QueryRegisteredQueryRequest) GetQueryId 

func (m *QueryRegisteredQueryRequest) GetQueryId() uint64

func (*QueryRegisteredQueryRequest) Marshal 

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

func (*QueryRegisteredQueryRequest) MarshalTo 

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

func (*QueryRegisteredQueryRequest) MarshalToSizedBuffer 

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

func (*QueryRegisteredQueryRequest) ProtoMessage 

func (*QueryRegisteredQueryRequest) ProtoMessage()

func (*QueryRegisteredQueryRequest) Reset 

func (m *QueryRegisteredQueryRequest) Reset()

func (*QueryRegisteredQueryRequest) Size 

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

func (*QueryRegisteredQueryRequest) String 

func (m *QueryRegisteredQueryRequest) String() string

func (*QueryRegisteredQueryRequest) Unmarshal 

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

func (*QueryRegisteredQueryRequest) XXX_DiscardUnknown 

func (m *QueryRegisteredQueryRequest) XXX_DiscardUnknown()

func (*QueryRegisteredQueryRequest) XXX_Marshal 

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

func (*QueryRegisteredQueryRequest) XXX_Merge 

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

func (*QueryRegisteredQueryRequest) XXX_Size 

func (m *QueryRegisteredQueryRequest) XXX_Size() int

func (*QueryRegisteredQueryRequest) XXX_Unmarshal 

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

type QueryRegisteredQueryResponse 

type QueryRegisteredQueryResponse struct {
	RegisteredQuery *RegisteredQuery `protobuf:"bytes,1,opt,name=registered_query,json=registeredQuery,proto3" json:"registered_query,omitempty"`
}

func (*QueryRegisteredQueryResponse) Descriptor 

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

func (*QueryRegisteredQueryResponse) GetRegisteredQuery 

func (m *QueryRegisteredQueryResponse) GetRegisteredQuery() *RegisteredQuery

func (*QueryRegisteredQueryResponse) Marshal 

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

func (*QueryRegisteredQueryResponse) MarshalTo 

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

func (*QueryRegisteredQueryResponse) MarshalToSizedBuffer 

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

func (*QueryRegisteredQueryResponse) ProtoMessage 

func (*QueryRegisteredQueryResponse) ProtoMessage()

func (*QueryRegisteredQueryResponse) Reset 

func (m *QueryRegisteredQueryResponse) Reset()

func (*QueryRegisteredQueryResponse) Size 

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

func (*QueryRegisteredQueryResponse) String 

func (m *QueryRegisteredQueryResponse) String() string

func (*QueryRegisteredQueryResponse) Unmarshal 

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

func (*QueryRegisteredQueryResponse) XXX_DiscardUnknown 

func (m *QueryRegisteredQueryResponse) XXX_DiscardUnknown()

func (*QueryRegisteredQueryResponse) XXX_Marshal 

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

func (*QueryRegisteredQueryResponse) XXX_Merge 

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

func (*QueryRegisteredQueryResponse) XXX_Size 

func (m *QueryRegisteredQueryResponse) XXX_Size() int

func (*QueryRegisteredQueryResponse) XXX_Unmarshal 

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

type QueryRegisteredQueryResultRequest 

type QueryRegisteredQueryResultRequest struct {
	QueryId uint64 `protobuf:"varint,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
}

func (*QueryRegisteredQueryResultRequest) Descriptor 

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

func (*QueryRegisteredQueryResultRequest) GetQueryId 

func (m *QueryRegisteredQueryResultRequest) GetQueryId() uint64

func (*QueryRegisteredQueryResultRequest) Marshal 

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

func (*QueryRegisteredQueryResultRequest) MarshalTo 

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

func (*QueryRegisteredQueryResultRequest) MarshalToSizedBuffer 

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

func (*QueryRegisteredQueryResultRequest) ProtoMessage 

func (*QueryRegisteredQueryResultRequest) ProtoMessage()

func (*QueryRegisteredQueryResultRequest) Reset 

func (m *QueryRegisteredQueryResultRequest) Reset()

func (*QueryRegisteredQueryResultRequest) Size 

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

func (*QueryRegisteredQueryResultRequest) String 

func (m *QueryRegisteredQueryResultRequest) String() string

func (*QueryRegisteredQueryResultRequest) Unmarshal 

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

func (*QueryRegisteredQueryResultRequest) XXX_DiscardUnknown 

func (m *QueryRegisteredQueryResultRequest) XXX_DiscardUnknown()

func (*QueryRegisteredQueryResultRequest) XXX_Marshal 

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

func (*QueryRegisteredQueryResultRequest) XXX_Merge 

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

func (*QueryRegisteredQueryResultRequest) XXX_Size 

func (m *QueryRegisteredQueryResultRequest) XXX_Size() int

func (*QueryRegisteredQueryResultRequest) XXX_Unmarshal 

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

type QueryRegisteredQueryResultResponse 

type QueryRegisteredQueryResultResponse struct {
	Result *QueryResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*QueryRegisteredQueryResultResponse) Descriptor 

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

func (*QueryRegisteredQueryResultResponse) GetResult 

func (m *QueryRegisteredQueryResultResponse) GetResult() *QueryResult

func (*QueryRegisteredQueryResultResponse) Marshal 

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

func (*QueryRegisteredQueryResultResponse) MarshalTo 

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

func (*QueryRegisteredQueryResultResponse) MarshalToSizedBuffer 

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

func (*QueryRegisteredQueryResultResponse) ProtoMessage 

func (*QueryRegisteredQueryResultResponse) ProtoMessage()

func (*QueryRegisteredQueryResultResponse) Reset 

func (m *QueryRegisteredQueryResultResponse) Reset()

func (*QueryRegisteredQueryResultResponse) Size 

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

func (*QueryRegisteredQueryResultResponse) String 

func (m *QueryRegisteredQueryResultResponse) String() string

func (*QueryRegisteredQueryResultResponse) Unmarshal 

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

func (*QueryRegisteredQueryResultResponse) XXX_DiscardUnknown 

func (m *QueryRegisteredQueryResultResponse) XXX_DiscardUnknown()

func (*QueryRegisteredQueryResultResponse) XXX_Marshal 

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

func (*QueryRegisteredQueryResultResponse) XXX_Merge 

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

func (*QueryRegisteredQueryResultResponse) XXX_Size 

func (m *QueryRegisteredQueryResultResponse) XXX_Size() int

func (*QueryRegisteredQueryResultResponse) XXX_Unmarshal 

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

type QueryResult 

type QueryResult struct {
	KvResults        []*StorageValue `protobuf:"bytes,1,rep,name=kv_results,json=kvResults,proto3" json:"kv_results,omitempty"`
	Block            *Block          `protobuf:"bytes,2,opt,name=block,proto3" json:"block,omitempty"`
	Height           uint64          `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	Revision         uint64          `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"`
	AllowKvCallbacks bool            `protobuf:"varint,5,opt,name=allow_kv_callbacks,json=allowKvCallbacks,proto3" json:"allow_kv_callbacks,omitempty"`
}

func (*QueryResult) Descriptor 

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

func (*QueryResult) GetAllowKvCallbacks 

func (m *QueryResult) GetAllowKvCallbacks() bool

func (*QueryResult) GetBlock 

func (m *QueryResult) GetBlock() *Block

func (*QueryResult) GetHeight 

func (m *QueryResult) GetHeight() uint64

func (*QueryResult) GetKvResults 

func (m *QueryResult) GetKvResults() []*StorageValue

func (*QueryResult) GetRevision 

func (m *QueryResult) GetRevision() uint64

func (*QueryResult) Marshal 

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

func (*QueryResult) MarshalTo 

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

func (*QueryResult) MarshalToSizedBuffer 

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

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset 

func (m *QueryResult) Reset()

func (*QueryResult) Size 

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

func (*QueryResult) String 

func (m *QueryResult) String() string

func (*QueryResult) Unmarshal 

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

func (*QueryResult) XXX_DiscardUnknown 

func (m *QueryResult) XXX_DiscardUnknown()

func (*QueryResult) XXX_Marshal 

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

func (*QueryResult) XXX_Merge 

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

func (*QueryResult) XXX_Size 

func (m *QueryResult) XXX_Size() int

func (*QueryResult) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Parameters queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	RegisteredQueries(context.Context, *QueryRegisteredQueriesRequest) (*QueryRegisteredQueriesResponse, error)
	RegisteredQuery(context.Context, *QueryRegisteredQueryRequest) (*QueryRegisteredQueryResponse, error)
	QueryResult(context.Context, *QueryRegisteredQueryResultRequest) (*QueryRegisteredQueryResultResponse, error)
	LastRemoteHeight(context.Context, *QueryLastRemoteHeight) (*QueryLastRemoteHeightResponse, error)
}

QueryServer is the server API for Query service.

type RegisteredQuery 

type RegisteredQuery struct {
	// The unique id of the registered query.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The address that registered the query.
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// The query type identifier: `kv` or `tx` now
	QueryType string `protobuf:"bytes,3,opt,name=query_type,json=queryType,proto3" json:"query_type,omitempty"`
	// The KV-storage keys for which we want to get values from remote chain
	Keys []*KVKey `protobuf:"bytes,4,rep,name=keys,proto3" json:"keys,omitempty"`
	// The filter for transaction search ICQ
	TransactionsFilter string `protobuf:"bytes,5,opt,name=transactions_filter,json=transactionsFilter,proto3" json:"transactions_filter,omitempty"`
	// The IBC connection ID for getting ConsensusState to verify proofs
	ConnectionId string `protobuf:"bytes,6,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// Parameter that defines how often the query must be updated.
	UpdatePeriod uint64 `protobuf:"varint,7,opt,name=update_period,json=updatePeriod,proto3" json:"update_period,omitempty"`
	// The local chain last block height when the query result was updated.
	LastSubmittedResultLocalHeight uint64 `` /* 158-byte string literal not displayed */
	// The remote chain last block height when the query result was updated.
	LastSubmittedResultRemoteHeight *types.Height `` /* 160-byte string literal not displayed */
	// Amount of coins deposited for the query.
	Deposit github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,10,rep,name=deposit,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"deposit"`
	// Timeout before query becomes available for everybody to remove.
	SubmitTimeout uint64 `protobuf:"varint,11,opt,name=submit_timeout,json=submitTimeout,proto3" json:"submit_timeout,omitempty"`
	// The local chain height when the query was registered.
	RegisteredAtHeight uint64 `protobuf:"varint,12,opt,name=registered_at_height,json=registeredAtHeight,proto3" json:"registered_at_height,omitempty"`
}

func (*RegisteredQuery) Descriptor 

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

func (*RegisteredQuery) GetConnectionId 

func (m *RegisteredQuery) GetConnectionId() string

func (*RegisteredQuery) GetDeposit 

func (m *RegisteredQuery) GetDeposit() github_com_cosmos_cosmos_sdk_types.Coins

func (*RegisteredQuery) GetId 

func (m *RegisteredQuery) GetId() uint64

func (*RegisteredQuery) GetKeys 

func (m *RegisteredQuery) GetKeys() []*KVKey

func (*RegisteredQuery) GetLastSubmittedResultLocalHeight 

func (m *RegisteredQuery) GetLastSubmittedResultLocalHeight() uint64

func (*RegisteredQuery) GetLastSubmittedResultRemoteHeight 

func (m *RegisteredQuery) GetLastSubmittedResultRemoteHeight() *types.Height

func (*RegisteredQuery) GetOwner 

func (m *RegisteredQuery) GetOwner() string

func (*RegisteredQuery) GetOwnerAddress 

func (q *RegisteredQuery) GetOwnerAddress() (creator sdk.AccAddress, err error)

func (*RegisteredQuery) GetQueryType 

func (m *RegisteredQuery) GetQueryType() string

func (*RegisteredQuery) GetRegisteredAtHeight 

func (m *RegisteredQuery) GetRegisteredAtHeight() uint64

func (*RegisteredQuery) GetSubmitTimeout 

func (m *RegisteredQuery) GetSubmitTimeout() uint64

func (*RegisteredQuery) GetTransactionsFilter 

func (m *RegisteredQuery) GetTransactionsFilter() string

func (*RegisteredQuery) GetUpdatePeriod 

func (m *RegisteredQuery) GetUpdatePeriod() uint64

func (*RegisteredQuery) Marshal 

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

func (*RegisteredQuery) MarshalTo 

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

func (*RegisteredQuery) MarshalToSizedBuffer 

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

func (*RegisteredQuery) ProtoMessage 

func (*RegisteredQuery) ProtoMessage()

func (*RegisteredQuery) Reset 

func (m *RegisteredQuery) Reset()

func (*RegisteredQuery) Size 

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

func (*RegisteredQuery) String 

func (m *RegisteredQuery) String() string

func (*RegisteredQuery) Unmarshal 

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

func (*RegisteredQuery) ValidateRemoval 

func (q *RegisteredQuery) ValidateRemoval(ctx sdk.Context, caller string) error

ValidateRemoval checks whether the caller is authorized to remove the query in current circumstances. Valid cases are: 1. owner removes query at any time; 2. anyone removes query if there's been q.SubmitTimeout blocks since last result submission height and query registration height.

func (*RegisteredQuery) XXX_DiscardUnknown 

func (m *RegisteredQuery) XXX_DiscardUnknown()

func (*RegisteredQuery) XXX_Marshal 

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

func (*RegisteredQuery) XXX_Merge 

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

func (*RegisteredQuery) XXX_Size 

func (m *RegisteredQuery) XXX_Size() int

func (*RegisteredQuery) XXX_Unmarshal 

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

type StorageValue 

type StorageValue struct {
	// is the substore name (acc, staking, etc.)
	StoragePrefix string `protobuf:"bytes,1,opt,name=storage_prefix,json=storagePrefix,proto3" json:"storage_prefix,omitempty"`
	// is the key in IAVL store
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// is the value in IAVL store
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// is the Merkle Proof which proves existence of key-value pair in IAVL
	// storage
	Proof *crypto.ProofOps `protobuf:"bytes,4,opt,name=Proof,proto3" json:"Proof,omitempty"`
}

func (*StorageValue) Descriptor 

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

func (*StorageValue) GetKey 

func (m *StorageValue) GetKey() []byte

func (*StorageValue) GetProof 

func (m *StorageValue) GetProof() *crypto.ProofOps

func (*StorageValue) GetStoragePrefix 

func (m *StorageValue) GetStoragePrefix() string

func (*StorageValue) GetValue 

func (m *StorageValue) GetValue() []byte

func (*StorageValue) Marshal 

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

func (*StorageValue) MarshalTo 

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

func (*StorageValue) MarshalToSizedBuffer 

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

func (*StorageValue) ProtoMessage 

func (*StorageValue) ProtoMessage()

func (*StorageValue) Reset 

func (m *StorageValue) Reset()

func (*StorageValue) Size 

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

func (*StorageValue) String 

func (m *StorageValue) String() string

func (*StorageValue) Unmarshal 

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

func (*StorageValue) XXX_DiscardUnknown 

func (m *StorageValue) XXX_DiscardUnknown()

func (*StorageValue) XXX_Marshal 

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

func (*StorageValue) XXX_Merge 

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

func (*StorageValue) XXX_Size 

func (m *StorageValue) XXX_Size() int

func (*StorageValue) XXX_Unmarshal 

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

type Transaction 

type Transaction struct {
	Id     uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Transaction) Descriptor 

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

func (*Transaction) GetData 

func (m *Transaction) GetData() []byte

func (*Transaction) GetHeight 

func (m *Transaction) GetHeight() uint64

func (*Transaction) GetId 

func (m *Transaction) GetId() uint64

func (*Transaction) Marshal 

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

func (*Transaction) MarshalTo 

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

func (*Transaction) MarshalToSizedBuffer 

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

func (*Transaction) ProtoMessage 

func (*Transaction) ProtoMessage()

func (*Transaction) Reset 

func (m *Transaction) Reset()

func (*Transaction) Size 

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

func (*Transaction) String 

func (m *Transaction) String() string

func (*Transaction) Unmarshal 

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

func (*Transaction) XXX_DiscardUnknown 

func (m *Transaction) XXX_DiscardUnknown()

func (*Transaction) XXX_Marshal 

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

func (*Transaction) XXX_Merge 

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

func (*Transaction) XXX_Size 

func (m *Transaction) XXX_Size() int

func (*Transaction) XXX_Unmarshal 

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

type TransactionVerifier 

type TransactionVerifier interface {
	VerifyTransaction(
		header *tendermintLightClientTypes.Header,
		nextHeader *tendermintLightClientTypes.Header,
		tx *TxValue,
	) error
}

type TransactionsFilter 

type TransactionsFilter []TransactionsFilterItem

TransactionsFilter represents the model of transactions filter parameter used in interchain queries of type TX.

type TransactionsFilterItem 

type TransactionsFilterItem struct {
	// Field is the field used in condition, e.g. tx.height or transfer.recipient.
	Field string `json:"field"`
	// Op is the operation for filtering, one of the following: eq, gt, gte, lt, lte.
	Op string `json:"op"`
	// Value is the value for comparison.
	Value interface{} `json:"value"`
}

TransactionsFilterItem is a single condition for filtering transactions in search.

type TxValue 

type TxValue struct {
	Response *types1.ResponseDeliverTx `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// is the Merkle Proof which proves existence of response in block with height
	// next_block_header.Height
	DeliveryProof *crypto.Proof `protobuf:"bytes,2,opt,name=delivery_proof,json=deliveryProof,proto3" json:"delivery_proof,omitempty"`
	// is the Merkle Proof which proves existence of data in block with height
	// header.Height
	InclusionProof *crypto.Proof `protobuf:"bytes,3,opt,name=inclusion_proof,json=inclusionProof,proto3" json:"inclusion_proof,omitempty"`
	// is body of the transaction
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

func (*TxValue) Descriptor 

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

func (*TxValue) GetData 

func (m *TxValue) GetData() []byte

func (*TxValue) GetDeliveryProof 

func (m *TxValue) GetDeliveryProof() *crypto.Proof

func (*TxValue) GetInclusionProof 

func (m *TxValue) GetInclusionProof() *crypto.Proof

func (*TxValue) GetResponse 

func (m *TxValue) GetResponse() *types1.ResponseDeliverTx

func (*TxValue) Marshal 

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

func (*TxValue) MarshalTo 

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

func (*TxValue) MarshalToSizedBuffer 

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

func (*TxValue) ProtoMessage 

func (*TxValue) ProtoMessage()

func (*TxValue) Reset 

func (m *TxValue) Reset()

func (*TxValue) Size 

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

func (*TxValue) String 

func (m *TxValue) String() string

func (*TxValue) Unmarshal 

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

func (*TxValue) XXX_DiscardUnknown 

func (m *TxValue) XXX_DiscardUnknown()

func (*TxValue) XXX_Marshal 

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

func (*TxValue) XXX_Merge 

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

func (*TxValue) XXX_Size 

func (m *TxValue) XXX_Size() int

func (*TxValue) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) RegisterInterchainQuery 

func (*UnimplementedMsgServer) RegisterInterchainQuery(ctx context.Context, req *MsgRegisterInterchainQuery) (*MsgRegisterInterchainQueryResponse, error)

func (*UnimplementedMsgServer) RemoveInterchainQuery 

func (*UnimplementedMsgServer) RemoveInterchainQuery(ctx context.Context, req *MsgRemoveInterchainQueryRequest) (*MsgRemoveInterchainQueryResponse, error)

func (*UnimplementedMsgServer) SubmitQueryResult 

func (*UnimplementedMsgServer) SubmitQueryResult(ctx context.Context, req *MsgSubmitQueryResult) (*MsgSubmitQueryResultResponse, error)

func (*UnimplementedMsgServer) UpdateInterchainQuery 

func (*UnimplementedMsgServer) UpdateInterchainQuery(ctx context.Context, req *MsgUpdateInterchainQueryRequest) (*MsgUpdateInterchainQueryResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) LastRemoteHeight 

func (*UnimplementedQueryServer) LastRemoteHeight(ctx context.Context, req *QueryLastRemoteHeight) (*QueryLastRemoteHeightResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

func (*UnimplementedQueryServer) QueryResult 

func (*UnimplementedQueryServer) QueryResult(ctx context.Context, req *QueryRegisteredQueryResultRequest) (*QueryRegisteredQueryResultResponse, error)

func (*UnimplementedQueryServer) RegisteredQueries 

func (*UnimplementedQueryServer) RegisteredQueries(ctx context.Context, req *QueryRegisteredQueriesRequest) (*QueryRegisteredQueriesResponse, error)

func (*UnimplementedQueryServer) RegisteredQuery 

func (*UnimplementedQueryServer) RegisteredQuery(ctx context.Context, req *QueryRegisteredQueryRequest) (*QueryRegisteredQueryResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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