types

package
v0.0.0-...-853bff8 Latest Latest
Warning

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

 Go to latest Published: May 28, 2023 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeMarketPriceUpdated = "market_price_updated"
	EventTypeOracleUpdatedPrice = "oracle_updated_price"
	EventTypeNoValidPrices      = "no_valid_prices"

	AttributeValueCategory = ModuleName
	AttributeMarketID      = "market_id"
	AttributeMarketPrice   = "market_price"
	AttributeOracle        = "oracle"
	AttributeExpiry        = "expiry"
)

Pricefeed module event types

View Source 
const (
	// ModuleName The name that will be used throughout the module
	ModuleName = "pricefeed"

	// StoreKey Top level store key where all module items will be stored
	StoreKey = ModuleName

	// RouterKey Top level router key
	RouterKey = ModuleName

	// QuerierRoute is the querier route for gov
	QuerierRoute = ModuleName

	// DefaultParamspace default namestore
	DefaultParamspace = ModuleName
)
View Source 
const (
	// TypeMsgPostPrice type of PostPrice msg
	TypeMsgPostPrice = "post_price"

	// MaxExpiry defines the max expiry time defined as UNIX time (9999-12-31 23:59:59 +0000 UTC)
	MaxExpiry = 253402300799
)
View Source 
const (
	// QueryGetParams command for params query
	QueryGetParams = "parameters"
	// QueryMarkets command for assets query
	QueryMarkets = "markets"
	// QueryOracles command for oracles query
	QueryOracles = "oracles"
	// QueryRawPrices command for raw price queries
	QueryRawPrices = "rawprices"
	// QueryPrice command for price queries
	QueryPrice = "price"
	// QueryPrices command for quering all prices
	QueryPrices = "prices"
)

Variables

View Source 
var (
	// ErrEmptyInput error for empty input
	ErrEmptyInput = errorsmod.Register(ModuleName, 2, "input must not be empty")
	// ErrExpired error for posted price messages with expired price
	ErrExpired = errorsmod.Register(ModuleName, 3, "price is expired")
	// ErrNoValidPrice error for posted price messages with expired price
	ErrNoValidPrice = errorsmod.Register(ModuleName, 4, "all input prices are expired")
	// ErrInvalidMarket error for posted price messages for invalid markets
	ErrInvalidMarket = errorsmod.Register(ModuleName, 5, "market does not exist")
	// ErrInvalidOracle error for posted price messages for invalid oracles
	ErrInvalidOracle = errorsmod.Register(ModuleName, 6, "oracle does not exist or not authorized")
	// ErrAssetNotFound error for not found asset
	ErrAssetNotFound = errorsmod.Register(ModuleName, 7, "asset not found")
)
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 (
	// CurrentPricePrefix prefix for the current price of an asset
	CurrentPricePrefix = []byte{0x00}

	// RawPriceFeedPrefix prefix for the raw pricefeed of an asset
	RawPriceFeedPrefix = []byte{0x01}
)
View Source 
var (
	KeyMarkets     = []byte("Markets")
	DefaultMarkets = []Market{}
)

Parameter keys

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 (
	ErrInvalidLengthStore        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStore          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStore = 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")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func CurrentPriceKey 

func CurrentPriceKey(marketID string) []byte

CurrentPriceKey returns the prefix for the current price

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable Key declaration for parameters

func RawPriceIteratorKey 

func RawPriceIteratorKey(marketID string) []byte

RawPriceIteratorKey returns the prefix for the raw price for a single market

func RawPriceKey 

func RawPriceKey(marketID string, oracleAddr sdk.AccAddress) []byte

RawPriceKey returns the prefix for the raw price

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers all the necessary types and interfaces for the governance module.

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 CurrentPrice 

type CurrentPrice struct {
	MarketID string                                 `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	Price    github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
}

CurrentPrice defines a current price for a particular market in the pricefeed module.

func NewCurrentPrice 

func NewCurrentPrice(marketID string, price sdk.Dec) CurrentPrice

NewCurrentPrice returns an instance of CurrentPrice

func (*CurrentPrice) Descriptor 

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

func (*CurrentPrice) Equal 

func (this *CurrentPrice) Equal(that interface{}) bool

func (*CurrentPrice) GetMarketID 

func (m *CurrentPrice) GetMarketID() string

func (*CurrentPrice) Marshal 

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

func (*CurrentPrice) MarshalTo 

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

func (*CurrentPrice) MarshalToSizedBuffer 

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

func (*CurrentPrice) ProtoMessage 

func (*CurrentPrice) ProtoMessage()

func (*CurrentPrice) Reset 

func (m *CurrentPrice) Reset()

func (*CurrentPrice) Size 

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

func (*CurrentPrice) String 

func (m *CurrentPrice) String() string

func (*CurrentPrice) Unmarshal 

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

func (*CurrentPrice) VerboseEqual 

func (this *CurrentPrice) VerboseEqual(that interface{}) error

func (*CurrentPrice) XXX_DiscardUnknown 

func (m *CurrentPrice) XXX_DiscardUnknown()

func (*CurrentPrice) XXX_Marshal 

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

func (*CurrentPrice) XXX_Merge 

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

func (*CurrentPrice) XXX_Size 

func (m *CurrentPrice) XXX_Size() int

func (*CurrentPrice) XXX_Unmarshal 

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

type CurrentPriceResponse 

type CurrentPriceResponse struct {
	MarketID string                                 `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	Price    github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
}

CurrentPriceResponse defines a current price for a particular market in the pricefeed module.

func NewCurrentPriceResponse 

func NewCurrentPriceResponse(marketID string, price sdk.Dec) CurrentPriceResponse

NewCurrentPriceResponse returns an instance of CurrentPriceResponse

func (*CurrentPriceResponse) Descriptor 

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

func (*CurrentPriceResponse) Equal 

func (this *CurrentPriceResponse) Equal(that interface{}) bool

func (*CurrentPriceResponse) GetMarketID 

func (m *CurrentPriceResponse) GetMarketID() string

func (*CurrentPriceResponse) Marshal 

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

func (*CurrentPriceResponse) MarshalTo 

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

func (*CurrentPriceResponse) MarshalToSizedBuffer 

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

func (*CurrentPriceResponse) ProtoMessage 

func (*CurrentPriceResponse) ProtoMessage()

func (*CurrentPriceResponse) Reset 

func (m *CurrentPriceResponse) Reset()

func (*CurrentPriceResponse) Size 

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

func (*CurrentPriceResponse) String 

func (m *CurrentPriceResponse) String() string

func (*CurrentPriceResponse) Unmarshal 

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

func (*CurrentPriceResponse) VerboseEqual 

func (this *CurrentPriceResponse) VerboseEqual(that interface{}) error

func (*CurrentPriceResponse) XXX_DiscardUnknown 

func (m *CurrentPriceResponse) XXX_DiscardUnknown()

func (*CurrentPriceResponse) XXX_Marshal 

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

func (*CurrentPriceResponse) XXX_Merge 

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

func (*CurrentPriceResponse) XXX_Size 

func (m *CurrentPriceResponse) XXX_Size() int

func (*CurrentPriceResponse) XXX_Unmarshal 

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

type CurrentPriceResponses 

type CurrentPriceResponses []CurrentPriceResponse

CurrentPriceResponses is a slice of CurrentPriceResponse

type CurrentPrices 

type CurrentPrices []CurrentPrice

CurrentPrices is a slice of CurrentPrice

type GenesisState 

type GenesisState struct {
	// params defines all the paramaters of the module.
	Params       Params       `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	PostedPrices PostedPrices `protobuf:"bytes,2,rep,name=posted_prices,json=postedPrices,proto3,castrepeated=PostedPrices" json:"posted_prices"`
}

GenesisState defines the pricefeed module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() GenesisState

DefaultGenesisState defines default GenesisState for pricefeed

func NewGenesisState 

func NewGenesisState(p Params, pp []PostedPrice) GenesisState

NewGenesisState creates a new genesis state for the pricefeed module

func (*GenesisState) Descriptor 

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

func (*GenesisState) Equal 

func (this *GenesisState) Equal(that interface{}) bool

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPostedPrices 

func (m *GenesisState) GetPostedPrices() PostedPrices

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 validation of genesis data returning an error for any failed validation criteria.

func (*GenesisState) VerboseEqual 

func (this *GenesisState) VerboseEqual(that interface{}) 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 Market 

type Market struct {
	MarketID   string                                          `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	BaseAsset  string                                          `protobuf:"bytes,2,opt,name=base_asset,json=baseAsset,proto3" json:"base_asset,omitempty"`
	QuoteAsset string                                          `protobuf:"bytes,3,opt,name=quote_asset,json=quoteAsset,proto3" json:"quote_asset,omitempty"`
	Oracles    []github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,rep,name=oracles,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"oracles,omitempty"`
	Active     bool                                            `protobuf:"varint,5,opt,name=active,proto3" json:"active,omitempty"`
}

Market defines an asset in the pricefeed.

func NewMarket 

func NewMarket(id, base, quote string, oracles []sdk.AccAddress, active bool) Market

NewMarket returns a new Market

func (*Market) Descriptor 

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

func (*Market) Equal 

func (this *Market) Equal(that interface{}) bool

func (*Market) GetActive 

func (m *Market) GetActive() bool

func (*Market) GetBaseAsset 

func (m *Market) GetBaseAsset() string

func (*Market) GetMarketID 

func (m *Market) GetMarketID() string

func (*Market) GetOracles 

func (m *Market) GetOracles() []github_com_cosmos_cosmos_sdk_types.AccAddress

func (*Market) GetQuoteAsset 

func (m *Market) GetQuoteAsset() string

func (*Market) Marshal 

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

func (*Market) MarshalTo 

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

func (*Market) MarshalToSizedBuffer 

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

func (*Market) ProtoMessage 

func (*Market) ProtoMessage()

func (*Market) Reset 

func (m *Market) Reset()

func (*Market) Size 

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

func (*Market) String 

func (m *Market) String() string

func (Market) ToMarketResponse 

func (m Market) ToMarketResponse() MarketResponse

ToMarketResponse returns a new MarketResponse from a Market

func (*Market) Unmarshal 

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

func (Market) Validate 

func (m Market) Validate() error

Validate performs a basic validation of the market params

func (*Market) VerboseEqual 

func (this *Market) VerboseEqual(that interface{}) error

func (*Market) XXX_DiscardUnknown 

func (m *Market) XXX_DiscardUnknown()

func (*Market) XXX_Marshal 

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

func (*Market) XXX_Merge 

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

func (*Market) XXX_Size 

func (m *Market) XXX_Size() int

func (*Market) XXX_Unmarshal 

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

type MarketResponse 

type MarketResponse struct {
	MarketID   string   `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	BaseAsset  string   `protobuf:"bytes,2,opt,name=base_asset,json=baseAsset,proto3" json:"base_asset,omitempty"`
	QuoteAsset string   `protobuf:"bytes,3,opt,name=quote_asset,json=quoteAsset,proto3" json:"quote_asset,omitempty"`
	Oracles    []string `protobuf:"bytes,4,rep,name=oracles,proto3" json:"oracles,omitempty"`
	Active     bool     `protobuf:"varint,5,opt,name=active,proto3" json:"active,omitempty"`
}

MarketResponse defines an asset in the pricefeed.

func NewMarketResponse 

func NewMarketResponse(id, base, quote string, oracles []sdk.AccAddress, active bool) MarketResponse

NewMarketResponse returns a new MarketResponse

func (*MarketResponse) Descriptor 

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

func (*MarketResponse) Equal 

func (this *MarketResponse) Equal(that interface{}) bool

func (*MarketResponse) GetActive 

func (m *MarketResponse) GetActive() bool

func (*MarketResponse) GetBaseAsset 

func (m *MarketResponse) GetBaseAsset() string

func (*MarketResponse) GetMarketID 

func (m *MarketResponse) GetMarketID() string

func (*MarketResponse) GetOracles 

func (m *MarketResponse) GetOracles() []string

func (*MarketResponse) GetQuoteAsset 

func (m *MarketResponse) GetQuoteAsset() string

func (*MarketResponse) Marshal 

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

func (*MarketResponse) MarshalTo 

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

func (*MarketResponse) MarshalToSizedBuffer 

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

func (*MarketResponse) ProtoMessage 

func (*MarketResponse) ProtoMessage()

func (*MarketResponse) Reset 

func (m *MarketResponse) Reset()

func (*MarketResponse) Size 

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

func (*MarketResponse) String 

func (m *MarketResponse) String() string

func (*MarketResponse) Unmarshal 

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

func (*MarketResponse) VerboseEqual 

func (this *MarketResponse) VerboseEqual(that interface{}) error

func (*MarketResponse) XXX_DiscardUnknown 

func (m *MarketResponse) XXX_DiscardUnknown()

func (*MarketResponse) XXX_Marshal 

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

func (*MarketResponse) XXX_Merge 

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

func (*MarketResponse) XXX_Size 

func (m *MarketResponse) XXX_Size() int

func (*MarketResponse) XXX_Unmarshal 

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

type MarketResponses 

type MarketResponses []MarketResponse

MarketResponses is a slice of MarketResponse

type Markets 

type Markets []Market

Markets is a slice of Market

func (Markets) Validate 

func (ms Markets) Validate() error

Validate checks if all the markets are valid and there are no duplicated entries.

type MsgClient 

type MsgClient interface {
	// PostPrice defines a method for creating a new post price
	PostPrice(ctx context.Context, in *MsgPostPrice, opts ...grpc.CallOption) (*MsgPostPriceResponse, 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 MsgPostPrice 

type MsgPostPrice struct {
	// address of client
	From     string                                 `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	MarketID string                                 `protobuf:"bytes,2,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	Price    github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,3,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
	Expiry   time.Time                              `protobuf:"bytes,4,opt,name=expiry,proto3,stdtime" json:"expiry"`
}

MsgPostPrice represents a method for creating a new post price

func NewMsgPostPrice 

func NewMsgPostPrice(from string, marketID string, price sdk.Dec, expiry time.Time) *MsgPostPrice

NewMsgPostPrice returns a new MsgPostPrice

func (*MsgPostPrice) Descriptor 

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

func (*MsgPostPrice) Equal 

func (this *MsgPostPrice) Equal(that interface{}) bool

func (MsgPostPrice) GetSignBytes 

func (msg MsgPostPrice) GetSignBytes() []byte

GetSignBytes Implements Msg.

func (MsgPostPrice) GetSigners 

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

GetSigners Implements Msg.

func (*MsgPostPrice) Marshal 

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

func (*MsgPostPrice) MarshalTo 

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

func (*MsgPostPrice) MarshalToSizedBuffer 

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

func (*MsgPostPrice) ProtoMessage 

func (*MsgPostPrice) ProtoMessage()

func (*MsgPostPrice) Reset 

func (m *MsgPostPrice) Reset()

func (MsgPostPrice) Route 

func (msg MsgPostPrice) Route() string

Route Implements Msg.

func (*MsgPostPrice) Size 

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

func (*MsgPostPrice) String 

func (m *MsgPostPrice) String() string

func (MsgPostPrice) Type 

func (msg MsgPostPrice) Type() string

Type Implements Msg

func (*MsgPostPrice) Unmarshal 

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

func (MsgPostPrice) ValidateBasic 

func (msg MsgPostPrice) ValidateBasic() error

ValidateBasic does a simple validation check that doesn't require access to any other information.

func (*MsgPostPrice) VerboseEqual 

func (this *MsgPostPrice) VerboseEqual(that interface{}) error

func (*MsgPostPrice) XXX_DiscardUnknown 

func (m *MsgPostPrice) XXX_DiscardUnknown()

func (*MsgPostPrice) XXX_Marshal 

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

func (*MsgPostPrice) XXX_Merge 

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

func (*MsgPostPrice) XXX_Size 

func (m *MsgPostPrice) XXX_Size() int

func (*MsgPostPrice) XXX_Unmarshal 

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

type MsgPostPriceResponse 

type MsgPostPriceResponse struct {
}

MsgPostPriceResponse defines the Msg/PostPrice response type.

func (*MsgPostPriceResponse) Descriptor 

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

func (*MsgPostPriceResponse) Equal 

func (this *MsgPostPriceResponse) Equal(that interface{}) bool

func (*MsgPostPriceResponse) Marshal 

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

func (*MsgPostPriceResponse) MarshalTo 

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

func (*MsgPostPriceResponse) MarshalToSizedBuffer 

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

func (*MsgPostPriceResponse) ProtoMessage 

func (*MsgPostPriceResponse) ProtoMessage()

func (*MsgPostPriceResponse) Reset 

func (m *MsgPostPriceResponse) Reset()

func (*MsgPostPriceResponse) Size 

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

func (*MsgPostPriceResponse) String 

func (m *MsgPostPriceResponse) String() string

func (*MsgPostPriceResponse) Unmarshal 

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

func (*MsgPostPriceResponse) VerboseEqual 

func (this *MsgPostPriceResponse) VerboseEqual(that interface{}) error

func (*MsgPostPriceResponse) XXX_DiscardUnknown 

func (m *MsgPostPriceResponse) XXX_DiscardUnknown()

func (*MsgPostPriceResponse) XXX_Marshal 

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

func (*MsgPostPriceResponse) XXX_Merge 

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

func (*MsgPostPriceResponse) XXX_Size 

func (m *MsgPostPriceResponse) XXX_Size() int

func (*MsgPostPriceResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// PostPrice defines a method for creating a new post price
	PostPrice(context.Context, *MsgPostPrice) (*MsgPostPriceResponse, error)
}

MsgServer is the server API for Msg service.

type Params 

type Params struct {
	Markets Markets `protobuf:"bytes,1,rep,name=markets,proto3,castrepeated=Markets" json:"markets"`
}

Params defines the parameters for the pricefeed module.

func DefaultParams 

func DefaultParams() Params

DefaultParams default params for pricefeed

func NewParams 

func NewParams(markets []Market) Params

NewParams creates a new AssetParams object

func (*Params) Descriptor 

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

func (*Params) Equal 

func (this *Params) Equal(that interface{}) bool

func (*Params) GetMarkets 

func (m *Params) GetMarkets() Markets

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs implements the ParamSet interface and returns all the key/value pairs pairs of pricefeed module's parameters.

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate ensure that params have valid values

func (*Params) VerboseEqual 

func (this *Params) VerboseEqual(that interface{}) error

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type PostedPrice 

type PostedPrice struct {
	MarketID      string                                        `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	OracleAddress github_com_cosmos_cosmos_sdk_types.AccAddress `` /* 155-byte string literal not displayed */
	Price         github_com_cosmos_cosmos_sdk_types.Dec        `protobuf:"bytes,3,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
	Expiry        time.Time                                     `protobuf:"bytes,4,opt,name=expiry,proto3,stdtime" json:"expiry"`
}

PostedPrice defines a price for market posted by a specific oracle.

func NewPostedPrice 

func NewPostedPrice(marketID string, oracle sdk.AccAddress, price sdk.Dec, expiry time.Time) PostedPrice

NewPostedPrice returns a new PostedPrice

func (*PostedPrice) Descriptor 

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

func (*PostedPrice) Equal 

func (this *PostedPrice) Equal(that interface{}) bool

func (*PostedPrice) GetExpiry 

func (m *PostedPrice) GetExpiry() time.Time

func (*PostedPrice) GetMarketID 

func (m *PostedPrice) GetMarketID() string

func (*PostedPrice) GetOracleAddress 

func (m *PostedPrice) GetOracleAddress() github_com_cosmos_cosmos_sdk_types.AccAddress

func (*PostedPrice) Marshal 

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

func (*PostedPrice) MarshalTo 

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

func (*PostedPrice) MarshalToSizedBuffer 

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

func (*PostedPrice) ProtoMessage 

func (*PostedPrice) ProtoMessage()

func (*PostedPrice) Reset 

func (m *PostedPrice) Reset()

func (*PostedPrice) Size 

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

func (*PostedPrice) String 

func (m *PostedPrice) String() string

func (*PostedPrice) Unmarshal 

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

func (PostedPrice) Validate 

func (pp PostedPrice) Validate() error

Validate performs a basic check of a PostedPrice params.

func (*PostedPrice) VerboseEqual 

func (this *PostedPrice) VerboseEqual(that interface{}) error

func (*PostedPrice) XXX_DiscardUnknown 

func (m *PostedPrice) XXX_DiscardUnknown()

func (*PostedPrice) XXX_Marshal 

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

func (*PostedPrice) XXX_Merge 

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

func (*PostedPrice) XXX_Size 

func (m *PostedPrice) XXX_Size() int

func (*PostedPrice) XXX_Unmarshal 

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

type PostedPriceResponse 

type PostedPriceResponse struct {
	MarketID      string                                 `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	OracleAddress string                                 `protobuf:"bytes,2,opt,name=oracle_address,json=oracleAddress,proto3" json:"oracle_address,omitempty"`
	Price         github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,3,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
	Expiry        time.Time                              `protobuf:"bytes,4,opt,name=expiry,proto3,stdtime" json:"expiry"`
}

PostedPriceResponse defines a price for market posted by a specific oracle.

func NewPostedPriceResponse 

func NewPostedPriceResponse(marketID string, oracle sdk.AccAddress, price sdk.Dec, expiry time.Time) PostedPriceResponse

NewPostedPrice returns a new PostedPrice

func (*PostedPriceResponse) Descriptor 

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

func (*PostedPriceResponse) Equal 

func (this *PostedPriceResponse) Equal(that interface{}) bool

func (*PostedPriceResponse) GetExpiry 

func (m *PostedPriceResponse) GetExpiry() time.Time

func (*PostedPriceResponse) GetMarketID 

func (m *PostedPriceResponse) GetMarketID() string

func (*PostedPriceResponse) GetOracleAddress 

func (m *PostedPriceResponse) GetOracleAddress() string

func (*PostedPriceResponse) Marshal 

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

func (*PostedPriceResponse) MarshalTo 

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

func (*PostedPriceResponse) MarshalToSizedBuffer 

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

func (*PostedPriceResponse) ProtoMessage 

func (*PostedPriceResponse) ProtoMessage()

func (*PostedPriceResponse) Reset 

func (m *PostedPriceResponse) Reset()

func (*PostedPriceResponse) Size 

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

func (*PostedPriceResponse) String 

func (m *PostedPriceResponse) String() string

func (*PostedPriceResponse) Unmarshal 

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

func (*PostedPriceResponse) VerboseEqual 

func (this *PostedPriceResponse) VerboseEqual(that interface{}) error

func (*PostedPriceResponse) XXX_DiscardUnknown 

func (m *PostedPriceResponse) XXX_DiscardUnknown()

func (*PostedPriceResponse) XXX_Marshal 

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

func (*PostedPriceResponse) XXX_Merge 

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

func (*PostedPriceResponse) XXX_Size 

func (m *PostedPriceResponse) XXX_Size() int

func (*PostedPriceResponse) XXX_Unmarshal 

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

type PostedPriceResponses 

type PostedPriceResponses []PostedPriceResponse

PostedPriceResponses is a slice of PostedPriceResponse

type PostedPrices 

type PostedPrices []PostedPrice

PostedPrices is a slice of PostedPrice

func (PostedPrices) Validate 

func (pps PostedPrices) Validate() error

Validate checks if all the posted prices are valid and there are no duplicated entries.

type QueryClient 

type QueryClient interface {
	// Params queries all parameters of the pricefeed module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Price queries price details based on a market
	Price(ctx context.Context, in *QueryPriceRequest, opts ...grpc.CallOption) (*QueryPriceResponse, error)
	// Prices queries all prices
	Prices(ctx context.Context, in *QueryPricesRequest, opts ...grpc.CallOption) (*QueryPricesResponse, error)
	// RawPrices queries all raw prices based on a market
	RawPrices(ctx context.Context, in *QueryRawPricesRequest, opts ...grpc.CallOption) (*QueryRawPricesResponse, error)
	// Oracles queries all oracles based on a market
	Oracles(ctx context.Context, in *QueryOraclesRequest, opts ...grpc.CallOption) (*QueryOraclesResponse, error)
	// Markets queries all markets
	Markets(ctx context.Context, in *QueryMarketsRequest, opts ...grpc.CallOption) (*QueryMarketsResponse, 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 QueryMarketsRequest 

type QueryMarketsRequest struct {
}

QueryMarketsRequest is the request type for the Query/Markets RPC method.

func (*QueryMarketsRequest) Descriptor 

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

func (*QueryMarketsRequest) Equal 

func (this *QueryMarketsRequest) Equal(that interface{}) bool

func (*QueryMarketsRequest) Marshal 

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

func (*QueryMarketsRequest) MarshalTo 

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

func (*QueryMarketsRequest) MarshalToSizedBuffer 

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

func (*QueryMarketsRequest) ProtoMessage 

func (*QueryMarketsRequest) ProtoMessage()

func (*QueryMarketsRequest) Reset 

func (m *QueryMarketsRequest) Reset()

func (*QueryMarketsRequest) Size 

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

func (*QueryMarketsRequest) String 

func (m *QueryMarketsRequest) String() string

func (*QueryMarketsRequest) Unmarshal 

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

func (*QueryMarketsRequest) VerboseEqual 

func (this *QueryMarketsRequest) VerboseEqual(that interface{}) error

func (*QueryMarketsRequest) XXX_DiscardUnknown 

func (m *QueryMarketsRequest) XXX_DiscardUnknown()

func (*QueryMarketsRequest) XXX_Marshal 

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

func (*QueryMarketsRequest) XXX_Merge 

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

func (*QueryMarketsRequest) XXX_Size 

func (m *QueryMarketsRequest) XXX_Size() int

func (*QueryMarketsRequest) XXX_Unmarshal 

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

type QueryMarketsResponse 

type QueryMarketsResponse struct {
	// List of markets
	Markets MarketResponses `protobuf:"bytes,1,rep,name=markets,proto3,castrepeated=MarketResponses" json:"markets"`
}

QueryMarketsResponse is the response type for the Query/Markets RPC method.

func (*QueryMarketsResponse) Descriptor 

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

func (*QueryMarketsResponse) Equal 

func (this *QueryMarketsResponse) Equal(that interface{}) bool

func (*QueryMarketsResponse) Marshal 

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

func (*QueryMarketsResponse) MarshalTo 

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

func (*QueryMarketsResponse) MarshalToSizedBuffer 

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

func (*QueryMarketsResponse) ProtoMessage 

func (*QueryMarketsResponse) ProtoMessage()

func (*QueryMarketsResponse) Reset 

func (m *QueryMarketsResponse) Reset()

func (*QueryMarketsResponse) Size 

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

func (*QueryMarketsResponse) String 

func (m *QueryMarketsResponse) String() string

func (*QueryMarketsResponse) Unmarshal 

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

func (*QueryMarketsResponse) VerboseEqual 

func (this *QueryMarketsResponse) VerboseEqual(that interface{}) error

func (*QueryMarketsResponse) XXX_DiscardUnknown 

func (m *QueryMarketsResponse) XXX_DiscardUnknown()

func (*QueryMarketsResponse) XXX_Marshal 

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

func (*QueryMarketsResponse) XXX_Merge 

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

func (*QueryMarketsResponse) XXX_Size 

func (m *QueryMarketsResponse) XXX_Size() int

func (*QueryMarketsResponse) XXX_Unmarshal 

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

type QueryOraclesRequest 

type QueryOraclesRequest struct {
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
}

QueryOraclesRequest is the request type for the Query/Oracles RPC method.

func (*QueryOraclesRequest) Descriptor 

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

func (*QueryOraclesRequest) Equal 

func (this *QueryOraclesRequest) Equal(that interface{}) bool

func (*QueryOraclesRequest) Marshal 

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

func (*QueryOraclesRequest) MarshalTo 

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

func (*QueryOraclesRequest) MarshalToSizedBuffer 

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

func (*QueryOraclesRequest) ProtoMessage 

func (*QueryOraclesRequest) ProtoMessage()

func (*QueryOraclesRequest) Reset 

func (m *QueryOraclesRequest) Reset()

func (*QueryOraclesRequest) Size 

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

func (*QueryOraclesRequest) String 

func (m *QueryOraclesRequest) String() string

func (*QueryOraclesRequest) Unmarshal 

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

func (*QueryOraclesRequest) VerboseEqual 

func (this *QueryOraclesRequest) VerboseEqual(that interface{}) error

func (*QueryOraclesRequest) XXX_DiscardUnknown 

func (m *QueryOraclesRequest) XXX_DiscardUnknown()

func (*QueryOraclesRequest) XXX_Marshal 

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

func (*QueryOraclesRequest) XXX_Merge 

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

func (*QueryOraclesRequest) XXX_Size 

func (m *QueryOraclesRequest) XXX_Size() int

func (*QueryOraclesRequest) XXX_Unmarshal 

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

type QueryOraclesResponse 

type QueryOraclesResponse struct {
	// List of oracle addresses
	Oracles []string `protobuf:"bytes,1,rep,name=oracles,proto3" json:"oracles,omitempty"`
}

QueryOraclesResponse is the response type for the Query/Oracles RPC method.

func (*QueryOraclesResponse) Descriptor 

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

func (*QueryOraclesResponse) Equal 

func (this *QueryOraclesResponse) Equal(that interface{}) bool

func (*QueryOraclesResponse) Marshal 

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

func (*QueryOraclesResponse) MarshalTo 

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

func (*QueryOraclesResponse) MarshalToSizedBuffer 

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

func (*QueryOraclesResponse) ProtoMessage 

func (*QueryOraclesResponse) ProtoMessage()

func (*QueryOraclesResponse) Reset 

func (m *QueryOraclesResponse) Reset()

func (*QueryOraclesResponse) Size 

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

func (*QueryOraclesResponse) String 

func (m *QueryOraclesResponse) String() string

func (*QueryOraclesResponse) Unmarshal 

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

func (*QueryOraclesResponse) VerboseEqual 

func (this *QueryOraclesResponse) VerboseEqual(that interface{}) error

func (*QueryOraclesResponse) XXX_DiscardUnknown 

func (m *QueryOraclesResponse) XXX_DiscardUnknown()

func (*QueryOraclesResponse) XXX_Marshal 

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

func (*QueryOraclesResponse) XXX_Merge 

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

func (*QueryOraclesResponse) XXX_Size 

func (m *QueryOraclesResponse) XXX_Size() int

func (*QueryOraclesResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest defines the request type for querying x/pricefeed parameters.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Equal 

func (this *QueryParamsRequest) Equal(that interface{}) bool

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) VerboseEqual 

func (this *QueryParamsRequest) VerboseEqual(that interface{}) 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"`
}

QueryParamsResponse defines the response type for querying x/pricefeed parameters.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) Equal 

func (this *QueryParamsResponse) Equal(that interface{}) bool

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) VerboseEqual 

func (this *QueryParamsResponse) VerboseEqual(that interface{}) 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 QueryPriceRequest 

type QueryPriceRequest struct {
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
}

QueryPriceRequest is the request type for the Query/PriceRequest RPC method.

func (*QueryPriceRequest) Descriptor 

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

func (*QueryPriceRequest) Equal 

func (this *QueryPriceRequest) Equal(that interface{}) bool

func (*QueryPriceRequest) Marshal 

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

func (*QueryPriceRequest) MarshalTo 

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

func (*QueryPriceRequest) MarshalToSizedBuffer 

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

func (*QueryPriceRequest) ProtoMessage 

func (*QueryPriceRequest) ProtoMessage()

func (*QueryPriceRequest) Reset 

func (m *QueryPriceRequest) Reset()

func (*QueryPriceRequest) Size 

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

func (*QueryPriceRequest) String 

func (m *QueryPriceRequest) String() string

func (*QueryPriceRequest) Unmarshal 

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

func (*QueryPriceRequest) VerboseEqual 

func (this *QueryPriceRequest) VerboseEqual(that interface{}) error

func (*QueryPriceRequest) XXX_DiscardUnknown 

func (m *QueryPriceRequest) XXX_DiscardUnknown()

func (*QueryPriceRequest) XXX_Marshal 

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

func (*QueryPriceRequest) XXX_Merge 

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

func (*QueryPriceRequest) XXX_Size 

func (m *QueryPriceRequest) XXX_Size() int

func (*QueryPriceRequest) XXX_Unmarshal 

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

type QueryPriceResponse 

type QueryPriceResponse struct {
	Price CurrentPriceResponse `protobuf:"bytes,1,opt,name=price,proto3" json:"price"`
}

QueryPriceResponse is the response type for the Query/Prices RPC method.

func (*QueryPriceResponse) Descriptor 

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

func (*QueryPriceResponse) Equal 

func (this *QueryPriceResponse) Equal(that interface{}) bool

func (*QueryPriceResponse) Marshal 

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

func (*QueryPriceResponse) MarshalTo 

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

func (*QueryPriceResponse) MarshalToSizedBuffer 

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

func (*QueryPriceResponse) ProtoMessage 

func (*QueryPriceResponse) ProtoMessage()

func (*QueryPriceResponse) Reset 

func (m *QueryPriceResponse) Reset()

func (*QueryPriceResponse) Size 

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

func (*QueryPriceResponse) String 

func (m *QueryPriceResponse) String() string

func (*QueryPriceResponse) Unmarshal 

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

func (*QueryPriceResponse) VerboseEqual 

func (this *QueryPriceResponse) VerboseEqual(that interface{}) error

func (*QueryPriceResponse) XXX_DiscardUnknown 

func (m *QueryPriceResponse) XXX_DiscardUnknown()

func (*QueryPriceResponse) XXX_Marshal 

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

func (*QueryPriceResponse) XXX_Merge 

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

func (*QueryPriceResponse) XXX_Size 

func (m *QueryPriceResponse) XXX_Size() int

func (*QueryPriceResponse) XXX_Unmarshal 

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

type QueryPricesRequest 

type QueryPricesRequest struct {
}

QueryPricesRequest is the request type for the Query/Prices RPC method.

func (*QueryPricesRequest) Descriptor 

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

func (*QueryPricesRequest) Equal 

func (this *QueryPricesRequest) Equal(that interface{}) bool

func (*QueryPricesRequest) Marshal 

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

func (*QueryPricesRequest) MarshalTo 

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

func (*QueryPricesRequest) MarshalToSizedBuffer 

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

func (*QueryPricesRequest) ProtoMessage 

func (*QueryPricesRequest) ProtoMessage()

func (*QueryPricesRequest) Reset 

func (m *QueryPricesRequest) Reset()

func (*QueryPricesRequest) Size 

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

func (*QueryPricesRequest) String 

func (m *QueryPricesRequest) String() string

func (*QueryPricesRequest) Unmarshal 

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

func (*QueryPricesRequest) VerboseEqual 

func (this *QueryPricesRequest) VerboseEqual(that interface{}) error

func (*QueryPricesRequest) XXX_DiscardUnknown 

func (m *QueryPricesRequest) XXX_DiscardUnknown()

func (*QueryPricesRequest) XXX_Marshal 

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

func (*QueryPricesRequest) XXX_Merge 

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

func (*QueryPricesRequest) XXX_Size 

func (m *QueryPricesRequest) XXX_Size() int

func (*QueryPricesRequest) XXX_Unmarshal 

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

type QueryPricesResponse 

type QueryPricesResponse struct {
	Prices CurrentPriceResponses `protobuf:"bytes,1,rep,name=prices,proto3,castrepeated=CurrentPriceResponses" json:"prices"`
}

QueryPricesResponse is the response type for the Query/Prices RPC method.

func (*QueryPricesResponse) Descriptor 

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

func (*QueryPricesResponse) Equal 

func (this *QueryPricesResponse) Equal(that interface{}) bool

func (*QueryPricesResponse) Marshal 

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

func (*QueryPricesResponse) MarshalTo 

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

func (*QueryPricesResponse) MarshalToSizedBuffer 

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

func (*QueryPricesResponse) ProtoMessage 

func (*QueryPricesResponse) ProtoMessage()

func (*QueryPricesResponse) Reset 

func (m *QueryPricesResponse) Reset()

func (*QueryPricesResponse) Size 

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

func (*QueryPricesResponse) String 

func (m *QueryPricesResponse) String() string

func (*QueryPricesResponse) Unmarshal 

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

func (*QueryPricesResponse) VerboseEqual 

func (this *QueryPricesResponse) VerboseEqual(that interface{}) error

func (*QueryPricesResponse) XXX_DiscardUnknown 

func (m *QueryPricesResponse) XXX_DiscardUnknown()

func (*QueryPricesResponse) XXX_Marshal 

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

func (*QueryPricesResponse) XXX_Merge 

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

func (*QueryPricesResponse) XXX_Size 

func (m *QueryPricesResponse) XXX_Size() int

func (*QueryPricesResponse) XXX_Unmarshal 

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

type QueryRawPricesRequest 

type QueryRawPricesRequest struct {
	MarketId string `protobuf:"bytes,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
}

QueryRawPricesRequest is the request type for the Query/RawPrices RPC method.

func (*QueryRawPricesRequest) Descriptor 

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

func (*QueryRawPricesRequest) Equal 

func (this *QueryRawPricesRequest) Equal(that interface{}) bool

func (*QueryRawPricesRequest) Marshal 

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

func (*QueryRawPricesRequest) MarshalTo 

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

func (*QueryRawPricesRequest) MarshalToSizedBuffer 

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

func (*QueryRawPricesRequest) ProtoMessage 

func (*QueryRawPricesRequest) ProtoMessage()

func (*QueryRawPricesRequest) Reset 

func (m *QueryRawPricesRequest) Reset()

func (*QueryRawPricesRequest) Size 

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

func (*QueryRawPricesRequest) String 

func (m *QueryRawPricesRequest) String() string

func (*QueryRawPricesRequest) Unmarshal 

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

func (*QueryRawPricesRequest) VerboseEqual 

func (this *QueryRawPricesRequest) VerboseEqual(that interface{}) error

func (*QueryRawPricesRequest) XXX_DiscardUnknown 

func (m *QueryRawPricesRequest) XXX_DiscardUnknown()

func (*QueryRawPricesRequest) XXX_Marshal 

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

func (*QueryRawPricesRequest) XXX_Merge 

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

func (*QueryRawPricesRequest) XXX_Size 

func (m *QueryRawPricesRequest) XXX_Size() int

func (*QueryRawPricesRequest) XXX_Unmarshal 

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

type QueryRawPricesResponse 

type QueryRawPricesResponse struct {
	RawPrices PostedPriceResponses `protobuf:"bytes,1,rep,name=raw_prices,json=rawPrices,proto3,castrepeated=PostedPriceResponses" json:"raw_prices"`
}

QueryRawPricesResponse is the response type for the Query/RawPrices RPC method.

func (*QueryRawPricesResponse) Descriptor 

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

func (*QueryRawPricesResponse) Equal 

func (this *QueryRawPricesResponse) Equal(that interface{}) bool

func (*QueryRawPricesResponse) Marshal 

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

func (*QueryRawPricesResponse) MarshalTo 

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

func (*QueryRawPricesResponse) MarshalToSizedBuffer 

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

func (*QueryRawPricesResponse) ProtoMessage 

func (*QueryRawPricesResponse) ProtoMessage()

func (*QueryRawPricesResponse) Reset 

func (m *QueryRawPricesResponse) Reset()

func (*QueryRawPricesResponse) Size 

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

func (*QueryRawPricesResponse) String 

func (m *QueryRawPricesResponse) String() string

func (*QueryRawPricesResponse) Unmarshal 

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

func (*QueryRawPricesResponse) VerboseEqual 

func (this *QueryRawPricesResponse) VerboseEqual(that interface{}) error

func (*QueryRawPricesResponse) XXX_DiscardUnknown 

func (m *QueryRawPricesResponse) XXX_DiscardUnknown()

func (*QueryRawPricesResponse) XXX_Marshal 

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

func (*QueryRawPricesResponse) XXX_Merge 

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

func (*QueryRawPricesResponse) XXX_Size 

func (m *QueryRawPricesResponse) XXX_Size() int

func (*QueryRawPricesResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params queries all parameters of the pricefeed module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Price queries price details based on a market
	Price(context.Context, *QueryPriceRequest) (*QueryPriceResponse, error)
	// Prices queries all prices
	Prices(context.Context, *QueryPricesRequest) (*QueryPricesResponse, error)
	// RawPrices queries all raw prices based on a market
	RawPrices(context.Context, *QueryRawPricesRequest) (*QueryRawPricesResponse, error)
	// Oracles queries all oracles based on a market
	Oracles(context.Context, *QueryOraclesRequest) (*QueryOraclesResponse, error)
	// Markets queries all markets
	Markets(context.Context, *QueryMarketsRequest) (*QueryMarketsResponse, error)
}

QueryServer is the server API for Query service.

type QueryWithMarketIDParams 

type QueryWithMarketIDParams struct {
	MarketID string
}

QueryWithMarketIDParams fields for querying information from a specific market

func NewQueryWithMarketIDParams 

func NewQueryWithMarketIDParams(marketID string) QueryWithMarketIDParams

NewQueryWithMarketIDParams creates a new instance of QueryWithMarketIDParams

type SortDecs 

type SortDecs []sdk.Dec

SortDecs provides the interface needed to sort sdk.Dec slices

func (SortDecs) Len 

func (a SortDecs) Len() int

func (SortDecs) Less 

func (a SortDecs) Less(i, j int) bool

func (SortDecs) Swap 

func (a SortDecs) Swap(i, j int)

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) PostPrice 

func (*UnimplementedMsgServer) PostPrice(ctx context.Context, req *MsgPostPrice) (*MsgPostPriceResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Markets 

func (*UnimplementedQueryServer) Markets(ctx context.Context, req *QueryMarketsRequest) (*QueryMarketsResponse, error)

func (*UnimplementedQueryServer) Oracles 

func (*UnimplementedQueryServer) Oracles(ctx context.Context, req *QueryOraclesRequest) (*QueryOraclesResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) Price 

func (*UnimplementedQueryServer) Price(ctx context.Context, req *QueryPriceRequest) (*QueryPriceResponse, error)

func (*UnimplementedQueryServer) Prices 

func (*UnimplementedQueryServer) Prices(ctx context.Context, req *QueryPricesRequest) (*QueryPricesResponse, error)

func (*UnimplementedQueryServer) RawPrices 

func (*UnimplementedQueryServer) RawPrices(ctx context.Context, req *QueryRawPricesRequest) (*QueryRawPricesResponse, 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.