Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func ContainsQueryPath(allowQueries []string, path string) bool
- func DeserializeCosmosQuery(bz []byte) (reqs []abci.RequestQuery, err error)
- func DeserializeCosmosResponse(bz []byte) (resps []abci.ResponseQuery, err error)
- func ParamKeyTable() paramtypes.KeyTable
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- func SerializeCosmosQuery(reqs []abci.RequestQuery) (bz []byte, err error)
- func SerializeCosmosResponse(resps []abci.ResponseQuery) (bz []byte, err error)
- type ChannelKeeper
- type CosmosQuery
- func (*CosmosQuery) Descriptor() ([]byte, []int)
- func (m *CosmosQuery) GetRequests() []types.RequestQuery
- func (m *CosmosQuery) Marshal() (dAtA []byte, err error)
- func (m *CosmosQuery) MarshalTo(dAtA []byte) (int, error)
- func (m *CosmosQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CosmosQuery) ProtoMessage()
- func (m *CosmosQuery) Reset()
- func (m *CosmosQuery) Size() (n int)
- func (m *CosmosQuery) String() string
- func (m *CosmosQuery) Unmarshal(dAtA []byte) error
- func (m *CosmosQuery) XXX_DiscardUnknown()
- func (m *CosmosQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CosmosQuery) XXX_Merge(src proto.Message)
- func (m *CosmosQuery) XXX_Size() int
- func (m *CosmosQuery) XXX_Unmarshal(b []byte) error
- type CosmosResponse
- func (*CosmosResponse) Descriptor() ([]byte, []int)
- func (m *CosmosResponse) GetResponses() []types.ResponseQuery
- func (m *CosmosResponse) Marshal() (dAtA []byte, err error)
- func (m *CosmosResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CosmosResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CosmosResponse) ProtoMessage()
- func (m *CosmosResponse) Reset()
- func (m *CosmosResponse) Size() (n int)
- func (m *CosmosResponse) String() string
- func (m *CosmosResponse) Unmarshal(dAtA []byte) error
- func (m *CosmosResponse) XXX_DiscardUnknown()
- func (m *CosmosResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CosmosResponse) XXX_Merge(src proto.Message)
- func (m *CosmosResponse) XXX_Size() int
- func (m *CosmosResponse) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetHostPort() string
- func (m *GenesisState) GetParams() Params
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type ICS4Wrapper
- type InterchainQueryPacketAck
- func (*InterchainQueryPacketAck) Descriptor() ([]byte, []int)
- func (m *InterchainQueryPacketAck) GetData() []byte
- func (m *InterchainQueryPacketAck) Marshal() (dAtA []byte, err error)
- func (m *InterchainQueryPacketAck) MarshalTo(dAtA []byte) (int, error)
- func (m *InterchainQueryPacketAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InterchainQueryPacketAck) ProtoMessage()
- func (m *InterchainQueryPacketAck) Reset()
- func (m *InterchainQueryPacketAck) Size() (n int)
- func (m *InterchainQueryPacketAck) String() string
- func (m *InterchainQueryPacketAck) Unmarshal(dAtA []byte) error
- func (m *InterchainQueryPacketAck) XXX_DiscardUnknown()
- func (m *InterchainQueryPacketAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InterchainQueryPacketAck) XXX_Merge(src proto.Message)
- func (m *InterchainQueryPacketAck) XXX_Size() int
- func (m *InterchainQueryPacketAck) XXX_Unmarshal(b []byte) error
- type InterchainQueryPacketData
- func (*InterchainQueryPacketData) Descriptor() ([]byte, []int)
- func (iqpd InterchainQueryPacketData) GetBytes() []byte
- func (m *InterchainQueryPacketData) GetData() []byte
- func (m *InterchainQueryPacketData) GetMemo() string
- func (m *InterchainQueryPacketData) Marshal() (dAtA []byte, err error)
- func (m *InterchainQueryPacketData) MarshalTo(dAtA []byte) (int, error)
- func (m *InterchainQueryPacketData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InterchainQueryPacketData) ProtoMessage()
- func (m *InterchainQueryPacketData) Reset()
- func (m *InterchainQueryPacketData) Size() (n int)
- func (m *InterchainQueryPacketData) String() string
- func (m *InterchainQueryPacketData) Unmarshal(dAtA []byte) error
- func (iqpd InterchainQueryPacketData) ValidateBasic() error
- func (m *InterchainQueryPacketData) XXX_DiscardUnknown()
- func (m *InterchainQueryPacketData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InterchainQueryPacketData) XXX_Merge(src proto.Message)
- func (m *InterchainQueryPacketData) XXX_Size() int
- func (m *InterchainQueryPacketData) XXX_Unmarshal(b []byte) error
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (m *Params) GetAllowQueries() []string
- func (m *Params) GetHostEnabled() bool
- func (m *Params) Marshal() (dAtA []byte, err error)
- func (m *Params) MarshalTo(dAtA []byte) (int, error)
- func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (m *Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (p Params) Validate() error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type PortKeeper
- type QueryClient
- type QueryParamsRequest
- func (*QueryParamsRequest) Descriptor() ([]byte, []int)
- func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsRequest) ProtoMessage()
- func (m *QueryParamsRequest) Reset()
- func (m *QueryParamsRequest) Size() (n int)
- func (m *QueryParamsRequest) String() string
- func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryParamsRequest) XXX_DiscardUnknown()
- func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
- func (m *QueryParamsRequest) XXX_Size() int
- func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)
- func (m *QueryParamsResponse) GetParams() *Params
- func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsResponse) ProtoMessage()
- func (m *QueryParamsResponse) Reset()
- func (m *QueryParamsResponse) Size() (n int)
- func (m *QueryParamsResponse) String() string
- func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryParamsResponse) XXX_DiscardUnknown()
- func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
- func (m *QueryParamsResponse) XXX_Size() int
- func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type UnimplementedQueryServer
Constants ¶
const ( EventTypePacketError = "icq_packet_error" AttributeKeyAckError = "error" AttributeKeyHostChannelID = "host_channel_id" )
ICQ Interchain Query events
const ( // ModuleName defines the interchain query module name ModuleName = "interchainquery" // PortID is the default port id that the interchain query module binds to PortID = "icqhost" // Version defines the current version for interchain query Version = "icq-1" // StoreKey is the store key string for interchain query StoreKey = ModuleName // RouterKey is the message route for interchain query RouterKey = ModuleName // QuerierRoute is the querier route for interchain query QuerierRoute = ModuleName )
const ( // DefaultHostEnabled is the default value for the host param (set to true) DefaultHostEnabled = true )
Variables ¶
var ( ErrUnknownDataType = errors.Register(ModuleName, 1, "unknown data type") ErrInvalidChannelFlow = errors.Register(ModuleName, 2, "invalid message sent to channel end") ErrInvalidHostPort = errors.Register(ModuleName, 3, "invalid host port") ErrHostDisabled = errors.Register(ModuleName, 4, "host is disabled") ErrInvalidVersion = errors.Register(ModuleName, 5, "invalid version") )
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthIcq = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowIcq = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupIcq = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPacket = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPacket = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPacket = fmt.Errorf("proto: unexpected end of group") )
var ( // KeyHostEnabled is the store key for HostEnabled Params KeyHostEnabled = []byte("HostEnabled") // KeyAllowQueries is the store key for the AllowQueries Params KeyAllowQueries = []byte("AllowQueries") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
ModuleCdc references the global interchain queries module codec. Note, the codec should ONLY be used in certain instances of tests and for JSON encoding.
The actual codec used for serialization should be provided to interchain queries and defined at the application level.
var PortKey = []byte{0x01}
PortKey defines the key to store the port ID in store
Functions ¶
func ContainsQueryPath ¶
ContainsQueryPath returns true if the path is present in allowQueries, otherwise false
func DeserializeCosmosQuery ¶
func DeserializeCosmosQuery(bz []byte) (reqs []abci.RequestQuery, err error)
func DeserializeCosmosResponse ¶
func DeserializeCosmosResponse(bz []byte) (resps []abci.ResponseQuery, err error)
func ParamKeyTable ¶
func ParamKeyTable() paramtypes.KeyTable
ParamKeyTable type declaration for parameters
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
func SerializeCosmosQuery ¶
func SerializeCosmosQuery(reqs []abci.RequestQuery) (bz []byte, err error)
func SerializeCosmosResponse ¶
func SerializeCosmosResponse(resps []abci.ResponseQuery) (bz []byte, err error)
Types ¶
type ChannelKeeper ¶
type ChannelKeeper interface { GetChannel(ctx sdk.Context, srcPort, srcChan string) (channel channeltypes.Channel, found bool) GetNextSequenceSend(ctx sdk.Context, portID, channelID string) (uint64, bool) GetConnection(ctx sdk.Context, connectionID string) (ibcexported.ConnectionI, error) }
ChannelKeeper defines the expected IBC channel keeper
type CosmosQuery ¶
type CosmosQuery struct {
Requests []types.RequestQuery `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests"`
}
CosmosQuery contains a list of tendermint ABCI query requests. It should be used when sending queries to an SDK host chain.
func (*CosmosQuery) Descriptor ¶
func (*CosmosQuery) Descriptor() ([]byte, []int)
func (*CosmosQuery) GetRequests ¶
func (m *CosmosQuery) GetRequests() []types.RequestQuery
func (*CosmosQuery) Marshal ¶
func (m *CosmosQuery) Marshal() (dAtA []byte, err error)
func (*CosmosQuery) MarshalToSizedBuffer ¶
func (m *CosmosQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CosmosQuery) ProtoMessage ¶
func (*CosmosQuery) ProtoMessage()
func (*CosmosQuery) Reset ¶
func (m *CosmosQuery) Reset()
func (*CosmosQuery) Size ¶
func (m *CosmosQuery) Size() (n int)
func (*CosmosQuery) String ¶
func (m *CosmosQuery) String() string
func (*CosmosQuery) Unmarshal ¶
func (m *CosmosQuery) Unmarshal(dAtA []byte) error
func (*CosmosQuery) XXX_DiscardUnknown ¶
func (m *CosmosQuery) XXX_DiscardUnknown()
func (*CosmosQuery) XXX_Marshal ¶
func (m *CosmosQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CosmosQuery) XXX_Merge ¶
func (m *CosmosQuery) XXX_Merge(src proto.Message)
func (*CosmosQuery) XXX_Size ¶
func (m *CosmosQuery) XXX_Size() int
func (*CosmosQuery) XXX_Unmarshal ¶
func (m *CosmosQuery) XXX_Unmarshal(b []byte) error
type CosmosResponse ¶
type CosmosResponse struct {
Responses []types.ResponseQuery `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses"`
}
CosmosResponse contains a list of tendermint ABCI query responses. It should be used when receiving responses from an SDK host chain.
func (*CosmosResponse) Descriptor ¶
func (*CosmosResponse) Descriptor() ([]byte, []int)
func (*CosmosResponse) GetResponses ¶
func (m *CosmosResponse) GetResponses() []types.ResponseQuery
func (*CosmosResponse) Marshal ¶
func (m *CosmosResponse) Marshal() (dAtA []byte, err error)
func (*CosmosResponse) MarshalToSizedBuffer ¶
func (m *CosmosResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CosmosResponse) ProtoMessage ¶
func (*CosmosResponse) ProtoMessage()
func (*CosmosResponse) Reset ¶
func (m *CosmosResponse) Reset()
func (*CosmosResponse) Size ¶
func (m *CosmosResponse) Size() (n int)
func (*CosmosResponse) String ¶
func (m *CosmosResponse) String() string
func (*CosmosResponse) Unmarshal ¶
func (m *CosmosResponse) Unmarshal(dAtA []byte) error
func (*CosmosResponse) XXX_DiscardUnknown ¶
func (m *CosmosResponse) XXX_DiscardUnknown()
func (*CosmosResponse) XXX_Marshal ¶
func (m *CosmosResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CosmosResponse) XXX_Merge ¶
func (m *CosmosResponse) XXX_Merge(src proto.Message)
func (*CosmosResponse) XXX_Size ¶
func (m *CosmosResponse) XXX_Size() int
func (*CosmosResponse) XXX_Unmarshal ¶
func (m *CosmosResponse) XXX_Unmarshal(b []byte) error
type GenesisState ¶
type GenesisState struct { HostPort string `protobuf:"bytes,1,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"` Params Params `protobuf:"bytes,4,opt,name=params,proto3" json:"params"` }
GenesisState defines the interchain query genesis state
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis creates and returns the default interchain query GenesisState
func NewHostGenesisState ¶
func NewHostGenesisState(hostPort string, params Params) *GenesisState
NewHostGenesisState creates a returns a new GenesisState instance
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetHostPort ¶
func (m *GenesisState) GetHostPort() string
func (*GenesisState) GetParams ¶
func (m *GenesisState) GetParams() Params
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic validation of the GenesisState
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 ICS4Wrapper ¶
type ICS4Wrapper interface { SendPacket(ctx sdk.Context, channelCap *capabilitytypes.Capability, packet ibcexported.PacketI) error GetAppVersion(ctx sdk.Context, portID, channelID string) (string, bool) }
ICS4Wrapper defines the expected ICS4Wrapper for middleware
type InterchainQueryPacketAck ¶
type InterchainQueryPacketAck struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}
InterchainQueryPacketAck is comprised of an ABCI query response with non-deterministic fields left empty (e.g. Codespace, Log, Info and ...).
func (*InterchainQueryPacketAck) Descriptor ¶
func (*InterchainQueryPacketAck) Descriptor() ([]byte, []int)
func (*InterchainQueryPacketAck) GetData ¶
func (m *InterchainQueryPacketAck) GetData() []byte
func (*InterchainQueryPacketAck) Marshal ¶
func (m *InterchainQueryPacketAck) Marshal() (dAtA []byte, err error)
func (*InterchainQueryPacketAck) MarshalTo ¶
func (m *InterchainQueryPacketAck) MarshalTo(dAtA []byte) (int, error)
func (*InterchainQueryPacketAck) MarshalToSizedBuffer ¶
func (m *InterchainQueryPacketAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InterchainQueryPacketAck) ProtoMessage ¶
func (*InterchainQueryPacketAck) ProtoMessage()
func (*InterchainQueryPacketAck) Reset ¶
func (m *InterchainQueryPacketAck) Reset()
func (*InterchainQueryPacketAck) Size ¶
func (m *InterchainQueryPacketAck) Size() (n int)
func (*InterchainQueryPacketAck) String ¶
func (m *InterchainQueryPacketAck) String() string
func (*InterchainQueryPacketAck) Unmarshal ¶
func (m *InterchainQueryPacketAck) Unmarshal(dAtA []byte) error
func (*InterchainQueryPacketAck) XXX_DiscardUnknown ¶
func (m *InterchainQueryPacketAck) XXX_DiscardUnknown()
func (*InterchainQueryPacketAck) XXX_Marshal ¶
func (m *InterchainQueryPacketAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InterchainQueryPacketAck) XXX_Merge ¶
func (m *InterchainQueryPacketAck) XXX_Merge(src proto.Message)
func (*InterchainQueryPacketAck) XXX_Size ¶
func (m *InterchainQueryPacketAck) XXX_Size() int
func (*InterchainQueryPacketAck) XXX_Unmarshal ¶
func (m *InterchainQueryPacketAck) XXX_Unmarshal(b []byte) error
type InterchainQueryPacketData ¶
type InterchainQueryPacketData struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // optional memo Memo string `protobuf:"bytes,2,opt,name=memo,proto3" json:"memo,omitempty"` }
InterchainQueryPacketData is comprised of raw query.
func (*InterchainQueryPacketData) Descriptor ¶
func (*InterchainQueryPacketData) Descriptor() ([]byte, []int)
func (InterchainQueryPacketData) GetBytes ¶
func (iqpd InterchainQueryPacketData) GetBytes() []byte
GetBytes returns the JSON marshalled interchain query packet data.
func (*InterchainQueryPacketData) GetData ¶
func (m *InterchainQueryPacketData) GetData() []byte
func (*InterchainQueryPacketData) GetMemo ¶
func (m *InterchainQueryPacketData) GetMemo() string
func (*InterchainQueryPacketData) Marshal ¶
func (m *InterchainQueryPacketData) Marshal() (dAtA []byte, err error)
func (*InterchainQueryPacketData) MarshalTo ¶
func (m *InterchainQueryPacketData) MarshalTo(dAtA []byte) (int, error)
func (*InterchainQueryPacketData) MarshalToSizedBuffer ¶
func (m *InterchainQueryPacketData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InterchainQueryPacketData) ProtoMessage ¶
func (*InterchainQueryPacketData) ProtoMessage()
func (*InterchainQueryPacketData) Reset ¶
func (m *InterchainQueryPacketData) Reset()
func (*InterchainQueryPacketData) Size ¶
func (m *InterchainQueryPacketData) Size() (n int)
func (*InterchainQueryPacketData) String ¶
func (m *InterchainQueryPacketData) String() string
func (*InterchainQueryPacketData) Unmarshal ¶
func (m *InterchainQueryPacketData) Unmarshal(dAtA []byte) error
func (InterchainQueryPacketData) ValidateBasic ¶
func (iqpd InterchainQueryPacketData) ValidateBasic() error
ValidateBasic performs basic validation of the interchain query packet data.
func (*InterchainQueryPacketData) XXX_DiscardUnknown ¶
func (m *InterchainQueryPacketData) XXX_DiscardUnknown()
func (*InterchainQueryPacketData) XXX_Marshal ¶
func (m *InterchainQueryPacketData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InterchainQueryPacketData) XXX_Merge ¶
func (m *InterchainQueryPacketData) XXX_Merge(src proto.Message)
func (*InterchainQueryPacketData) XXX_Size ¶
func (m *InterchainQueryPacketData) XXX_Size() int
func (*InterchainQueryPacketData) XXX_Unmarshal ¶
func (m *InterchainQueryPacketData) XXX_Unmarshal(b []byte) error
type Params ¶
type Params struct { // host_enabled enables or disables the host submodule. HostEnabled bool `protobuf:"varint,2,opt,name=host_enabled,json=hostEnabled,proto3" json:"host_enabled,omitempty" yaml:"host_enabled"` // allow_queries defines a list of query paths allowed to be queried on a host chain. AllowQueries []string `protobuf:"bytes,3,rep,name=allow_queries,json=allowQueries,proto3" json:"allow_queries,omitempty" yaml:"allow_queries"` }
Params defines the set of on-chain interchain query parameters.
func DefaultParams ¶
func DefaultParams() Params
DefaultParams is the default parameter configuration
func (*Params) Descriptor ¶
func (*Params) GetAllowQueries ¶
func (*Params) GetHostEnabled ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ParamSetPairs ¶
func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
ParamSetPairs implements params.ParamSet
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
type PortKeeper ¶
type PortKeeper interface { BindPort(ctx sdk.Context, portID string) *capabilitytypes.Capability IsBound(ctx sdk.Context, portID string) bool }
PortKeeper defines the expected IBC port keeper
type QueryClient ¶
type QueryClient interface { // Params queries all parameters of the ICQ module. Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 QueryParamsRequest ¶
type QueryParamsRequest struct { }
QueryParamsRequest is the 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 defines the parameters of the module. Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"` }
QueryParamsResponse is the 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 QueryServer ¶
type QueryServer interface { // Params queries all parameters of the ICQ module. Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) }
QueryServer is the server API for Query service.
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) Params ¶
func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)