types

package
v0.1.1 Latest Latest
Warning

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

Go to latest
Published: May 22, 2022 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

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

	AttributeValueCategory = ModuleName
	AttributePairID        = "pair_id"
	AttributePairPrice     = "market_price"
	AttributeOracle        = "oracle"
	AttributeExpiry        = "expiry"
)

Pricefeed module event types

View Source
const (
	// ModuleName defines the module name
	ModuleName = "pricefeed"

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

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_pricefeed"
)
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 DefaultIndex uint64 = 1

DefaultIndex is the default capability global index

Variables

View Source
var (
	ErrSample = sdkerrors.Register(ModuleName, 1100, "Sample error")
	// ErrEmptyInput error for empty input
	ErrEmptyInput = sdkerrors.Register(ModuleName, 2, "Input must not be empty")
	// ErrExpired error for posted price messages with expired price
	ErrExpired = sdkerrors.Register(ModuleName, 3, "Price is expired")
	// ErrNoValidPrice error for posted price messages with expired price
	ErrNoValidPrice = sdkerrors.Register(ModuleName, 4, "All input prices are expired")
	// ErrInvalidPair error for posted price messages for invalid markets
	ErrInvalidPair = sdkerrors.Register(ModuleName, 5, "Pair does not exist")
	// ErrInvalidOracle error for posted price messages for invalid oracles
	ErrInvalidOracle = sdkerrors.Register(ModuleName, 6, "Oracle does not exist or not authorized")
	// ErrAssetNotFound error for not found asset
	ErrAssetNotFound = sdkerrors.Register(ModuleName, 7, "Asset not found")
	// ErrNoValidTWAP error for not found asset
	ErrNoValidTWAP = sdkerrors.Register(ModuleName, 8, "TWA price not found")
)

x/pricefeed module sentinel errors

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}

	// TWAPPricePrefix prefix for the current price of an asset
	TWAPPricePrefix = []byte{0x02}
)
View Source
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = 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 (
	KeyPairs     = []byte("Pairs")
	DefaultPairs = []Pair{
		{Token0: common.CollDenom, Token1: common.StableDenom, Active: true},
		{Token0: common.GovDenom, Token1: common.StableDenom, Active: true},
	}
)

Parameter keys

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 CurrentPriceKey

func CurrentPriceKey(pairID string) []byte

CurrentPriceKey returns the prefix for the current price

func CurrentTWAPPriceKey added in v0.1.0

func CurrentTWAPPriceKey(twapPairID string) []byte

CurrentTWAPPriceKey returns the prefix for the current TWAP price

func KeyPrefix

func KeyPrefix(p string) []byte

func ParamKeyTable

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable Key declaration for parameters

func RawPriceIteratorKey

func RawPriceIteratorKey(pairID string) []byte

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

func RawPriceKey

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

RawPriceKey returns the prefix for the raw price

func RegisterCodec

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgHandler added in v0.1.0

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

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

func RegisterMsgHandlerClient added in v0.1.0

func RegisterMsgHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgClient) error

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

func RegisterMsgHandlerFromEndpoint added in v0.1.0

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

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

func RegisterMsgHandlerServer added in v0.1.0

func RegisterMsgHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgServer) error

RegisterMsgHandlerServer registers the http handlers for service Msg to "mux". UnaryRPC :call MsgServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterMsgHandlerFromEndpoint instead.

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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper

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

AccountKeeper defines the expected account keeper used for simulations (noalias)

type BankKeeper

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

BankKeeper defines the expected interface needed to retrieve account balances.

type CurrentPrice

type CurrentPrice struct {
	PairID string                                 `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_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 the current price for an asset pair in the pricefeed module.

func NewCurrentPrice

func NewCurrentPrice(token0 string, token1 string, price sdk.Dec) CurrentPrice

NewCurrentPrice returns an instance of CurrentPrice

Args:

token0 (string):
token1 (string):
price (sdk.Dec): Price in units of token1 / token0

Returns:

(CurrentPrice): Price for the asset pair.

func (*CurrentPrice) Descriptor

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

func (*CurrentPrice) Equal

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

func (*CurrentPrice) GetPairID

func (m *CurrentPrice) GetPairID() 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 {
	PairID string                                 `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_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 'PairID' in the pricefeed module.

func NewCurrentPriceResponse

func NewCurrentPriceResponse(pairID 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) GetPairID

func (m *CurrentPriceResponse) GetPairID() 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 CurrentTWAP added in v0.1.0

type CurrentTWAP struct {
	PairID      string                                 `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	Numerator   github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=numerator,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"numerator"`
	Denominator github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=denominator,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"denominator"`
	Price       github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,4,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
}

CurrentTWAP states defines the numerator and denominator for the TWAP calculation

func NewCurrentTWAP added in v0.1.0

func NewCurrentTWAP(token0 string, token1 string, numerator sdk.Dec, denominator sdk.Int, price sdk.Dec) CurrentTWAP

NewCurrentTWAP returns an instance of CurrentTWAP

Args:

token0 (string):
token1 (string):
price (sdk.Dec): Price in units of token1 / token0

Returns:

(CurrentTWAP): Current TWAP price for the asset pair.

func (*CurrentTWAP) Descriptor added in v0.1.0

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

func (*CurrentTWAP) Equal added in v0.1.0

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

func (*CurrentTWAP) GetPairID added in v0.1.0

func (m *CurrentTWAP) GetPairID() string

func (*CurrentTWAP) Marshal added in v0.1.0

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

func (*CurrentTWAP) MarshalTo added in v0.1.0

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

func (*CurrentTWAP) MarshalToSizedBuffer added in v0.1.0

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

func (*CurrentTWAP) ProtoMessage added in v0.1.0

func (*CurrentTWAP) ProtoMessage()

func (*CurrentTWAP) Reset added in v0.1.0

func (m *CurrentTWAP) Reset()

func (*CurrentTWAP) Size added in v0.1.0

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

func (*CurrentTWAP) String added in v0.1.0

func (m *CurrentTWAP) String() string

func (*CurrentTWAP) Unmarshal added in v0.1.0

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

func (*CurrentTWAP) VerboseEqual added in v0.1.0

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

func (*CurrentTWAP) XXX_DiscardUnknown added in v0.1.0

func (m *CurrentTWAP) XXX_DiscardUnknown()

func (*CurrentTWAP) XXX_Marshal added in v0.1.0

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

func (*CurrentTWAP) XXX_Merge added in v0.1.0

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

func (*CurrentTWAP) XXX_Size added in v0.1.0

func (m *CurrentTWAP) XXX_Size() int

func (*CurrentTWAP) XXX_Unmarshal added in v0.1.0

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

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 DefaultGenesis

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

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) 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 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 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 {
	// From: address of oracle
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	// Token0: denominator unit of the price, a.k.a. quote asset
	Token0 string `protobuf:"bytes,2,opt,name=token0,proto3" json:"token0,omitempty"`
	// Token1: numerator unit of price, a.k.a. base asset
	Token1 string `protobuf:"bytes,3,opt,name=token1,proto3" json:"token1,omitempty"`
	// Price: Price of the trading pair in units of token1 / token0.
	Price  github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,4,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
	Expiry time.Time                              `protobuf:"bytes,5,opt,name=expiry,proto3,stdtime" json:"expiry"`
}

MsgPostPrice represents a method for creating a new post price

func NewMsgPostPrice

func NewMsgPostPrice(creator string, token0 string, token1 string, price sdk.Dec, expiry time.Time) *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

func (*MsgPostPrice) GetSigners

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

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

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

func (*MsgPostPrice) Unmarshal

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

func (*MsgPostPrice) ValidateBasic

func (msg *MsgPostPrice) ValidateBasic() error

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 Pair

type Pair struct {
	Token0  string                                          `protobuf:"bytes,1,opt,name=token0,proto3" json:"token0,omitempty"`
	Token1  string                                          `protobuf:"bytes,2,opt,name=token1,proto3" json:"token1,omitempty"`
	Oracles []github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,rep,name=oracles,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"oracles,omitempty"`
	Active  bool                                            `protobuf:"varint,4,opt,name=active,proto3" json:"active,omitempty"`
}

Pair defines an asset in the pricefeed.

func NewPair

func NewPair(
	token0 string, token1 string, oracles []sdk.AccAddress, active bool,
) Pair

NewPair returns a new Pair

func (Pair) AsString

func (pair Pair) AsString() string

func (*Pair) Descriptor

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

func (*Pair) Equal

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

func (*Pair) GetActive

func (m *Pair) GetActive() bool

func (*Pair) GetOracles

func (*Pair) GetToken0

func (m *Pair) GetToken0() string

func (*Pair) GetToken1

func (m *Pair) GetToken1() string

func (Pair) Inverse

func (pair Pair) Inverse() Pair

func (Pair) IsProperOrder

func (pair Pair) IsProperOrder() bool

func (*Pair) Marshal

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

func (*Pair) MarshalTo

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

func (*Pair) MarshalToSizedBuffer

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

func (Pair) Name

func (pair Pair) Name() string

name is the name of the pool that corresponds to the two assets on this pair.

func (Pair) PairID

func (pair Pair) PairID() string

func (*Pair) ProtoMessage

func (*Pair) ProtoMessage()

func (*Pair) Reset

func (m *Pair) Reset()

func (*Pair) Size

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

func (*Pair) String

func (m *Pair) String() string

func (Pair) ToPairResponse

func (m Pair) ToPairResponse() PairResponse

ToPairResponse returns a new PairResponse from a Pair

func (*Pair) Unmarshal

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

func (Pair) Validate

func (m Pair) Validate() error

Validate performs a basic validation of the market params

func (*Pair) VerboseEqual

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

func (*Pair) XXX_DiscardUnknown

func (m *Pair) XXX_DiscardUnknown()

func (*Pair) XXX_Marshal

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

func (*Pair) XXX_Merge

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

func (*Pair) XXX_Size

func (m *Pair) XXX_Size() int

func (*Pair) XXX_Unmarshal

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

type PairResponse

type PairResponse struct {
	PairID  string   `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	Token0  string   `protobuf:"bytes,2,opt,name=token0,proto3" json:"token0,omitempty"`
	Token1  string   `protobuf:"bytes,3,opt,name=token1,proto3" json:"token1,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"`
}

PairResponse defines an asset in the pricefeed.

func NewPairResponse

func NewPairResponse(token1 string, token0 string, oracles []sdk.AccAddress, active bool) PairResponse

NewPairResponse returns a new PairResponse

func (*PairResponse) Descriptor

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

func (*PairResponse) Equal

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

func (*PairResponse) GetActive

func (m *PairResponse) GetActive() bool

func (*PairResponse) GetOracles

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

func (*PairResponse) GetPairID

func (m *PairResponse) GetPairID() string

func (*PairResponse) GetToken0

func (m *PairResponse) GetToken0() string

func (*PairResponse) GetToken1

func (m *PairResponse) GetToken1() string

func (*PairResponse) Marshal

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

func (*PairResponse) MarshalTo

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

func (*PairResponse) MarshalToSizedBuffer

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

func (*PairResponse) ProtoMessage

func (*PairResponse) ProtoMessage()

func (*PairResponse) Reset

func (m *PairResponse) Reset()

func (*PairResponse) Size

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

func (*PairResponse) String

func (m *PairResponse) String() string

func (*PairResponse) Unmarshal

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

func (*PairResponse) VerboseEqual

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

func (*PairResponse) XXX_DiscardUnknown

func (m *PairResponse) XXX_DiscardUnknown()

func (*PairResponse) XXX_Marshal

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

func (*PairResponse) XXX_Merge

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

func (*PairResponse) XXX_Size

func (m *PairResponse) XXX_Size() int

func (*PairResponse) XXX_Unmarshal

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

type PairResponses

type PairResponses []PairResponse

PairResponses is a slice of PairResponse

type Pairs

type Pairs []Pair

Pairs is a slice of Pair

func (Pairs) Validate

func (ms Pairs) Validate() error

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

type Params

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

Params defines the parameters for the module.

func DefaultParams

func DefaultParams() Params

DefaultParams default params for pricefeed

func NewParams

func NewParams(pairs []Pair) 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) GetPairs

func (m *Params) GetPairs() Pairs

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 {
	PairID        string                                        `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_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 an asset pair posted by a specific oracle.

func NewPostedPrice

func NewPostedPrice(pairID 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) GetOracleAddress

func (*PostedPrice) GetPairID

func (m *PostedPrice) GetPairID() string

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 {
	PairID        string                                 `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_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 'PairID' posted by a specific oracle.

func NewPostedPriceResponse

func NewPostedPriceResponse(
	pairID 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) GetOracleAddress

func (m *PostedPriceResponse) GetOracleAddress() string

func (*PostedPriceResponse) GetPairID

func (m *PostedPriceResponse) GetPairID() 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 for a pair
	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 for an asset pair
	RawPrices(ctx context.Context, in *QueryRawPricesRequest, opts ...grpc.CallOption) (*QueryRawPricesResponse, error)
	// Oracles queries all oracles for an asset pair
	Oracles(ctx context.Context, in *QueryOraclesRequest, opts ...grpc.CallOption) (*QueryOraclesResponse, error)
	// Pairs queries all pairs
	Pairs(ctx context.Context, in *QueryPairsRequest, opts ...grpc.CallOption) (*QueryPairsResponse, 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 QueryOraclesRequest

type QueryOraclesRequest struct {
	PairId string `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_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 QueryPairsRequest

type QueryPairsRequest struct {
}

QueryPairsRequest is the request type for the Query/Pairs RPC method.

func (*QueryPairsRequest) Descriptor

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

func (*QueryPairsRequest) Equal

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

func (*QueryPairsRequest) Marshal

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

func (*QueryPairsRequest) MarshalTo

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

func (*QueryPairsRequest) MarshalToSizedBuffer

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

func (*QueryPairsRequest) ProtoMessage

func (*QueryPairsRequest) ProtoMessage()

func (*QueryPairsRequest) Reset

func (m *QueryPairsRequest) Reset()

func (*QueryPairsRequest) Size

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

func (*QueryPairsRequest) String

func (m *QueryPairsRequest) String() string

func (*QueryPairsRequest) Unmarshal

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

func (*QueryPairsRequest) VerboseEqual

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

func (*QueryPairsRequest) XXX_DiscardUnknown

func (m *QueryPairsRequest) XXX_DiscardUnknown()

func (*QueryPairsRequest) XXX_Marshal

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

func (*QueryPairsRequest) XXX_Merge

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

func (*QueryPairsRequest) XXX_Size

func (m *QueryPairsRequest) XXX_Size() int

func (*QueryPairsRequest) XXX_Unmarshal

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

type QueryPairsResponse

type QueryPairsResponse struct {
	// List of 'PairResponse'
	Pairs PairResponses `protobuf:"bytes,1,rep,name=pairs,proto3,castrepeated=PairResponses" json:"pairs"`
}

QueryPairsResponse is the response type for the Query/Pairs RPC method.

func (*QueryPairsResponse) Descriptor

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

func (*QueryPairsResponse) Equal

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

func (*QueryPairsResponse) Marshal

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

func (*QueryPairsResponse) MarshalTo

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

func (*QueryPairsResponse) MarshalToSizedBuffer

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

func (*QueryPairsResponse) ProtoMessage

func (*QueryPairsResponse) ProtoMessage()

func (*QueryPairsResponse) Reset

func (m *QueryPairsResponse) Reset()

func (*QueryPairsResponse) Size

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

func (*QueryPairsResponse) String

func (m *QueryPairsResponse) String() string

func (*QueryPairsResponse) Unmarshal

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

func (*QueryPairsResponse) VerboseEqual

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

func (*QueryPairsResponse) XXX_DiscardUnknown

func (m *QueryPairsResponse) XXX_DiscardUnknown()

func (*QueryPairsResponse) XXX_Marshal

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

func (*QueryPairsResponse) XXX_Merge

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

func (*QueryPairsResponse) XXX_Size

func (m *QueryPairsResponse) XXX_Size() int

func (*QueryPairsResponse) XXX_Unmarshal

func (m *QueryPairsResponse) 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 {
	PairId string `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_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 {
	PairId string `protobuf:"bytes,1,opt,name=pair_id,json=pairId,proto3" json:"pair_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 for a pair
	Price(context.Context, *QueryPriceRequest) (*QueryPriceResponse, error)
	// Prices queries all prices
	Prices(context.Context, *QueryPricesRequest) (*QueryPricesResponse, error)
	// RawPrices queries all raw prices for an asset pair
	RawPrices(context.Context, *QueryRawPricesRequest) (*QueryRawPricesResponse, error)
	// Oracles queries all oracles for an asset pair
	Oracles(context.Context, *QueryOraclesRequest) (*QueryOraclesResponse, error)
	// Pairs queries all pairs
	Pairs(context.Context, *QueryPairsRequest) (*QueryPairsResponse, error)
}

QueryServer is the server API for Query service.

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

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Oracles

func (*UnimplementedQueryServer) Pairs

func (*UnimplementedQueryServer) Params

func (*UnimplementedQueryServer) Price

func (*UnimplementedQueryServer) Prices

func (*UnimplementedQueryServer) RawPrices

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL