Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func GetRefStoreKey(symbol string) []byte
- func ParamKeyTable() paramtypes.KeyTable
- func RegisterInterfaces(registry codectypes.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 BankKeeper
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- 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 GetReferenceData
- func (*GetReferenceData) Descriptor() ([]byte, []int)
- func (m *GetReferenceData) GetBaseQuoteRate() string
- func (m *GetReferenceData) GetBaseQuoteSymbol() string
- func (m *GetReferenceData) GetLastUpdateBase() string
- func (m *GetReferenceData) GetLastUpdateQuote() string
- func (m *GetReferenceData) Marshal() (dAtA []byte, err error)
- func (m *GetReferenceData) MarshalTo(dAtA []byte) (int, error)
- func (m *GetReferenceData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetReferenceData) ProtoMessage()
- func (m *GetReferenceData) Reset()
- func (m *GetReferenceData) Size() (n int)
- func (m *GetReferenceData) String() string
- func (m *GetReferenceData) Unmarshal(dAtA []byte) error
- func (m *GetReferenceData) XXX_DiscardUnknown()
- func (m *GetReferenceData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetReferenceData) XXX_Merge(src proto.Message)
- func (m *GetReferenceData) XXX_Size() int
- func (m *GetReferenceData) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgRelay
- func (*MsgRelay) Descriptor() ([]byte, []int)
- func (m *MsgRelay) GetRates() []uint64
- func (m *MsgRelay) GetRelayer() string
- func (m *MsgRelay) GetRequestIDs() []uint64
- func (m *MsgRelay) GetResolveTimes() []uint64
- func (msg *MsgRelay) GetSignBytes() []byte
- func (msg MsgRelay) GetSigners() []sdk.AccAddress
- func (m *MsgRelay) GetSymbols() []string
- func (m *MsgRelay) Marshal() (dAtA []byte, err error)
- func (m *MsgRelay) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRelay) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRelay) ProtoMessage()
- func (m *MsgRelay) Reset()
- func (msg MsgRelay) Route() string
- func (m *MsgRelay) Size() (n int)
- func (m *MsgRelay) String() string
- func (msg MsgRelay) Type() string
- func (m *MsgRelay) Unmarshal(dAtA []byte) error
- func (msg MsgRelay) ValidateBasic() error
- func (m *MsgRelay) XXX_DiscardUnknown()
- func (m *MsgRelay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRelay) XXX_Merge(src proto.Message)
- func (m *MsgRelay) XXX_Size() int
- func (m *MsgRelay) XXX_Unmarshal(b []byte) error
- type MsgRelayResponse
- func (*MsgRelayResponse) Descriptor() ([]byte, []int)
- func (m *MsgRelayResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgRelayResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRelayResponse) ProtoMessage()
- func (m *MsgRelayResponse) Reset()
- func (m *MsgRelayResponse) Size() (n int)
- func (m *MsgRelayResponse) String() string
- func (m *MsgRelayResponse) Unmarshal(dAtA []byte) error
- func (m *MsgRelayResponse) XXX_DiscardUnknown()
- func (m *MsgRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRelayResponse) XXX_Merge(src proto.Message)
- func (m *MsgRelayResponse) XXX_Size() int
- func (m *MsgRelayResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type MsgSetPrice
- func (*MsgSetPrice) Descriptor() ([]byte, []int)
- func (msg *MsgSetPrice) GetSignBytes() []byte
- func (msg MsgSetPrice) GetSigners() []sdk.AccAddress
- func (m *MsgSetPrice) Marshal() (dAtA []byte, err error)
- func (m *MsgSetPrice) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSetPrice) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSetPrice) ProtoMessage()
- func (m *MsgSetPrice) Reset()
- func (msg MsgSetPrice) Route() string
- func (m *MsgSetPrice) Size() (n int)
- func (m *MsgSetPrice) String() string
- func (msg MsgSetPrice) Type() string
- func (m *MsgSetPrice) Unmarshal(dAtA []byte) error
- func (msg MsgSetPrice) ValidateBasic() error
- func (m *MsgSetPrice) XXX_DiscardUnknown()
- func (m *MsgSetPrice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSetPrice) XXX_Merge(src proto.Message)
- func (m *MsgSetPrice) XXX_Size() int
- func (m *MsgSetPrice) XXX_Unmarshal(b []byte) error
- type MsgSetPriceResponse
- func (*MsgSetPriceResponse) Descriptor() ([]byte, []int)
- func (m *MsgSetPriceResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgSetPriceResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgSetPriceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgSetPriceResponse) ProtoMessage()
- func (m *MsgSetPriceResponse) Reset()
- func (m *MsgSetPriceResponse) Size() (n int)
- func (m *MsgSetPriceResponse) String() string
- func (m *MsgSetPriceResponse) Unmarshal(dAtA []byte) error
- func (m *MsgSetPriceResponse) XXX_DiscardUnknown()
- func (m *MsgSetPriceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgSetPriceResponse) XXX_Merge(src proto.Message)
- func (m *MsgSetPriceResponse) XXX_Size() int
- func (m *MsgSetPriceResponse) XXX_Unmarshal(b []byte) error
- type ParamSet
- type ParamSetPair
- type ParamSetPairs
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (this *Params) Equal(that interface{}) bool
- func (m *Params) GetRelayers() []string
- 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 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 Ref
- func (*Ref) Descriptor() ([]byte, []int)
- func (m *Ref) GetRate() uint64
- func (m *Ref) GetRequest_ID() uint64
- func (m *Ref) GetResolveTime() uint64
- func (m *Ref) Marshal() (dAtA []byte, err error)
- func (m *Ref) MarshalTo(dAtA []byte) (int, error)
- func (m *Ref) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Ref) ProtoMessage()
- func (m *Ref) Reset()
- func (m *Ref) Size() (n int)
- func (m *Ref) String() string
- func (m *Ref) Unmarshal(dAtA []byte) error
- func (m *Ref) XXX_DiscardUnknown()
- func (m *Ref) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Ref) XXX_Merge(src proto.Message)
- func (m *Ref) XXX_Size() int
- func (m *Ref) XXX_Unmarshal(b []byte) error
- type ReferenceData
- func (*ReferenceData) Descriptor() ([]byte, []int)
- func (m *ReferenceData) GetLastUpdateBase() uint64
- func (m *ReferenceData) GetLastUpdateQuote() uint64
- func (m *ReferenceData) Marshal() (dAtA []byte, err error)
- func (m *ReferenceData) MarshalTo(dAtA []byte) (int, error)
- func (m *ReferenceData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReferenceData) ProtoMessage()
- func (m *ReferenceData) Reset()
- func (m *ReferenceData) Size() (n int)
- func (m *ReferenceData) String() string
- func (m *ReferenceData) Unmarshal(dAtA []byte) error
- func (m *ReferenceData) XXX_DiscardUnknown()
- func (m *ReferenceData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReferenceData) XXX_Merge(src proto.Message)
- func (m *ReferenceData) XXX_Size() int
- func (m *ReferenceData) XXX_Unmarshal(b []byte) error
- type SetRef
- func (*SetRef) Descriptor() ([]byte, []int)
- func (m *SetRef) GetRate() string
- func (m *SetRef) GetRelayer() string
- func (m *SetRef) GetRequestId() string
- func (m *SetRef) GetResolveTime() string
- func (m *SetRef) GetSymbol() string
- func (m *SetRef) Marshal() (dAtA []byte, err error)
- func (m *SetRef) MarshalTo(dAtA []byte) (int, error)
- func (m *SetRef) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetRef) ProtoMessage()
- func (m *SetRef) Reset()
- func (m *SetRef) Size() (n int)
- func (m *SetRef) String() string
- func (m *SetRef) Unmarshal(dAtA []byte) error
- func (m *SetRef) XXX_DiscardUnknown()
- func (m *SetRef) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetRef) XXX_Merge(src proto.Message)
- func (m *SetRef) XXX_Size() int
- func (m *SetRef) XXX_Unmarshal(b []byte) error
- type UnimplementedMsgServer
- type UnimplementedQueryServer
- type ValueValidatorFn
Constants ¶
const ( ModuleName = "oracle" StoreKey = ModuleName )
const (
EventTypeNewBid = "new_bid"
)
Auction module event types
const RouterKey = ModuleName
Variables ¶
var ( ErrEmptyRelayerAddr = sdkerrors.Register(ModuleName, 1, "relayer address is empty") ErrBadRatesCount = sdkerrors.Register(ModuleName, 2, "bad rates count") ErrBadResolveTimesCount = sdkerrors.Register(ModuleName, 3, "bad resolve times") ErrBadRequestIDsCount = sdkerrors.Register(ModuleName, 4, "bad request ID") ErrRelayerNotAuthorized = sdkerrors.Register(ModuleName, 5, "relayer not authorized") )
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 ( ErrInvalidLengthOracle = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowOracle = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupOracle = fmt.Errorf("proto: unexpected end of group") )
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 ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var (
KeyOracleRelayers = []byte("OracleRelayers")
)
Parameter keys
var ( // ModuleCdc references the global oracle 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 modules/oracle and // defined at the application level. ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry()) )
var ( // Keys for store prefixes RefKey = []byte{0x01} )
Functions ¶
func GetRefStoreKey ¶
func ParamKeyTable ¶
func ParamKeyTable() paramtypes.KeyTable
ParamKeyTable returns the parameter key table.
func RegisterInterfaces ¶
func RegisterInterfaces(registry codectypes.InterfaceRegistry)
RegisterCodec registers concrete types on the Amino codec
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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type BankKeeper ¶
type BankKeeper interface { GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins SendCoinsFromModuleToModule(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error 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 BurnCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error GetDenomMetaData(ctx sdk.Context, denom string) banktypes.Metadata }
BankKeeper defines the expected bank keeper methods
type GenesisState ¶
type GenesisState struct { // params defines all the parameters of related to oracle. Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` }
GenesisState defines the oracle module's genesis state.
func DefaultGenesisState ¶
func DefaultGenesisState() *GenesisState
func NewGenesisState ¶
func NewGenesisState() GenesisState
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
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
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 GetReferenceData ¶
type GetReferenceData struct { BaseQuoteSymbol string `protobuf:"bytes,1,opt,name=base_quote_symbol,json=baseQuoteSymbol,proto3" json:"base_quote_symbol,omitempty"` BaseQuoteRate string `protobuf:"bytes,2,opt,name=base_quote_rate,json=baseQuoteRate,proto3" json:"base_quote_rate,omitempty"` LastUpdateBase string `protobuf:"bytes,3,opt,name=last_update_base,json=lastUpdateBase,proto3" json:"last_update_base,omitempty"` LastUpdateQuote string `protobuf:"bytes,4,opt,name=last_update_quote,json=lastUpdateQuote,proto3" json:"last_update_quote,omitempty"` }
Event type for getting reference data
func (*GetReferenceData) Descriptor ¶
func (*GetReferenceData) Descriptor() ([]byte, []int)
func (*GetReferenceData) GetBaseQuoteRate ¶
func (m *GetReferenceData) GetBaseQuoteRate() string
func (*GetReferenceData) GetBaseQuoteSymbol ¶
func (m *GetReferenceData) GetBaseQuoteSymbol() string
func (*GetReferenceData) GetLastUpdateBase ¶
func (m *GetReferenceData) GetLastUpdateBase() string
func (*GetReferenceData) GetLastUpdateQuote ¶
func (m *GetReferenceData) GetLastUpdateQuote() string
func (*GetReferenceData) Marshal ¶
func (m *GetReferenceData) Marshal() (dAtA []byte, err error)
func (*GetReferenceData) MarshalToSizedBuffer ¶
func (m *GetReferenceData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetReferenceData) ProtoMessage ¶
func (*GetReferenceData) ProtoMessage()
func (*GetReferenceData) Reset ¶
func (m *GetReferenceData) Reset()
func (*GetReferenceData) Size ¶
func (m *GetReferenceData) Size() (n int)
func (*GetReferenceData) String ¶
func (m *GetReferenceData) String() string
func (*GetReferenceData) Unmarshal ¶
func (m *GetReferenceData) Unmarshal(dAtA []byte) error
func (*GetReferenceData) XXX_DiscardUnknown ¶
func (m *GetReferenceData) XXX_DiscardUnknown()
func (*GetReferenceData) XXX_Marshal ¶
func (m *GetReferenceData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetReferenceData) XXX_Merge ¶
func (m *GetReferenceData) XXX_Merge(src proto.Message)
func (*GetReferenceData) XXX_Size ¶
func (m *GetReferenceData) XXX_Size() int
func (*GetReferenceData) XXX_Unmarshal ¶
func (m *GetReferenceData) XXX_Unmarshal(b []byte) error
type MsgClient ¶
type MsgClient interface { // SetPrice defines a method for setting a price on an oracle SetPrice(ctx context.Context, in *MsgSetPrice, opts ...grpc.CallOption) (*MsgSetPriceResponse, error) // Relay defines a method for relaying rates from Band Relay(ctx context.Context, in *MsgRelay, opts ...grpc.CallOption) (*MsgRelayResponse, 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 MsgRelay ¶
type MsgRelay struct { Relayer string `protobuf:"bytes,1,opt,name=relayer,proto3" json:"relayer,omitempty"` Symbols []string `protobuf:"bytes,2,rep,name=symbols,proto3" json:"symbols,omitempty"` Rates []uint64 `protobuf:"varint,3,rep,packed,name=rates,proto3" json:"rates,omitempty"` ResolveTimes []uint64 `protobuf:"varint,4,rep,packed,name=resolve_times,json=resolveTimes,proto3" json:"resolve_times,omitempty"` RequestIDs []uint64 `protobuf:"varint,5,rep,packed,name=requestIDs,proto3" json:"requestIDs,omitempty"` }
func (*MsgRelay) Descriptor ¶
func (*MsgRelay) GetRelayer ¶
func (*MsgRelay) GetRequestIDs ¶
func (*MsgRelay) GetResolveTimes ¶
func (*MsgRelay) GetSignBytes ¶
GetSignBytes implements the sdk.Msg interface. It encodes the message for signing
func (MsgRelay) GetSigners ¶
func (msg MsgRelay) GetSigners() []sdk.AccAddress
GetSigners implements the sdk.Msg interface. It defines whose signature is required
func (*MsgRelay) GetSymbols ¶
func (*MsgRelay) MarshalToSizedBuffer ¶
func (*MsgRelay) ProtoMessage ¶
func (*MsgRelay) ProtoMessage()
func (MsgRelay) Route ¶
Route implements the sdk.Msg interface. It should return the name of the module
func (MsgRelay) ValidateBasic ¶
ValidateBasic implements the sdk.Msg interface for MsgRelay.
func (*MsgRelay) XXX_DiscardUnknown ¶
func (m *MsgRelay) XXX_DiscardUnknown()
func (*MsgRelay) XXX_Marshal ¶
func (*MsgRelay) XXX_Unmarshal ¶
type MsgRelayResponse ¶
type MsgRelayResponse struct { }
func (*MsgRelayResponse) Descriptor ¶
func (*MsgRelayResponse) Descriptor() ([]byte, []int)
func (*MsgRelayResponse) Marshal ¶
func (m *MsgRelayResponse) Marshal() (dAtA []byte, err error)
func (*MsgRelayResponse) MarshalToSizedBuffer ¶
func (m *MsgRelayResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRelayResponse) ProtoMessage ¶
func (*MsgRelayResponse) ProtoMessage()
func (*MsgRelayResponse) Reset ¶
func (m *MsgRelayResponse) Reset()
func (*MsgRelayResponse) Size ¶
func (m *MsgRelayResponse) Size() (n int)
func (*MsgRelayResponse) String ¶
func (m *MsgRelayResponse) String() string
func (*MsgRelayResponse) Unmarshal ¶
func (m *MsgRelayResponse) Unmarshal(dAtA []byte) error
func (*MsgRelayResponse) XXX_DiscardUnknown ¶
func (m *MsgRelayResponse) XXX_DiscardUnknown()
func (*MsgRelayResponse) XXX_Marshal ¶
func (m *MsgRelayResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRelayResponse) XXX_Merge ¶
func (m *MsgRelayResponse) XXX_Merge(src proto.Message)
func (*MsgRelayResponse) XXX_Size ¶
func (m *MsgRelayResponse) XXX_Size() int
func (*MsgRelayResponse) XXX_Unmarshal ¶
func (m *MsgRelayResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { // SetPrice defines a method for setting a price on an oracle SetPrice(context.Context, *MsgSetPrice) (*MsgSetPriceResponse, error) // Relay defines a method for relaying rates from Band Relay(context.Context, *MsgRelay) (*MsgRelayResponse, error) }
MsgServer is the server API for Msg service.
type MsgSetPrice ¶
type MsgSetPrice struct {
Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
}
MsgSetPrice defines a SDK message for for creating an oracle
func (*MsgSetPrice) Descriptor ¶
func (*MsgSetPrice) Descriptor() ([]byte, []int)
func (*MsgSetPrice) GetSignBytes ¶
func (msg *MsgSetPrice) GetSignBytes() []byte
GetSignBytes implements the sdk.Msg interface. It encodes the message for signing
func (MsgSetPrice) GetSigners ¶
func (msg MsgSetPrice) GetSigners() []sdk.AccAddress
GetSigners implements the sdk.Msg interface. It defines whose signature is required
func (*MsgSetPrice) Marshal ¶
func (m *MsgSetPrice) Marshal() (dAtA []byte, err error)
func (*MsgSetPrice) MarshalToSizedBuffer ¶
func (m *MsgSetPrice) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgSetPrice) ProtoMessage ¶
func (*MsgSetPrice) ProtoMessage()
func (*MsgSetPrice) Reset ¶
func (m *MsgSetPrice) Reset()
func (MsgSetPrice) Route ¶
func (msg MsgSetPrice) Route() string
Route implements the sdk.Msg interface. It should return the name of the module
func (*MsgSetPrice) Size ¶
func (m *MsgSetPrice) Size() (n int)
func (*MsgSetPrice) String ¶
func (m *MsgSetPrice) String() string
func (MsgSetPrice) Type ¶
func (msg MsgSetPrice) Type() string
Type implements the sdk.Msg interface. It should return the action.
func (*MsgSetPrice) Unmarshal ¶
func (m *MsgSetPrice) Unmarshal(dAtA []byte) error
func (MsgSetPrice) ValidateBasic ¶
func (msg MsgSetPrice) ValidateBasic() error
ValidateBasic implements the sdk.Msg interface. It runs stateless checks on the message
func (*MsgSetPrice) XXX_DiscardUnknown ¶
func (m *MsgSetPrice) XXX_DiscardUnknown()
func (*MsgSetPrice) XXX_Marshal ¶
func (m *MsgSetPrice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgSetPrice) XXX_Merge ¶
func (m *MsgSetPrice) XXX_Merge(src proto.Message)
func (*MsgSetPrice) XXX_Size ¶
func (m *MsgSetPrice) XXX_Size() int
func (*MsgSetPrice) XXX_Unmarshal ¶
func (m *MsgSetPrice) XXX_Unmarshal(b []byte) error
type MsgSetPriceResponse ¶
type MsgSetPriceResponse struct { }
func (*MsgSetPriceResponse) Descriptor ¶
func (*MsgSetPriceResponse) Descriptor() ([]byte, []int)
func (*MsgSetPriceResponse) Marshal ¶
func (m *MsgSetPriceResponse) Marshal() (dAtA []byte, err error)
func (*MsgSetPriceResponse) MarshalTo ¶
func (m *MsgSetPriceResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgSetPriceResponse) MarshalToSizedBuffer ¶
func (m *MsgSetPriceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgSetPriceResponse) ProtoMessage ¶
func (*MsgSetPriceResponse) ProtoMessage()
func (*MsgSetPriceResponse) Reset ¶
func (m *MsgSetPriceResponse) Reset()
func (*MsgSetPriceResponse) Size ¶
func (m *MsgSetPriceResponse) Size() (n int)
func (*MsgSetPriceResponse) String ¶
func (m *MsgSetPriceResponse) String() string
func (*MsgSetPriceResponse) Unmarshal ¶
func (m *MsgSetPriceResponse) Unmarshal(dAtA []byte) error
func (*MsgSetPriceResponse) XXX_DiscardUnknown ¶
func (m *MsgSetPriceResponse) XXX_DiscardUnknown()
func (*MsgSetPriceResponse) XXX_Marshal ¶
func (m *MsgSetPriceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgSetPriceResponse) XXX_Merge ¶
func (m *MsgSetPriceResponse) XXX_Merge(src proto.Message)
func (*MsgSetPriceResponse) XXX_Size ¶
func (m *MsgSetPriceResponse) XXX_Size() int
func (*MsgSetPriceResponse) XXX_Unmarshal ¶
func (m *MsgSetPriceResponse) XXX_Unmarshal(b []byte) error
type ParamSet ¶
type ParamSet interface {
ParamSetPairs() ParamSetPairs
}
ParamSet defines an interface for structs containing parameters for a module
type ParamSetPair ¶
type ParamSetPair struct { Key []byte Value interface{} ValidatorFn ValueValidatorFn }
ParamSetPair is used for associating paramsubspace key and field of param structs.
func NewParamSetPair ¶
func NewParamSetPair(key []byte, value interface{}, vfn ValueValidatorFn) ParamSetPair
NewParamSetPair creates a new ParamSetPair instance.
type Params ¶
type Params struct {
Relayers []string `protobuf:"bytes,1,rep,name=relayers,proto3" json:"relayers,omitempty"`
}
func (*Params) Descriptor ¶
func (*Params) GetRelayers ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ParamSetPairs ¶
func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
ParamSetPairs returns the parameter set pairs.
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
type QueryClient ¶
type QueryClient interface { // Retrieves oracle params 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 { }
QueryOracleParamsRequest is the request type for the Query/OracleParams 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 Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}
QueryOracleParamsResponse is the response type for the Query/OracleParams 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 { // Retrieves oracle params Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) }
QueryServer is the server API for Query service.
type Ref ¶
type Ref struct { Rate uint64 `protobuf:"varint,1,opt,name=rate,proto3" json:"rate,omitempty"` // unix timestamp seconds ResolveTime uint64 `protobuf:"varint,2,opt,name=resolve_time,json=resolveTime,proto3" json:"resolve_time,omitempty"` Request_ID uint64 `protobuf:"varint,3,opt,name=request_ID,json=requestID,proto3" json:"request_ID,omitempty"` }
func (*Ref) Descriptor ¶
func (*Ref) GetRequest_ID ¶
func (*Ref) GetResolveTime ¶
func (*Ref) ProtoMessage ¶
func (*Ref) ProtoMessage()
func (*Ref) XXX_DiscardUnknown ¶
func (m *Ref) XXX_DiscardUnknown()
func (*Ref) XXX_Unmarshal ¶
type ReferenceData ¶
type ReferenceData struct { Rate github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=rate,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"rate"` LastUpdateBase uint64 `protobuf:"varint,2,opt,name=last_update_base,json=lastUpdateBase,proto3" json:"last_update_base,omitempty"` LastUpdateQuote uint64 `protobuf:"varint,3,opt,name=last_update_quote,json=lastUpdateQuote,proto3" json:"last_update_quote,omitempty"` }
func (*ReferenceData) Descriptor ¶
func (*ReferenceData) Descriptor() ([]byte, []int)
func (*ReferenceData) GetLastUpdateBase ¶
func (m *ReferenceData) GetLastUpdateBase() uint64
func (*ReferenceData) GetLastUpdateQuote ¶
func (m *ReferenceData) GetLastUpdateQuote() uint64
func (*ReferenceData) Marshal ¶
func (m *ReferenceData) Marshal() (dAtA []byte, err error)
func (*ReferenceData) MarshalToSizedBuffer ¶
func (m *ReferenceData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReferenceData) ProtoMessage ¶
func (*ReferenceData) ProtoMessage()
func (*ReferenceData) Reset ¶
func (m *ReferenceData) Reset()
func (*ReferenceData) Size ¶
func (m *ReferenceData) Size() (n int)
func (*ReferenceData) String ¶
func (m *ReferenceData) String() string
func (*ReferenceData) Unmarshal ¶
func (m *ReferenceData) Unmarshal(dAtA []byte) error
func (*ReferenceData) XXX_DiscardUnknown ¶
func (m *ReferenceData) XXX_DiscardUnknown()
func (*ReferenceData) XXX_Marshal ¶
func (m *ReferenceData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReferenceData) XXX_Merge ¶
func (m *ReferenceData) XXX_Merge(src proto.Message)
func (*ReferenceData) XXX_Size ¶
func (m *ReferenceData) XXX_Size() int
func (*ReferenceData) XXX_Unmarshal ¶
func (m *ReferenceData) XXX_Unmarshal(b []byte) error
type SetRef ¶
type SetRef struct { Relayer string `protobuf:"bytes,1,opt,name=relayer,proto3" json:"relayer,omitempty"` Symbol string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty"` Rate string `protobuf:"bytes,3,opt,name=rate,proto3" json:"rate,omitempty"` ResolveTime string `protobuf:"bytes,4,opt,name=resolve_time,json=resolveTime,proto3" json:"resolve_time,omitempty"` RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` }
Event type upon set ref
func (*SetRef) Descriptor ¶
func (*SetRef) GetRelayer ¶
func (*SetRef) GetRequestId ¶
func (*SetRef) GetResolveTime ¶
func (*SetRef) MarshalToSizedBuffer ¶
func (*SetRef) ProtoMessage ¶
func (*SetRef) ProtoMessage()
func (*SetRef) XXX_DiscardUnknown ¶
func (m *SetRef) XXX_DiscardUnknown()
func (*SetRef) XXX_Marshal ¶
func (*SetRef) XXX_Unmarshal ¶
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) Relay ¶
func (*UnimplementedMsgServer) Relay(ctx context.Context, req *MsgRelay) (*MsgRelayResponse, error)
func (*UnimplementedMsgServer) SetPrice ¶
func (*UnimplementedMsgServer) SetPrice(ctx context.Context, req *MsgSetPrice) (*MsgSetPriceResponse, 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)
type ValueValidatorFn ¶
type ValueValidatorFn func(value interface{}) error