types

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2022 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ModuleName     = "oracle"
	ParamsSubspace = ModuleName
	QuerierRoute   = ModuleName
	RouterKey      = ModuleName
	StoreKey       = ModuleName
)
View Source 
const (
	MaxMarketSymbolLength = 8
	MaxAssetNameLength    = 16
)
View Source 
const (
	DefaultIBCPort          = "oracle"
	DefaultIBCVersion       = "comdex-ics-01"
	DefaultOracleAskCount   = 1
	DefaultOracleMinCount   = 1
	DefaultOracleMultiplier = 9
)
View Source 
const (
	ProposalTypeUpdateAdmin = "UpdateOracleAdmin"
)

Variables

View Source 
var (
	ErrorInvalidDecimals         = errors.Register(ModuleName, 101, "invalid decimals")
	ErrorInvalidDenom            = errors.Register(ModuleName, 102, "invalid denom")
	ErrorInvalidFrom             = errors.Register(ModuleName, 103, "invalid from")
	ErrorInvalidID               = errors.Register(ModuleName, 104, "invalid id")
	ErrorInvalidLiquidationRatio = errors.Register(ModuleName, 105, "invalid liquidation ratio")
	ErrorInvalidName             = errors.Register(ModuleName, 106, "invalid name")
	ErrorInvalidScriptID         = errors.Register(ModuleName, 107, "invalid script id")
	ErrorInvalidSourceChannel    = errors.Register(ModuleName, 108, "invalid source channel")
	ErrorInvalidSourcePort       = errors.Register(ModuleName, 109, "invalid source port")
	ErrorInvalidSymbol           = errors.Register(ModuleName, 110, "invalid symbol")
	ErrorInvalidSymbols          = errors.Register(ModuleName, 111, "invalid symbols")
)
View Source 
var (
	ErrorAssetDoesNotExist          = errors.Register(ModuleName, 201, "asset does not exist")
	ErrorDuplicateAsset             = errors.Register(ModuleName, 202, "duplicate asset")
	ErrorDuplicateMarket            = errors.Register(ModuleName, 203, "duplicate market")
	ErrorDuplicateMarketForAsset    = errors.Register(ModuleName, 204, "duplicate market for asset")
	ErrorMarketDoesNotExist         = errors.Register(ModuleName, 205, "market does not exist")
	ErrorMarketForAssetDoesNotExist = errors.Register(ModuleName, 206, "market for asset does not exist")
	ErrorPairDoesNotExist           = errors.Register(ModuleName, 207, "pair does not exist")
	ErrorScriptIDMismatch           = errors.Register(ModuleName, 208, "script id mismatch")
	ErrorUnauthorized               = errors.Register(ModuleName, 209, "unauthorized")
)
View Source 
var (
	ErrorInvalidVersion   = errors.Register(ModuleName, 501, "invalid version")
	ErrorMaxAssetChannels = errors.Register(ModuleName, 502, "max asset channels")
)
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 (
	ErrInvalidLengthGov        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGov          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGov = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	CalldataIDKey = []byte{0x02}

	CalldataKeyPrefix = []byte{0x12}
	MarketKeyPrefix   = []byte{0x13}

	MarketForAssetKeyPrefix = []byte{0x22}
	PriceForMarketKeyPrefix = []byte{0x23}
)
View Source 
var (
	ErrInvalidLengthMsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsg = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthOracle        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOracle          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOracle = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyIBCPort          = []byte("IBCPort")
	KeyIBCVersion       = []byte("IBCVersion")
	KeyOracleAskCount   = []byte("OracleAskCount")
	KeyOracleMinCount   = []byte("OracleMinCount")
	KeyOracleMultiplier = []byte("OracleMultiplier")
)
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 (
	ErrInvalidLengthQuerier        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuerier          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuerier = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrorUnknownMsgType = errors.Register(ModuleName, 301, "unknown message type")
)
View Source 
var (
	ErrorUnknownProposalType = errors.Register(ModuleName, 401, "unknown proposal type")
)
View Source 
var (
	ModuleCdc = codec.NewProtoCodec(types.NewInterfaceRegistry())
)

Functions

func CalldataKey 

func CalldataKey(id uint64) []byte

func MarketForAssetKey 

func MarketForAssetKey(id uint64) []byte

func MarketKey 

func MarketKey(symbol string) []byte

func ParamKeyTable 

func ParamKeyTable() paramstypes.KeyTable

func PriceForMarketKey 

func PriceForMarketKey(symbol string) []byte

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterMsgServiceServer 

func RegisterMsgServiceServer(s grpc1.Server, srv MsgServiceServer)

func RegisterQueryServiceHandler 

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

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

func RegisterQueryServiceHandlerClient 

func RegisterQueryServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryServiceClient) error

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

func RegisterQueryServiceHandlerFromEndpoint 

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

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

func RegisterQueryServiceHandlerServer 

func RegisterQueryServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServiceServer) error

RegisterQueryServiceHandlerServer registers the http handlers for service QueryService to "mux". UnaryRPC :call QueryServiceServer 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 RegisterQueryServiceHandlerFromEndpoint instead.

func RegisterQueryServiceServer 

func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)

func ValidateGenesis 

func ValidateGenesis(_ *GenesisState) error

Types

type Calldata 

type Calldata struct {
	Symbols    []string `protobuf:"bytes,1,rep,name=symbols,proto3" json:"symbols,omitempty" yaml:"symbols"`
	Multiplier uint64   `protobuf:"varint,2,opt,name=multiplier,proto3" json:"multiplier,omitempty" yaml:"multiplier"`
}

func (*Calldata) Descriptor 

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

func (*Calldata) Marshal 

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

func (*Calldata) MarshalTo 

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

func (*Calldata) MarshalToSizedBuffer 

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

func (*Calldata) ProtoMessage 

func (*Calldata) ProtoMessage()

func (*Calldata) Reset 

func (m *Calldata) Reset()

func (*Calldata) Size 

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

func (*Calldata) String 

func (m *Calldata) String() string

func (*Calldata) Unmarshal 

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

func (*Calldata) XXX_DiscardUnknown 

func (m *Calldata) XXX_DiscardUnknown()

func (*Calldata) XXX_Marshal 

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

func (*Calldata) XXX_Merge 

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

func (*Calldata) XXX_Size 

func (m *Calldata) XXX_Size() int

func (*Calldata) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Markets []Market `protobuf:"bytes,1,rep,name=markets,proto3" json:"markets" yaml:"markets"`
	Params  Params   `protobuf:"bytes,2,opt,name=params,proto3" json:"params" yaml:"params"`
}

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

func NewGenesisState 

func NewGenesisState(markets []Market, params Params) *GenesisState

func (*GenesisState) Descriptor 

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

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

type IBCParams struct {
	Port    string `protobuf:"bytes,1,opt,name=port,proto3" json:"port,omitempty" yaml:"port"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty" yaml:"version"`
}

func DefaultIBCParams 

func DefaultIBCParams() IBCParams

func NewIBCParams 

func NewIBCParams(port, version string) IBCParams

func (*IBCParams) Descriptor 

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

func (*IBCParams) Marshal 

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

func (*IBCParams) MarshalTo 

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

func (*IBCParams) MarshalToSizedBuffer 

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

func (*IBCParams) ProtoMessage 

func (*IBCParams) ProtoMessage()

func (*IBCParams) Reset 

func (m *IBCParams) Reset()

func (*IBCParams) Size 

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

func (*IBCParams) String 

func (m *IBCParams) String() string

func (*IBCParams) Unmarshal 

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

func (*IBCParams) Validate 

func (m *IBCParams) Validate() error

func (*IBCParams) XXX_DiscardUnknown 

func (m *IBCParams) XXX_DiscardUnknown()

func (*IBCParams) XXX_Marshal 

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

func (*IBCParams) XXX_Merge 

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

func (*IBCParams) XXX_Size 

func (m *IBCParams) XXX_Size() int

func (*IBCParams) XXX_Unmarshal 

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

type Market 

type Market struct {
	Symbol   string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty" yaml:"symbol"`
	ScriptID uint64 `protobuf:"varint,2,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty" yaml:"script_id"`
}

func (*Market) Descriptor 

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

func (*Market) Marshal 

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

func (*Market) MarshalTo 

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

func (*Market) MarshalToSizedBuffer 

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

func (*Market) ProtoMessage 

func (*Market) ProtoMessage()

func (*Market) Reset 

func (m *Market) Reset()

func (*Market) Size 

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

func (*Market) String 

func (m *Market) String() string

func (*Market) Unmarshal 

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

func (*Market) Validate 

func (m *Market) Validate() error

func (*Market) XXX_DiscardUnknown 

func (m *Market) XXX_DiscardUnknown()

func (*Market) XXX_Marshal 

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

func (*Market) XXX_Merge 

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

func (*Market) XXX_Size 

func (m *Market) XXX_Size() int

func (*Market) XXX_Unmarshal 

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

type MsgAddMarketRequest 

type MsgAddMarketRequest struct {
	From     string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
	Symbol   string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty" yaml:"symbol"`
	ScriptID uint64 `protobuf:"varint,3,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty" yaml:"script_id"`
	Id       uint64 `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
}

func NewMsgAddMarketRequest 

func NewMsgAddMarketRequest(from sdk.AccAddress, symbol string, scriptID uint64, assetID uint64) *MsgAddMarketRequest

func (*MsgAddMarketRequest) Descriptor 

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

func (*MsgAddMarketRequest) GetSigners 

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

func (*MsgAddMarketRequest) Marshal 

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

func (*MsgAddMarketRequest) MarshalTo 

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

func (*MsgAddMarketRequest) MarshalToSizedBuffer 

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

func (*MsgAddMarketRequest) ProtoMessage 

func (*MsgAddMarketRequest) ProtoMessage()

func (*MsgAddMarketRequest) Reset 

func (m *MsgAddMarketRequest) Reset()

func (*MsgAddMarketRequest) Size 

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

func (*MsgAddMarketRequest) String 

func (m *MsgAddMarketRequest) String() string

func (*MsgAddMarketRequest) Unmarshal 

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

func (*MsgAddMarketRequest) ValidateBasic 

func (m *MsgAddMarketRequest) ValidateBasic() error

func (*MsgAddMarketRequest) XXX_DiscardUnknown 

func (m *MsgAddMarketRequest) XXX_DiscardUnknown()

func (*MsgAddMarketRequest) XXX_Marshal 

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

func (*MsgAddMarketRequest) XXX_Merge 

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

func (*MsgAddMarketRequest) XXX_Size 

func (m *MsgAddMarketRequest) XXX_Size() int

func (*MsgAddMarketRequest) XXX_Unmarshal 

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

type MsgAddMarketResponse 

type MsgAddMarketResponse struct {
}

func (*MsgAddMarketResponse) Descriptor 

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

func (*MsgAddMarketResponse) Marshal 

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

func (*MsgAddMarketResponse) MarshalTo 

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

func (*MsgAddMarketResponse) MarshalToSizedBuffer 

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

func (*MsgAddMarketResponse) ProtoMessage 

func (*MsgAddMarketResponse) ProtoMessage()

func (*MsgAddMarketResponse) Reset 

func (m *MsgAddMarketResponse) Reset()

func (*MsgAddMarketResponse) Size 

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

func (*MsgAddMarketResponse) String 

func (m *MsgAddMarketResponse) String() string

func (*MsgAddMarketResponse) Unmarshal 

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

func (*MsgAddMarketResponse) XXX_DiscardUnknown 

func (m *MsgAddMarketResponse) XXX_DiscardUnknown()

func (*MsgAddMarketResponse) XXX_Marshal 

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

func (*MsgAddMarketResponse) XXX_Merge 

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

func (*MsgAddMarketResponse) XXX_Size 

func (m *MsgAddMarketResponse) XXX_Size() int

func (*MsgAddMarketResponse) XXX_Unmarshal 

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

type MsgFetchPriceRequest 

type MsgFetchPriceRequest struct {
	From             string                                   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
	SourcePort       string                                   `protobuf:"bytes,2,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty" yaml:"source_port"`
	SourceChannel    string                                   `protobuf:"bytes,3,opt,name=source_channel,json=sourceChannel,proto3" json:"source_channel,omitempty" yaml:"source_channel"`
	TimeoutHeight    types.Height                             `protobuf:"bytes,4,opt,name=timeout_height,json=timeoutHeight,proto3" json:"timeout_height" yaml:"timeout_height"`
	TimeoutTimestamp uint64                                   `` /* 135-byte string literal not displayed */
	Symbols          []string                                 `protobuf:"bytes,6,rep,name=symbols,proto3" json:"symbols,omitempty" yaml:"symbols"`
	ScriptID         uint64                                   `protobuf:"varint,7,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty" yaml:"script_id"`
	FeeLimit         github_com_cosmos_cosmos_sdk_types.Coins `` /* 146-byte string literal not displayed */
	PrepareGas       uint64                                   `protobuf:"varint,9,opt,name=prepare_gas,json=prepareGas,proto3" json:"prepare_gas,omitempty" yaml:"prepare_gas"`
	ExecuteGas       uint64                                   `protobuf:"varint,10,opt,name=execute_gas,json=executeGas,proto3" json:"execute_gas,omitempty" yaml:"execute_gas"`
}

func NewMsgFetchPriceRequest 

func NewMsgFetchPriceRequest(
	from sdk.AccAddress,
	sourcePort, sourceChannel string,
	timeoutHeight ibcclienttypes.Height,
	timeoutTimestamp uint64,
	symbols []string,
	scriptID uint64,
	feeLimit sdk.Coins,
	prepareGas, executeGas uint64,
) *MsgFetchPriceRequest

func (*MsgFetchPriceRequest) Descriptor 

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

func (*MsgFetchPriceRequest) GetSigners 

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

func (*MsgFetchPriceRequest) Marshal 

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

func (*MsgFetchPriceRequest) MarshalTo 

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

func (*MsgFetchPriceRequest) MarshalToSizedBuffer 

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

func (*MsgFetchPriceRequest) ProtoMessage 

func (*MsgFetchPriceRequest) ProtoMessage()

func (*MsgFetchPriceRequest) Reset 

func (m *MsgFetchPriceRequest) Reset()

func (*MsgFetchPriceRequest) Size 

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

func (*MsgFetchPriceRequest) String 

func (m *MsgFetchPriceRequest) String() string

func (*MsgFetchPriceRequest) Unmarshal 

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

func (*MsgFetchPriceRequest) ValidateBasic 

func (m *MsgFetchPriceRequest) ValidateBasic() error

func (*MsgFetchPriceRequest) XXX_DiscardUnknown 

func (m *MsgFetchPriceRequest) XXX_DiscardUnknown()

func (*MsgFetchPriceRequest) XXX_Marshal 

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

func (*MsgFetchPriceRequest) XXX_Merge 

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

func (*MsgFetchPriceRequest) XXX_Size 

func (m *MsgFetchPriceRequest) XXX_Size() int

func (*MsgFetchPriceRequest) XXX_Unmarshal 

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

type MsgFetchPriceResponse 

type MsgFetchPriceResponse struct {
}

func (*MsgFetchPriceResponse) Descriptor 

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

func (*MsgFetchPriceResponse) Marshal 

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

func (*MsgFetchPriceResponse) MarshalTo 

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

func (*MsgFetchPriceResponse) MarshalToSizedBuffer 

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

func (*MsgFetchPriceResponse) ProtoMessage 

func (*MsgFetchPriceResponse) ProtoMessage()

func (*MsgFetchPriceResponse) Reset 

func (m *MsgFetchPriceResponse) Reset()

func (*MsgFetchPriceResponse) Size 

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

func (*MsgFetchPriceResponse) String 

func (m *MsgFetchPriceResponse) String() string

func (*MsgFetchPriceResponse) Unmarshal 

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

func (*MsgFetchPriceResponse) XXX_DiscardUnknown 

func (m *MsgFetchPriceResponse) XXX_DiscardUnknown()

func (*MsgFetchPriceResponse) XXX_Marshal 

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

func (*MsgFetchPriceResponse) XXX_Merge 

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

func (*MsgFetchPriceResponse) XXX_Size 

func (m *MsgFetchPriceResponse) XXX_Size() int

func (*MsgFetchPriceResponse) XXX_Unmarshal 

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

type MsgRemoveMarketForAssetRequest 

type MsgRemoveMarketForAssetRequest struct {
	From   string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
	Id     uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Symbol string `protobuf:"bytes,3,opt,name=symbol,proto3" json:"symbol,omitempty" yaml:"symbol"`
}

func NewMsgRemoveMarketForAssetRequest 

func NewMsgRemoveMarketForAssetRequest(from sdk.AccAddress, id uint64, symbol string) *MsgRemoveMarketForAssetRequest

func (*MsgRemoveMarketForAssetRequest) Descriptor 

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

func (*MsgRemoveMarketForAssetRequest) GetSigners 

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

func (*MsgRemoveMarketForAssetRequest) Marshal 

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

func (*MsgRemoveMarketForAssetRequest) MarshalTo 

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

func (*MsgRemoveMarketForAssetRequest) MarshalToSizedBuffer 

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

func (*MsgRemoveMarketForAssetRequest) ProtoMessage 

func (*MsgRemoveMarketForAssetRequest) ProtoMessage()

func (*MsgRemoveMarketForAssetRequest) Reset 

func (m *MsgRemoveMarketForAssetRequest) Reset()

func (*MsgRemoveMarketForAssetRequest) Size 

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

func (*MsgRemoveMarketForAssetRequest) String 

func (m *MsgRemoveMarketForAssetRequest) String() string

func (*MsgRemoveMarketForAssetRequest) Unmarshal 

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

func (*MsgRemoveMarketForAssetRequest) ValidateBasic 

func (m *MsgRemoveMarketForAssetRequest) ValidateBasic() error

func (*MsgRemoveMarketForAssetRequest) XXX_DiscardUnknown 

func (m *MsgRemoveMarketForAssetRequest) XXX_DiscardUnknown()

func (*MsgRemoveMarketForAssetRequest) XXX_Marshal 

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

func (*MsgRemoveMarketForAssetRequest) XXX_Merge 

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

func (*MsgRemoveMarketForAssetRequest) XXX_Size 

func (m *MsgRemoveMarketForAssetRequest) XXX_Size() int

func (*MsgRemoveMarketForAssetRequest) XXX_Unmarshal 

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

type MsgRemoveMarketForAssetResponse 

type MsgRemoveMarketForAssetResponse struct {
}

func (*MsgRemoveMarketForAssetResponse) Descriptor 

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

func (*MsgRemoveMarketForAssetResponse) Marshal 

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

func (*MsgRemoveMarketForAssetResponse) MarshalTo 

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

func (*MsgRemoveMarketForAssetResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveMarketForAssetResponse) ProtoMessage 

func (*MsgRemoveMarketForAssetResponse) ProtoMessage()

func (*MsgRemoveMarketForAssetResponse) Reset 

func (m *MsgRemoveMarketForAssetResponse) Reset()

func (*MsgRemoveMarketForAssetResponse) Size 

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

func (*MsgRemoveMarketForAssetResponse) String 

func (m *MsgRemoveMarketForAssetResponse) String() string

func (*MsgRemoveMarketForAssetResponse) Unmarshal 

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

func (*MsgRemoveMarketForAssetResponse) XXX_DiscardUnknown 

func (m *MsgRemoveMarketForAssetResponse) XXX_DiscardUnknown()

func (*MsgRemoveMarketForAssetResponse) XXX_Marshal 

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

func (*MsgRemoveMarketForAssetResponse) XXX_Merge 

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

func (*MsgRemoveMarketForAssetResponse) XXX_Size 

func (m *MsgRemoveMarketForAssetResponse) XXX_Size() int

func (*MsgRemoveMarketForAssetResponse) XXX_Unmarshal 

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

type MsgServiceClient 

type MsgServiceClient interface {
	MsgAddMarket(ctx context.Context, in *MsgAddMarketRequest, opts ...grpc.CallOption) (*MsgAddMarketResponse, error)
	MsgUpdateMarket(ctx context.Context, in *MsgUpdateMarketRequest, opts ...grpc.CallOption) (*MsgUpdateMarketResponse, error)
	MsgRemoveMarketForAsset(ctx context.Context, in *MsgRemoveMarketForAssetRequest, opts ...grpc.CallOption) (*MsgRemoveMarketForAssetResponse, error)
	MsgFetchPrice(ctx context.Context, in *MsgFetchPriceRequest, opts ...grpc.CallOption) (*MsgFetchPriceResponse, error)
}

MsgServiceClient is the client API for MsgService service.

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

func NewMsgServiceClient 

func NewMsgServiceClient(cc grpc1.ClientConn) MsgServiceClient

type MsgServiceServer 

type MsgServiceServer interface {
	MsgAddMarket(context.Context, *MsgAddMarketRequest) (*MsgAddMarketResponse, error)
	MsgUpdateMarket(context.Context, *MsgUpdateMarketRequest) (*MsgUpdateMarketResponse, error)
	MsgRemoveMarketForAsset(context.Context, *MsgRemoveMarketForAssetRequest) (*MsgRemoveMarketForAssetResponse, error)
	MsgFetchPrice(context.Context, *MsgFetchPriceRequest) (*MsgFetchPriceResponse, error)
}

MsgServiceServer is the server API for MsgService service.

type MsgUpdateMarketRequest 

type MsgUpdateMarketRequest struct {
	From     string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
	Symbol   string `protobuf:"bytes,2,opt,name=symbol,proto3" json:"symbol,omitempty" yaml:"symbol"`
	ScriptID uint64 `protobuf:"varint,3,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty" yaml:"script_id"`
}

func NewMsgUpdateMarketRequest 

func NewMsgUpdateMarketRequest(from sdk.AccAddress, symbol string, scriptID uint64) *MsgUpdateMarketRequest

func (*MsgUpdateMarketRequest) Descriptor 

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

func (*MsgUpdateMarketRequest) GetSigners 

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

func (*MsgUpdateMarketRequest) Marshal 

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

func (*MsgUpdateMarketRequest) MarshalTo 

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

func (*MsgUpdateMarketRequest) MarshalToSizedBuffer 

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

func (*MsgUpdateMarketRequest) ProtoMessage 

func (*MsgUpdateMarketRequest) ProtoMessage()

func (*MsgUpdateMarketRequest) Reset 

func (m *MsgUpdateMarketRequest) Reset()

func (*MsgUpdateMarketRequest) Size 

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

func (*MsgUpdateMarketRequest) String 

func (m *MsgUpdateMarketRequest) String() string

func (*MsgUpdateMarketRequest) Unmarshal 

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

func (*MsgUpdateMarketRequest) ValidateBasic 

func (m *MsgUpdateMarketRequest) ValidateBasic() error

func (*MsgUpdateMarketRequest) XXX_DiscardUnknown 

func (m *MsgUpdateMarketRequest) XXX_DiscardUnknown()

func (*MsgUpdateMarketRequest) XXX_Marshal 

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

func (*MsgUpdateMarketRequest) XXX_Merge 

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

func (*MsgUpdateMarketRequest) XXX_Size 

func (m *MsgUpdateMarketRequest) XXX_Size() int

func (*MsgUpdateMarketRequest) XXX_Unmarshal 

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

type MsgUpdateMarketResponse 

type MsgUpdateMarketResponse struct {
}

func (*MsgUpdateMarketResponse) Descriptor 

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

func (*MsgUpdateMarketResponse) Marshal 

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

func (*MsgUpdateMarketResponse) MarshalTo 

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

func (*MsgUpdateMarketResponse) MarshalToSizedBuffer 

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

func (*MsgUpdateMarketResponse) ProtoMessage 

func (*MsgUpdateMarketResponse) ProtoMessage()

func (*MsgUpdateMarketResponse) Reset 

func (m *MsgUpdateMarketResponse) Reset()

func (*MsgUpdateMarketResponse) Size 

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

func (*MsgUpdateMarketResponse) String 

func (m *MsgUpdateMarketResponse) String() string

func (*MsgUpdateMarketResponse) Unmarshal 

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

func (*MsgUpdateMarketResponse) XXX_DiscardUnknown 

func (m *MsgUpdateMarketResponse) XXX_DiscardUnknown()

func (*MsgUpdateMarketResponse) XXX_Marshal 

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

func (*MsgUpdateMarketResponse) XXX_Merge 

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

func (*MsgUpdateMarketResponse) XXX_Size 

func (m *MsgUpdateMarketResponse) XXX_Size() int

func (*MsgUpdateMarketResponse) XXX_Unmarshal 

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

type OracleParams 

type OracleParams struct {
	AskCount   uint64 `protobuf:"varint,1,opt,name=ask_count,json=askCount,proto3" json:"ask_count,omitempty" yaml:"ask_count"`
	MinCount   uint64 `protobuf:"varint,2,opt,name=min_count,json=minCount,proto3" json:"min_count,omitempty" yaml:"min_count"`
	Multiplier uint64 `protobuf:"varint,3,opt,name=multiplier,proto3" json:"multiplier,omitempty" yaml:"multiplier"`
}

func DefaultOracleParams 

func DefaultOracleParams() OracleParams

func NewOracleParams 

func NewOracleParams(askCount, minCount, multiplier uint64) OracleParams

func (*OracleParams) Descriptor 

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

func (*OracleParams) Marshal 

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

func (*OracleParams) MarshalTo 

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

func (*OracleParams) MarshalToSizedBuffer 

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

func (*OracleParams) ProtoMessage 

func (*OracleParams) ProtoMessage()

func (*OracleParams) Reset 

func (m *OracleParams) Reset()

func (*OracleParams) Size 

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

func (*OracleParams) String 

func (m *OracleParams) String() string

func (*OracleParams) Unmarshal 

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

func (*OracleParams) Validate 

func (m *OracleParams) Validate() error

func (*OracleParams) XXX_DiscardUnknown 

func (m *OracleParams) XXX_DiscardUnknown()

func (*OracleParams) XXX_Marshal 

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

func (*OracleParams) XXX_Merge 

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

func (*OracleParams) XXX_Size 

func (m *OracleParams) XXX_Size() int

func (*OracleParams) XXX_Unmarshal 

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

type Params 

type Params struct {
	IBC    IBCParams    `protobuf:"bytes,1,opt,name=ibc,proto3" json:"ibc" yaml:"ibc"`
	Oracle OracleParams `protobuf:"bytes,2,opt,name=oracle,proto3" json:"oracle" yaml:"oracle"`
}

func DefaultParams 

func DefaultParams() Params

func NewParams 

func NewParams(ibc IBCParams, oracle OracleParams) Params

func (*Params) Descriptor 

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

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 (m *Params) ParamSetPairs() paramstypes.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) Validate 

func (m *Params) Validate() 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 QueryMarketRequest 

type QueryMarketRequest struct {
	Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty" yaml:"symbol"`
}

func (*QueryMarketRequest) Descriptor 

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

func (*QueryMarketRequest) Marshal 

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

func (*QueryMarketRequest) MarshalTo 

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

func (*QueryMarketRequest) MarshalToSizedBuffer 

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

func (*QueryMarketRequest) ProtoMessage 

func (*QueryMarketRequest) ProtoMessage()

func (*QueryMarketRequest) Reset 

func (m *QueryMarketRequest) Reset()

func (*QueryMarketRequest) Size 

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

func (*QueryMarketRequest) String 

func (m *QueryMarketRequest) String() string

func (*QueryMarketRequest) Unmarshal 

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

func (*QueryMarketRequest) XXX_DiscardUnknown 

func (m *QueryMarketRequest) XXX_DiscardUnknown()

func (*QueryMarketRequest) XXX_Marshal 

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

func (*QueryMarketRequest) XXX_Merge 

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

func (*QueryMarketRequest) XXX_Size 

func (m *QueryMarketRequest) XXX_Size() int

func (*QueryMarketRequest) XXX_Unmarshal 

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

type QueryMarketResponse 

type QueryMarketResponse struct {
	Market Market `protobuf:"bytes,1,opt,name=market,proto3" json:"market" yaml:"market"`
}

func (*QueryMarketResponse) Descriptor 

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

func (*QueryMarketResponse) Marshal 

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

func (*QueryMarketResponse) MarshalTo 

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

func (*QueryMarketResponse) MarshalToSizedBuffer 

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

func (*QueryMarketResponse) ProtoMessage 

func (*QueryMarketResponse) ProtoMessage()

func (*QueryMarketResponse) Reset 

func (m *QueryMarketResponse) Reset()

func (*QueryMarketResponse) Size 

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

func (*QueryMarketResponse) String 

func (m *QueryMarketResponse) String() string

func (*QueryMarketResponse) Unmarshal 

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

func (*QueryMarketResponse) XXX_DiscardUnknown 

func (m *QueryMarketResponse) XXX_DiscardUnknown()

func (*QueryMarketResponse) XXX_Marshal 

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

func (*QueryMarketResponse) XXX_Merge 

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

func (*QueryMarketResponse) XXX_Size 

func (m *QueryMarketResponse) XXX_Size() int

func (*QueryMarketResponse) XXX_Unmarshal 

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

type QueryMarketsRequest 

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

func (*QueryMarketsRequest) Descriptor 

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

func (*QueryMarketsRequest) Marshal 

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

func (*QueryMarketsRequest) MarshalTo 

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

func (*QueryMarketsRequest) MarshalToSizedBuffer 

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

func (*QueryMarketsRequest) ProtoMessage 

func (*QueryMarketsRequest) ProtoMessage()

func (*QueryMarketsRequest) Reset 

func (m *QueryMarketsRequest) Reset()

func (*QueryMarketsRequest) Size 

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

func (*QueryMarketsRequest) String 

func (m *QueryMarketsRequest) String() string

func (*QueryMarketsRequest) Unmarshal 

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

func (*QueryMarketsRequest) XXX_DiscardUnknown 

func (m *QueryMarketsRequest) XXX_DiscardUnknown()

func (*QueryMarketsRequest) XXX_Marshal 

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

func (*QueryMarketsRequest) XXX_Merge 

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

func (*QueryMarketsRequest) XXX_Size 

func (m *QueryMarketsRequest) XXX_Size() int

func (*QueryMarketsRequest) XXX_Unmarshal 

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

type QueryMarketsResponse 

type QueryMarketsResponse struct {
	Markets    []Market            `protobuf:"bytes,1,rep,name=markets,proto3" json:"markets" yaml:"markets"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty" yaml:"pagination"`
}

func (*QueryMarketsResponse) Descriptor 

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

func (*QueryMarketsResponse) Marshal 

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

func (*QueryMarketsResponse) MarshalTo 

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

func (*QueryMarketsResponse) MarshalToSizedBuffer 

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

func (*QueryMarketsResponse) ProtoMessage 

func (*QueryMarketsResponse) ProtoMessage()

func (*QueryMarketsResponse) Reset 

func (m *QueryMarketsResponse) Reset()

func (*QueryMarketsResponse) Size 

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

func (*QueryMarketsResponse) String 

func (m *QueryMarketsResponse) String() string

func (*QueryMarketsResponse) Unmarshal 

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

func (*QueryMarketsResponse) XXX_DiscardUnknown 

func (m *QueryMarketsResponse) XXX_DiscardUnknown()

func (*QueryMarketsResponse) XXX_Marshal 

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

func (*QueryMarketsResponse) XXX_Merge 

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

func (*QueryMarketsResponse) XXX_Size 

func (m *QueryMarketsResponse) XXX_Size() int

func (*QueryMarketsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

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" yaml:"params"`
}

func (*QueryParamsResponse) Descriptor 

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

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 QueryServiceClient 

type QueryServiceClient interface {
	QueryMarkets(ctx context.Context, in *QueryMarketsRequest, opts ...grpc.CallOption) (*QueryMarketsResponse, error)
	QueryMarket(ctx context.Context, in *QueryMarketRequest, opts ...grpc.CallOption) (*QueryMarketResponse, error)
	QueryParams(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
}

QueryServiceClient is the client API for QueryService service.

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

func NewQueryServiceClient 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	QueryMarkets(context.Context, *QueryMarketsRequest) (*QueryMarketsResponse, error)
	QueryMarket(context.Context, *QueryMarketRequest) (*QueryMarketResponse, error)
	QueryParams(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServiceServer is the server API for QueryService service.

type Result 

type Result struct {
	Rates []uint64 `protobuf:"varint,1,rep,packed,name=rates,proto3" json:"rates,omitempty" yaml:"rates"`
}

func (*Result) Descriptor 

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

func (*Result) Marshal 

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

func (*Result) MarshalTo 

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

func (*Result) MarshalToSizedBuffer 

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

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

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

func (*Result) String 

func (m *Result) String() string

func (*Result) Unmarshal 

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

func (*Result) XXX_DiscardUnknown 

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal 

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

func (*Result) XXX_Merge 

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

func (*Result) XXX_Size 

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal 

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

type UnimplementedMsgServiceServer 

type UnimplementedMsgServiceServer struct {
}

UnimplementedMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServiceServer) MsgAddMarket 

func (*UnimplementedMsgServiceServer) MsgAddMarket(ctx context.Context, req *MsgAddMarketRequest) (*MsgAddMarketResponse, error)

func (*UnimplementedMsgServiceServer) MsgFetchPrice 

func (*UnimplementedMsgServiceServer) MsgFetchPrice(ctx context.Context, req *MsgFetchPriceRequest) (*MsgFetchPriceResponse, error)

func (*UnimplementedMsgServiceServer) MsgRemoveMarketForAsset 

func (*UnimplementedMsgServiceServer) MsgRemoveMarketForAsset(ctx context.Context, req *MsgRemoveMarketForAssetRequest) (*MsgRemoveMarketForAssetResponse, error)

func (*UnimplementedMsgServiceServer) MsgUpdateMarket 

func (*UnimplementedMsgServiceServer) MsgUpdateMarket(ctx context.Context, req *MsgUpdateMarketRequest) (*MsgUpdateMarketResponse, error)

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) QueryMarket 

func (*UnimplementedQueryServiceServer) QueryMarket(ctx context.Context, req *QueryMarketRequest) (*QueryMarketResponse, error)

func (*UnimplementedQueryServiceServer) QueryMarkets 

func (*UnimplementedQueryServiceServer) QueryMarkets(ctx context.Context, req *QueryMarketsRequest) (*QueryMarketsResponse, error)

func (*UnimplementedQueryServiceServer) QueryParams 

func (*UnimplementedQueryServiceServer) QueryParams(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

type UpdateAdminProposal 

type UpdateAdminProposal struct {
	Title       string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty" yaml:"title"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty" yaml:"description"`
	Address     string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
}

func (*UpdateAdminProposal) Descriptor 

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

func (*UpdateAdminProposal) GetDescription 

func (m *UpdateAdminProposal) GetDescription() string

func (*UpdateAdminProposal) GetTitle 

func (m *UpdateAdminProposal) GetTitle() string

func (*UpdateAdminProposal) Marshal 

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

func (*UpdateAdminProposal) MarshalTo 

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

func (*UpdateAdminProposal) MarshalToSizedBuffer 

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

func (*UpdateAdminProposal) ProposalRoute 

func (m *UpdateAdminProposal) ProposalRoute() string

func (*UpdateAdminProposal) ProposalType 

func (m *UpdateAdminProposal) ProposalType() string

func (*UpdateAdminProposal) ProtoMessage 

func (*UpdateAdminProposal) ProtoMessage()

func (*UpdateAdminProposal) Reset 

func (m *UpdateAdminProposal) Reset()

func (*UpdateAdminProposal) Size 

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

func (*UpdateAdminProposal) String 

func (m *UpdateAdminProposal) String() string

func (*UpdateAdminProposal) Unmarshal 

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

func (*UpdateAdminProposal) ValidateBasic 

func (m *UpdateAdminProposal) ValidateBasic() error

func (*UpdateAdminProposal) XXX_DiscardUnknown 

func (m *UpdateAdminProposal) XXX_DiscardUnknown()

func (*UpdateAdminProposal) XXX_Marshal 

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

func (*UpdateAdminProposal) XXX_Merge 

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

func (*UpdateAdminProposal) XXX_Size 

func (m *UpdateAdminProposal) XXX_Size() int

func (*UpdateAdminProposal) XXX_Unmarshal 

func (m *UpdateAdminProposal) 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.