Documentation ¶
Overview ¶
Package types is a reverse proxy. It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func KeyPrefix(p string) []byte
- func ParamKeyTable() paramtypes.KeyTable
- func QueryRequestStoreKey(packetSequence uint64) []byte
- func QueryResponseStoreKey(packetSequence uint64) []byte
- func RegisterCodec(cdc *codec.LegacyAmino)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type AccountKeeper
- type BankKeeper
- type ChannelKeeper
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetParams() Params
- func (m *GenesisState) GetPortId() string
- 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 MsgClient
- type MsgServer
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- 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 (p 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 QueryQueryStateRequest
- func (*QueryQueryStateRequest) Descriptor() ([]byte, []int)
- func (m *QueryQueryStateRequest) GetSequence() uint64
- func (m *QueryQueryStateRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryQueryStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryQueryStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryQueryStateRequest) ProtoMessage()
- func (m *QueryQueryStateRequest) Reset()
- func (m *QueryQueryStateRequest) Size() (n int)
- func (m *QueryQueryStateRequest) String() string
- func (m *QueryQueryStateRequest) Unmarshal(dAtA []byte) error
- func (m *QueryQueryStateRequest) XXX_DiscardUnknown()
- func (m *QueryQueryStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryQueryStateRequest) XXX_Merge(src proto.Message)
- func (m *QueryQueryStateRequest) XXX_Size() int
- func (m *QueryQueryStateRequest) XXX_Unmarshal(b []byte) error
- type QueryQueryStateResponse
- func (*QueryQueryStateResponse) Descriptor() ([]byte, []int)
- func (m *QueryQueryStateResponse) GetRequest() types.Any
- func (m *QueryQueryStateResponse) GetResponse() *types.Any
- func (m *QueryQueryStateResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryQueryStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryQueryStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryQueryStateResponse) ProtoMessage()
- func (m *QueryQueryStateResponse) Reset()
- func (m *QueryQueryStateResponse) Size() (n int)
- func (m *QueryQueryStateResponse) String() string
- func (m *QueryQueryStateResponse) Unmarshal(dAtA []byte) error
- func (m *QueryQueryStateResponse) XXX_DiscardUnknown()
- func (m *QueryQueryStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryQueryStateResponse) XXX_Merge(src proto.Message)
- func (m *QueryQueryStateResponse) XXX_Size() int
- func (m *QueryQueryStateResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type QuerySpotPriceStruct
- func (*QuerySpotPriceStruct) Descriptor() ([]byte, []int)
- func (x *QuerySpotPriceStruct) GetBaseAssetDenom() string
- func (x *QuerySpotPriceStruct) GetChannelID() string
- func (x *QuerySpotPriceStruct) GetCreater() string
- func (x *QuerySpotPriceStruct) GetPoolID() string
- func (x *QuerySpotPriceStruct) GetQuoteAssetDenom() string
- func (msg *QuerySpotPriceStruct) GetSignBytes() []byte
- func (msg *QuerySpotPriceStruct) GetSigners() []sdk.AccAddress
- func (m *QuerySpotPriceStruct) Marshal() (dAtA []byte, err error)
- func (m *QuerySpotPriceStruct) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySpotPriceStruct) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySpotPriceStruct) ProtoMessage()
- func (m *QuerySpotPriceStruct) Reset()
- func (msg *QuerySpotPriceStruct) Route() string
- func (m *QuerySpotPriceStruct) Size() (n int)
- func (m *QuerySpotPriceStruct) String() string
- func (msg *QuerySpotPriceStruct) Type() string
- func (m *QuerySpotPriceStruct) Unmarshal(dAtA []byte) error
- func (msg *QuerySpotPriceStruct) ValidateBasic() error
- func (m *QuerySpotPriceStruct) XXX_DiscardUnknown()
- func (m *QuerySpotPriceStruct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySpotPriceStruct) XXX_Merge(src proto.Message)
- func (m *QuerySpotPriceStruct) XXX_Size() int
- func (m *QuerySpotPriceStruct) XXX_Unmarshal(b []byte) error
- type QuerySpotPriceStructResponse
- func (*QuerySpotPriceStructResponse) Descriptor() ([]byte, []int)
- func (m *QuerySpotPriceStructResponse) GetSequence() uint64
- func (m *QuerySpotPriceStructResponse) Marshal() (dAtA []byte, err error)
- func (m *QuerySpotPriceStructResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QuerySpotPriceStructResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QuerySpotPriceStructResponse) ProtoMessage()
- func (m *QuerySpotPriceStructResponse) Reset()
- func (m *QuerySpotPriceStructResponse) Size() (n int)
- func (m *QuerySpotPriceStructResponse) String() string
- func (m *QuerySpotPriceStructResponse) Unmarshal(dAtA []byte) error
- func (m *QuerySpotPriceStructResponse) XXX_DiscardUnknown()
- func (m *QuerySpotPriceStructResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QuerySpotPriceStructResponse) XXX_Merge(src proto.Message)
- func (m *QuerySpotPriceStructResponse) XXX_Size() int
- func (m *QuerySpotPriceStructResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedMsgServer
- type UnimplementedQueryServer
Constants ¶
const ( EventTypeQueryResult = "query_result" EventTypeTimeout = "timeout" AttributeKeyAckSuccess = "success" AttributeKeyAck = "acknowledgement" AttributeKeyAckError = "error" AttributeKeySequence = "sequence" )
IBC events
const ( // ModuleName defines the module name ModuleName = "interchain-swap" // StoreKey defines the primary module store key StoreKey = ModuleName // RouterKey defines the module's message routing key RouterKey = ModuleName QuerierRoute = ModuleName // MemStoreKey defines the in-memory store key MemStoreKey = "mem_interchain-swap" PortID = "interquery" // Version defines the current version the IBC module supports Version = icqtypes.Version )
const DefaultIndex uint64 = 1
DefaultIndex is the default global index
const TypeMsgSendQueryOsmosisDex = "send_query_to_OsmosisDex"
Variables ¶
var ( Amino = codec.NewLegacyAmino() ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry()) )
var ( ErrSample = sdkerrors.Register(ModuleName, 1100, "sample error") ErrInvalidPacketTimeout = sdkerrors.Register(ModuleName, 1500, "invalid packet timeout") ErrInvalidVersion = sdkerrors.Register(ModuleName, 1501, "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 ( ErrInvalidLengthParams = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowParams = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group") )
var ( // QueryResponseStoreKeyPrefix is a prefix for storing request QueryRequestStoreKeyPrefix = "coin_rates_request" // QueryResponseStoreKeyPrefix is a prefix for storing result QueryResponseStoreKeyPrefix = "coin_rates_response" // LastQueryPacketSeqKey is the key for the last packet sequence LastQueryPacketSeqKey = "coin_rates_last_id" )
Functions ¶
func ParamKeyTable ¶
func ParamKeyTable() paramtypes.KeyTable
ParamKeyTable the param key table for launch module
func QueryRequestStoreKey ¶
QueryRequestStoreKey is a function to generate key for each result in store
func QueryResponseStoreKey ¶
QueryResponseStoreKey is a function to generate key for each result in store
func RegisterCodec ¶
func RegisterCodec(cdc *codec.LegacyAmino)
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type AccountKeeper ¶
AccountKeeper defines the expected account keeper used for simulations (noalias)
type BankKeeper ¶
BankKeeper defines the expected interface needed to retrieve account balances.
type ChannelKeeper ¶
type GenesisState ¶
type GenesisState struct { Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` PortId string `protobuf:"bytes,2,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` }
GenesisState defines the interquery module's genesis state.
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns the default genesis state
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetParams ¶
func (m *GenesisState) GetParams() Params
func (*GenesisState) GetPortId ¶
func (m *GenesisState) GetPortId() string
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type ICS4Wrapper ¶
type ICS4Wrapper interface {
SendPacket(ctx sdk.Context, channelCap *capabilitytypes.Capability, packet ibcexported.PacketI) error
}
ICS4Wrapper defines the expected ICS4Wrapper for middleware
type MsgClient ¶
type MsgClient interface {
SendQueryOsmosisDEX(ctx context.Context, in *QuerySpotPriceStructResponse, opts ...grpc.CallOption) (*QuerySpotPriceStructResponse, 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 MsgServer ¶
type MsgServer interface {
SendQueryOsmosisDEX(context.Context, *QuerySpotPriceStruct) (*QuerySpotPriceStructResponse, error)
}
MsgServer is the server API for Msg service.
type Params ¶
type Params struct { }
Params defines the parameters for the module.
func (*Params) Descriptor ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ParamSetPairs ¶
func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
ParamSetPairs get the 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 { // Parameters queries the parameters of the module. Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) // Queries a list of QueryState items. QueryState(ctx context.Context, in *QueryQueryStateRequest, opts ...grpc.CallOption) (*QueryQueryStateResponse, 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 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 QueryQueryStateRequest ¶
type QueryQueryStateRequest struct {
Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
}
func (*QueryQueryStateRequest) Descriptor ¶
func (*QueryQueryStateRequest) Descriptor() ([]byte, []int)
func (*QueryQueryStateRequest) GetSequence ¶
func (m *QueryQueryStateRequest) GetSequence() uint64
func (*QueryQueryStateRequest) Marshal ¶
func (m *QueryQueryStateRequest) Marshal() (dAtA []byte, err error)
func (*QueryQueryStateRequest) MarshalTo ¶
func (m *QueryQueryStateRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryQueryStateRequest) MarshalToSizedBuffer ¶
func (m *QueryQueryStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryQueryStateRequest) ProtoMessage ¶
func (*QueryQueryStateRequest) ProtoMessage()
func (*QueryQueryStateRequest) Reset ¶
func (m *QueryQueryStateRequest) Reset()
func (*QueryQueryStateRequest) Size ¶
func (m *QueryQueryStateRequest) Size() (n int)
func (*QueryQueryStateRequest) String ¶
func (m *QueryQueryStateRequest) String() string
func (*QueryQueryStateRequest) Unmarshal ¶
func (m *QueryQueryStateRequest) Unmarshal(dAtA []byte) error
func (*QueryQueryStateRequest) XXX_DiscardUnknown ¶
func (m *QueryQueryStateRequest) XXX_DiscardUnknown()
func (*QueryQueryStateRequest) XXX_Marshal ¶
func (m *QueryQueryStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryQueryStateRequest) XXX_Merge ¶
func (m *QueryQueryStateRequest) XXX_Merge(src proto.Message)
func (*QueryQueryStateRequest) XXX_Size ¶
func (m *QueryQueryStateRequest) XXX_Size() int
func (*QueryQueryStateRequest) XXX_Unmarshal ¶
func (m *QueryQueryStateRequest) XXX_Unmarshal(b []byte) error
type QueryQueryStateResponse ¶
type QueryQueryStateResponse struct { Request types.Any `protobuf:"bytes,1,opt,name=request,proto3" json:"request"` Response *types.Any `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"` }
func (*QueryQueryStateResponse) Descriptor ¶
func (*QueryQueryStateResponse) Descriptor() ([]byte, []int)
func (*QueryQueryStateResponse) GetRequest ¶
func (m *QueryQueryStateResponse) GetRequest() types.Any
func (*QueryQueryStateResponse) GetResponse ¶
func (m *QueryQueryStateResponse) GetResponse() *types.Any
func (*QueryQueryStateResponse) Marshal ¶
func (m *QueryQueryStateResponse) Marshal() (dAtA []byte, err error)
func (*QueryQueryStateResponse) MarshalTo ¶
func (m *QueryQueryStateResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryQueryStateResponse) MarshalToSizedBuffer ¶
func (m *QueryQueryStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryQueryStateResponse) ProtoMessage ¶
func (*QueryQueryStateResponse) ProtoMessage()
func (*QueryQueryStateResponse) Reset ¶
func (m *QueryQueryStateResponse) Reset()
func (*QueryQueryStateResponse) Size ¶
func (m *QueryQueryStateResponse) Size() (n int)
func (*QueryQueryStateResponse) String ¶
func (m *QueryQueryStateResponse) String() string
func (*QueryQueryStateResponse) Unmarshal ¶
func (m *QueryQueryStateResponse) Unmarshal(dAtA []byte) error
func (*QueryQueryStateResponse) XXX_DiscardUnknown ¶
func (m *QueryQueryStateResponse) XXX_DiscardUnknown()
func (*QueryQueryStateResponse) XXX_Marshal ¶
func (m *QueryQueryStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryQueryStateResponse) XXX_Merge ¶
func (m *QueryQueryStateResponse) XXX_Merge(src proto.Message)
func (*QueryQueryStateResponse) XXX_Size ¶
func (m *QueryQueryStateResponse) XXX_Size() int
func (*QueryQueryStateResponse) XXX_Unmarshal ¶
func (m *QueryQueryStateResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Parameters queries the parameters of the module. Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) // Queries a list of QueryState items. QueryState(context.Context, *QueryQueryStateRequest) (*QueryQueryStateResponse, error) }
QueryServer is the server API for Query service.
type QuerySpotPriceStruct ¶
type QuerySpotPriceStruct struct { Creater string `protobuf:"bytes,1,opt,name=Creater,proto3" json:"Creater,omitempty"` ChannelID string `protobuf:"bytes,2,opt,name=ChannelID,proto3" json:"ChannelID,omitempty"` PoolID string `protobuf:"bytes,3,opt,name=PoolID,proto3" json:"PoolID,omitempty"` BaseAssetDenom string `protobuf:"bytes,4,opt,name=BaseAssetDenom,proto3" json:"BaseAssetDenom,omitempty"` QuoteAssetDenom string `protobuf:"bytes,5,opt,name=QuoteAssetDenom,proto3" json:"QuoteAssetDenom,omitempty"` }
func NewMsgSendQueryAllBalances ¶
func NewMsgSendQueryAllBalances(creator, channelId string, poolID string, baseAssetDenom string, quoteAssetDenom string) *QuerySpotPriceStruct
func (*QuerySpotPriceStruct) Descriptor ¶
func (*QuerySpotPriceStruct) Descriptor() ([]byte, []int)
func (*QuerySpotPriceStruct) GetBaseAssetDenom ¶
func (x *QuerySpotPriceStruct) GetBaseAssetDenom() string
func (*QuerySpotPriceStruct) GetChannelID ¶
func (x *QuerySpotPriceStruct) GetChannelID() string
func (*QuerySpotPriceStruct) GetCreater ¶
func (x *QuerySpotPriceStruct) GetCreater() string
func (*QuerySpotPriceStruct) GetPoolID ¶
func (x *QuerySpotPriceStruct) GetPoolID() string
func (*QuerySpotPriceStruct) GetQuoteAssetDenom ¶
func (x *QuerySpotPriceStruct) GetQuoteAssetDenom() string
func (*QuerySpotPriceStruct) GetSignBytes ¶
func (msg *QuerySpotPriceStruct) GetSignBytes() []byte
func (*QuerySpotPriceStruct) GetSigners ¶
func (msg *QuerySpotPriceStruct) GetSigners() []sdk.AccAddress
func (*QuerySpotPriceStruct) Marshal ¶
func (m *QuerySpotPriceStruct) Marshal() (dAtA []byte, err error)
func (*QuerySpotPriceStruct) MarshalTo ¶
func (m *QuerySpotPriceStruct) MarshalTo(dAtA []byte) (int, error)
func (*QuerySpotPriceStruct) MarshalToSizedBuffer ¶
func (m *QuerySpotPriceStruct) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySpotPriceStruct) ProtoMessage ¶
func (*QuerySpotPriceStruct) ProtoMessage()
func (*QuerySpotPriceStruct) Reset ¶
func (m *QuerySpotPriceStruct) Reset()
func (*QuerySpotPriceStruct) Route ¶
func (msg *QuerySpotPriceStruct) Route() string
func (*QuerySpotPriceStruct) Size ¶
func (m *QuerySpotPriceStruct) Size() (n int)
func (*QuerySpotPriceStruct) String ¶
func (m *QuerySpotPriceStruct) String() string
func (*QuerySpotPriceStruct) Type ¶
func (msg *QuerySpotPriceStruct) Type() string
func (*QuerySpotPriceStruct) Unmarshal ¶
func (m *QuerySpotPriceStruct) Unmarshal(dAtA []byte) error
func (*QuerySpotPriceStruct) ValidateBasic ¶
func (msg *QuerySpotPriceStruct) ValidateBasic() error
func (*QuerySpotPriceStruct) XXX_DiscardUnknown ¶
func (m *QuerySpotPriceStruct) XXX_DiscardUnknown()
func (*QuerySpotPriceStruct) XXX_Marshal ¶
func (m *QuerySpotPriceStruct) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySpotPriceStruct) XXX_Merge ¶
func (m *QuerySpotPriceStruct) XXX_Merge(src proto.Message)
func (*QuerySpotPriceStruct) XXX_Size ¶
func (m *QuerySpotPriceStruct) XXX_Size() int
func (*QuerySpotPriceStruct) XXX_Unmarshal ¶
func (m *QuerySpotPriceStruct) XXX_Unmarshal(b []byte) error
type QuerySpotPriceStructResponse ¶
type QuerySpotPriceStructResponse struct {
Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
}
func (*QuerySpotPriceStructResponse) Descriptor ¶
func (*QuerySpotPriceStructResponse) Descriptor() ([]byte, []int)
func (*QuerySpotPriceStructResponse) GetSequence ¶
func (m *QuerySpotPriceStructResponse) GetSequence() uint64
func (*QuerySpotPriceStructResponse) Marshal ¶
func (m *QuerySpotPriceStructResponse) Marshal() (dAtA []byte, err error)
func (*QuerySpotPriceStructResponse) MarshalTo ¶
func (m *QuerySpotPriceStructResponse) MarshalTo(dAtA []byte) (int, error)
func (*QuerySpotPriceStructResponse) MarshalToSizedBuffer ¶
func (m *QuerySpotPriceStructResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QuerySpotPriceStructResponse) ProtoMessage ¶
func (*QuerySpotPriceStructResponse) ProtoMessage()
func (*QuerySpotPriceStructResponse) Reset ¶
func (m *QuerySpotPriceStructResponse) Reset()
func (*QuerySpotPriceStructResponse) Size ¶
func (m *QuerySpotPriceStructResponse) Size() (n int)
func (*QuerySpotPriceStructResponse) String ¶
func (m *QuerySpotPriceStructResponse) String() string
func (*QuerySpotPriceStructResponse) Unmarshal ¶
func (m *QuerySpotPriceStructResponse) Unmarshal(dAtA []byte) error
func (*QuerySpotPriceStructResponse) XXX_DiscardUnknown ¶
func (m *QuerySpotPriceStructResponse) XXX_DiscardUnknown()
func (*QuerySpotPriceStructResponse) XXX_Marshal ¶
func (m *QuerySpotPriceStructResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QuerySpotPriceStructResponse) XXX_Merge ¶
func (m *QuerySpotPriceStructResponse) XXX_Merge(src proto.Message)
func (*QuerySpotPriceStructResponse) XXX_Size ¶
func (m *QuerySpotPriceStructResponse) XXX_Size() int
func (*QuerySpotPriceStructResponse) XXX_Unmarshal ¶
func (m *QuerySpotPriceStructResponse) XXX_Unmarshal(b []byte) error
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) SendQueryOsmosisDEX ¶
func (*UnimplementedMsgServer) SendQueryOsmosisDEX(ctx context.Context, req *QuerySpotPriceStruct) (*QuerySpotPriceStructResponse, error)
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)
func (*UnimplementedQueryServer) QueryState ¶
func (*UnimplementedQueryServer) QueryState(ctx context.Context, req *QueryQueryStateRequest) (*QueryQueryStateResponse, error)