types

package
v29.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2025 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ModuleName = "icqoracle"

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

	// RouterKey defines the routing key
	RouterKey = ModuleName
)
View Source 
const (
	TypeMsgRegisterTokenPriceQuery = "register_token_price_query"
	TypeMsgRemoveTokenPriceQuery   = "remove_token_price_query"
	TypeMsgUpdateParams            = "update_params"
)

Variables

View Source 
var (
	ErrTokenPriceAlreadyExists = sdkerrors.Register(ModuleName, 16001, "token price already exists")
	ErrQuotePriceNotFound      = sdkerrors.Register(ModuleName, 16002, "token price not found for quote denom")
)

x/icqoracle 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 (
	ErrInvalidLengthIcqoracle        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIcqoracle          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIcqoracle = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ParamsKey        = []byte("params")
	TokenPricePrefix = []byte("tokenprice")
)
View Source 
var (
	ErrInvalidLengthOsmosis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOsmosis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOsmosis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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)

func TokenPriceByDenomKey 

func TokenPriceByDenomKey(baseDenom string) []byte

func TokenPriceKey 

func TokenPriceKey(baseDenom, quoteDenom string, poolId uint64) []byte

func ValidateTokenPriceQueryParams 

func ValidateTokenPriceQueryParams(
	baseDenom string,
	quoteDenom string,
	osmosisPoolId uint64,
	osmosisBaseDenom string,
	osmosisQuoteDenom string,
) error

Types

type GenesisState 

type GenesisState struct {
	// Module parameters
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// List of token prices
	TokenPrices []TokenPrice `protobuf:"bytes,2,rep,name=token_prices,json=tokenPrices,proto3" json:"token_prices"`
}

GenesisState defines the icqoracle module's genesis state

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetTokenPrices 

func (m *GenesisState) GetTokenPrices() []TokenPrice

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

Performs basic genesis state validation by iterating through all token prices and validating using ValidateTokenPriceQueryParams().

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 IbcTransferKeeper 

type IbcTransferKeeper interface {
	GetDenomTrace(ctx sdk.Context, denomTraceHash tmbytes.HexBytes) (ibctransfertypes.DenomTrace, bool)
}

IbcTransferKeeper defines the expected interface needed to convert an ibc token hash to its denom on the source chain.

type IcqKeeper 

type IcqKeeper interface {
	SubmitICQRequest(ctx sdk.Context, icqtypes types.Query, forceUnique bool) error
}

IcqKeeper defines the expected interface needed to send ICQ requests.

type MsgClient 

type MsgClient interface {
	// RegisterTokenPriceQuery registers a new token to track prices for
	RegisterTokenPriceQuery(ctx context.Context, in *MsgRegisterTokenPriceQuery, opts ...grpc.CallOption) (*MsgRegisterTokenPriceQueryResponse, error)
	// RemoveTokenPriceQuery removes a token from price tracking
	RemoveTokenPriceQuery(ctx context.Context, in *MsgRemoveTokenPriceQuery, opts ...grpc.CallOption) (*MsgRemoveTokenPriceQueryResponse, error)
	// UpdateParams defines a governance operation for updating the x/icqoracle
	// module parameters. The authority is defined in the keeper.
	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 MsgRegisterTokenPriceQuery 

type MsgRegisterTokenPriceQuery struct {
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty"`
	// Token denom on Stride
	BaseDenom string `protobuf:"bytes,2,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty"`
	// Quote denom on Stride
	QuoteDenom string `protobuf:"bytes,3,opt,name=quote_denom,json=quoteDenom,proto3" json:"quote_denom,omitempty"`
	// Token denom on Osmosis
	OsmosisBaseDenom string `protobuf:"bytes,4,opt,name=osmosis_base_denom,json=osmosisBaseDenom,proto3" json:"osmosis_base_denom,omitempty"`
	// Quote denom on Osmosis
	OsmosisQuoteDenom string `protobuf:"bytes,5,opt,name=osmosis_quote_denom,json=osmosisQuoteDenom,proto3" json:"osmosis_quote_denom,omitempty"`
	// Pool ID on Osmosis
	OsmosisPoolId uint64 `protobuf:"varint,6,opt,name=osmosis_pool_id,json=osmosisPoolId,proto3" json:"osmosis_pool_id,omitempty"`
}

MsgRegisterTokenPriceQuery defines the message for adding a new token to track prices

func NewMsgRegisterTokenPriceQuery 

func NewMsgRegisterTokenPriceQuery(
	admin string,
	baseDenom string,
	quoteDenom string,
	poolId uint64,
	osmosisBaseDenom string,
	osmosisQuoteDenom string,
) *MsgRegisterTokenPriceQuery

func (*MsgRegisterTokenPriceQuery) Descriptor 

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

func (*MsgRegisterTokenPriceQuery) GetAdmin 

func (m *MsgRegisterTokenPriceQuery) GetAdmin() string

func (*MsgRegisterTokenPriceQuery) GetBaseDenom 

func (m *MsgRegisterTokenPriceQuery) GetBaseDenom() string

func (*MsgRegisterTokenPriceQuery) GetOsmosisBaseDenom 

func (m *MsgRegisterTokenPriceQuery) GetOsmosisBaseDenom() string

func (*MsgRegisterTokenPriceQuery) GetOsmosisPoolId 

func (m *MsgRegisterTokenPriceQuery) GetOsmosisPoolId() uint64

func (*MsgRegisterTokenPriceQuery) GetOsmosisQuoteDenom 

func (m *MsgRegisterTokenPriceQuery) GetOsmosisQuoteDenom() string

func (*MsgRegisterTokenPriceQuery) GetQuoteDenom 

func (m *MsgRegisterTokenPriceQuery) GetQuoteDenom() string

func (*MsgRegisterTokenPriceQuery) GetSigners 

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

func (*MsgRegisterTokenPriceQuery) Marshal 

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

func (*MsgRegisterTokenPriceQuery) MarshalTo 

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

func (*MsgRegisterTokenPriceQuery) MarshalToSizedBuffer 

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

func (*MsgRegisterTokenPriceQuery) ProtoMessage 

func (*MsgRegisterTokenPriceQuery) ProtoMessage()

func (*MsgRegisterTokenPriceQuery) Reset 

func (m *MsgRegisterTokenPriceQuery) Reset()

func (MsgRegisterTokenPriceQuery) Route 

func (msg MsgRegisterTokenPriceQuery) Route() string

func (*MsgRegisterTokenPriceQuery) Size 

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

func (*MsgRegisterTokenPriceQuery) String 

func (m *MsgRegisterTokenPriceQuery) String() string

func (MsgRegisterTokenPriceQuery) Type 

func (msg MsgRegisterTokenPriceQuery) Type() string

func (*MsgRegisterTokenPriceQuery) Unmarshal 

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

func (*MsgRegisterTokenPriceQuery) ValidateBasic 

func (msg *MsgRegisterTokenPriceQuery) ValidateBasic() error

func (*MsgRegisterTokenPriceQuery) XXX_DiscardUnknown 

func (m *MsgRegisterTokenPriceQuery) XXX_DiscardUnknown()

func (*MsgRegisterTokenPriceQuery) XXX_Marshal 

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

func (*MsgRegisterTokenPriceQuery) XXX_Merge 

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

func (*MsgRegisterTokenPriceQuery) XXX_Size 

func (m *MsgRegisterTokenPriceQuery) XXX_Size() int

func (*MsgRegisterTokenPriceQuery) XXX_Unmarshal 

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

type MsgRegisterTokenPriceQueryResponse 

type MsgRegisterTokenPriceQueryResponse struct {
}

func (*MsgRegisterTokenPriceQueryResponse) Descriptor 

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

func (*MsgRegisterTokenPriceQueryResponse) Marshal 

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

func (*MsgRegisterTokenPriceQueryResponse) MarshalTo 

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

func (*MsgRegisterTokenPriceQueryResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterTokenPriceQueryResponse) ProtoMessage 

func (*MsgRegisterTokenPriceQueryResponse) ProtoMessage()

func (*MsgRegisterTokenPriceQueryResponse) Reset 

func (m *MsgRegisterTokenPriceQueryResponse) Reset()

func (*MsgRegisterTokenPriceQueryResponse) Size 

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

func (*MsgRegisterTokenPriceQueryResponse) String 

func (m *MsgRegisterTokenPriceQueryResponse) String() string

func (*MsgRegisterTokenPriceQueryResponse) Unmarshal 

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

func (*MsgRegisterTokenPriceQueryResponse) XXX_DiscardUnknown 

func (m *MsgRegisterTokenPriceQueryResponse) XXX_DiscardUnknown()

func (*MsgRegisterTokenPriceQueryResponse) XXX_Marshal 

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

func (*MsgRegisterTokenPriceQueryResponse) XXX_Merge 

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

func (*MsgRegisterTokenPriceQueryResponse) XXX_Size 

func (m *MsgRegisterTokenPriceQueryResponse) XXX_Size() int

func (*MsgRegisterTokenPriceQueryResponse) XXX_Unmarshal 

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

type MsgRemoveTokenPriceQuery 

type MsgRemoveTokenPriceQuery struct {
	Admin string `protobuf:"bytes,1,opt,name=admin,proto3" json:"admin,omitempty"`
	// Token denom on Stride
	BaseDenom string `protobuf:"bytes,2,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty"`
	// Quote denom on Stride
	QuoteDenom string `protobuf:"bytes,3,opt,name=quote_denom,json=quoteDenom,proto3" json:"quote_denom,omitempty"`
	// Pool ID on Osmosis
	OsmosisPoolId uint64 `protobuf:"varint,4,opt,name=osmosis_pool_id,json=osmosisPoolId,proto3" json:"osmosis_pool_id,omitempty"`
}

MsgRemoveTokenPriceQuery defines the message for removing a token from price tracking

func NewMsgRemoveTokenPriceQuery 

func NewMsgRemoveTokenPriceQuery(admin, baseDenom, quoteDenom string, osmosisPoolId uint64) *MsgRemoveTokenPriceQuery

func (*MsgRemoveTokenPriceQuery) Descriptor 

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

func (*MsgRemoveTokenPriceQuery) GetAdmin 

func (m *MsgRemoveTokenPriceQuery) GetAdmin() string

func (*MsgRemoveTokenPriceQuery) GetBaseDenom 

func (m *MsgRemoveTokenPriceQuery) GetBaseDenom() string

func (*MsgRemoveTokenPriceQuery) GetOsmosisPoolId 

func (m *MsgRemoveTokenPriceQuery) GetOsmosisPoolId() uint64

func (*MsgRemoveTokenPriceQuery) GetQuoteDenom 

func (m *MsgRemoveTokenPriceQuery) GetQuoteDenom() string

func (*MsgRemoveTokenPriceQuery) GetSigners 

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

func (*MsgRemoveTokenPriceQuery) Marshal 

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

func (*MsgRemoveTokenPriceQuery) MarshalTo 

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

func (*MsgRemoveTokenPriceQuery) MarshalToSizedBuffer 

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

func (*MsgRemoveTokenPriceQuery) ProtoMessage 

func (*MsgRemoveTokenPriceQuery) ProtoMessage()

func (*MsgRemoveTokenPriceQuery) Reset 

func (m *MsgRemoveTokenPriceQuery) Reset()

func (MsgRemoveTokenPriceQuery) Route 

func (msg MsgRemoveTokenPriceQuery) Route() string

func (*MsgRemoveTokenPriceQuery) Size 

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

func (*MsgRemoveTokenPriceQuery) String 

func (m *MsgRemoveTokenPriceQuery) String() string

func (MsgRemoveTokenPriceQuery) Type 

func (msg MsgRemoveTokenPriceQuery) Type() string

func (*MsgRemoveTokenPriceQuery) Unmarshal 

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

func (*MsgRemoveTokenPriceQuery) ValidateBasic 

func (msg *MsgRemoveTokenPriceQuery) ValidateBasic() error

func (*MsgRemoveTokenPriceQuery) XXX_DiscardUnknown 

func (m *MsgRemoveTokenPriceQuery) XXX_DiscardUnknown()

func (*MsgRemoveTokenPriceQuery) XXX_Marshal 

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

func (*MsgRemoveTokenPriceQuery) XXX_Merge 

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

func (*MsgRemoveTokenPriceQuery) XXX_Size 

func (m *MsgRemoveTokenPriceQuery) XXX_Size() int

func (*MsgRemoveTokenPriceQuery) XXX_Unmarshal 

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

type MsgRemoveTokenPriceQueryResponse 

type MsgRemoveTokenPriceQueryResponse struct {
}

func (*MsgRemoveTokenPriceQueryResponse) Descriptor 

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

func (*MsgRemoveTokenPriceQueryResponse) Marshal 

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

func (*MsgRemoveTokenPriceQueryResponse) MarshalTo 

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

func (*MsgRemoveTokenPriceQueryResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveTokenPriceQueryResponse) ProtoMessage 

func (*MsgRemoveTokenPriceQueryResponse) ProtoMessage()

func (*MsgRemoveTokenPriceQueryResponse) Reset 

func (m *MsgRemoveTokenPriceQueryResponse) Reset()

func (*MsgRemoveTokenPriceQueryResponse) Size 

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

func (*MsgRemoveTokenPriceQueryResponse) String 

func (m *MsgRemoveTokenPriceQueryResponse) String() string

func (*MsgRemoveTokenPriceQueryResponse) Unmarshal 

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

func (*MsgRemoveTokenPriceQueryResponse) XXX_DiscardUnknown 

func (m *MsgRemoveTokenPriceQueryResponse) XXX_DiscardUnknown()

func (*MsgRemoveTokenPriceQueryResponse) XXX_Marshal 

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

func (*MsgRemoveTokenPriceQueryResponse) XXX_Merge 

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

func (*MsgRemoveTokenPriceQueryResponse) XXX_Size 

func (m *MsgRemoveTokenPriceQueryResponse) XXX_Size() int

func (*MsgRemoveTokenPriceQueryResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// RegisterTokenPriceQuery registers a new token to track prices for
	RegisterTokenPriceQuery(context.Context, *MsgRegisterTokenPriceQuery) (*MsgRegisterTokenPriceQueryResponse, error)
	// RemoveTokenPriceQuery removes a token from price tracking
	RemoveTokenPriceQuery(context.Context, *MsgRemoveTokenPriceQuery) (*MsgRemoveTokenPriceQueryResponse, error)
	// UpdateParams defines a governance operation for updating the x/icqoracle
	// module parameters. The authority is defined in the keeper.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams 

type MsgUpdateParams struct {
	// authority is the address that controls the module (defaults to x/gov unless
	// overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/icqoracle 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.

func NewMsgUpdateParams 

func NewMsgUpdateParams(
	authority string,
	osmosisChainId string,
	osmosisConnectionId string,
	updateIntervalSec uint64,
	priceExpirationTimeoutSec uint64,
) *MsgUpdateParams

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

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

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 

func (msg MsgUpdateParams) Route() string

func (*MsgUpdateParams) Size 

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

func (*MsgUpdateParams) String 

func (m *MsgUpdateParams) String() string

func (MsgUpdateParams) Type 

func (msg MsgUpdateParams) Type() string

func (*MsgUpdateParams) Unmarshal 

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

func (*MsgUpdateParams) ValidateBasic 

func (msg *MsgUpdateParams) ValidateBasic() error

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.

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 OsmosisTwapRecord 

type OsmosisTwapRecord struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// Lexicographically smaller denom of the pair
	Asset0Denom string `protobuf:"bytes,2,opt,name=asset0_denom,json=asset0Denom,proto3" json:"asset0_denom,omitempty"`
	// Lexicographically larger denom of the pair
	Asset1Denom string `protobuf:"bytes,3,opt,name=asset1_denom,json=asset1Denom,proto3" json:"asset1_denom,omitempty"`
	// height this record corresponds to, for debugging purposes
	Height int64 `protobuf:"varint,4,opt,name=height,proto3" json:"record_height" yaml:"record_height"`
	// This field should only exist until we have a global registry in the state
	// machine, mapping prior block heights within {TIME RANGE} to times.
	Time time.Time `protobuf:"bytes,5,opt,name=time,proto3,stdtime" json:"time" yaml:"record_time"`
	// We store the last spot prices in the struct, so that we can interpolate
	// accumulator values for times between when accumulator records are stored.
	P0LastSpotPrice             cosmossdk_io_math.LegacyDec `` /* 139-byte string literal not displayed */
	P1LastSpotPrice             cosmossdk_io_math.LegacyDec `` /* 139-byte string literal not displayed */
	P0ArithmeticTwapAccumulator cosmossdk_io_math.LegacyDec `` /* 175-byte string literal not displayed */
	P1ArithmeticTwapAccumulator cosmossdk_io_math.LegacyDec `` /* 175-byte string literal not displayed */
	GeometricTwapAccumulator    cosmossdk_io_math.LegacyDec `` /* 165-byte string literal not displayed */
	// This field contains the time in which the last spot price error occurred.
	// It is used to alert the caller if they are getting a potentially erroneous
	// TWAP, due to an unforeseen underlying error.
	LastErrorTime time.Time `protobuf:"bytes,11,opt,name=last_error_time,json=lastErrorTime,proto3,stdtime" json:"last_error_time" yaml:"last_error_time"`
}

A TWAP record should be indexed in state by pool_id, (asset pair), timestamp The asset pair assets should be lexicographically sorted. Technically (pool_id, asset_0_denom, asset_1_denom, height) do not need to appear in the struct however we view this as the wrong performance tradeoff given SDK today. Would rather we optimize for readability and correctness, than an optimal state storage format. The system bottleneck is elsewhere for now.

func (*OsmosisTwapRecord) Descriptor 

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

func (*OsmosisTwapRecord) GetAsset0Denom 

func (m *OsmosisTwapRecord) GetAsset0Denom() string

func (*OsmosisTwapRecord) GetAsset1Denom 

func (m *OsmosisTwapRecord) GetAsset1Denom() string

func (*OsmosisTwapRecord) GetHeight 

func (m *OsmosisTwapRecord) GetHeight() int64

func (*OsmosisTwapRecord) GetLastErrorTime 

func (m *OsmosisTwapRecord) GetLastErrorTime() time.Time

func (*OsmosisTwapRecord) GetPoolId 

func (m *OsmosisTwapRecord) GetPoolId() uint64

func (*OsmosisTwapRecord) GetTime 

func (m *OsmosisTwapRecord) GetTime() time.Time

func (*OsmosisTwapRecord) Marshal 

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

func (*OsmosisTwapRecord) MarshalTo 

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

func (*OsmosisTwapRecord) MarshalToSizedBuffer 

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

func (*OsmosisTwapRecord) ProtoMessage 

func (*OsmosisTwapRecord) ProtoMessage()

func (*OsmosisTwapRecord) Reset 

func (m *OsmosisTwapRecord) Reset()

func (*OsmosisTwapRecord) Size 

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

func (*OsmosisTwapRecord) String 

func (m *OsmosisTwapRecord) String() string

func (*OsmosisTwapRecord) Unmarshal 

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

func (*OsmosisTwapRecord) XXX_DiscardUnknown 

func (m *OsmosisTwapRecord) XXX_DiscardUnknown()

func (*OsmosisTwapRecord) XXX_Marshal 

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

func (*OsmosisTwapRecord) XXX_Merge 

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

func (*OsmosisTwapRecord) XXX_Size 

func (m *OsmosisTwapRecord) XXX_Size() int

func (*OsmosisTwapRecord) XXX_Unmarshal 

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

type Params 

type Params struct {
	// Osmosis chain identifier
	OsmosisChainId string `protobuf:"bytes,1,opt,name=osmosis_chain_id,json=osmosisChainId,proto3" json:"osmosis_chain_id" yaml:"osmosis_chain_id"`
	// Osmosis IBC connection identifier
	OsmosisConnectionId string `` /* 139-byte string literal not displayed */
	// Time between price updates
	// Also used to timeout icq requests
	UpdateIntervalSec uint64 `` /* 132-byte string literal not displayed */
	// Max time before price is considered stale/expired
	PriceExpirationTimeoutSec uint64 `` /* 167-byte string literal not displayed */
}

OracleParams stores global oracle parameters

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams() Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetOsmosisChainId 

func (m *Params) GetOsmosisChainId() string

func (*Params) GetOsmosisConnectionId 

func (m *Params) GetOsmosisConnectionId() string

func (*Params) GetPriceExpirationTimeoutSec 

func (m *Params) GetPriceExpirationTimeoutSec() uint64

func (*Params) GetUpdateIntervalSec 

func (m *Params) GetUpdateIntervalSec() uint64

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) 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 validates the set of params

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 QueryClient 

type QueryClient interface {
	// TokenPrice queries the current price for a specific token
	TokenPrice(ctx context.Context, in *QueryTokenPriceRequest, opts ...grpc.CallOption) (*TokenPriceResponse, error)
	// TokenPrices queries all token prices
	TokenPrices(ctx context.Context, in *QueryTokenPricesRequest, opts ...grpc.CallOption) (*QueryTokenPricesResponse, error)
	// Params queries the oracle parameters
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// TokenPriceForQuoteDenom queries the exchange rate between two tokens
	TokenPriceForQuoteDenom(ctx context.Context, in *QueryTokenPriceForQuoteDenomRequest, opts ...grpc.CallOption) (*QueryTokenPriceForQuoteDenomResponse, 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 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 QueryServer 

type QueryServer interface {
	// TokenPrice queries the current price for a specific token
	TokenPrice(context.Context, *QueryTokenPriceRequest) (*TokenPriceResponse, error)
	// TokenPrices queries all token prices
	TokenPrices(context.Context, *QueryTokenPricesRequest) (*QueryTokenPricesResponse, error)
	// Params queries the oracle parameters
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// TokenPriceForQuoteDenom queries the exchange rate between two tokens
	TokenPriceForQuoteDenom(context.Context, *QueryTokenPriceForQuoteDenomRequest) (*QueryTokenPriceForQuoteDenomResponse, error)
}

QueryServer is the server API for Query service.

type QueryTokenPriceForQuoteDenomRequest 

type QueryTokenPriceForQuoteDenomRequest struct {
	BaseDenom  string `protobuf:"bytes,1,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty"`
	QuoteDenom string `protobuf:"bytes,2,opt,name=quote_denom,json=quoteDenom,proto3" json:"quote_denom,omitempty"`
}

QueryTokenPriceForQuoteDenomRequest is the request type for the Query/TokenPriceForQuoteDenom RPC method

func (*QueryTokenPriceForQuoteDenomRequest) Descriptor 

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

func (*QueryTokenPriceForQuoteDenomRequest) GetBaseDenom 

func (m *QueryTokenPriceForQuoteDenomRequest) GetBaseDenom() string

func (*QueryTokenPriceForQuoteDenomRequest) GetQuoteDenom 

func (m *QueryTokenPriceForQuoteDenomRequest) GetQuoteDenom() string

func (*QueryTokenPriceForQuoteDenomRequest) Marshal 

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

func (*QueryTokenPriceForQuoteDenomRequest) MarshalTo 

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

func (*QueryTokenPriceForQuoteDenomRequest) MarshalToSizedBuffer 

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

func (*QueryTokenPriceForQuoteDenomRequest) ProtoMessage 

func (*QueryTokenPriceForQuoteDenomRequest) ProtoMessage()

func (*QueryTokenPriceForQuoteDenomRequest) Reset 

func (m *QueryTokenPriceForQuoteDenomRequest) Reset()

func (*QueryTokenPriceForQuoteDenomRequest) Size 

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

func (*QueryTokenPriceForQuoteDenomRequest) String 

func (m *QueryTokenPriceForQuoteDenomRequest) String() string

func (*QueryTokenPriceForQuoteDenomRequest) Unmarshal 

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

func (*QueryTokenPriceForQuoteDenomRequest) XXX_DiscardUnknown 

func (m *QueryTokenPriceForQuoteDenomRequest) XXX_DiscardUnknown()

func (*QueryTokenPriceForQuoteDenomRequest) XXX_Marshal 

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

func (*QueryTokenPriceForQuoteDenomRequest) XXX_Merge 

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

func (*QueryTokenPriceForQuoteDenomRequest) XXX_Size 

func (m *QueryTokenPriceForQuoteDenomRequest) XXX_Size() int

func (*QueryTokenPriceForQuoteDenomRequest) XXX_Unmarshal 

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

type QueryTokenPriceForQuoteDenomResponse 

type QueryTokenPriceForQuoteDenomResponse struct {
	Price cosmossdk_io_math.LegacyDec `protobuf:"bytes,1,opt,name=price,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"price"`
}

QueryTokenPriceForQuoteDenomResponse is the response type for the Query/TokenPriceForQuoteDenom RPC method

func (*QueryTokenPriceForQuoteDenomResponse) Descriptor 

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

func (*QueryTokenPriceForQuoteDenomResponse) Marshal 

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

func (*QueryTokenPriceForQuoteDenomResponse) MarshalTo 

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

func (*QueryTokenPriceForQuoteDenomResponse) MarshalToSizedBuffer 

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

func (*QueryTokenPriceForQuoteDenomResponse) ProtoMessage 

func (*QueryTokenPriceForQuoteDenomResponse) ProtoMessage()

func (*QueryTokenPriceForQuoteDenomResponse) Reset 

func (m *QueryTokenPriceForQuoteDenomResponse) Reset()

func (*QueryTokenPriceForQuoteDenomResponse) Size 

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

func (*QueryTokenPriceForQuoteDenomResponse) String 

func (m *QueryTokenPriceForQuoteDenomResponse) String() string

func (*QueryTokenPriceForQuoteDenomResponse) Unmarshal 

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

func (*QueryTokenPriceForQuoteDenomResponse) XXX_DiscardUnknown 

func (m *QueryTokenPriceForQuoteDenomResponse) XXX_DiscardUnknown()

func (*QueryTokenPriceForQuoteDenomResponse) XXX_Marshal 

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

func (*QueryTokenPriceForQuoteDenomResponse) XXX_Merge 

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

func (*QueryTokenPriceForQuoteDenomResponse) XXX_Size 

func (m *QueryTokenPriceForQuoteDenomResponse) XXX_Size() int

func (*QueryTokenPriceForQuoteDenomResponse) XXX_Unmarshal 

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

type QueryTokenPriceRequest 

type QueryTokenPriceRequest struct {
	BaseDenom  string `protobuf:"bytes,1,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty"`
	QuoteDenom string `protobuf:"bytes,2,opt,name=quote_denom,json=quoteDenom,proto3" json:"quote_denom,omitempty"`
	PoolId     uint64 `protobuf:"varint,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

QueryTokenPriceRequest is the request type for the Query/TokenPrice RPC method

func (*QueryTokenPriceRequest) Descriptor 

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

func (*QueryTokenPriceRequest) GetBaseDenom 

func (m *QueryTokenPriceRequest) GetBaseDenom() string

func (*QueryTokenPriceRequest) GetPoolId 

func (m *QueryTokenPriceRequest) GetPoolId() uint64

func (*QueryTokenPriceRequest) GetQuoteDenom 

func (m *QueryTokenPriceRequest) GetQuoteDenom() string

func (*QueryTokenPriceRequest) Marshal 

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

func (*QueryTokenPriceRequest) MarshalTo 

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

func (*QueryTokenPriceRequest) MarshalToSizedBuffer 

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

func (*QueryTokenPriceRequest) ProtoMessage 

func (*QueryTokenPriceRequest) ProtoMessage()

func (*QueryTokenPriceRequest) Reset 

func (m *QueryTokenPriceRequest) Reset()

func (*QueryTokenPriceRequest) Size 

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

func (*QueryTokenPriceRequest) String 

func (m *QueryTokenPriceRequest) String() string

func (*QueryTokenPriceRequest) Unmarshal 

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

func (*QueryTokenPriceRequest) XXX_DiscardUnknown 

func (m *QueryTokenPriceRequest) XXX_DiscardUnknown()

func (*QueryTokenPriceRequest) XXX_Marshal 

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

func (*QueryTokenPriceRequest) XXX_Merge 

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

func (*QueryTokenPriceRequest) XXX_Size 

func (m *QueryTokenPriceRequest) XXX_Size() int

func (*QueryTokenPriceRequest) XXX_Unmarshal 

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

type QueryTokenPricesRequest 

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

QueryTokenPricesRequest is the request type for the Query/TokenPrices RPC method

func (*QueryTokenPricesRequest) Descriptor 

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

func (*QueryTokenPricesRequest) GetPagination 

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

func (*QueryTokenPricesRequest) Marshal 

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

func (*QueryTokenPricesRequest) MarshalTo 

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

func (*QueryTokenPricesRequest) MarshalToSizedBuffer 

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

func (*QueryTokenPricesRequest) ProtoMessage 

func (*QueryTokenPricesRequest) ProtoMessage()

func (*QueryTokenPricesRequest) Reset 

func (m *QueryTokenPricesRequest) Reset()

func (*QueryTokenPricesRequest) Size 

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

func (*QueryTokenPricesRequest) String 

func (m *QueryTokenPricesRequest) String() string

func (*QueryTokenPricesRequest) Unmarshal 

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

func (*QueryTokenPricesRequest) XXX_DiscardUnknown 

func (m *QueryTokenPricesRequest) XXX_DiscardUnknown()

func (*QueryTokenPricesRequest) XXX_Marshal 

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

func (*QueryTokenPricesRequest) XXX_Merge 

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

func (*QueryTokenPricesRequest) XXX_Size 

func (m *QueryTokenPricesRequest) XXX_Size() int

func (*QueryTokenPricesRequest) XXX_Unmarshal 

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

type QueryTokenPricesResponse 

type QueryTokenPricesResponse struct {
	TokenPrices []TokenPriceResponse `protobuf:"bytes,1,rep,name=token_prices,json=tokenPrices,proto3" json:"token_prices"`
	Pagination  *query.PageResponse  `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryTokenPricesResponse is the response type for the Query/TokenPrices RPC method

func (*QueryTokenPricesResponse) Descriptor 

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

func (*QueryTokenPricesResponse) GetPagination 

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

func (*QueryTokenPricesResponse) GetTokenPrices 

func (m *QueryTokenPricesResponse) GetTokenPrices() []TokenPriceResponse

func (*QueryTokenPricesResponse) Marshal 

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

func (*QueryTokenPricesResponse) MarshalTo 

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

func (*QueryTokenPricesResponse) MarshalToSizedBuffer 

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

func (*QueryTokenPricesResponse) ProtoMessage 

func (*QueryTokenPricesResponse) ProtoMessage()

func (*QueryTokenPricesResponse) Reset 

func (m *QueryTokenPricesResponse) Reset()

func (*QueryTokenPricesResponse) Size 

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

func (*QueryTokenPricesResponse) String 

func (m *QueryTokenPricesResponse) String() string

func (*QueryTokenPricesResponse) Unmarshal 

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

func (*QueryTokenPricesResponse) XXX_DiscardUnknown 

func (m *QueryTokenPricesResponse) XXX_DiscardUnknown()

func (*QueryTokenPricesResponse) XXX_Marshal 

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

func (*QueryTokenPricesResponse) XXX_Merge 

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

func (*QueryTokenPricesResponse) XXX_Size 

func (m *QueryTokenPricesResponse) XXX_Size() int

func (*QueryTokenPricesResponse) XXX_Unmarshal 

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

type TokenPrice 

type TokenPrice struct {
	// Base denom on Stride
	BaseDenom string `protobuf:"bytes,1,opt,name=base_denom,json=baseDenom,proto3" json:"base_denom,omitempty"`
	// Quote denom on Stride
	QuoteDenom string `protobuf:"bytes,2,opt,name=quote_denom,json=quoteDenom,proto3" json:"quote_denom,omitempty"`
	// Base denom on Osmosis
	OsmosisBaseDenom string `protobuf:"bytes,3,opt,name=osmosis_base_denom,json=osmosisBaseDenom,proto3" json:"osmosis_base_denom,omitempty"`
	// Quote denom on Osmosis
	OsmosisQuoteDenom string `protobuf:"bytes,4,opt,name=osmosis_quote_denom,json=osmosisQuoteDenom,proto3" json:"osmosis_quote_denom,omitempty"`
	// Pool ID on Osmosis
	OsmosisPoolId uint64 `protobuf:"varint,5,opt,name=osmosis_pool_id,json=osmosisPoolId,proto3" json:"osmosis_pool_id,omitempty"`
	// Spot price of base_denom denominated in quote_denom
	SpotPrice cosmossdk_io_math.LegacyDec `protobuf:"bytes,6,opt,name=spot_price,json=spotPrice,proto3,customtype=cosmossdk.io/math.LegacyDec" json:"spot_price"`
	// Last time a query request was submitted
	LastRequestTime time.Time `protobuf:"bytes,7,opt,name=last_request_time,json=lastRequestTime,proto3,stdtime" json:"last_request_time"`
	// Last time a query response was received
	LastResponseTime time.Time `protobuf:"bytes,8,opt,name=last_response_time,json=lastResponseTime,proto3,stdtime" json:"last_response_time"`
	// Whether there is a spot price query currently in progress
	QueryInProgress bool `protobuf:"varint,9,opt,name=query_in_progress,json=queryInProgress,proto3" json:"query_in_progress,omitempty"`
}

TokenPrice stores latest price data for a token

func (*TokenPrice) Descriptor 

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

func (*TokenPrice) GetBaseDenom 

func (m *TokenPrice) GetBaseDenom() string

func (*TokenPrice) GetLastRequestTime 

func (m *TokenPrice) GetLastRequestTime() time.Time

func (*TokenPrice) GetLastResponseTime 

func (m *TokenPrice) GetLastResponseTime() time.Time

func (*TokenPrice) GetOsmosisBaseDenom 

func (m *TokenPrice) GetOsmosisBaseDenom() string

func (*TokenPrice) GetOsmosisPoolId 

func (m *TokenPrice) GetOsmosisPoolId() uint64

func (*TokenPrice) GetOsmosisQuoteDenom 

func (m *TokenPrice) GetOsmosisQuoteDenom() string

func (*TokenPrice) GetQueryInProgress 

func (m *TokenPrice) GetQueryInProgress() bool

func (*TokenPrice) GetQuoteDenom 

func (m *TokenPrice) GetQuoteDenom() string

func (*TokenPrice) Marshal 

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

func (*TokenPrice) MarshalTo 

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

func (*TokenPrice) MarshalToSizedBuffer 

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

func (*TokenPrice) ProtoMessage 

func (*TokenPrice) ProtoMessage()

func (*TokenPrice) Reset 

func (m *TokenPrice) Reset()

func (*TokenPrice) Size 

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

func (*TokenPrice) String 

func (m *TokenPrice) String() string

func (*TokenPrice) Unmarshal 

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

func (*TokenPrice) XXX_DiscardUnknown 

func (m *TokenPrice) XXX_DiscardUnknown()

func (*TokenPrice) XXX_Marshal 

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

func (*TokenPrice) XXX_Merge 

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

func (*TokenPrice) XXX_Size 

func (m *TokenPrice) XXX_Size() int

func (*TokenPrice) XXX_Unmarshal 

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

type TokenPriceResponse 

type TokenPriceResponse struct {
	// If IBC token, base denom unwrapped (e.g. ibc/... -> uatom)
	BaseDenomUnwrapped string `protobuf:"bytes,1,opt,name=base_denom_unwrapped,json=baseDenomUnwrapped,proto3" json:"base_denom_unwrapped,omitempty"`
	// If IBC token, Quote denom unwrapped (e.g. ibc/... -> uatom)
	QuoteDenomUnwrapped string `protobuf:"bytes,2,opt,name=quote_denom_unwrapped,json=quoteDenomUnwrapped,proto3" json:"quote_denom_unwrapped,omitempty"`
	// The token price object with the remaining price metadata
	TokenPrice TokenPrice `protobuf:"bytes,3,opt,name=token_price,json=tokenPrice,proto3" json:"token_price"`
}

TokenPriceResponse adds human readable info on to of TokenPrice

func (*TokenPriceResponse) Descriptor 

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

func (*TokenPriceResponse) GetBaseDenomUnwrapped 

func (m *TokenPriceResponse) GetBaseDenomUnwrapped() string

func (*TokenPriceResponse) GetQuoteDenomUnwrapped 

func (m *TokenPriceResponse) GetQuoteDenomUnwrapped() string

func (*TokenPriceResponse) GetTokenPrice 

func (m *TokenPriceResponse) GetTokenPrice() TokenPrice

func (*TokenPriceResponse) Marshal 

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

func (*TokenPriceResponse) MarshalTo 

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

func (*TokenPriceResponse) MarshalToSizedBuffer 

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

func (*TokenPriceResponse) ProtoMessage 

func (*TokenPriceResponse) ProtoMessage()

func (*TokenPriceResponse) Reset 

func (m *TokenPriceResponse) Reset()

func (*TokenPriceResponse) Size 

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

func (*TokenPriceResponse) String 

func (m *TokenPriceResponse) String() string

func (*TokenPriceResponse) Unmarshal 

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

func (*TokenPriceResponse) XXX_DiscardUnknown 

func (m *TokenPriceResponse) XXX_DiscardUnknown()

func (*TokenPriceResponse) XXX_Marshal 

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

func (*TokenPriceResponse) XXX_Merge 

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

func (*TokenPriceResponse) XXX_Size 

func (m *TokenPriceResponse) XXX_Size() int

func (*TokenPriceResponse) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) RegisterTokenPriceQuery 

func (*UnimplementedMsgServer) RegisterTokenPriceQuery(ctx context.Context, req *MsgRegisterTokenPriceQuery) (*MsgRegisterTokenPriceQueryResponse, error)

func (*UnimplementedMsgServer) RemoveTokenPriceQuery 

func (*UnimplementedMsgServer) RemoveTokenPriceQuery(ctx context.Context, req *MsgRemoveTokenPriceQuery) (*MsgRemoveTokenPriceQueryResponse, 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) Params 

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

func (*UnimplementedQueryServer) TokenPrice 

func (*UnimplementedQueryServer) TokenPrice(ctx context.Context, req *QueryTokenPriceRequest) (*TokenPriceResponse, error)

func (*UnimplementedQueryServer) TokenPriceForQuoteDenom 

func (*UnimplementedQueryServer) TokenPriceForQuoteDenom(ctx context.Context, req *QueryTokenPriceForQuoteDenomRequest) (*QueryTokenPriceForQuoteDenomResponse, error)

func (*UnimplementedQueryServer) TokenPrices 

func (*UnimplementedQueryServer) TokenPrices(ctx context.Context, req *QueryTokenPricesRequest) (*QueryTokenPricesResponse, 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.