types

package
v0.0.0-...-a9c8dba Latest Latest
Warning

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

 Go to latest Published: Aug 27, 2024 License: AGPL-3.0 Imports: 32 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	MarketIsRecentDuration          = 20 * time.Second
	PriceDaemonInitializationBlocks = 20
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "prices"

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

Module name and store keys

View Source 
const (
	// MarketParamKeyPrefix is the prefix to retrieve all MarketParams
	MarketParamKeyPrefix = "Param:"

	// MarketPriceKeyPrefix is the prefix to retrieve all MarketPrices
	MarketPriceKeyPrefix = "Price:"
)

State

View Source 
const (
	PriceSmoothingPpm = uint32(300_000)
)
View Source 
const (
	// SmoothedPriceTrackingBlockHistoryLength is the number of blocks we track smoothed prices for to determine if the
	// next smoothed price should be used in the price update proposal.
	// TODO(CORE-396): Put this on-chain and configure it in the application via chain state.
	SmoothedPriceTrackingBlockHistoryLength = uint32(5)
)

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(module.InterfaceRegistry)
)
View Source 
var (
	// 1 - 99: Default.
	ErrInvalidInput = errorsmod.Register(ModuleName, 1, "Invalid input")

	// 100 - 199: Exchange related errors.
	ErrExchangeDoesNotExist = errorsmod.Register(ModuleName, 100, "Exchange does not exist")
	ErrZeroMinExchanges     = errorsmod.Register(ModuleName, 101, "Min exchanges must be greater than zero")
	ErrTooFewExchanges      = errorsmod.Register(ModuleName, 102, "Exchanges is fewer than minExchanges")
	ErrDuplicateExchanges   = errorsmod.Register(
		ModuleName,
		103,
		"Exchanges must not contain duplicates and must be provided in ascending order",
	)

	// 200 - 299: Market related errors.
	ErrMarketParamDoesNotExist        = errorsmod.Register(ModuleName, 200, "Market param does not exist")
	ErrMarketPriceDoesNotExist        = errorsmod.Register(ModuleName, 201, "Market price does not exist")
	ErrMarketExponentCannotBeUpdated  = errorsmod.Register(ModuleName, 202, "Market exponent cannot be updated")
	ErrMarketPricesAndParamsDontMatch = errorsmod.Register(ModuleName, 203, "Market prices and params don't match")
	ErrMarketParamAlreadyExists       = errorsmod.Register(ModuleName, 204, "Market params already exists")

	// 300 - 399: Price related errors.
	ErrIndexPriceNotAvailable = errorsmod.Register(ModuleName, 300, "Index price is not available")

	// 400 - 499: Market price update related errors.
	ErrInvalidMarketPriceUpdateStateless = errorsmod.Register(
		ModuleName, 400, "Market price update is invalid: stateless.")
	ErrInvalidMarketPriceUpdateDeterministic = errorsmod.Register(
		ModuleName, 401, "Market price update is invalid: deterministic.")
	ErrInvalidMarketPriceUpdateNonDeterministic = errorsmod.Register(
		ModuleName, 402, "Market price update is invalid: non-deterministic.")

	// 500 - 599: sdk.Msg related errors.
	ErrInvalidAuthority = errorsmod.Register(
		ModuleName,
		500,
		"Authority is invalid",
	)
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMarketParam        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMarketParam          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMarketParam = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMarketPrice        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMarketPrice          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMarketPrice = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

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

AccountKeeper defines the expected account keeper used for simulations.

type BankKeeper 

type BankKeeper interface {
	SpendableCoins(ctx context.Context, addr sdk.AccAddress) sdk.Coins
}

AccountKeeper defines the expected bank keeper used for simulations.

type GenesisState 

type GenesisState struct {
	MarketParams []MarketParam `protobuf:"bytes,1,rep,name=market_params,json=marketParams,proto3" json:"market_params"`
	MarketPrices []MarketPrice `protobuf:"bytes,2,rep,name=market_prices,json=marketPrices,proto3" json:"market_prices"`
}

GenesisState defines the prices module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Prices genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetMarketParams 

func (m *GenesisState) GetMarketParams() []MarketParam

func (*GenesisState) GetMarketPrices 

func (m *GenesisState) GetMarketPrices() []MarketPrice

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type MarketParam 

type MarketParam struct {
	// Unique, sequentially-generated value.
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The human-readable name of the market pair (e.g. `BTC-USD`).
	Pair string `protobuf:"bytes,2,opt,name=pair,proto3" json:"pair,omitempty"`
	// Static value. The exponent of the price.
	// For example if `Exponent == -5` then a `Value` of `1,000,000,000`
	// represents “$10,000`. Therefore `10 ^ Exponent` represents the smallest
	// price step (in dollars) that can be recorded.
	Exponent int32 `protobuf:"zigzag32,3,opt,name=exponent,proto3" json:"exponent,omitempty"`
	// The minimum number of exchanges that should be reporting a live price for
	// a price update to be considered valid.
	MinExchanges uint32 `protobuf:"varint,4,opt,name=min_exchanges,json=minExchanges,proto3" json:"min_exchanges,omitempty"`
	// The minimum allowable change in `price` value that would cause a price
	// update on the network. Measured as `1e-6` (parts per million).
	MinPriceChangePpm uint32 `protobuf:"varint,5,opt,name=min_price_change_ppm,json=minPriceChangePpm,proto3" json:"min_price_change_ppm,omitempty"`
	// A string of json that encodes the configuration for resolving the price
	// of this market on various exchanges.
	ExchangeConfigJson string `protobuf:"bytes,6,opt,name=exchange_config_json,json=exchangeConfigJson,proto3" json:"exchange_config_json,omitempty"`
}

MarketParam represents the x/prices configuration for markets, including representing price values, resolving markets on individual exchanges, and generating price updates. This configuration is specific to the quote currency.

func (*MarketParam) Descriptor 

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

func (*MarketParam) GetExchangeConfigJson 

func (m *MarketParam) GetExchangeConfigJson() string

func (*MarketParam) GetExponent 

func (m *MarketParam) GetExponent() int32

func (*MarketParam) GetId 

func (m *MarketParam) GetId() uint32

func (*MarketParam) GetMinExchanges 

func (m *MarketParam) GetMinExchanges() uint32

func (*MarketParam) GetMinPriceChangePpm 

func (m *MarketParam) GetMinPriceChangePpm() uint32

func (*MarketParam) GetPair 

func (m *MarketParam) GetPair() string

func (*MarketParam) Marshal 

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

func (*MarketParam) MarshalTo 

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

func (*MarketParam) MarshalToSizedBuffer 

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

func (*MarketParam) ProtoMessage 

func (*MarketParam) ProtoMessage()

func (*MarketParam) Reset 

func (m *MarketParam) Reset()

func (*MarketParam) Size 

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

func (*MarketParam) String 

func (m *MarketParam) String() string

func (*MarketParam) Unmarshal 

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

func (*MarketParam) Validate 

func (mp *MarketParam) Validate() error

Validate checks that the MarketParam is valid.

func (*MarketParam) XXX_DiscardUnknown 

func (m *MarketParam) XXX_DiscardUnknown()

func (*MarketParam) XXX_Marshal 

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

func (*MarketParam) XXX_Merge 

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

func (*MarketParam) XXX_Size 

func (m *MarketParam) XXX_Size() int

func (*MarketParam) XXX_Unmarshal 

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

type MarketParamPrice 

type MarketParamPrice struct {
	Param MarketParam
	Price MarketPrice
}

MarketParamPrice is a struct that combines a MarketParam and a MarketPrice.

type MarketPnlPriceUpdate 

type MarketPnlPriceUpdate struct {
	// The id of market to update
	MarketId uint32 `protobuf:"varint,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// The updated pnl price
	PnlPrice uint64 `protobuf:"varint,2,opt,name=pnl_price,json=pnlPrice,proto3" json:"pnl_price,omitempty"`
}

MarketPnlPriceUpdate is used to update the pnl price of a single market.

func (*MarketPnlPriceUpdate) Descriptor 

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

func (*MarketPnlPriceUpdate) GetMarketId 

func (m *MarketPnlPriceUpdate) GetMarketId() uint32

func (*MarketPnlPriceUpdate) GetPnlPrice 

func (m *MarketPnlPriceUpdate) GetPnlPrice() uint64

func (*MarketPnlPriceUpdate) Marshal 

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

func (*MarketPnlPriceUpdate) MarshalTo 

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

func (*MarketPnlPriceUpdate) MarshalToSizedBuffer 

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

func (*MarketPnlPriceUpdate) ProtoMessage 

func (*MarketPnlPriceUpdate) ProtoMessage()

func (*MarketPnlPriceUpdate) Reset 

func (m *MarketPnlPriceUpdate) Reset()

func (*MarketPnlPriceUpdate) Size 

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

func (*MarketPnlPriceUpdate) String 

func (m *MarketPnlPriceUpdate) String() string

func (*MarketPnlPriceUpdate) Unmarshal 

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

func (*MarketPnlPriceUpdate) XXX_DiscardUnknown 

func (m *MarketPnlPriceUpdate) XXX_DiscardUnknown()

func (*MarketPnlPriceUpdate) XXX_Marshal 

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

func (*MarketPnlPriceUpdate) XXX_Merge 

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

func (*MarketPnlPriceUpdate) XXX_Size 

func (m *MarketPnlPriceUpdate) XXX_Size() int

func (*MarketPnlPriceUpdate) XXX_Unmarshal 

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

type MarketPrice 

type MarketPrice struct {
	// Unique, sequentially-generated value that matches `MarketParam`.
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Static value. The exponent of the price. See the comment on the duplicate
	// MarketParam field for more information.
	Exponent int32 `protobuf:"zigzag32,2,opt,name=exponent,proto3" json:"exponent,omitempty"`
	// The spot price value that is updated by oracle price updates. `0` if it has
	// never been updated, `>0` otherwise.
	SpotPrice uint64 `protobuf:"varint,3,opt,name=spot_price,json=spotPrice,proto3" json:"spot_price,omitempty"`
	// The pnl price value that is updated by oracle price updates. `0` if it has
	// never been updated, `>0` otherwise.
	PnlPrice uint64 `protobuf:"varint,4,opt,name=pnl_price,json=pnlPrice,proto3" json:"pnl_price,omitempty"`
}

MarketPrice is used by the application to store/retrieve oracle prices.

func (*MarketPrice) Descriptor 

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

func (*MarketPrice) GetExponent 

func (m *MarketPrice) GetExponent() int32

func (*MarketPrice) GetId 

func (m *MarketPrice) GetId() uint32

func (*MarketPrice) GetPnlPrice 

func (m *MarketPrice) GetPnlPrice() uint64

func (*MarketPrice) GetSpotPrice 

func (m *MarketPrice) GetSpotPrice() uint64

func (*MarketPrice) Marshal 

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

func (*MarketPrice) MarshalTo 

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

func (*MarketPrice) MarshalToSizedBuffer 

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

func (*MarketPrice) ProtoMessage 

func (*MarketPrice) ProtoMessage()

func (*MarketPrice) Reset 

func (m *MarketPrice) Reset()

func (*MarketPrice) Size 

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

func (*MarketPrice) String 

func (m *MarketPrice) String() string

func (*MarketPrice) Unmarshal 

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

func (*MarketPrice) ValidateFromParam 

func (mp *MarketPrice) ValidateFromParam(marketParam MarketParam) error

ValidateFromParam checks that the MarketPrice is valid and that it corresponds to the given MarketParam.

func (*MarketPrice) XXX_DiscardUnknown 

func (m *MarketPrice) XXX_DiscardUnknown()

func (*MarketPrice) XXX_Marshal 

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

func (*MarketPrice) XXX_Merge 

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

func (*MarketPrice) XXX_Size 

func (m *MarketPrice) XXX_Size() int

func (*MarketPrice) XXX_Unmarshal 

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

type MarketPriceUpdate 

type MarketPriceUpdate struct {
	// The id of market to update
	MarketId uint32 `protobuf:"varint,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// The updated spot price
	SpotPrice uint64 `protobuf:"varint,2,opt,name=spot_price,json=spotPrice,proto3" json:"spot_price,omitempty"`
	// The updated pnl price
	PnlPrice uint64 `protobuf:"varint,3,opt,name=pnl_price,json=pnlPrice,proto3" json:"pnl_price,omitempty"`
}

MarketPriceUpdate is used to update the price of a single market.

func NewMarketPriceUpdate 

func NewMarketPriceUpdate(id uint32, spotPrice uint64, pnlPrice uint64) *MarketPriceUpdate

func (*MarketPriceUpdate) Descriptor 

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

func (*MarketPriceUpdate) GetMarketId 

func (m *MarketPriceUpdate) GetMarketId() uint32

func (*MarketPriceUpdate) GetPnlPrice 

func (m *MarketPriceUpdate) GetPnlPrice() uint64

func (*MarketPriceUpdate) GetSpotPrice 

func (m *MarketPriceUpdate) GetSpotPrice() uint64

func (*MarketPriceUpdate) Marshal 

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

func (*MarketPriceUpdate) MarshalTo 

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

func (*MarketPriceUpdate) MarshalToSizedBuffer 

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

func (*MarketPriceUpdate) ProtoMessage 

func (*MarketPriceUpdate) ProtoMessage()

func (*MarketPriceUpdate) Reset 

func (m *MarketPriceUpdate) Reset()

func (*MarketPriceUpdate) Size 

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

func (*MarketPriceUpdate) String 

func (m *MarketPriceUpdate) String() string

func (*MarketPriceUpdate) Unmarshal 

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

func (*MarketPriceUpdate) XXX_DiscardUnknown 

func (m *MarketPriceUpdate) XXX_DiscardUnknown()

func (*MarketPriceUpdate) XXX_Marshal 

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

func (*MarketPriceUpdate) XXX_Merge 

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

func (*MarketPriceUpdate) XXX_Size 

func (m *MarketPriceUpdate) XXX_Size() int

func (*MarketPriceUpdate) XXX_Unmarshal 

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

type MarketPriceUpdates 

type MarketPriceUpdates struct {
	MarketPriceUpdates []*MarketPriceUpdate `protobuf:"bytes,1,rep,name=market_price_updates,json=marketPriceUpdates,proto3" json:"market_price_updates,omitempty"`
}

MarketPriceUpdates is a collection of MarketPriceUpdate messages.

func (*MarketPriceUpdates) Descriptor 

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

func (*MarketPriceUpdates) GetMarketPriceUpdates 

func (m *MarketPriceUpdates) GetMarketPriceUpdates() []*MarketPriceUpdate

func (*MarketPriceUpdates) Marshal 

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

func (*MarketPriceUpdates) MarshalTo 

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

func (*MarketPriceUpdates) MarshalToSizedBuffer 

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

func (*MarketPriceUpdates) ProtoMessage 

func (*MarketPriceUpdates) ProtoMessage()

func (*MarketPriceUpdates) Reset 

func (m *MarketPriceUpdates) Reset()

func (*MarketPriceUpdates) Size 

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

func (*MarketPriceUpdates) String 

func (m *MarketPriceUpdates) String() string

func (*MarketPriceUpdates) Unmarshal 

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

func (*MarketPriceUpdates) XXX_DiscardUnknown 

func (m *MarketPriceUpdates) XXX_DiscardUnknown()

func (*MarketPriceUpdates) XXX_Marshal 

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

func (*MarketPriceUpdates) XXX_Merge 

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

func (*MarketPriceUpdates) XXX_Size 

func (m *MarketPriceUpdates) XXX_Size() int

func (*MarketPriceUpdates) XXX_Unmarshal 

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

type MarketSpotPrice 

type MarketSpotPrice struct {
	// Unique, sequentially-generated value that matches `MarketParam`.
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Static value. The exponent of the price. See the comment on the duplicate
	// MarketParam field for more information.
	Exponent int32 `protobuf:"zigzag32,2,opt,name=exponent,proto3" json:"exponent,omitempty"`
	// The spot price value that is updated by oracle price updates. `0` if it has
	// never been updated, `>0` otherwise.
	SpotPrice uint64 `protobuf:"varint,3,opt,name=spot_price,json=spotPrice,proto3" json:"spot_price,omitempty"`
}

MarketSpotPrice is used by the application to store/retrieve spot prices.

func (*MarketSpotPrice) Descriptor 

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

func (*MarketSpotPrice) GetExponent 

func (m *MarketSpotPrice) GetExponent() int32

func (*MarketSpotPrice) GetId 

func (m *MarketSpotPrice) GetId() uint32

func (*MarketSpotPrice) GetSpotPrice 

func (m *MarketSpotPrice) GetSpotPrice() uint64

func (*MarketSpotPrice) Marshal 

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

func (*MarketSpotPrice) MarshalTo 

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

func (*MarketSpotPrice) MarshalToSizedBuffer 

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

func (*MarketSpotPrice) ProtoMessage 

func (*MarketSpotPrice) ProtoMessage()

func (*MarketSpotPrice) Reset 

func (m *MarketSpotPrice) Reset()

func (*MarketSpotPrice) Size 

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

func (*MarketSpotPrice) String 

func (m *MarketSpotPrice) String() string

func (*MarketSpotPrice) Unmarshal 

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

func (*MarketSpotPrice) XXX_DiscardUnknown 

func (m *MarketSpotPrice) XXX_DiscardUnknown()

func (*MarketSpotPrice) XXX_Marshal 

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

func (*MarketSpotPrice) XXX_Merge 

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

func (*MarketSpotPrice) XXX_Size 

func (m *MarketSpotPrice) XXX_Size() int

func (*MarketSpotPrice) XXX_Unmarshal 

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

type MarketSpotPriceUpdate 

type MarketSpotPriceUpdate struct {
	// The id of market to update
	MarketId uint32 `protobuf:"varint,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// The updated spot price
	SpotPrice uint64 `protobuf:"varint,2,opt,name=spot_price,json=spotPrice,proto3" json:"spot_price,omitempty"`
}

MarketSpotPriceUpdate is used to update the spot price of a single market.

func NewMarketSpotPriceUpdate 

func NewMarketSpotPriceUpdate(id uint32, spotPrice uint64) *MarketSpotPriceUpdate

func (*MarketSpotPriceUpdate) Descriptor 

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

func (*MarketSpotPriceUpdate) GetMarketId 

func (m *MarketSpotPriceUpdate) GetMarketId() uint32

func (*MarketSpotPriceUpdate) GetSpotPrice 

func (m *MarketSpotPriceUpdate) GetSpotPrice() uint64

func (*MarketSpotPriceUpdate) Marshal 

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

func (*MarketSpotPriceUpdate) MarshalTo 

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

func (*MarketSpotPriceUpdate) MarshalToSizedBuffer 

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

func (*MarketSpotPriceUpdate) ProtoMessage 

func (*MarketSpotPriceUpdate) ProtoMessage()

func (*MarketSpotPriceUpdate) Reset 

func (m *MarketSpotPriceUpdate) Reset()

func (*MarketSpotPriceUpdate) Size 

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

func (*MarketSpotPriceUpdate) String 

func (m *MarketSpotPriceUpdate) String() string

func (*MarketSpotPriceUpdate) Unmarshal 

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

func (*MarketSpotPriceUpdate) XXX_DiscardUnknown 

func (m *MarketSpotPriceUpdate) XXX_DiscardUnknown()

func (*MarketSpotPriceUpdate) XXX_Marshal 

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

func (*MarketSpotPriceUpdate) XXX_Merge 

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

func (*MarketSpotPriceUpdate) XXX_Size 

func (m *MarketSpotPriceUpdate) XXX_Size() int

func (*MarketSpotPriceUpdate) XXX_Unmarshal 

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

type MarketToSmoothedPrices 

type MarketToSmoothedPrices interface {
	GetSmoothedSpotPrice(marketId uint32) (price uint64, ok bool)
	GetSmoothedSpotPricesForTest() map[uint32]uint64
	GetHistoricalSmoothedSpotPrices(marketId uint32) []uint64
	PushSmoothedSpotPrice(marketId uint32, price uint64)
}

MarketToSmoothedPrices tracks current and historical exponentially smoothed prices for each market.

func NewMarketToSmoothedSpotPrices 

func NewMarketToSmoothedSpotPrices(historyLength uint32) MarketToSmoothedPrices

NewMarketToSmoothedPrices returns a new `MarketToSmoothedPrices` that tracks the previous `historyLength` prices per market. The default value to use for the protocol is `SmoothedPriceTrackingBlockHistoryLength`.

type MarketToSmoothedPricesImpl 

type MarketToSmoothedPricesImpl struct {
	// contains filtered or unexported fields
}

func (*MarketToSmoothedPricesImpl) GetHistoricalSmoothedSpotPrices 

func (m *MarketToSmoothedPricesImpl) GetHistoricalSmoothedSpotPrices(marketId uint32) []uint64

GetHistoricalSmoothedPrices returns up to the last `SmoothedPriceTrackingBlockHistoryLength` smoothed prices for the given market. The returned slice is ordered from newest to oldest, and the first entry in the slice will be the most recent valid smoothed price.

func (*MarketToSmoothedPricesImpl) GetSmoothedSpotPrice 

func (m *MarketToSmoothedPricesImpl) GetSmoothedSpotPrice(marketId uint32) (
	price uint64,
	ok bool,
)

GetSmoothedPrice returns the smoothed price for the given market.

func (*MarketToSmoothedPricesImpl) GetSmoothedSpotPricesForTest 

func (m *MarketToSmoothedPricesImpl) GetSmoothedSpotPricesForTest() map[uint32]uint64

GetSmoothedPricesForTest returns a map of market ids to smoothed prices. This is primarily here for testing.

func (*MarketToSmoothedPricesImpl) PushSmoothedSpotPrice 

func (m *MarketToSmoothedPricesImpl) PushSmoothedSpotPrice(id uint32, price uint64)

PushSmoothedPrice sets the smoothed price for the given market.

type MsgClient 

type MsgClient interface {
	// CreateOracleMarket creates a new oracle market.
	CreateOracleMarket(ctx context.Context, in *MsgCreateOracleMarket, opts ...grpc.CallOption) (*MsgCreateOracleMarketResponse, error)
	// UpdateMarketParams allows governance to update the parameters of an
	// oracle market.
	UpdateMarketParam(ctx context.Context, in *MsgUpdateMarketParam, opts ...grpc.CallOption) (*MsgUpdateMarketParamResponse, 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 MsgCreateOracleMarket 

type MsgCreateOracleMarket struct {
	// The address that controls the module.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// `params` defines parameters for the new oracle market.
	Params MarketParam `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgCreateOracleMarket is a message used by x/gov for creating a new oracle market.

func (*MsgCreateOracleMarket) Descriptor 

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

func (*MsgCreateOracleMarket) GetAuthority 

func (m *MsgCreateOracleMarket) GetAuthority() string

func (*MsgCreateOracleMarket) GetParams 

func (m *MsgCreateOracleMarket) GetParams() MarketParam

func (*MsgCreateOracleMarket) Marshal 

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

func (*MsgCreateOracleMarket) MarshalTo 

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

func (*MsgCreateOracleMarket) MarshalToSizedBuffer 

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

func (*MsgCreateOracleMarket) ProtoMessage 

func (*MsgCreateOracleMarket) ProtoMessage()

func (*MsgCreateOracleMarket) Reset 

func (m *MsgCreateOracleMarket) Reset()

func (*MsgCreateOracleMarket) Size 

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

func (*MsgCreateOracleMarket) String 

func (m *MsgCreateOracleMarket) String() string

func (*MsgCreateOracleMarket) Unmarshal 

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

func (*MsgCreateOracleMarket) ValidateBasic 

func (msg *MsgCreateOracleMarket) ValidateBasic() error

func (*MsgCreateOracleMarket) XXX_DiscardUnknown 

func (m *MsgCreateOracleMarket) XXX_DiscardUnknown()

func (*MsgCreateOracleMarket) XXX_Marshal 

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

func (*MsgCreateOracleMarket) XXX_Merge 

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

func (*MsgCreateOracleMarket) XXX_Size 

func (m *MsgCreateOracleMarket) XXX_Size() int

func (*MsgCreateOracleMarket) XXX_Unmarshal 

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

type MsgCreateOracleMarketResponse 

type MsgCreateOracleMarketResponse struct {
}

MsgCreateOracleMarketResponse defines the CreateOracleMarket response type.

func (*MsgCreateOracleMarketResponse) Descriptor 

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

func (*MsgCreateOracleMarketResponse) Marshal 

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

func (*MsgCreateOracleMarketResponse) MarshalTo 

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

func (*MsgCreateOracleMarketResponse) MarshalToSizedBuffer 

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

func (*MsgCreateOracleMarketResponse) ProtoMessage 

func (*MsgCreateOracleMarketResponse) ProtoMessage()

func (*MsgCreateOracleMarketResponse) Reset 

func (m *MsgCreateOracleMarketResponse) Reset()

func (*MsgCreateOracleMarketResponse) Size 

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

func (*MsgCreateOracleMarketResponse) String 

func (m *MsgCreateOracleMarketResponse) String() string

func (*MsgCreateOracleMarketResponse) Unmarshal 

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

func (*MsgCreateOracleMarketResponse) XXX_DiscardUnknown 

func (m *MsgCreateOracleMarketResponse) XXX_DiscardUnknown()

func (*MsgCreateOracleMarketResponse) XXX_Marshal 

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

func (*MsgCreateOracleMarketResponse) XXX_Merge 

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

func (*MsgCreateOracleMarketResponse) XXX_Size 

func (m *MsgCreateOracleMarketResponse) XXX_Size() int

func (*MsgCreateOracleMarketResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreateOracleMarket creates a new oracle market.
	CreateOracleMarket(context.Context, *MsgCreateOracleMarket) (*MsgCreateOracleMarketResponse, error)
	// UpdateMarketParams allows governance to update the parameters of an
	// oracle market.
	UpdateMarketParam(context.Context, *MsgUpdateMarketParam) (*MsgUpdateMarketParamResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateMarketParam 

type MsgUpdateMarketParam struct {
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// The market param to update. Each field must be set.
	MarketParam MarketParam `protobuf:"bytes,2,opt,name=market_param,json=marketParam,proto3" json:"market_param"`
}

MsgUpdateMarketParam is a message used by x/gov for updating the parameters of an oracle market.

func (*MsgUpdateMarketParam) Descriptor 

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

func (*MsgUpdateMarketParam) GetAuthority 

func (m *MsgUpdateMarketParam) GetAuthority() string

func (*MsgUpdateMarketParam) GetMarketParam 

func (m *MsgUpdateMarketParam) GetMarketParam() MarketParam

func (*MsgUpdateMarketParam) Marshal 

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

func (*MsgUpdateMarketParam) MarshalTo 

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

func (*MsgUpdateMarketParam) MarshalToSizedBuffer 

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

func (*MsgUpdateMarketParam) ProtoMessage 

func (*MsgUpdateMarketParam) ProtoMessage()

func (*MsgUpdateMarketParam) Reset 

func (m *MsgUpdateMarketParam) Reset()

func (*MsgUpdateMarketParam) Size 

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

func (*MsgUpdateMarketParam) String 

func (m *MsgUpdateMarketParam) String() string

func (*MsgUpdateMarketParam) Unmarshal 

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

func (*MsgUpdateMarketParam) ValidateBasic 

func (msg *MsgUpdateMarketParam) ValidateBasic() error

func (*MsgUpdateMarketParam) XXX_DiscardUnknown 

func (m *MsgUpdateMarketParam) XXX_DiscardUnknown()

func (*MsgUpdateMarketParam) XXX_Marshal 

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

func (*MsgUpdateMarketParam) XXX_Merge 

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

func (*MsgUpdateMarketParam) XXX_Size 

func (m *MsgUpdateMarketParam) XXX_Size() int

func (*MsgUpdateMarketParam) XXX_Unmarshal 

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

type MsgUpdateMarketParamResponse 

type MsgUpdateMarketParamResponse struct {
}

MsgUpdateMarketParamResponse defines the UpdateMarketParam response type.

func (*MsgUpdateMarketParamResponse) Descriptor 

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

func (*MsgUpdateMarketParamResponse) Marshal 

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

func (*MsgUpdateMarketParamResponse) MarshalTo 

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

func (*MsgUpdateMarketParamResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateMarketParamResponse) ProtoMessage 

func (*MsgUpdateMarketParamResponse) ProtoMessage()

func (*MsgUpdateMarketParamResponse) Reset 

func (m *MsgUpdateMarketParamResponse) Reset()

func (*MsgUpdateMarketParamResponse) Size 

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

func (*MsgUpdateMarketParamResponse) String 

func (m *MsgUpdateMarketParamResponse) String() string

func (*MsgUpdateMarketParamResponse) Unmarshal 

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

func (*MsgUpdateMarketParamResponse) XXX_DiscardUnknown 

func (m *MsgUpdateMarketParamResponse) XXX_DiscardUnknown()

func (*MsgUpdateMarketParamResponse) XXX_Marshal 

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

func (*MsgUpdateMarketParamResponse) XXX_Merge 

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

func (*MsgUpdateMarketParamResponse) XXX_Size 

func (m *MsgUpdateMarketParamResponse) XXX_Size() int

func (*MsgUpdateMarketParamResponse) XXX_Unmarshal 

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

type PricesKeeper 

type PricesKeeper interface {
	// Market related.
	CreateMarket(
		ctx sdk.Context,
		param MarketParam,
		price MarketPrice,
	) (createdMarketParam MarketParam, err error)

	ModifyMarketParam(
		ctx sdk.Context,
		param MarketParam,
	) (updatedMarketParam MarketParam, err error)

	UpdateSpotAndPnlMarketPrices(
		ctx sdk.Context,
		updates *MarketPriceUpdate,
	) (err error)

	UpdatePnlPrice(
		ctx sdk.Context,
		update *MarketPnlPriceUpdate,
	) (err error)

	UpdateSpotPrice(
		ctx sdk.Context,
		update *MarketSpotPriceUpdate,
	) (err error)

	GetAllMarketParamPrices(ctx sdk.Context) (marketPramPrices []MarketParamPrice, err error)
	GetMarketParam(ctx sdk.Context, id uint32) (marketParam MarketParam, exists bool)
	GetMarketIdToValidIndexPrice(ctx sdk.Context) (marketIdToIndexPrice map[uint32]MarketSpotPrice)
	GetAllMarketParams(ctx sdk.Context) (marketParams []MarketParam)
	GetMarketPrice(ctx sdk.Context, id uint32) (marketPrice MarketPrice, err error)
	GetAllMarketPrices(ctx sdk.Context) (marketPrices []MarketPrice)
	HasAuthority(authority string) bool

	// Validation related.
	PerformStatefulPriceUpdateValidation(
		ctx sdk.Context,
		marketPriceUpdates *MarketPriceUpdate,
	) (isSpotValid bool, isPnlValid bool)

	// Proposal related.
	UpdateSmoothedSpotPrices(
		ctx sdk.Context,
		linearInterpolateFunc func(v0 uint64, v1 uint64, ppm uint32) (uint64, error),
	) error

	// Misc.
	Logger(ctx sdk.Context) log.Logger
}

type QueryAllMarketParamsRequest 

type QueryAllMarketParamsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllMarketParamsRequest is request type for the Query/Params `AllMarketParams` RPC method.

func (*QueryAllMarketParamsRequest) Descriptor 

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

func (*QueryAllMarketParamsRequest) GetPagination 

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

func (*QueryAllMarketParamsRequest) Marshal 

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

func (*QueryAllMarketParamsRequest) MarshalTo 

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

func (*QueryAllMarketParamsRequest) MarshalToSizedBuffer 

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

func (*QueryAllMarketParamsRequest) ProtoMessage 

func (*QueryAllMarketParamsRequest) ProtoMessage()

func (*QueryAllMarketParamsRequest) Reset 

func (m *QueryAllMarketParamsRequest) Reset()

func (*QueryAllMarketParamsRequest) Size 

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

func (*QueryAllMarketParamsRequest) String 

func (m *QueryAllMarketParamsRequest) String() string

func (*QueryAllMarketParamsRequest) Unmarshal 

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

func (*QueryAllMarketParamsRequest) XXX_DiscardUnknown 

func (m *QueryAllMarketParamsRequest) XXX_DiscardUnknown()

func (*QueryAllMarketParamsRequest) XXX_Marshal 

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

func (*QueryAllMarketParamsRequest) XXX_Merge 

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

func (*QueryAllMarketParamsRequest) XXX_Size 

func (m *QueryAllMarketParamsRequest) XXX_Size() int

func (*QueryAllMarketParamsRequest) XXX_Unmarshal 

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

type QueryAllMarketParamsResponse 

type QueryAllMarketParamsResponse struct {
	MarketParams []MarketParam       `protobuf:"bytes,1,rep,name=market_params,json=marketParams,proto3" json:"market_params"`
	Pagination   *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllMarketParamsResponse is response type for the Query/Params `AllMarketParams` RPC method.

func (*QueryAllMarketParamsResponse) Descriptor 

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

func (*QueryAllMarketParamsResponse) GetMarketParams 

func (m *QueryAllMarketParamsResponse) GetMarketParams() []MarketParam

func (*QueryAllMarketParamsResponse) GetPagination 

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

func (*QueryAllMarketParamsResponse) Marshal 

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

func (*QueryAllMarketParamsResponse) MarshalTo 

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

func (*QueryAllMarketParamsResponse) MarshalToSizedBuffer 

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

func (*QueryAllMarketParamsResponse) ProtoMessage 

func (*QueryAllMarketParamsResponse) ProtoMessage()

func (*QueryAllMarketParamsResponse) Reset 

func (m *QueryAllMarketParamsResponse) Reset()

func (*QueryAllMarketParamsResponse) Size 

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

func (*QueryAllMarketParamsResponse) String 

func (m *QueryAllMarketParamsResponse) String() string

func (*QueryAllMarketParamsResponse) Unmarshal 

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

func (*QueryAllMarketParamsResponse) XXX_DiscardUnknown 

func (m *QueryAllMarketParamsResponse) XXX_DiscardUnknown()

func (*QueryAllMarketParamsResponse) XXX_Marshal 

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

func (*QueryAllMarketParamsResponse) XXX_Merge 

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

func (*QueryAllMarketParamsResponse) XXX_Size 

func (m *QueryAllMarketParamsResponse) XXX_Size() int

func (*QueryAllMarketParamsResponse) XXX_Unmarshal 

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

type QueryAllMarketPricesRequest 

type QueryAllMarketPricesRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllMarketPricesRequest is request type for the Query/Params `AllMarketPrices` RPC method.

func (*QueryAllMarketPricesRequest) Descriptor 

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

func (*QueryAllMarketPricesRequest) GetPagination 

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

func (*QueryAllMarketPricesRequest) Marshal 

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

func (*QueryAllMarketPricesRequest) MarshalTo 

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

func (*QueryAllMarketPricesRequest) MarshalToSizedBuffer 

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

func (*QueryAllMarketPricesRequest) ProtoMessage 

func (*QueryAllMarketPricesRequest) ProtoMessage()

func (*QueryAllMarketPricesRequest) Reset 

func (m *QueryAllMarketPricesRequest) Reset()

func (*QueryAllMarketPricesRequest) Size 

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

func (*QueryAllMarketPricesRequest) String 

func (m *QueryAllMarketPricesRequest) String() string

func (*QueryAllMarketPricesRequest) Unmarshal 

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

func (*QueryAllMarketPricesRequest) XXX_DiscardUnknown 

func (m *QueryAllMarketPricesRequest) XXX_DiscardUnknown()

func (*QueryAllMarketPricesRequest) XXX_Marshal 

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

func (*QueryAllMarketPricesRequest) XXX_Merge 

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

func (*QueryAllMarketPricesRequest) XXX_Size 

func (m *QueryAllMarketPricesRequest) XXX_Size() int

func (*QueryAllMarketPricesRequest) XXX_Unmarshal 

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

type QueryAllMarketPricesResponse 

type QueryAllMarketPricesResponse struct {
	MarketPrices []MarketPrice       `protobuf:"bytes,1,rep,name=market_prices,json=marketPrices,proto3" json:"market_prices"`
	Pagination   *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAllMarketPricesResponse is response type for the Query/Params `AllMarketPrices` RPC method.

func (*QueryAllMarketPricesResponse) Descriptor 

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

func (*QueryAllMarketPricesResponse) GetMarketPrices 

func (m *QueryAllMarketPricesResponse) GetMarketPrices() []MarketPrice

func (*QueryAllMarketPricesResponse) GetPagination 

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

func (*QueryAllMarketPricesResponse) Marshal 

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

func (*QueryAllMarketPricesResponse) MarshalTo 

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

func (*QueryAllMarketPricesResponse) MarshalToSizedBuffer 

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

func (*QueryAllMarketPricesResponse) ProtoMessage 

func (*QueryAllMarketPricesResponse) ProtoMessage()

func (*QueryAllMarketPricesResponse) Reset 

func (m *QueryAllMarketPricesResponse) Reset()

func (*QueryAllMarketPricesResponse) Size 

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

func (*QueryAllMarketPricesResponse) String 

func (m *QueryAllMarketPricesResponse) String() string

func (*QueryAllMarketPricesResponse) Unmarshal 

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

func (*QueryAllMarketPricesResponse) XXX_DiscardUnknown 

func (m *QueryAllMarketPricesResponse) XXX_DiscardUnknown()

func (*QueryAllMarketPricesResponse) XXX_Marshal 

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

func (*QueryAllMarketPricesResponse) XXX_Merge 

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

func (*QueryAllMarketPricesResponse) XXX_Size 

func (m *QueryAllMarketPricesResponse) XXX_Size() int

func (*QueryAllMarketPricesResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Queries a MarketPrice by id.
	MarketPrice(ctx context.Context, in *QueryMarketPriceRequest, opts ...grpc.CallOption) (*QueryMarketPriceResponse, error)
	// Queries a list of MarketPrice items.
	AllMarketPrices(ctx context.Context, in *QueryAllMarketPricesRequest, opts ...grpc.CallOption) (*QueryAllMarketPricesResponse, error)
	// Queries a MarketParam by id.
	MarketParam(ctx context.Context, in *QueryMarketParamRequest, opts ...grpc.CallOption) (*QueryMarketParamResponse, error)
	// Queries a list of MarketParam items.
	AllMarketParams(ctx context.Context, in *QueryAllMarketParamsRequest, opts ...grpc.CallOption) (*QueryAllMarketParamsResponse, 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 QueryMarketParamRequest 

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

QueryMarketParamsRequest is request type for the Query/Params `MarketParams` RPC method.

func (*QueryMarketParamRequest) Descriptor 

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

func (*QueryMarketParamRequest) GetId 

func (m *QueryMarketParamRequest) GetId() uint32

func (*QueryMarketParamRequest) Marshal 

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

func (*QueryMarketParamRequest) MarshalTo 

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

func (*QueryMarketParamRequest) MarshalToSizedBuffer 

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

func (*QueryMarketParamRequest) ProtoMessage 

func (*QueryMarketParamRequest) ProtoMessage()

func (*QueryMarketParamRequest) Reset 

func (m *QueryMarketParamRequest) Reset()

func (*QueryMarketParamRequest) Size 

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

func (*QueryMarketParamRequest) String 

func (m *QueryMarketParamRequest) String() string

func (*QueryMarketParamRequest) Unmarshal 

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

func (*QueryMarketParamRequest) XXX_DiscardUnknown 

func (m *QueryMarketParamRequest) XXX_DiscardUnknown()

func (*QueryMarketParamRequest) XXX_Marshal 

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

func (*QueryMarketParamRequest) XXX_Merge 

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

func (*QueryMarketParamRequest) XXX_Size 

func (m *QueryMarketParamRequest) XXX_Size() int

func (*QueryMarketParamRequest) XXX_Unmarshal 

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

type QueryMarketParamResponse 

type QueryMarketParamResponse struct {
	MarketParam MarketParam `protobuf:"bytes,1,opt,name=market_param,json=marketParam,proto3" json:"market_param"`
}

QueryMarketParamResponse is response type for the Query/Params `MarketParams` RPC method.

func (*QueryMarketParamResponse) Descriptor 

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

func (*QueryMarketParamResponse) GetMarketParam 

func (m *QueryMarketParamResponse) GetMarketParam() MarketParam

func (*QueryMarketParamResponse) Marshal 

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

func (*QueryMarketParamResponse) MarshalTo 

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

func (*QueryMarketParamResponse) MarshalToSizedBuffer 

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

func (*QueryMarketParamResponse) ProtoMessage 

func (*QueryMarketParamResponse) ProtoMessage()

func (*QueryMarketParamResponse) Reset 

func (m *QueryMarketParamResponse) Reset()

func (*QueryMarketParamResponse) Size 

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

func (*QueryMarketParamResponse) String 

func (m *QueryMarketParamResponse) String() string

func (*QueryMarketParamResponse) Unmarshal 

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

func (*QueryMarketParamResponse) XXX_DiscardUnknown 

func (m *QueryMarketParamResponse) XXX_DiscardUnknown()

func (*QueryMarketParamResponse) XXX_Marshal 

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

func (*QueryMarketParamResponse) XXX_Merge 

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

func (*QueryMarketParamResponse) XXX_Size 

func (m *QueryMarketParamResponse) XXX_Size() int

func (*QueryMarketParamResponse) XXX_Unmarshal 

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

type QueryMarketPriceRequest 

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

QueryMarketPriceRequest is request type for the Query/Params `MarketPrice` RPC method.

func (*QueryMarketPriceRequest) Descriptor 

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

func (*QueryMarketPriceRequest) GetId 

func (m *QueryMarketPriceRequest) GetId() uint32

func (*QueryMarketPriceRequest) Marshal 

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

func (*QueryMarketPriceRequest) MarshalTo 

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

func (*QueryMarketPriceRequest) MarshalToSizedBuffer 

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

func (*QueryMarketPriceRequest) ProtoMessage 

func (*QueryMarketPriceRequest) ProtoMessage()

func (*QueryMarketPriceRequest) Reset 

func (m *QueryMarketPriceRequest) Reset()

func (*QueryMarketPriceRequest) Size 

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

func (*QueryMarketPriceRequest) String 

func (m *QueryMarketPriceRequest) String() string

func (*QueryMarketPriceRequest) Unmarshal 

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

func (*QueryMarketPriceRequest) XXX_DiscardUnknown 

func (m *QueryMarketPriceRequest) XXX_DiscardUnknown()

func (*QueryMarketPriceRequest) XXX_Marshal 

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

func (*QueryMarketPriceRequest) XXX_Merge 

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

func (*QueryMarketPriceRequest) XXX_Size 

func (m *QueryMarketPriceRequest) XXX_Size() int

func (*QueryMarketPriceRequest) XXX_Unmarshal 

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

type QueryMarketPriceResponse 

type QueryMarketPriceResponse struct {
	MarketPrice MarketPrice `protobuf:"bytes,1,opt,name=market_price,json=marketPrice,proto3" json:"market_price"`
}

QueryMarketPriceResponse is response type for the Query/Params `MarketPrice` RPC method.

func (*QueryMarketPriceResponse) Descriptor 

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

func (*QueryMarketPriceResponse) GetMarketPrice 

func (m *QueryMarketPriceResponse) GetMarketPrice() MarketPrice

func (*QueryMarketPriceResponse) Marshal 

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

func (*QueryMarketPriceResponse) MarshalTo 

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

func (*QueryMarketPriceResponse) MarshalToSizedBuffer 

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

func (*QueryMarketPriceResponse) ProtoMessage 

func (*QueryMarketPriceResponse) ProtoMessage()

func (*QueryMarketPriceResponse) Reset 

func (m *QueryMarketPriceResponse) Reset()

func (*QueryMarketPriceResponse) Size 

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

func (*QueryMarketPriceResponse) String 

func (m *QueryMarketPriceResponse) String() string

func (*QueryMarketPriceResponse) Unmarshal 

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

func (*QueryMarketPriceResponse) XXX_DiscardUnknown 

func (m *QueryMarketPriceResponse) XXX_DiscardUnknown()

func (*QueryMarketPriceResponse) XXX_Marshal 

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

func (*QueryMarketPriceResponse) XXX_Merge 

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

func (*QueryMarketPriceResponse) XXX_Size 

func (m *QueryMarketPriceResponse) XXX_Size() int

func (*QueryMarketPriceResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Queries a MarketPrice by id.
	MarketPrice(context.Context, *QueryMarketPriceRequest) (*QueryMarketPriceResponse, error)
	// Queries a list of MarketPrice items.
	AllMarketPrices(context.Context, *QueryAllMarketPricesRequest) (*QueryAllMarketPricesResponse, error)
	// Queries a MarketParam by id.
	MarketParam(context.Context, *QueryMarketParamRequest) (*QueryMarketParamResponse, error)
	// Queries a list of MarketParam items.
	AllMarketParams(context.Context, *QueryAllMarketParamsRequest) (*QueryAllMarketParamsResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreateOracleMarket 

func (*UnimplementedMsgServer) CreateOracleMarket(ctx context.Context, req *MsgCreateOracleMarket) (*MsgCreateOracleMarketResponse, error)

func (*UnimplementedMsgServer) UpdateMarketParam 

func (*UnimplementedMsgServer) UpdateMarketParam(ctx context.Context, req *MsgUpdateMarketParam) (*MsgUpdateMarketParamResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AllMarketParams 

func (*UnimplementedQueryServer) AllMarketParams(ctx context.Context, req *QueryAllMarketParamsRequest) (*QueryAllMarketParamsResponse, error)

func (*UnimplementedQueryServer) AllMarketPrices 

func (*UnimplementedQueryServer) AllMarketPrices(ctx context.Context, req *QueryAllMarketPricesRequest) (*QueryAllMarketPricesResponse, error)

func (*UnimplementedQueryServer) MarketParam 

func (*UnimplementedQueryServer) MarketParam(ctx context.Context, req *QueryMarketParamRequest) (*QueryMarketParamResponse, error)

func (*UnimplementedQueryServer) MarketPrice 

func (*UnimplementedQueryServer) MarketPrice(ctx context.Context, req *QueryMarketPriceRequest) (*QueryMarketPriceResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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