v1

package
v0.2.0-b13 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2026 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Overview

Package v1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName is the module name constant used in many places
	ModuleName = "oracle"

	// StoreKey is the store key string for deployment
	StoreKey = ModuleName

	// RouterKey is the message route for deployment
	RouterKey = ModuleName
)

Variables

View Source 
var (
	// ErrPriceEntryExists is the error when price entry already exists
	ErrPriceEntryExists = cerrors.Register(ModuleName, errPriceEntryExists, "price entry exist")
	// ErrInvalidTimestamp is the error indicating invalid timestamp
	ErrInvalidTimestamp = cerrors.Register(ModuleName, errInvalidTimestamp, "invalid timestamp")
	// ErrUnauthorizedWriterAddress is the error indicating signer is not allowed to add price records
	ErrUnauthorizedWriterAddress = cerrors.Register(ModuleName, errUnauthorizedWriterAddress, "unauthorized writer address")
	// ErrPriceStalled is the error when price data is stale
	ErrPriceStalled = cerrors.Register(ModuleName, errPriceStalled, "price stalled")
	// ErrInvalidFeedContractParams is the error when feed contract params are invalid
	ErrInvalidFeedContractParams = cerrors.Register(ModuleName, errInvalidFeedContractParams, "invalid feed contract params")
	// ErrInvalidFeedContractConfig is the error when feed contract config is invalid
	ErrInvalidFeedContractConfig = cerrors.Register(ModuleName, errInvalidFeedContractConfig, "invalid feed contract config")
	ErrTWAPZeroWeight            = cerrors.Register(ModuleName, errTWAPZeroWeight, "invalid TWAP calculation: zero weight")
)
View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthMsgs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsgs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsgs = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthPrices        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPrices          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPrices = 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 (
	// ModuleCdc references the global x/oracle module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/oracle and
	// defined at the application level.
	//
	// Deprecated: ModuleCdc use is deprecated
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var Msg_serviceDesc = _Msg_serviceDesc
View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions

func DefaultFeedContractsParams 

func DefaultFeedContractsParams() []sdk.Msg

DefaultFeedContractsParams returns default feed contract params using Pyth

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable for oracle module Deprecated: now params can be accessed on key `0x01` on the oracle store.

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces registers the x/oracle interfaces types with the interface registry

func RegisterLegacyAminoCodec deprecated 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec register concrete types on codec

Deprecated: RegisterLegacyAminoCodec is deprecated

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 AggregatedPrice 

type AggregatedPrice struct {
	// denom is the asset denomination
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom" yaml:"denom"`
	// twap is the time-weighted average price over the configured window
	TWAP cosmossdk_io_math.LegacyDec `protobuf:"bytes,2,opt,name=twap,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"twap" yaml:"twap"`
	// median_price is the median of all source prices
	MedianPrice cosmossdk_io_math.LegacyDec `` /* 143-byte string literal not displayed */
	// min_price is the minimum price from all sources
	MinPrice cosmossdk_io_math.LegacyDec `` /* 131-byte string literal not displayed */
	// max_price is the maximum price from all sources
	MaxPrice cosmossdk_io_math.LegacyDec `` /* 131-byte string literal not displayed */
	// timestamp is when the aggregated price was computed
	Timestamp time.Time `protobuf:"bytes,6,opt,name=timestamp,proto3,stdtime" json:"timestamp" yaml:"timestamp"`
	// num_sources is the number of price sources contributing to this aggregation
	NumSources uint32 `protobuf:"varint,7,opt,name=num_sources,json=numSources,proto3" json:"num_sources" yaml:"num_sources"`
	// deviation_bps is the price deviation in basis points between min and max prices
	DeviationBps uint64 `protobuf:"varint,8,opt,name=deviation_bps,json=deviationBps,proto3" json:"deviation_bps" yaml:"deviation_bps"`
}

AggregatedPrice represents the final aggregated price from all sources

func (*AggregatedPrice) Descriptor 

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

func (*AggregatedPrice) GetDenom 

func (m *AggregatedPrice) GetDenom() string

func (*AggregatedPrice) GetDeviationBps 

func (m *AggregatedPrice) GetDeviationBps() uint64

func (*AggregatedPrice) GetNumSources 

func (m *AggregatedPrice) GetNumSources() uint32

func (*AggregatedPrice) GetTimestamp 

func (m *AggregatedPrice) GetTimestamp() time.Time

func (*AggregatedPrice) Marshal 

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

func (*AggregatedPrice) MarshalTo 

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

func (*AggregatedPrice) MarshalToSizedBuffer 

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

func (*AggregatedPrice) ProtoMessage 

func (*AggregatedPrice) ProtoMessage()

func (*AggregatedPrice) Reset 

func (m *AggregatedPrice) Reset()

func (*AggregatedPrice) Size 

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

func (*AggregatedPrice) String 

func (m *AggregatedPrice) String() string

func (*AggregatedPrice) Unmarshal 

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

func (*AggregatedPrice) XXX_DiscardUnknown 

func (m *AggregatedPrice) XXX_DiscardUnknown()

func (*AggregatedPrice) XXX_Marshal 

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

func (*AggregatedPrice) XXX_Merge 

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

func (*AggregatedPrice) XXX_Size 

func (m *AggregatedPrice) XXX_Size() int

func (*AggregatedPrice) XXX_Unmarshal 

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

type DataID 

type DataID struct {
	// denom is the asset denomination (e.g., "uakt")
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom" yaml:"denom"`
	// base_denom is the base denomination for the price pair (e.g., "usd")
	BaseDenom string `protobuf:"bytes,2,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom" yaml:"base_denom"`
}

DataID uniquely identifies a price pair by asset and base denomination

func (*DataID) Descriptor 

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

func (*DataID) GetBaseDenom 

func (m *DataID) GetBaseDenom() string

func (*DataID) GetDenom 

func (m *DataID) GetDenom() string

func (*DataID) Marshal 

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

func (*DataID) MarshalTo 

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

func (*DataID) MarshalToSizedBuffer 

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

func (*DataID) ProtoMessage 

func (*DataID) ProtoMessage()

func (*DataID) Reset 

func (m *DataID) Reset()

func (*DataID) Size 

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

func (*DataID) String 

func (m *DataID) String() string

func (*DataID) Unmarshal 

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

func (*DataID) XXX_DiscardUnknown 

func (m *DataID) XXX_DiscardUnknown()

func (*DataID) XXX_Marshal 

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

func (*DataID) XXX_Merge 

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

func (*DataID) XXX_Size 

func (m *DataID) XXX_Size() int

func (*DataID) XXX_Unmarshal 

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

type EventPriceData 

type EventPriceData struct {
	// source is the address of the price source (oracle provider)
	Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source" yaml:"source"`
	// id identifies the price pair (denom and base_denom)
	Id DataID `protobuf:"bytes,2,opt,name=id,proto3" json:"id" yaml:"id"`
	// data contains the price value and timestamp
	Data PriceDataState `protobuf:"bytes,3,opt,name=data,proto3" json:"data" yaml:"data"`
}

EventPriceData is emitted when new price data is added to the oracle

func (*EventPriceData) Descriptor 

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

func (*EventPriceData) GetData 

func (m *EventPriceData) GetData() PriceDataState

func (*EventPriceData) GetId 

func (m *EventPriceData) GetId() DataID

func (*EventPriceData) GetSource 

func (m *EventPriceData) GetSource() string

func (*EventPriceData) Marshal 

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

func (*EventPriceData) MarshalTo 

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

func (*EventPriceData) MarshalToSizedBuffer 

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

func (*EventPriceData) ProtoMessage 

func (*EventPriceData) ProtoMessage()

func (*EventPriceData) Reset 

func (m *EventPriceData) Reset()

func (*EventPriceData) Size 

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

func (*EventPriceData) String 

func (m *EventPriceData) String() string

func (*EventPriceData) Unmarshal 

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

func (*EventPriceData) XXX_DiscardUnknown 

func (m *EventPriceData) XXX_DiscardUnknown()

func (*EventPriceData) XXX_Marshal 

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

func (*EventPriceData) XXX_Merge 

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

func (*EventPriceData) XXX_Size 

func (m *EventPriceData) XXX_Size() int

func (*EventPriceData) XXX_Unmarshal 

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

type EventPriceRecovered 

type EventPriceRecovered struct {
	// source is the address of the price source
	Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source" yaml:"source"`
	// id identifies the price pair
	Id DataID `protobuf:"bytes,2,opt,name=id,proto3" json:"id" yaml:"id"`
	// height is the block height when the price recovery was detected
	Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height" yaml:"height"`
}

EventPriceRecovered is emitted when a stale price has started receiving updates again

func (*EventPriceRecovered) Descriptor 

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

func (*EventPriceRecovered) GetHeight 

func (m *EventPriceRecovered) GetHeight() int64

func (*EventPriceRecovered) GetId 

func (m *EventPriceRecovered) GetId() DataID

func (*EventPriceRecovered) GetSource 

func (m *EventPriceRecovered) GetSource() string

func (*EventPriceRecovered) Marshal 

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

func (*EventPriceRecovered) MarshalTo 

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

func (*EventPriceRecovered) MarshalToSizedBuffer 

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

func (*EventPriceRecovered) ProtoMessage 

func (*EventPriceRecovered) ProtoMessage()

func (*EventPriceRecovered) Reset 

func (m *EventPriceRecovered) Reset()

func (*EventPriceRecovered) Size 

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

func (*EventPriceRecovered) String 

func (m *EventPriceRecovered) String() string

func (*EventPriceRecovered) Unmarshal 

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

func (*EventPriceRecovered) XXX_DiscardUnknown 

func (m *EventPriceRecovered) XXX_DiscardUnknown()

func (*EventPriceRecovered) XXX_Marshal 

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

func (*EventPriceRecovered) XXX_Merge 

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

func (*EventPriceRecovered) XXX_Size 

func (m *EventPriceRecovered) XXX_Size() int

func (*EventPriceRecovered) XXX_Unmarshal 

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

type EventPriceStaleWarning 

type EventPriceStaleWarning struct {
	// source is the address of the price source
	Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source" yaml:"source"`
	// id identifies the price pair
	Id DataID `protobuf:"bytes,2,opt,name=id,proto3" json:"id" yaml:"id"`
	// last_height is the block height when the price was last updated
	LastHeight int64 `protobuf:"varint,3,opt,name=last_height,json=lastHeight,proto3" json:"last_height" yaml:"last_height"`
	// blocks_to_stall is the number of blocks until the price becomes stale
	BlocksToStall int64 `protobuf:"varint,4,opt,name=blocks_to_stall,json=blocksToStall,proto3" json:"blocks_to_stall" yaml:"blocks_to_stall"`
}

EventPriceStaleWarning is emitted when price has not been updated and is about to become stale

func (*EventPriceStaleWarning) Descriptor 

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

func (*EventPriceStaleWarning) GetBlocksToStall 

func (m *EventPriceStaleWarning) GetBlocksToStall() int64

func (*EventPriceStaleWarning) GetId 

func (m *EventPriceStaleWarning) GetId() DataID

func (*EventPriceStaleWarning) GetLastHeight 

func (m *EventPriceStaleWarning) GetLastHeight() int64

func (*EventPriceStaleWarning) GetSource 

func (m *EventPriceStaleWarning) GetSource() string

func (*EventPriceStaleWarning) Marshal 

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

func (*EventPriceStaleWarning) MarshalTo 

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

func (*EventPriceStaleWarning) MarshalToSizedBuffer 

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

func (*EventPriceStaleWarning) ProtoMessage 

func (*EventPriceStaleWarning) ProtoMessage()

func (*EventPriceStaleWarning) Reset 

func (m *EventPriceStaleWarning) Reset()

func (*EventPriceStaleWarning) Size 

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

func (*EventPriceStaleWarning) String 

func (m *EventPriceStaleWarning) String() string

func (*EventPriceStaleWarning) Unmarshal 

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

func (*EventPriceStaleWarning) XXX_DiscardUnknown 

func (m *EventPriceStaleWarning) XXX_DiscardUnknown()

func (*EventPriceStaleWarning) XXX_Marshal 

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

func (*EventPriceStaleWarning) XXX_Merge 

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

func (*EventPriceStaleWarning) XXX_Size 

func (m *EventPriceStaleWarning) XXX_Size() int

func (*EventPriceStaleWarning) XXX_Unmarshal 

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

type EventPriceStaled 

type EventPriceStaled struct {
	// source is the address of the price source
	Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source" yaml:"source"`
	// id identifies the price pair
	Id DataID `protobuf:"bytes,2,opt,name=id,proto3" json:"id" yaml:"id"`
	// last_height is the block height when the price was last updated before becoming stale
	LastHeight int64 `protobuf:"varint,3,opt,name=last_height,json=lastHeight,proto3" json:"last_height" yaml:"last_height"`
}

EventPriceStaled is emitted when a price has become stale

func (*EventPriceStaled) Descriptor 

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

func (*EventPriceStaled) GetId 

func (m *EventPriceStaled) GetId() DataID

func (*EventPriceStaled) GetLastHeight 

func (m *EventPriceStaled) GetLastHeight() int64

func (*EventPriceStaled) GetSource 

func (m *EventPriceStaled) GetSource() string

func (*EventPriceStaled) Marshal 

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

func (*EventPriceStaled) MarshalTo 

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

func (*EventPriceStaled) MarshalToSizedBuffer 

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

func (*EventPriceStaled) ProtoMessage 

func (*EventPriceStaled) ProtoMessage()

func (*EventPriceStaled) Reset 

func (m *EventPriceStaled) Reset()

func (*EventPriceStaled) Size 

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

func (*EventPriceStaled) String 

func (m *EventPriceStaled) String() string

func (*EventPriceStaled) Unmarshal 

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

func (*EventPriceStaled) XXX_DiscardUnknown 

func (m *EventPriceStaled) XXX_DiscardUnknown()

func (*EventPriceStaled) XXX_Marshal 

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

func (*EventPriceStaled) XXX_Merge 

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

func (*EventPriceStaled) XXX_Size 

func (m *EventPriceStaled) XXX_Size() int

func (*EventPriceStaled) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// params holds the oracle module parameters
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params" yaml:"params"`
	// prices is the list of all historical price data entries
	Prices []PriceData `protobuf:"bytes,2,rep,name=prices,proto3" json:"prices" yaml:"prices"`
	// latest_height tracks the most recent block height for each price feed source
	LatestHeight []PriceDataID `protobuf:"bytes,3,rep,name=latest_height,json=latestHeight,proto3" json:"latest_height" yaml:"latest_height"`
}

GenesisState defines the oracle module's genesis state

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState returns the default genesis state.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetLatestHeight 

func (m *GenesisState) GetLatestHeight() []PriceDataID

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPrices 

func (m *GenesisState) GetPrices() []PriceData

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 validates the genesis state.

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 MsgAddPriceEntry 

type MsgAddPriceEntry struct {
	// Signer is the bech32 address of the account of the provider.
	// It is a string representing a valid account address.
	//
	// Example:
	//   "akash1..."
	Signer string `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer" yaml:"signer"`
	// id uniquely identifies the price data by denomination and base denomination
	ID DataID `protobuf:"bytes,2,opt,name=id,proto3" json:"id" yaml:"id"`
	// price contains the price value and timestamp for this entry
	Price PriceDataState `protobuf:"bytes,3,opt,name=price,proto3" json:"price" yaml:"price"`
}

MsgAddPriceEntry defines an SDK message to add oracle price entry.

func (*MsgAddPriceEntry) Descriptor 

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

func (*MsgAddPriceEntry) GetID 

func (m *MsgAddPriceEntry) GetID() DataID

func (*MsgAddPriceEntry) GetPrice 

func (m *MsgAddPriceEntry) GetPrice() PriceDataState

func (*MsgAddPriceEntry) GetSignBytes deprecated 

func (m *MsgAddPriceEntry) GetSignBytes() []byte

GetSignBytes encodes the message for signing

Deprecated: GetSignBytes is deprecated

func (*MsgAddPriceEntry) GetSigner 

func (m *MsgAddPriceEntry) GetSigner() string

func (*MsgAddPriceEntry) GetSigners 

func (m *MsgAddPriceEntry) GetSigners() []sdk.AccAddress

GetSigners returns the expected signers for a MsgAddPriceEntry message.

func (*MsgAddPriceEntry) Marshal 

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

func (*MsgAddPriceEntry) MarshalTo 

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

func (*MsgAddPriceEntry) MarshalToSizedBuffer 

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

func (*MsgAddPriceEntry) ProtoMessage 

func (*MsgAddPriceEntry) ProtoMessage()

func (*MsgAddPriceEntry) Reset 

func (m *MsgAddPriceEntry) Reset()

func (*MsgAddPriceEntry) Route deprecated 

func (m *MsgAddPriceEntry) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgAddPriceEntry) Size 

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

func (*MsgAddPriceEntry) String 

func (m *MsgAddPriceEntry) String() string

func (*MsgAddPriceEntry) Type 

func (m *MsgAddPriceEntry) Type() string

Type implements the sdk.Msg interface

func (*MsgAddPriceEntry) Unmarshal 

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

func (*MsgAddPriceEntry) ValidateBasic 

func (m *MsgAddPriceEntry) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgAddPriceEntry) XXX_DiscardUnknown 

func (m *MsgAddPriceEntry) XXX_DiscardUnknown()

func (*MsgAddPriceEntry) XXX_Marshal 

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

func (*MsgAddPriceEntry) XXX_Merge 

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

func (*MsgAddPriceEntry) XXX_Size 

func (m *MsgAddPriceEntry) XXX_Size() int

func (*MsgAddPriceEntry) XXX_Unmarshal 

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

type MsgAddPriceEntryResponse 

type MsgAddPriceEntryResponse struct {
}

MsgAddPriceEntryResponse defines the Msg/MsgAddDPriceEntry response type.

func (*MsgAddPriceEntryResponse) Descriptor 

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

func (*MsgAddPriceEntryResponse) Marshal 

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

func (*MsgAddPriceEntryResponse) MarshalTo 

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

func (*MsgAddPriceEntryResponse) MarshalToSizedBuffer 

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

func (*MsgAddPriceEntryResponse) ProtoMessage 

func (*MsgAddPriceEntryResponse) ProtoMessage()

func (*MsgAddPriceEntryResponse) Reset 

func (m *MsgAddPriceEntryResponse) Reset()

func (*MsgAddPriceEntryResponse) Size 

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

func (*MsgAddPriceEntryResponse) String 

func (m *MsgAddPriceEntryResponse) String() string

func (*MsgAddPriceEntryResponse) Unmarshal 

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

func (*MsgAddPriceEntryResponse) XXX_DiscardUnknown 

func (m *MsgAddPriceEntryResponse) XXX_DiscardUnknown()

func (*MsgAddPriceEntryResponse) XXX_Marshal 

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

func (*MsgAddPriceEntryResponse) XXX_Merge 

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

func (*MsgAddPriceEntryResponse) XXX_Size 

func (m *MsgAddPriceEntryResponse) XXX_Size() int

func (*MsgAddPriceEntryResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// AddPriceEntry adds a new price entry for a denomination from an authorized source
	AddPriceEntry(ctx context.Context, in *MsgAddPriceEntry, opts ...grpc.CallOption) (*MsgAddPriceEntryResponse, error)
	// UpdateParams defines a governance operation for updating the x/wasm module
	// parameters. The authority is hard-coded to the x/gov module account.
	//
	// Since: akash v2.0.0
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgServer 

type MsgServer interface {
	// AddPriceEntry adds a new price entry for a denomination from an authorized source
	AddPriceEntry(context.Context, *MsgAddPriceEntry) (*MsgAddPriceEntryResponse, error)
	// UpdateParams defines a governance operation for updating the x/wasm module
	// parameters. The authority is hard-coded to the x/gov module account.
	//
	// Since: akash v2.0.0
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/oracle parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the Msg/UpdateParams request type.

Since: akash v2.0.0

func (*MsgUpdateParams) Descriptor 

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

func (*MsgUpdateParams) GetAuthority 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) GetSignBytes deprecated 

func (m *MsgUpdateParams) GetSignBytes() []byte

GetSignBytes encodes the message for signing

Deprecated: GetSignBytes is deprecated

func (*MsgUpdateParams) GetSigners 

func (m *MsgUpdateParams) GetSigners() []sdk.AccAddress

GetSigners returns the expected signers for a MsgUpdateParams message.

func (*MsgUpdateParams) Marshal 

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

func (*MsgUpdateParams) MarshalTo 

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

func (*MsgUpdateParams) MarshalToSizedBuffer 

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

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Route deprecated 

func (m *MsgUpdateParams) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Type 

func (m *MsgUpdateParams) Type() string

Type implements the sdk.Msg interface

func (*MsgUpdateParams) Unmarshal 

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

func (MsgUpdateParams) UnpackInterfaces 

func (p MsgUpdateParams) UnpackInterfaces(unpacker cdctypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage

func (*MsgUpdateParams) ValidateBasic 

func (m *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal 

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

func (*MsgUpdateParams) XXX_Merge 

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

func (*MsgUpdateParams) XXX_Size 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal 

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

type MsgUpdateParamsResponse 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

Since: akash v2.0.0

func (*MsgUpdateParamsResponse) Descriptor 

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

func (*MsgUpdateParamsResponse) Marshal 

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

func (*MsgUpdateParamsResponse) MarshalTo 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size 

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

func (*MsgUpdateParamsResponse) String 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal 

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

func (*MsgUpdateParamsResponse) XXX_Merge 

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

func (*MsgUpdateParamsResponse) XXX_Size 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// sources addresses allowed to write prices into oracle module
	// those are to be smartcontract addresses
	Sources []string `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources" yaml:"sources"`
	// Minimum number of price sources required (default: 2)
	MinPriceSources uint32 `protobuf:"varint,2,opt,name=min_price_sources,json=minPriceSources,proto3" json:"min_price_sources,omitempty"`
	// Maximum price staleness in blocks (default: 50 = ~ 5 minutes)
	MaxPriceStalenessBlocks int64 `` /* 135-byte string literal not displayed */
	// TWAP window in blocks (default: 50 = ~ 5 minutes)
	TwapWindow int64 `protobuf:"varint,4,opt,name=twap_window,json=twapWindow,proto3" json:"twap_window,omitempty"`
	// Maximum price deviation in basis points (default: 150 = 1.5%)
	MaxPriceDeviationBps uint64 `` /* 126-byte string literal not displayed */
	// feed_contracts_params contains the configuration for the price feed contracts
	FeedContractsParams []*any.Any `protobuf:"bytes,6,rep,name=feed_contracts_params,json=feedContractsParams,proto3" json:"feed_contracts_params,omitempty"`
}

Params defines the parameters for the oracle module

func DefaultParams 

func DefaultParams() Params

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) GetFeedContractsParams 

func (m *Params) GetFeedContractsParams() []*any.Any

func (*Params) GetMaxPriceDeviationBps 

func (m *Params) GetMaxPriceDeviationBps() uint64

func (*Params) GetMaxPriceStalenessBlocks 

func (m *Params) GetMaxPriceStalenessBlocks() int64

func (*Params) GetMinPriceSources 

func (m *Params) GetMinPriceSources() uint32

func (*Params) GetSources 

func (m *Params) GetSources() []string

func (*Params) GetTwapWindow 

func (m *Params) GetTwapWindow() int64

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

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

func (p Params) UnpackInterfaces(unpacker cdctypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage

func (*Params) ValidateBasic 

func (p *Params) ValidateBasic() 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 PriceData 

type PriceData struct {
	// id uniquely identifies this price record
	ID PriceDataRecordID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	// state contains the price value and timestamp
	State PriceDataState `protobuf:"bytes,2,opt,name=state,proto3" json:"state" yaml:"state"`
}

PriceData combines a price record identifier with its state

func (*PriceData) Descriptor 

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

func (*PriceData) GetID 

func (m *PriceData) GetID() PriceDataRecordID

func (*PriceData) GetState 

func (m *PriceData) GetState() PriceDataState

func (*PriceData) Marshal 

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

func (*PriceData) MarshalTo 

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

func (*PriceData) MarshalToSizedBuffer 

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

func (*PriceData) ProtoMessage 

func (*PriceData) ProtoMessage()

func (*PriceData) Reset 

func (m *PriceData) Reset()

func (*PriceData) Size 

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

func (*PriceData) String 

func (m *PriceData) String() string

func (*PriceData) Unmarshal 

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

func (*PriceData) XXX_DiscardUnknown 

func (m *PriceData) XXX_DiscardUnknown()

func (*PriceData) XXX_Marshal 

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

func (*PriceData) XXX_Merge 

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

func (*PriceData) XXX_Size 

func (m *PriceData) XXX_Size() int

func (*PriceData) XXX_Unmarshal 

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

type PriceDataID 

type PriceDataID struct {
	// source is the index of the price source (oracle provider)
	Source uint32 `protobuf:"varint,1,opt,name=source,proto3" json:"source" yaml:"source"`
	// denom is the asset denomination
	Denom string `protobuf:"bytes,2,opt,name=denom,proto3" json:"denom" yaml:"denom"`
	// base_denom is the base denomination for the price pair
	BaseDenom string `protobuf:"bytes,3,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom" yaml:"base_denom"`
}

PriceDataID identifies price data from a specific source for a specific pair

func (*PriceDataID) Descriptor 

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

func (*PriceDataID) GetBaseDenom 

func (m *PriceDataID) GetBaseDenom() string

func (*PriceDataID) GetDenom 

func (m *PriceDataID) GetDenom() string

func (*PriceDataID) GetSource 

func (m *PriceDataID) GetSource() uint32

func (*PriceDataID) Marshal 

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

func (*PriceDataID) MarshalTo 

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

func (*PriceDataID) MarshalToSizedBuffer 

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

func (*PriceDataID) ProtoMessage 

func (*PriceDataID) ProtoMessage()

func (*PriceDataID) Reset 

func (m *PriceDataID) Reset()

func (*PriceDataID) Size 

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

func (*PriceDataID) String 

func (m *PriceDataID) String() string

func (*PriceDataID) Unmarshal 

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

func (*PriceDataID) XXX_DiscardUnknown 

func (m *PriceDataID) XXX_DiscardUnknown()

func (*PriceDataID) XXX_Marshal 

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

func (*PriceDataID) XXX_Merge 

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

func (*PriceDataID) XXX_Size 

func (m *PriceDataID) XXX_Size() int

func (*PriceDataID) XXX_Unmarshal 

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

type PriceDataRecordID 

type PriceDataRecordID struct {
	// source is the index of the price source (oracle provider)
	Source uint32 `protobuf:"varint,1,opt,name=source,proto3" json:"source" yaml:"source"`
	// denom is the asset denomination
	Denom string `protobuf:"bytes,2,opt,name=denom,proto3" json:"denom" yaml:"denom"`
	// base_denom is the base denomination for the price pair
	BaseDenom string `protobuf:"bytes,3,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom" yaml:"base_denom"`
	// height is the block height when this price was recorded
	Height int64 `protobuf:"varint,4,opt,name=height,proto3" json:"height" yaml:"height"`
}

PriceDataRecordID represents a price from a specific source at a specific time. It also represents a single data point in TWAP history

func (*PriceDataRecordID) Descriptor 

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

func (*PriceDataRecordID) GetBaseDenom 

func (m *PriceDataRecordID) GetBaseDenom() string

func (*PriceDataRecordID) GetDenom 

func (m *PriceDataRecordID) GetDenom() string

func (*PriceDataRecordID) GetHeight 

func (m *PriceDataRecordID) GetHeight() int64

func (*PriceDataRecordID) GetSource 

func (m *PriceDataRecordID) GetSource() uint32

func (*PriceDataRecordID) Marshal 

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

func (*PriceDataRecordID) MarshalTo 

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

func (*PriceDataRecordID) MarshalToSizedBuffer 

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

func (*PriceDataRecordID) ProtoMessage 

func (*PriceDataRecordID) ProtoMessage()

func (*PriceDataRecordID) Reset 

func (m *PriceDataRecordID) Reset()

func (*PriceDataRecordID) Size 

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

func (*PriceDataRecordID) String 

func (m *PriceDataRecordID) String() string

func (*PriceDataRecordID) Unmarshal 

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

func (*PriceDataRecordID) XXX_DiscardUnknown 

func (m *PriceDataRecordID) XXX_DiscardUnknown()

func (*PriceDataRecordID) XXX_Marshal 

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

func (*PriceDataRecordID) XXX_Merge 

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

func (*PriceDataRecordID) XXX_Size 

func (m *PriceDataRecordID) XXX_Size() int

func (*PriceDataRecordID) XXX_Unmarshal 

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

type PriceDataState 

type PriceDataState struct {
	// price is the decimal price value
	Price cosmossdk_io_math.LegacyDec `protobuf:"bytes,1,opt,name=price,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"price" yaml:"price"`
	// timestamp is when the price was recorded
	Timestamp time.Time `protobuf:"bytes,2,opt,name=timestamp,proto3,stdtime" json:"timestamp" yaml:"timestamp"`
}

PriceDataState represents the price value and timestamp for a price entry

func (*PriceDataState) Descriptor 

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

func (*PriceDataState) GetTimestamp 

func (m *PriceDataState) GetTimestamp() time.Time

func (*PriceDataState) Marshal 

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

func (*PriceDataState) MarshalTo 

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

func (*PriceDataState) MarshalToSizedBuffer 

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

func (*PriceDataState) ProtoMessage 

func (*PriceDataState) ProtoMessage()

func (*PriceDataState) Reset 

func (m *PriceDataState) Reset()

func (*PriceDataState) Size 

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

func (*PriceDataState) String 

func (m *PriceDataState) String() string

func (*PriceDataState) Unmarshal 

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

func (*PriceDataState) XXX_DiscardUnknown 

func (m *PriceDataState) XXX_DiscardUnknown()

func (*PriceDataState) XXX_Marshal 

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

func (*PriceDataState) XXX_Merge 

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

func (*PriceDataState) XXX_Size 

func (m *PriceDataState) XXX_Size() int

func (*PriceDataState) XXX_Unmarshal 

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

type PriceHealth 

type PriceHealth struct {
	// denom is the asset denomination
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom" yaml:"denom"`
	// is_healthy indicates if the price feed meets all health requirements
	IsHealthy bool `protobuf:"varint,3,opt,name=is_healthy,json=isHealthy,proto3" json:"is_healthy,omitempty"`
	// has_min_sources indicates if minimum number of sources are reporting
	HasMinSources bool `protobuf:"varint,4,opt,name=has_min_sources,json=hasMinSources,proto3" json:"has_min_sources,omitempty"`
	// deviation_ok indicates if price deviation is within acceptable limits
	DeviationOk bool `protobuf:"varint,5,opt,name=deviation_ok,json=deviationOk,proto3" json:"deviation_ok,omitempty"`
	// total_sources indicates total amount of sources registered for price calculations
	TotalSources uint32 `protobuf:"varint,6,opt,name=total_sources,json=totalSources,proto3" json:"total_sources,omitempty"`
	// total_healthy_sources indicates total usable sources for price calculations
	TotalHealthySources uint32 `protobuf:"varint,7,opt,name=total_healthy_sources,json=totalHealthySources,proto3" json:"total_healthy_sources,omitempty"`
	// failure_reason lists reasons for unhealthy status, if any
	FailureReason []string `protobuf:"bytes,8,rep,name=failure_reason,json=failureReason,proto3" json:"failure_reason,omitempty"`
}

PriceHealth represents the health status of a price feed

func (*PriceHealth) Descriptor 

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

func (*PriceHealth) GetDenom 

func (m *PriceHealth) GetDenom() string

func (*PriceHealth) GetDeviationOk 

func (m *PriceHealth) GetDeviationOk() bool

func (*PriceHealth) GetFailureReason 

func (m *PriceHealth) GetFailureReason() []string

func (*PriceHealth) GetHasMinSources 

func (m *PriceHealth) GetHasMinSources() bool

func (*PriceHealth) GetIsHealthy 

func (m *PriceHealth) GetIsHealthy() bool

func (*PriceHealth) GetTotalHealthySources 

func (m *PriceHealth) GetTotalHealthySources() uint32

func (*PriceHealth) GetTotalSources 

func (m *PriceHealth) GetTotalSources() uint32

func (*PriceHealth) Marshal 

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

func (*PriceHealth) MarshalTo 

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

func (*PriceHealth) MarshalToSizedBuffer 

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

func (*PriceHealth) ProtoMessage 

func (*PriceHealth) ProtoMessage()

func (*PriceHealth) Reset 

func (m *PriceHealth) Reset()

func (*PriceHealth) Size 

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

func (*PriceHealth) String 

func (m *PriceHealth) String() string

func (*PriceHealth) Unmarshal 

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

func (*PriceHealth) XXX_DiscardUnknown 

func (m *PriceHealth) XXX_DiscardUnknown()

func (*PriceHealth) XXX_Marshal 

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

func (*PriceHealth) XXX_Merge 

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

func (*PriceHealth) XXX_Size 

func (m *PriceHealth) XXX_Size() int

func (*PriceHealth) XXX_Unmarshal 

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

type PricesFilter 

type PricesFilter struct {
	// asset_denom is the asset denomination to filter by
	AssetDenom string `protobuf:"bytes,1,opt,name=asset_denom,json=assetDenom,proto3" json:"asset_denom" yaml:"asset_denom"`
	// base_denom is the base denomination to filter by
	BaseDenom string `protobuf:"bytes,2,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom" yaml:"base_denom"`
	// height is the block height to filter by
	Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height" yaml:"height"`
}

PricesFilter defines filters used to query price data

func (*PricesFilter) Descriptor 

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

func (*PricesFilter) GetAssetDenom 

func (m *PricesFilter) GetAssetDenom() string

func (*PricesFilter) GetBaseDenom 

func (m *PricesFilter) GetBaseDenom() string

func (*PricesFilter) GetHeight 

func (m *PricesFilter) GetHeight() int64

func (*PricesFilter) Marshal 

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

func (*PricesFilter) MarshalTo 

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

func (*PricesFilter) MarshalToSizedBuffer 

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

func (*PricesFilter) ProtoMessage 

func (*PricesFilter) ProtoMessage()

func (*PricesFilter) Reset 

func (m *PricesFilter) Reset()

func (*PricesFilter) Size 

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

func (*PricesFilter) String 

func (m *PricesFilter) String() string

func (*PricesFilter) Unmarshal 

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

func (*PricesFilter) XXX_DiscardUnknown 

func (m *PricesFilter) XXX_DiscardUnknown()

func (*PricesFilter) XXX_Marshal 

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

func (*PricesFilter) XXX_Merge 

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

func (*PricesFilter) XXX_Size 

func (m *PricesFilter) XXX_Size() int

func (*PricesFilter) XXX_Unmarshal 

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

type PythContractParams 

type PythContractParams struct {
	// akt_price_feed_id is the Pyth price feed identifier for AKT/USD
	AktPriceFeedId string `protobuf:"bytes,1,opt,name=akt_price_feed_id,json=aktPriceFeedId,proto3" json:"akt_price_feed_id,omitempty"`
}

PythContractParams contains configuration for Pyth price feeds

func DefaultPythContractParams 

func DefaultPythContractParams() *PythContractParams

DefaultPythContractParams returns default Pyth contract params

func (*PythContractParams) Descriptor 

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

func (*PythContractParams) Equal 

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

func (*PythContractParams) GetAktPriceFeedId 

func (m *PythContractParams) GetAktPriceFeedId() string

func (*PythContractParams) Marshal 

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

func (*PythContractParams) MarshalTo 

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

func (*PythContractParams) MarshalToSizedBuffer 

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

func (*PythContractParams) ProtoMessage 

func (*PythContractParams) ProtoMessage()

func (*PythContractParams) Reset 

func (m *PythContractParams) Reset()

func (*PythContractParams) Size 

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

func (*PythContractParams) String 

func (m *PythContractParams) String() string

func (*PythContractParams) Unmarshal 

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

func (*PythContractParams) ValidateBasic 

func (p *PythContractParams) ValidateBasic() error

ValidateBasic validates PythContractParams

func (*PythContractParams) XXX_DiscardUnknown 

func (m *PythContractParams) XXX_DiscardUnknown()

func (*PythContractParams) XXX_Marshal 

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

func (*PythContractParams) XXX_Merge 

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

func (*PythContractParams) XXX_Size 

func (m *PythContractParams) XXX_Size() int

func (*PythContractParams) XXX_Unmarshal 

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

type QueryAggregatedPriceRequest 

type QueryAggregatedPriceRequest struct {
	// denom is the asset denomination
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryAggregatedPriceRequest is the request type for aggregated price.

func (*QueryAggregatedPriceRequest) Descriptor 

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

func (*QueryAggregatedPriceRequest) GetDenom 

func (m *QueryAggregatedPriceRequest) GetDenom() string

func (*QueryAggregatedPriceRequest) Marshal 

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

func (*QueryAggregatedPriceRequest) MarshalTo 

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

func (*QueryAggregatedPriceRequest) MarshalToSizedBuffer 

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

func (*QueryAggregatedPriceRequest) ProtoMessage 

func (*QueryAggregatedPriceRequest) ProtoMessage()

func (*QueryAggregatedPriceRequest) Reset 

func (m *QueryAggregatedPriceRequest) Reset()

func (*QueryAggregatedPriceRequest) Size 

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

func (*QueryAggregatedPriceRequest) String 

func (m *QueryAggregatedPriceRequest) String() string

func (*QueryAggregatedPriceRequest) Unmarshal 

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

func (*QueryAggregatedPriceRequest) XXX_DiscardUnknown 

func (m *QueryAggregatedPriceRequest) XXX_DiscardUnknown()

func (*QueryAggregatedPriceRequest) XXX_Marshal 

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

func (*QueryAggregatedPriceRequest) XXX_Merge 

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

func (*QueryAggregatedPriceRequest) XXX_Size 

func (m *QueryAggregatedPriceRequest) XXX_Size() int

func (*QueryAggregatedPriceRequest) XXX_Unmarshal 

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

type QueryAggregatedPriceResponse 

type QueryAggregatedPriceResponse struct {
	// aggregated_price is the aggregated price data
	AggregatedPrice AggregatedPrice `protobuf:"bytes,1,opt,name=aggregated_price,json=aggregatedPrice,proto3" json:"aggregated_price"`
	// price_health is the health status for the price feed
	PriceHealth PriceHealth `protobuf:"bytes,2,opt,name=price_health,json=priceHealth,proto3" json:"price_health"`
}

QueryAggregatedPriceResponse is the response type for aggregated price.

func (*QueryAggregatedPriceResponse) Descriptor 

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

func (*QueryAggregatedPriceResponse) GetAggregatedPrice 

func (m *QueryAggregatedPriceResponse) GetAggregatedPrice() AggregatedPrice

func (*QueryAggregatedPriceResponse) GetPriceHealth 

func (m *QueryAggregatedPriceResponse) GetPriceHealth() PriceHealth

func (*QueryAggregatedPriceResponse) Marshal 

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

func (*QueryAggregatedPriceResponse) MarshalTo 

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

func (*QueryAggregatedPriceResponse) MarshalToSizedBuffer 

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

func (*QueryAggregatedPriceResponse) ProtoMessage 

func (*QueryAggregatedPriceResponse) ProtoMessage()

func (*QueryAggregatedPriceResponse) Reset 

func (m *QueryAggregatedPriceResponse) Reset()

func (*QueryAggregatedPriceResponse) Size 

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

func (*QueryAggregatedPriceResponse) String 

func (m *QueryAggregatedPriceResponse) String() string

func (*QueryAggregatedPriceResponse) Unmarshal 

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

func (*QueryAggregatedPriceResponse) XXX_DiscardUnknown 

func (m *QueryAggregatedPriceResponse) XXX_DiscardUnknown()

func (*QueryAggregatedPriceResponse) XXX_Marshal 

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

func (*QueryAggregatedPriceResponse) XXX_Merge 

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

func (*QueryAggregatedPriceResponse) XXX_Size 

func (m *QueryAggregatedPriceResponse) XXX_Size() int

func (*QueryAggregatedPriceResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Prices query prices for specific denom
	Prices(ctx context.Context, in *QueryPricesRequest, opts ...grpc.CallOption) (*QueryPricesResponse, error)
	// Params returns the total set of minting parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// PriceFeedConfig queries the price feed configuration for a given denom.
	PriceFeedConfig(ctx context.Context, in *QueryPriceFeedConfigRequest, opts ...grpc.CallOption) (*QueryPriceFeedConfigResponse, error)
	// AggregatedPrice queries the aggregated price for a given denom.
	AggregatedPrice(ctx context.Context, in *QueryAggregatedPriceRequest, opts ...grpc.CallOption) (*QueryAggregatedPriceResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is the request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params defines the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryPriceFeedConfigRequest 

type QueryPriceFeedConfigRequest struct {
	// denom is the denomination to query the price feed configuration for
	Denom string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
}

QueryPriceFeedConfigRequest is the request type for price feed config.

func (*QueryPriceFeedConfigRequest) Descriptor 

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

func (*QueryPriceFeedConfigRequest) GetDenom 

func (m *QueryPriceFeedConfigRequest) GetDenom() string

func (*QueryPriceFeedConfigRequest) Marshal 

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

func (*QueryPriceFeedConfigRequest) MarshalTo 

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

func (*QueryPriceFeedConfigRequest) MarshalToSizedBuffer 

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

func (*QueryPriceFeedConfigRequest) ProtoMessage 

func (*QueryPriceFeedConfigRequest) ProtoMessage()

func (*QueryPriceFeedConfigRequest) Reset 

func (m *QueryPriceFeedConfigRequest) Reset()

func (*QueryPriceFeedConfigRequest) Size 

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

func (*QueryPriceFeedConfigRequest) String 

func (m *QueryPriceFeedConfigRequest) String() string

func (*QueryPriceFeedConfigRequest) Unmarshal 

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

func (*QueryPriceFeedConfigRequest) XXX_DiscardUnknown 

func (m *QueryPriceFeedConfigRequest) XXX_DiscardUnknown()

func (*QueryPriceFeedConfigRequest) XXX_Marshal 

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

func (*QueryPriceFeedConfigRequest) XXX_Merge 

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

func (*QueryPriceFeedConfigRequest) XXX_Size 

func (m *QueryPriceFeedConfigRequest) XXX_Size() int

func (*QueryPriceFeedConfigRequest) XXX_Unmarshal 

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

type QueryPriceFeedConfigResponse 

type QueryPriceFeedConfigResponse struct {
	// price_feed_id is the Pyth price feed identifier for this denomination
	PriceFeedId string `protobuf:"bytes,1,opt,name=price_feed_id,json=priceFeedId,proto3" json:"price_feed_id,omitempty"`
	// pyth_contract_address is the address of the Pyth smart contract
	PythContractAddress string `protobuf:"bytes,2,opt,name=pyth_contract_address,json=pythContractAddress,proto3" json:"pyth_contract_address,omitempty"`
	// enabled indicates if the price feed is enabled for this denomination
	Enabled bool `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
}

QueryPriceFeedConfigResponse is the response type for price feed config.

func (*QueryPriceFeedConfigResponse) Descriptor 

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

func (*QueryPriceFeedConfigResponse) GetEnabled 

func (m *QueryPriceFeedConfigResponse) GetEnabled() bool

func (*QueryPriceFeedConfigResponse) GetPriceFeedId 

func (m *QueryPriceFeedConfigResponse) GetPriceFeedId() string

func (*QueryPriceFeedConfigResponse) GetPythContractAddress 

func (m *QueryPriceFeedConfigResponse) GetPythContractAddress() string

func (*QueryPriceFeedConfigResponse) Marshal 

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

func (*QueryPriceFeedConfigResponse) MarshalTo 

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

func (*QueryPriceFeedConfigResponse) MarshalToSizedBuffer 

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

func (*QueryPriceFeedConfigResponse) ProtoMessage 

func (*QueryPriceFeedConfigResponse) ProtoMessage()

func (*QueryPriceFeedConfigResponse) Reset 

func (m *QueryPriceFeedConfigResponse) Reset()

func (*QueryPriceFeedConfigResponse) Size 

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

func (*QueryPriceFeedConfigResponse) String 

func (m *QueryPriceFeedConfigResponse) String() string

func (*QueryPriceFeedConfigResponse) Unmarshal 

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

func (*QueryPriceFeedConfigResponse) XXX_DiscardUnknown 

func (m *QueryPriceFeedConfigResponse) XXX_DiscardUnknown()

func (*QueryPriceFeedConfigResponse) XXX_Marshal 

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

func (*QueryPriceFeedConfigResponse) XXX_Merge 

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

func (*QueryPriceFeedConfigResponse) XXX_Size 

func (m *QueryPriceFeedConfigResponse) XXX_Size() int

func (*QueryPriceFeedConfigResponse) XXX_Unmarshal 

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

type QueryPricesRequest 

type QueryPricesRequest struct {
	// filters holds the price fields to filter the request
	Filters PricesFilter `protobuf:"bytes,1,opt,name=filters,proto3" json:"filters"`
	// pagination is used to paginate the request
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPricesRequest is the request type for querying price history

func (*QueryPricesRequest) Descriptor 

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

func (*QueryPricesRequest) GetFilters 

func (m *QueryPricesRequest) GetFilters() PricesFilter

func (*QueryPricesRequest) GetPagination 

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

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) 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 is the list of historical price data matching the filters
	Prices []PriceData `protobuf:"bytes,1,rep,name=prices,proto3" json:"prices" yaml:"prices"`
	// pagination contains the information about response pagination
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPricesResponse is the response type for querying price history

func (*QueryPricesResponse) Descriptor 

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

func (*QueryPricesResponse) GetPagination 

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

func (*QueryPricesResponse) GetPrices 

func (m *QueryPricesResponse) GetPrices() []PriceData

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

type QueryServer interface {
	// Prices query prices for specific denom
	Prices(context.Context, *QueryPricesRequest) (*QueryPricesResponse, error)
	// Params returns the total set of minting parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// PriceFeedConfig queries the price feed configuration for a given denom.
	PriceFeedConfig(context.Context, *QueryPriceFeedConfigRequest) (*QueryPriceFeedConfigResponse, error)
	// AggregatedPrice queries the aggregated price for a given denom.
	AggregatedPrice(context.Context, *QueryAggregatedPriceRequest) (*QueryAggregatedPriceResponse, error)
}

QueryServer is the server API for Query service.

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddPriceEntry 

func (*UnimplementedMsgServer) AddPriceEntry(ctx context.Context, req *MsgAddPriceEntry) (*MsgAddPriceEntryResponse, error)

func (*UnimplementedMsgServer) UpdateParams 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AggregatedPrice 

func (*UnimplementedQueryServer) AggregatedPrice(ctx context.Context, req *QueryAggregatedPriceRequest) (*QueryAggregatedPriceResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) PriceFeedConfig 

func (*UnimplementedQueryServer) PriceFeedConfig(ctx context.Context, req *QueryPriceFeedConfigRequest) (*QueryPriceFeedConfigResponse, error)

func (*UnimplementedQueryServer) Prices 

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

type WormholeContractParams 

type WormholeContractParams struct {
	// guardian_addresses is the list of Wormhole guardian addresses.
	// Each address is a 20-byte Ethereum-style address, hex-encoded.
	// The Wormhole contract uses these to verify VAA signatures.
	GuardianAddresses []string `protobuf:"bytes,1,rep,name=guardian_addresses,json=guardianAddresses,proto3" json:"guardian_addresses,omitempty"`
}

WormholeContractParams contains configuration for Wormhole guardian set. This allows the Wormhole contract to pull guardian public keys from x/oracle module params, enabling guardian set updates via Akash governance.

func DefaultWormholeContractParams 

func DefaultWormholeContractParams() *WormholeContractParams

DefaultWormholeContractParams returns default Wormhole contract params Guardian addresses are from Wormhole Mainnet Guardian Set 4 Source: https://wormhole.com/docs/protocol/infrastructure/guardians/

func (*WormholeContractParams) Descriptor 

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

func (*WormholeContractParams) Equal 

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

func (*WormholeContractParams) GetGuardianAddresses 

func (m *WormholeContractParams) GetGuardianAddresses() []string

func (*WormholeContractParams) Marshal 

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

func (*WormholeContractParams) MarshalTo 

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

func (*WormholeContractParams) MarshalToSizedBuffer 

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

func (*WormholeContractParams) ProtoMessage 

func (*WormholeContractParams) ProtoMessage()

func (*WormholeContractParams) Reset 

func (m *WormholeContractParams) Reset()

func (*WormholeContractParams) Size 

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

func (*WormholeContractParams) String 

func (m *WormholeContractParams) String() string

func (*WormholeContractParams) Unmarshal 

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

func (*WormholeContractParams) ValidateBasic 

func (p *WormholeContractParams) ValidateBasic() error

ValidateBasic validates WormholeContractParams

func (*WormholeContractParams) XXX_DiscardUnknown 

func (m *WormholeContractParams) XXX_DiscardUnknown()

func (*WormholeContractParams) XXX_Marshal 

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

func (*WormholeContractParams) XXX_Merge 

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

func (*WormholeContractParams) XXX_Size 

func (m *WormholeContractParams) XXX_Size() int

func (*WormholeContractParams) XXX_Unmarshal 

func (m *WormholeContractParams) XXX_Unmarshal(b []byte) 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.