types

package
v3.0.0 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2022 License: Apache-2.0 Imports: 41 Imported by: 2

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Examples

Constants

View Source 
const (
	EventTypeCreatePair       = "create_pair"
	EventTypeCreatePool       = "create_pool"
	EventTypeCreateRangedPool = "create_ranged_pool"
	EventTypeDeposit          = "deposit"
	EventTypeWithdraw         = "withdraw"
	EventTypeLimitOrder       = "limit_order"
	EventTypeMarketOrder      = "market_order"
	EventTypeMMOrder          = "mm_order"
	EventTypeCancelOrder      = "cancel_order"
	EventTypeCancelAllOrders  = "cancel_all_orders"
	EventTypeCancelMMOrder    = "cancel_mm_order"
	EventTypeDepositResult    = "deposit_result"
	EventTypeWithdrawalResult = "withdrawal_result"
	EventTypeOrderResult      = "order_result"
	EventTypeUserOrderMatched = "user_order_matched"
	EventTypePoolOrderMatched = "pool_order_matched"

	AttributeKeyCreator            = "creator"
	AttributeKeyDepositor          = "depositor"
	AttributeKeyWithdrawer         = "withdrawer"
	AttributeKeyOrderer            = "orderer"
	AttributeKeyBaseCoinDenom      = "base_coin_denom"
	AttributeKeyQuoteCoinDenom     = "quote_coin_denom"
	AttributeKeyDepositCoins       = "deposit_coins"
	AttributeKeyAcceptedCoins      = "accepted_coins"
	AttributeKeyMintedPoolCoin     = "minted_pool_coin"
	AttributeKeyPoolCoin           = "pool_coin"
	AttributeKeyWithdrawnCoins     = "withdrawn_coins"
	AttributeKeyRefundedCoins      = "refunded_coins"
	AttributeKeyReserveAddress     = "reserve_address"
	AttributeKeyEscrowAddress      = "escrow_address"
	AttributeKeyRequestId          = "request_id"
	AttributeKeyPoolId             = "pool_id"
	AttributeKeyPairId             = "pair_id"
	AttributeKeyBatchId            = "batch_id"
	AttributeKeyOrderId            = "order_id"
	AttributeKeyOrderIds           = "order_ids"
	AttributeKeyOrderDirection     = "order_direction"
	AttributeKeyOfferCoin          = "offer_coin"
	AttributeKeyDemandCoinDenom    = "demand_coin_denom"
	AttributeKeyPrice              = "price"
	AttributeKeyAmount             = "amount"
	AttributeKeyOpenAmount         = "open_amount"
	AttributeKeyExpireAt           = "expire_at"
	AttributeKeyRemainingOfferCoin = "remaining_offer_coin"
	AttributeKeyReceivedCoin       = "received_coin"
	AttributeKeyPairIds            = "pair_ids"
	AttributeKeyCanceledOrderIds   = "canceled_order_ids"
	AttributeKeyStatus             = "status"
	AttributeKeyMatchedAmount      = "matched_amount"
	AttributeKeyPaidCoin           = "paid_coin"
)

Event types for the liquidity module.

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

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

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

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName
)
View Source 
const (
	TypeMsgCreatePair       = "create_pair"
	TypeMsgCreatePool       = "create_pool"
	TypeMsgCreateRangedPool = "create_ranged_pool"
	TypeMsgDeposit          = "deposit"
	TypeMsgWithdraw         = "withdraw"
	TypeMsgLimitOrder       = "limit_order"
	TypeMsgMarketOrder      = "market_order"
	TypeMsgMMOrder          = "mm_order"
	TypeMsgCancelOrder      = "cancel_order"
	TypeMsgCancelAllOrders  = "cancel_all_orders"
	TypeMsgCancelMMOrder    = "cancel_mm_order"
)

Message types for the liquidity module

View Source 
const (
	DefaultBatchSize                    uint32 = 1
	DefaultTickPrecision                uint32 = 4
	DefaultMaxNumMarketMakingOrderTicks        = 10
	DefaultMaxOrderLifespan                    = 24 * time.Hour
	DefaultMaxNumActivePoolsPerPair            = 20
)

Liquidity params default values

View Source 
const (
	PoolReserveAddressPrefix  = "PoolReserveAddress"
	PairEscrowAddressPrefix   = "PairEscrowAddress"
	ModuleAddressNameSplitter = "|"
	AddressType               = farmingtypes.AddressType32Bytes
)

General constants

Variables

View Source 
var (
	ErrInsufficientDepositAmount = sdkerrors.Register(ModuleName, 2, "insufficient deposit amount")
	ErrPairAlreadyExists         = sdkerrors.Register(ModuleName, 3, "pair already exists")
	ErrPoolAlreadyExists         = sdkerrors.Register(ModuleName, 4, "pool already exists")
	ErrWrongPoolCoinDenom        = sdkerrors.Register(ModuleName, 5, "wrong pool coin denom")
	ErrInvalidCoinDenom          = sdkerrors.Register(ModuleName, 6, "invalid coin denom")
	ErrNoLastPrice               = sdkerrors.Register(ModuleName, 8, "cannot make a market order to a pair with no last price")
	ErrInsufficientOfferCoin     = sdkerrors.Register(ModuleName, 9, "insufficient offer coin")
	ErrPriceOutOfRange           = sdkerrors.Register(ModuleName, 10, "price out of range limit")
	ErrTooLongOrderLifespan      = sdkerrors.Register(ModuleName, 11, "order lifespan is too long")
	ErrDisabledPool              = sdkerrors.Register(ModuleName, 12, "disabled pool")
	ErrWrongPair                 = sdkerrors.Register(ModuleName, 13, "wrong denom pair")
	ErrSameBatch                 = sdkerrors.Register(ModuleName, 14, "cannot cancel an order within the same batch")
	ErrAlreadyCanceled           = sdkerrors.Register(ModuleName, 15, "the order is already canceled")
	ErrDuplicatePairId           = sdkerrors.Register(ModuleName, 16, "duplicate pair id presents in the pair id list")
	ErrTooSmallOrder             = sdkerrors.Register(ModuleName, 17, "too small order")
	ErrTooLargePool              = sdkerrors.Register(ModuleName, 18, "too large pool")
	ErrTooManyPools              = sdkerrors.Register(ModuleName, 19, "too many pools in the pair")
	ErrPriceNotOnTicks           = sdkerrors.Register(ModuleName, 20, "price is not on ticks")
)

x/liquidity 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 (
	LastPairIdKey = []byte{0xa0} // key for the latest pair id
	LastPoolIdKey = []byte{0xa1} // key for the latest pool id

	PairKeyPrefix               = []byte{0xa5}
	PairIndexKeyPrefix          = []byte{0xa6}
	PairsByDenomsIndexKeyPrefix = []byte{0xa7}

	PoolKeyPrefix                      = []byte{0xab}
	PoolByReserveAddressIndexKeyPrefix = []byte{0xac}
	PoolsByPairIndexKeyPrefix          = []byte{0xad}

	DepositRequestKeyPrefix       = []byte{0xb0}
	DepositRequestIndexKeyPrefix  = []byte{0xb4} // TODO: rearrange prefixes
	WithdrawRequestKeyPrefix      = []byte{0xb1}
	WithdrawRequestIndexKeyPrefix = []byte{0xb5}
	OrderKeyPrefix                = []byte{0xb2}
	OrderIndexKeyPrefix           = []byte{0xb3}
	MMOrderIndexKeyPrefix         = []byte{0xb6}
)
View Source 
var (
	ErrInvalidLengthLiquidity        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLiquidity          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLiquidity = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	DefaultFeeCollectorAddress      = farmingtypes.DeriveAddress(AddressType, ModuleName, "FeeCollector")
	DefaultDustCollectorAddress     = farmingtypes.DeriveAddress(AddressType, ModuleName, "DustCollector")
	DefaultMinInitialPoolCoinSupply = sdk.NewInt(1_000_000_000_000)
	DefaultPairCreationFee          = sdk.NewCoins(sdk.NewInt64Coin(sdk.DefaultBondDenom, 1000000))
	DefaultPoolCreationFee          = sdk.NewCoins(sdk.NewInt64Coin(sdk.DefaultBondDenom, 1000000))
	DefaultMinInitialDepositAmount  = sdk.NewInt(1000000)
	DefaultMaxPriceLimitRatio       = sdk.NewDecWithPrec(1, 1) // 10%
	DefaultSwapFeeRate              = sdk.ZeroDec()
	DefaultWithdrawFeeRate          = sdk.ZeroDec()
	DefaultDepositExtraGas          = sdk.Gas(60000)
	DefaultWithdrawExtraGas         = sdk.Gas(64000)
	DefaultOrderExtraGas            = sdk.Gas(37000)
)

Liquidity params default values

View Source 
var (
	KeyBatchSize                    = []byte("BatchSize")
	KeyTickPrecision                = []byte("TickPrecision")
	KeyFeeCollectorAddress          = []byte("FeeCollectorAddress")
	KeyDustCollectorAddress         = []byte("DustCollectorAddress")
	KeyMinInitialPoolCoinSupply     = []byte("MinInitialPoolCoinSupply")
	KeyPairCreationFee              = []byte("PairCreationFee")
	KeyPoolCreationFee              = []byte("PoolCreationFee")
	KeyMinInitialDepositAmount      = []byte("MinInitialDepositAmount")
	KeyMaxPriceLimitRatio           = []byte("MaxPriceLimitRatio")
	KeyMaxNumMarketMakingOrderTicks = []byte("MaxNumMarketMakingOrderTicks")
	KeyMaxOrderLifespan             = []byte("MaxOrderLifespan")
	KeySwapFeeRate                  = []byte("SwapFeeRate")
	KeyWithdrawFeeRate              = []byte("WithdrawFeeRate")
	KeyDepositExtraGas              = []byte("DepositExtraGas")
	KeyWithdrawExtraGas             = []byte("WithdrawExtraGas")
	KeyOrderExtraGas                = []byte("OrderExtraGas")
	KeyMaxNumActivePoolsPerPair     = []byte("MaxNumActivePoolsPerPair")
)
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")
)
View Source 
var (
	// GlobalEscrowAddress is an escrow for deposit/withdraw requests.
	GlobalEscrowAddress = farmingtypes.DeriveAddress(AddressType, ModuleName, "GlobalEscrow")
)
View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)
View Source 
var OrderDirection_name = map[int32]string{
	0: "ORDER_DIRECTION_UNSPECIFIED",
	1: "ORDER_DIRECTION_BUY",
	2: "ORDER_DIRECTION_SELL",
}
View Source 
var OrderDirection_value = map[string]int32{
	"ORDER_DIRECTION_UNSPECIFIED": 0,
	"ORDER_DIRECTION_BUY":         1,
	"ORDER_DIRECTION_SELL":        2,
}
View Source 
var OrderStatus_name = map[int32]string{
	0: "ORDER_STATUS_UNSPECIFIED",
	1: "ORDER_STATUS_NOT_EXECUTED",
	2: "ORDER_STATUS_NOT_MATCHED",
	3: "ORDER_STATUS_PARTIALLY_MATCHED",
	4: "ORDER_STATUS_COMPLETED",
	5: "ORDER_STATUS_CANCELED",
	6: "ORDER_STATUS_EXPIRED",
}
View Source 
var OrderStatus_value = map[string]int32{
	"ORDER_STATUS_UNSPECIFIED":       0,
	"ORDER_STATUS_NOT_EXECUTED":      1,
	"ORDER_STATUS_NOT_MATCHED":       2,
	"ORDER_STATUS_PARTIALLY_MATCHED": 3,
	"ORDER_STATUS_COMPLETED":         4,
	"ORDER_STATUS_CANCELED":          5,
	"ORDER_STATUS_EXPIRED":           6,
}
View Source 
var OrderType_name = map[int32]string{
	0: "ORDER_TYPE_UNSPECIFIED",
	1: "ORDER_TYPE_LIMIT",
	2: "ORDER_TYPE_MARKET",
	3: "ORDER_TYPE_MM",
}
View Source 
var OrderType_value = map[string]int32{
	"ORDER_TYPE_UNSPECIFIED": 0,
	"ORDER_TYPE_LIMIT":       1,
	"ORDER_TYPE_MARKET":      2,
	"ORDER_TYPE_MM":          3,
}
View Source 
var PoolType_name = map[int32]string{
	0: "POOL_TYPE_UNSPECIFIED",
	1: "POOL_TYPE_BASIC",
	2: "POOL_TYPE_RANGED",
}
View Source 
var PoolType_value = map[string]int32{
	"POOL_TYPE_UNSPECIFIED": 0,
	"POOL_TYPE_BASIC":       1,
	"POOL_TYPE_RANGED":      2,
}
View Source 
var RequestStatus_name = map[int32]string{
	0: "REQUEST_STATUS_UNSPECIFIED",
	1: "REQUEST_STATUS_NOT_EXECUTED",
	2: "REQUEST_STATUS_SUCCEEDED",
	3: "REQUEST_STATUS_FAILED",
}
View Source 
var RequestStatus_value = map[string]int32{
	"REQUEST_STATUS_UNSPECIFIED":  0,
	"REQUEST_STATUS_NOT_EXECUTED": 1,
	"REQUEST_STATUS_SUCCEEDED":    2,
	"REQUEST_STATUS_FAILED":       3,
}

Functions

func FitPriceToTickGap 

func FitPriceToTickGap(price, gap sdk.Dec, down bool) sdk.Dec

FitPriceToTickGap fits price into given tick gap.

func FormatUint64s 

func FormatUint64s(us []uint64) (s string)

FormatUint64s returns comma-separated string representation of a slice of uint64.

func GetDepositRequestIndexKey 

func GetDepositRequestIndexKey(depositor sdk.AccAddress, poolId, reqId uint64) []byte

GetDepositRequestIndexKey returns the index key to map deposit requests with a depositor.

func GetDepositRequestIndexKeyPrefix 

func GetDepositRequestIndexKeyPrefix(depositor sdk.AccAddress) []byte

GetDepositRequestIndexKeyPrefix returns the index key prefix to iterate deposit requests by a depositor.

func GetDepositRequestKey 

func GetDepositRequestKey(poolId, id uint64) []byte

GetDepositRequestKey returns the store key to retrieve deposit request object from the pool id and request id.

func GetMMOrderIndexKey 

func GetMMOrderIndexKey(orderer sdk.AccAddress, pairId uint64) []byte

GetMMOrderIndexKey returns the store key to retrieve MMOrderIndex object by orderer and pair id.

func GetOrderIndexKey 

func GetOrderIndexKey(orderer sdk.AccAddress, pairId, orderId uint64) []byte

GetOrderIndexKey returns the index key to map orders with an orderer.

func GetOrderIndexKeyPrefix 

func GetOrderIndexKeyPrefix(orderer sdk.AccAddress) []byte

GetOrderIndexKeyPrefix returns the index key prefix to iterate orders by an orderer.

func GetOrderKey 

func GetOrderKey(pairId, id uint64) []byte

GetOrderKey returns the store key to retrieve order object from the pair id and request id.

func GetOrdersByPairKeyPrefix 

func GetOrdersByPairKeyPrefix(pairId uint64) []byte

GetOrdersByPairKeyPrefix returns the store key to iterate orders by pair.

func GetPairIndexKey 

func GetPairIndexKey(baseCoinDenom, quoteCoinDenom string) []byte

GetPairIndexKey returns the index key to get a pair by denoms.

func GetPairKey 

func GetPairKey(pairId uint64) []byte

GetPairKey returns the store key to retrieve pair object from the pair id.

func GetPairsByDenomIndexKeyPrefix 

func GetPairsByDenomIndexKeyPrefix(denomA string) []byte

GetPairsByDenomIndexKeyPrefix returns the index key prefix to lookup pairs with given denom.

func GetPairsByDenomsIndexKey 

func GetPairsByDenomsIndexKey(denomA, denomB string, pairId uint64) []byte

GetPairsByDenomsIndexKey returns the index key to lookup pairs with given denoms.

func GetPairsByDenomsIndexKeyPrefix 

func GetPairsByDenomsIndexKeyPrefix(denomA, denomB string) []byte

GetPairsByDenomsIndexKeyPrefix returns the index key prefix to lookup pairs with given denoms.

func GetPoolByReserveAddressIndexKey 

func GetPoolByReserveAddressIndexKey(reserveAddr sdk.AccAddress) []byte

GetPoolByReserveAddressIndexKey returns the index key to retrieve the particular pool.

func GetPoolKey 

func GetPoolKey(poolId uint64) []byte

GetPoolKey returns the store key to retrieve pool object from the pool id.

func GetPoolsByPairIndexKey 

func GetPoolsByPairIndexKey(pairId, poolId uint64) []byte

GetPoolsByPairIndexKey returns the index key to retrieve pool id that is used to iterate pools.

func GetPoolsByPairIndexKeyPrefix 

func GetPoolsByPairIndexKeyPrefix(pairId uint64) []byte

GetPoolsByPairIndexKeyPrefix returns the store key to retrieve pool id to iterate pools.

func GetWithdrawRequestIndexKey 

func GetWithdrawRequestIndexKey(withdrawer sdk.AccAddress, poolId, reqId uint64) []byte

GetWithdrawRequestIndexKey returns the index key to map withdraw requests with a withdrawer.

func GetWithdrawRequestIndexKeyPrefix 

func GetWithdrawRequestIndexKeyPrefix(depositor sdk.AccAddress) []byte

GetWithdrawRequestIndexKeyPrefix returns the index key prefix to iterate withdraw requests by a withdrawer.

func GetWithdrawRequestKey 

func GetWithdrawRequestKey(poolId, id uint64) []byte

GetWithdrawRequestKey returns the store key to retrieve withdraw request object from the pool id and request id.

func IsTooSmallOrderAmount 

func IsTooSmallOrderAmount(amt sdk.Int, price sdk.Dec) bool

IsTooSmallOrderAmount returns whether the order amount is too small for matching, based on the order price.

func LengthPrefixString 

func LengthPrefixString(s string) []byte

LengthPrefixString returns length-prefixed bytes representation of a string.

func MustMarshaOrder 

func MustMarshaOrder(cdc codec.BinaryCodec, order Order) []byte

MustMarshaOrder returns the Order bytes. It throws panic if it fails.

func MustMarshaWithdrawRequest 

func MustMarshaWithdrawRequest(cdc codec.BinaryCodec, msg WithdrawRequest) []byte

MustMarshaWithdrawRequest returns the WithdrawRequest bytes. It throws panic if it fails.

func MustMarshalDepositRequest 

func MustMarshalDepositRequest(cdc codec.BinaryCodec, msg DepositRequest) []byte

MustMarshalDepositRequest returns the DepositRequest bytes. Panics if fails.

func MustMarshalPair 

func MustMarshalPair(cdc codec.BinaryCodec, pair Pair) []byte

MustMarshalPair returns the pair bytes. It throws panic if it fails.

func MustMarshalPool 

func MustMarshalPool(cdc codec.BinaryCodec, pool Pool) []byte

MustMarshalPool returns the pool bytes. It throws panic if it fails.

func OrderBookBasePrice 

func OrderBookBasePrice(ov amm.OrderView, tickPrec int) (sdk.Dec, bool)

func PairEscrowAddress 

func PairEscrowAddress(pairId uint64) sdk.AccAddress

PairEscrowAddress returns a unique address of the pair's escrow.

func ParamKeyTable 

func ParamKeyTable() paramstypes.KeyTable

func ParseDepositRequestIndexKey 

func ParseDepositRequestIndexKey(key []byte) (depositor sdk.AccAddress, poolId, reqId uint64)

ParseDepositRequestIndexKey parses a deposit request index key.

func ParseOrderIndexKey 

func ParseOrderIndexKey(key []byte) (orderer sdk.AccAddress, pairId, orderId uint64)

ParseOrderIndexKey parses an order index key.

func ParsePairsByDenomsIndexKey 

func ParsePairsByDenomsIndexKey(key []byte) (denomA, denomB string, pairId uint64)

ParsePairsByDenomsIndexKey parses a pair by denom index key.

func ParsePoolCoinDenom 

func ParsePoolCoinDenom(denom string) (poolId uint64, err error)

ParsePoolCoinDenom parses a pool coin denom and returns the pool id.

func ParsePoolsByPairIndexKey 

func ParsePoolsByPairIndexKey(key []byte) (poolId uint64)

ParsePoolsByPairIndexKey parses a pool id from the index key.

func ParseWithdrawRequestIndexKey 

func ParseWithdrawRequestIndexKey(key []byte) (withdrawer sdk.AccAddress, poolId, reqId uint64)

ParseWithdrawRequestIndexKey parses a withdraw request index key.

func PoolCoinDenom 

func PoolCoinDenom(poolId uint64) string

PoolCoinDenom returns a unique pool coin denom for a pool.

func PoolReserveAddress 

func PoolReserveAddress(poolId uint64) sdk.AccAddress

PoolReserveAddress returns a unique pool reserve account address for each pool.

func PriceLimits 

func PriceLimits(lastPrice, priceLimitRatio sdk.Dec, tickPrec int) (lowestPrice, highestPrice sdk.Dec)

PriceLimits returns the lowest and the highest price limits with given last price and price limit ratio.

func PrintOrderBookResponse 

func PrintOrderBookResponse(ob OrderBookResponse, basePrice sdk.Dec)

PrintOrderBookResponse prints out OrderBookResponse in human-readable form.

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces registers the x/liquidity interfaces types with the interface registry.

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/liquidity interfaces and concrete types on the provided LegacyAmino codec. These types are used for Amino JSON serialization.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetModuleAddress(moduleName string) sdk.AccAddress
}

AccountKeeper is the expected account keeper

type BankKeeper 

type BankKeeper interface {
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetSupply(ctx sdk.Context, denom string) sdk.Coin
	IterateTotalSupply(ctx sdk.Context, cb func(sdk.Coin) bool)
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	SendCoins(ctx sdk.Context, fromAddr, toAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	InputOutputCoins(ctx sdk.Context, inputs []banktypes.Input, outputs []banktypes.Output) error
}

BankKeeper is the expected bank keeper

type BulkSendCoinsOperation 

type BulkSendCoinsOperation struct {
	// contains filtered or unexported fields
}

BulkSendCoinsOperation holds a list of SendCoins operations for bulk execution.

func NewBulkSendCoinsOperation 

func NewBulkSendCoinsOperation() *BulkSendCoinsOperation

NewBulkSendCoinsOperation returns an empty BulkSendCoinsOperation.

func (*BulkSendCoinsOperation) QueueSendCoins 

func (op *BulkSendCoinsOperation) QueueSendCoins(fromAddr, toAddr sdk.AccAddress, amt sdk.Coins)

QueueSendCoins queues a BankKeeper.SendCoins operation for later execution.

func (*BulkSendCoinsOperation) Run 

func (op *BulkSendCoinsOperation) Run(ctx sdk.Context, bankKeeper BankKeeper) error

Run runs BankKeeper.InputOutputCoins once for queued operations.

type DepositRequest 

type DepositRequest struct {
	// id specifies the id for the request
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// pool_id specifies the pool id
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// msg_height specifies the block height when the request is stored for the batch execution
	MsgHeight int64 `protobuf:"varint,3,opt,name=msg_height,json=msgHeight,proto3" json:"msg_height,omitempty"`
	// depositor specifies the bech32-encoded address that makes a deposit to the pool
	Depositor string `protobuf:"bytes,4,opt,name=depositor,proto3" json:"depositor,omitempty"`
	// deposit_coins specifies the amount of coins to deposit.
	DepositCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	// accepted_coins specifies the amount of coins that are accepted.
	AcceptedCoins  github_com_cosmos_cosmos_sdk_types.Coins `` /* 144-byte string literal not displayed */
	MintedPoolCoin types.Coin                               `protobuf:"bytes,7,opt,name=minted_pool_coin,json=mintedPoolCoin,proto3" json:"minted_pool_coin"`
	Status         RequestStatus                            `protobuf:"varint,8,opt,name=status,proto3,enum=crescent.liquidity.v1beta1.RequestStatus" json:"status,omitempty"`
}

DepositRequest defines a deposit request.

func MustUnmarshalDepositRequest 

func MustUnmarshalDepositRequest(cdc codec.BinaryCodec, value []byte) DepositRequest

MustUnmarshalDepositRequest returns the DepositRequest from bytes. It throws panic if it fails.

func NewDepositRequest 

func NewDepositRequest(msg *MsgDeposit, pool Pool, id uint64, msgHeight int64) DepositRequest

NewDepositRequest returns a new DepositRequest.

func UnmarshalDepositRequest 

func UnmarshalDepositRequest(cdc codec.BinaryCodec, value []byte) (msg DepositRequest, err error)

UnmarshalDepositRequest returns the DepositRequest from bytes.

func (*DepositRequest) Descriptor 

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

func (DepositRequest) GetDepositor 

func (req DepositRequest) GetDepositor() sdk.AccAddress

func (*DepositRequest) Marshal 

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

func (*DepositRequest) MarshalTo 

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

func (*DepositRequest) MarshalToSizedBuffer 

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

func (*DepositRequest) ProtoMessage 

func (*DepositRequest) ProtoMessage()

func (*DepositRequest) Reset 

func (m *DepositRequest) Reset()

func (*DepositRequest) SetStatus 

func (req *DepositRequest) SetStatus(status RequestStatus)

SetStatus sets the request's status. SetStatus is to easily find locations where the status is changed.

func (*DepositRequest) Size 

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

func (*DepositRequest) String 

func (m *DepositRequest) String() string

func (*DepositRequest) Unmarshal 

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

func (DepositRequest) Validate 

func (req DepositRequest) Validate() error

Validate validates DepositRequest for genesis.

func (*DepositRequest) XXX_DiscardUnknown 

func (m *DepositRequest) XXX_DiscardUnknown()

func (*DepositRequest) XXX_Marshal 

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

func (*DepositRequest) XXX_Merge 

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

func (*DepositRequest) XXX_Size 

func (m *DepositRequest) XXX_Size() int

func (*DepositRequest) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params                   Params            `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	LastPairId               uint64            `protobuf:"varint,2,opt,name=last_pair_id,json=lastPairId,proto3" json:"last_pair_id,omitempty"`
	LastPoolId               uint64            `protobuf:"varint,3,opt,name=last_pool_id,json=lastPoolId,proto3" json:"last_pool_id,omitempty"`
	Pairs                    []Pair            `protobuf:"bytes,4,rep,name=pairs,proto3" json:"pairs"`
	Pools                    []Pool            `protobuf:"bytes,5,rep,name=pools,proto3" json:"pools"`
	DepositRequests          []DepositRequest  `protobuf:"bytes,6,rep,name=deposit_requests,json=depositRequests,proto3" json:"deposit_requests"`
	WithdrawRequests         []WithdrawRequest `protobuf:"bytes,7,rep,name=withdraw_requests,json=withdrawRequests,proto3" json:"withdraw_requests"`
	Orders                   []Order           `protobuf:"bytes,8,rep,name=orders,proto3" json:"orders"`
	MarketMakingOrderIndexes []MMOrderIndex    `` /* 127-byte string literal not displayed */
}

GenesisState defines the liquidity module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

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

func (genState GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type MMOrderIndex 

type MMOrderIndex struct {
	Orderer  string   `protobuf:"bytes,1,opt,name=orderer,proto3" json:"orderer,omitempty"`
	PairId   uint64   `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	OrderIds []uint64 `protobuf:"varint,3,rep,packed,name=order_ids,json=orderIds,proto3" json:"order_ids,omitempty"`
}

MMOrderIndex defines an index type to quickly find market making orders from an orderer.

func NewMMOrderIndex 

func NewMMOrderIndex(orderer sdk.AccAddress, pairId uint64, orderIds []uint64) MMOrderIndex

func (*MMOrderIndex) Descriptor 

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

func (MMOrderIndex) GetOrderer 

func (index MMOrderIndex) GetOrderer() sdk.AccAddress

func (*MMOrderIndex) Marshal 

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

func (*MMOrderIndex) MarshalTo 

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

func (*MMOrderIndex) MarshalToSizedBuffer 

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

func (*MMOrderIndex) ProtoMessage 

func (*MMOrderIndex) ProtoMessage()

func (*MMOrderIndex) Reset 

func (m *MMOrderIndex) Reset()

func (*MMOrderIndex) Size 

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

func (*MMOrderIndex) String 

func (m *MMOrderIndex) String() string

func (*MMOrderIndex) Unmarshal 

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

func (*MMOrderIndex) XXX_DiscardUnknown 

func (m *MMOrderIndex) XXX_DiscardUnknown()

func (*MMOrderIndex) XXX_Marshal 

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

func (*MMOrderIndex) XXX_Merge 

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

func (*MMOrderIndex) XXX_Size 

func (m *MMOrderIndex) XXX_Size() int

func (*MMOrderIndex) XXX_Unmarshal 

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

type MMOrderTick 

type MMOrderTick struct {
	OfferCoinAmount sdk.Int
	Price           sdk.Dec
	Amount          sdk.Int
}

MMOrderTick holds information about each tick's price and amount of an MMOrder.

func MMOrderTicks 

func MMOrderTicks(dir OrderDirection, minPrice, maxPrice sdk.Dec, amt sdk.Int, maxNumTicks, tickPrec int) (ticks []MMOrderTick)

MMOrderTicks returns fairly distributed tick information with given parameters.

type MsgCancelAllOrders 

type MsgCancelAllOrders struct {
	// orderer specifies the bech32-encoded address that makes an order
	Orderer string `protobuf:"bytes,1,opt,name=orderer,proto3" json:"orderer,omitempty"`
	// pair_ids specifies pair ids to cancel orders
	PairIds []uint64 `protobuf:"varint,2,rep,packed,name=pair_ids,json=pairIds,proto3" json:"pair_ids,omitempty"`
}

MsgCancelAllOrders defines an SDK message for cancelling all orders

func NewMsgCancelAllOrders 

func NewMsgCancelAllOrders(
	orderer sdk.AccAddress,
	pairIds []uint64,
) *MsgCancelAllOrders

NewMsgCancelAllOrders creates a new MsgCancelAllOrders.

func (*MsgCancelAllOrders) Descriptor 

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

func (MsgCancelAllOrders) GetOrderer 

func (msg MsgCancelAllOrders) GetOrderer() sdk.AccAddress

func (MsgCancelAllOrders) GetSignBytes 

func (msg MsgCancelAllOrders) GetSignBytes() []byte

func (MsgCancelAllOrders) GetSigners 

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

func (*MsgCancelAllOrders) Marshal 

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

func (*MsgCancelAllOrders) MarshalTo 

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

func (*MsgCancelAllOrders) MarshalToSizedBuffer 

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

func (*MsgCancelAllOrders) ProtoMessage 

func (*MsgCancelAllOrders) ProtoMessage()

func (*MsgCancelAllOrders) Reset 

func (m *MsgCancelAllOrders) Reset()

func (MsgCancelAllOrders) Route 

func (msg MsgCancelAllOrders) Route() string

func (*MsgCancelAllOrders) Size 

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

func (*MsgCancelAllOrders) String 

func (m *MsgCancelAllOrders) String() string

func (MsgCancelAllOrders) Type 

func (msg MsgCancelAllOrders) Type() string

func (*MsgCancelAllOrders) Unmarshal 

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

func (MsgCancelAllOrders) ValidateBasic 

func (msg MsgCancelAllOrders) ValidateBasic() error

func (*MsgCancelAllOrders) XXX_DiscardUnknown 

func (m *MsgCancelAllOrders) XXX_DiscardUnknown()

func (*MsgCancelAllOrders) XXX_Marshal 

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

func (*MsgCancelAllOrders) XXX_Merge 

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

func (*MsgCancelAllOrders) XXX_Size 

func (m *MsgCancelAllOrders) XXX_Size() int

func (*MsgCancelAllOrders) XXX_Unmarshal 

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

type MsgCancelAllOrdersResponse 

type MsgCancelAllOrdersResponse struct {
}

MsgCancelAllOrdersResponse defines the Msg/CancelAllOrders response type.

func (*MsgCancelAllOrdersResponse) Descriptor 

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

func (*MsgCancelAllOrdersResponse) Marshal 

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

func (*MsgCancelAllOrdersResponse) MarshalTo 

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

func (*MsgCancelAllOrdersResponse) MarshalToSizedBuffer 

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

func (*MsgCancelAllOrdersResponse) ProtoMessage 

func (*MsgCancelAllOrdersResponse) ProtoMessage()

func (*MsgCancelAllOrdersResponse) Reset 

func (m *MsgCancelAllOrdersResponse) Reset()

func (*MsgCancelAllOrdersResponse) Size 

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

func (*MsgCancelAllOrdersResponse) String 

func (m *MsgCancelAllOrdersResponse) String() string

func (*MsgCancelAllOrdersResponse) Unmarshal 

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

func (*MsgCancelAllOrdersResponse) XXX_DiscardUnknown 

func (m *MsgCancelAllOrdersResponse) XXX_DiscardUnknown()

func (*MsgCancelAllOrdersResponse) XXX_Marshal 

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

func (*MsgCancelAllOrdersResponse) XXX_Merge 

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

func (*MsgCancelAllOrdersResponse) XXX_Size 

func (m *MsgCancelAllOrdersResponse) XXX_Size() int

func (*MsgCancelAllOrdersResponse) XXX_Unmarshal 

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

type MsgCancelMMOrder 

type MsgCancelMMOrder struct {
	// orderer specifies the bech32-encoded address that makes an order
	Orderer string `protobuf:"bytes,1,opt,name=orderer,proto3" json:"orderer,omitempty"`
	// pair_id specifies the pair id to cancel orders
	PairId uint64 `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
}

MsgCancelMMOrder defines an SDK message for cancelling all market making orders

func NewMsgCancelMMOrder 

func NewMsgCancelMMOrder(
	orderer sdk.AccAddress,
	pairId uint64,
) *MsgCancelMMOrder

NewMsgCancelMMOrder creates a new MsgCancelMMOrder.

func (*MsgCancelMMOrder) Descriptor 

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

func (MsgCancelMMOrder) GetOrderer 

func (msg MsgCancelMMOrder) GetOrderer() sdk.AccAddress

func (MsgCancelMMOrder) GetSignBytes 

func (msg MsgCancelMMOrder) GetSignBytes() []byte

func (MsgCancelMMOrder) GetSigners 

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

func (*MsgCancelMMOrder) Marshal 

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

func (*MsgCancelMMOrder) MarshalTo 

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

func (*MsgCancelMMOrder) MarshalToSizedBuffer 

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

func (*MsgCancelMMOrder) ProtoMessage 

func (*MsgCancelMMOrder) ProtoMessage()

func (*MsgCancelMMOrder) Reset 

func (m *MsgCancelMMOrder) Reset()

func (MsgCancelMMOrder) Route 

func (msg MsgCancelMMOrder) Route() string

func (*MsgCancelMMOrder) Size 

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

func (*MsgCancelMMOrder) String 

func (m *MsgCancelMMOrder) String() string

func (MsgCancelMMOrder) Type 

func (msg MsgCancelMMOrder) Type() string

func (*MsgCancelMMOrder) Unmarshal 

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

func (MsgCancelMMOrder) ValidateBasic 

func (msg MsgCancelMMOrder) ValidateBasic() error

func (*MsgCancelMMOrder) XXX_DiscardUnknown 

func (m *MsgCancelMMOrder) XXX_DiscardUnknown()

func (*MsgCancelMMOrder) XXX_Marshal 

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

func (*MsgCancelMMOrder) XXX_Merge 

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

func (*MsgCancelMMOrder) XXX_Size 

func (m *MsgCancelMMOrder) XXX_Size() int

func (*MsgCancelMMOrder) XXX_Unmarshal 

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

type MsgCancelMMOrderResponse 

type MsgCancelMMOrderResponse struct {
}

MsgCancelMMOrderResponse defines the Msg/CancelMMOrder response type.

func (*MsgCancelMMOrderResponse) Descriptor 

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

func (*MsgCancelMMOrderResponse) Marshal 

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

func (*MsgCancelMMOrderResponse) MarshalTo 

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

func (*MsgCancelMMOrderResponse) MarshalToSizedBuffer 

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

func (*MsgCancelMMOrderResponse) ProtoMessage 

func (*MsgCancelMMOrderResponse) ProtoMessage()

func (*MsgCancelMMOrderResponse) Reset 

func (m *MsgCancelMMOrderResponse) Reset()

func (*MsgCancelMMOrderResponse) Size 

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

func (*MsgCancelMMOrderResponse) String 

func (m *MsgCancelMMOrderResponse) String() string

func (*MsgCancelMMOrderResponse) Unmarshal 

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

func (*MsgCancelMMOrderResponse) XXX_DiscardUnknown 

func (m *MsgCancelMMOrderResponse) XXX_DiscardUnknown()

func (*MsgCancelMMOrderResponse) XXX_Marshal 

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

func (*MsgCancelMMOrderResponse) XXX_Merge 

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

func (*MsgCancelMMOrderResponse) XXX_Size 

func (m *MsgCancelMMOrderResponse) XXX_Size() int

func (*MsgCancelMMOrderResponse) XXX_Unmarshal 

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

type MsgCancelOrder 

type MsgCancelOrder struct {
	// orderer specifies the bech32-encoded address that makes an order
	Orderer string `protobuf:"bytes,1,opt,name=orderer,proto3" json:"orderer,omitempty"`
	// pair_id specifies the pair id
	PairId uint64 `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	// order_id specifies the order id
	OrderId uint64 `protobuf:"varint,3,opt,name=order_id,json=orderId,proto3" json:"order_id,omitempty"`
}

MsgCancelOrder defines an SDK message for cancelling an order

func NewMsgCancelOrder 

func NewMsgCancelOrder(
	orderer sdk.AccAddress,
	pairId uint64,
	orderId uint64,
) *MsgCancelOrder

NewMsgCancelOrder creates a new MsgCancelOrder.

func (*MsgCancelOrder) Descriptor 

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

func (MsgCancelOrder) GetOrderer 

func (msg MsgCancelOrder) GetOrderer() sdk.AccAddress

func (MsgCancelOrder) GetSignBytes 

func (msg MsgCancelOrder) GetSignBytes() []byte

func (MsgCancelOrder) GetSigners 

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

func (*MsgCancelOrder) Marshal 

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

func (*MsgCancelOrder) MarshalTo 

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

func (*MsgCancelOrder) MarshalToSizedBuffer 

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

func (*MsgCancelOrder) ProtoMessage 

func (*MsgCancelOrder) ProtoMessage()

func (*MsgCancelOrder) Reset 

func (m *MsgCancelOrder) Reset()

func (MsgCancelOrder) Route 

func (msg MsgCancelOrder) Route() string

func (*MsgCancelOrder) Size 

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

func (*MsgCancelOrder) String 

func (m *MsgCancelOrder) String() string

func (MsgCancelOrder) Type 

func (msg MsgCancelOrder) Type() string

func (*MsgCancelOrder) Unmarshal 

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

func (MsgCancelOrder) ValidateBasic 

func (msg MsgCancelOrder) ValidateBasic() error

func (*MsgCancelOrder) XXX_DiscardUnknown 

func (m *MsgCancelOrder) XXX_DiscardUnknown()

func (*MsgCancelOrder) XXX_Marshal 

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

func (*MsgCancelOrder) XXX_Merge 

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

func (*MsgCancelOrder) XXX_Size 

func (m *MsgCancelOrder) XXX_Size() int

func (*MsgCancelOrder) XXX_Unmarshal 

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

type MsgCancelOrderResponse 

type MsgCancelOrderResponse struct {
}

MsgCancelOrderResponse defines the Msg/CancelOrder response type.

func (*MsgCancelOrderResponse) Descriptor 

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

func (*MsgCancelOrderResponse) Marshal 

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

func (*MsgCancelOrderResponse) MarshalTo 

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

func (*MsgCancelOrderResponse) MarshalToSizedBuffer 

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

func (*MsgCancelOrderResponse) ProtoMessage 

func (*MsgCancelOrderResponse) ProtoMessage()

func (*MsgCancelOrderResponse) Reset 

func (m *MsgCancelOrderResponse) Reset()

func (*MsgCancelOrderResponse) Size 

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

func (*MsgCancelOrderResponse) String 

func (m *MsgCancelOrderResponse) String() string

func (*MsgCancelOrderResponse) Unmarshal 

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

func (*MsgCancelOrderResponse) XXX_DiscardUnknown 

func (m *MsgCancelOrderResponse) XXX_DiscardUnknown()

func (*MsgCancelOrderResponse) XXX_Marshal 

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

func (*MsgCancelOrderResponse) XXX_Merge 

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

func (*MsgCancelOrderResponse) XXX_Size 

func (m *MsgCancelOrderResponse) XXX_Size() int

func (*MsgCancelOrderResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// CreatePair defines a method for creating a pair
	CreatePair(ctx context.Context, in *MsgCreatePair, opts ...grpc.CallOption) (*MsgCreatePairResponse, error)
	// CreatePool defines a method for creating a pool
	CreatePool(ctx context.Context, in *MsgCreatePool, opts ...grpc.CallOption) (*MsgCreatePoolResponse, error)
	// CreateRangePool defines a method for creating a ranged pool
	CreateRangedPool(ctx context.Context, in *MsgCreateRangedPool, opts ...grpc.CallOption) (*MsgCreateRangedPoolResponse, error)
	// Deposit defines a method for depositing coins to the pool
	Deposit(ctx context.Context, in *MsgDeposit, opts ...grpc.CallOption) (*MsgDepositResponse, error)
	// Withdraw defines a method for withdrawing pool coin from the pool
	Withdraw(ctx context.Context, in *MsgWithdraw, opts ...grpc.CallOption) (*MsgWithdrawResponse, error)
	// LimitOrder defines a method for making a limit order
	LimitOrder(ctx context.Context, in *MsgLimitOrder, opts ...grpc.CallOption) (*MsgLimitOrderResponse, error)
	// MarketOrder defines a method for making a market order
	MarketOrder(ctx context.Context, in *MsgMarketOrder, opts ...grpc.CallOption) (*MsgMarketOrderResponse, error)
	// MsgMMOrder defines a method for making a MM(market making) order
	MMOrder(ctx context.Context, in *MsgMMOrder, opts ...grpc.CallOption) (*MsgMMOrderResponse, error)
	// CancelOrder defines a method for cancelling an order
	CancelOrder(ctx context.Context, in *MsgCancelOrder, opts ...grpc.CallOption) (*MsgCancelOrderResponse, error)
	// CancelAllOrders defines a method for cancelling all orders
	CancelAllOrders(ctx context.Context, in *MsgCancelAllOrders, opts ...grpc.CallOption) (*MsgCancelAllOrdersResponse, error)
	// CancelMMOrder defines a method for cancelling previously placed market making orders
	CancelMMOrder(ctx context.Context, in *MsgCancelMMOrder, opts ...grpc.CallOption) (*MsgCancelMMOrderResponse, 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 MsgCreatePair 

type MsgCreatePair struct {
	// creator specifies the bech32-encoded address that is the pair creator.
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// base_coin_denom specifies the base coin denom of the pair.
	BaseCoinDenom string `protobuf:"bytes,2,opt,name=base_coin_denom,json=baseCoinDenom,proto3" json:"base_coin_denom,omitempty"`
	// quote_coin_denom specifies the quote coin denom of the pair.
	QuoteCoinDenom string `protobuf:"bytes,3,opt,name=quote_coin_denom,json=quoteCoinDenom,proto3" json:"quote_coin_denom,omitempty"`
}

MsgCreatePair defines an SDK message for creating a pair.

func NewMsgCreatePair 

func NewMsgCreatePair(creator sdk.AccAddress, baseCoinDenom, quoteCoinDenom string) *MsgCreatePair

NewMsgCreatePair returns a new MsgCreatePair.

func (*MsgCreatePair) Descriptor 

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

func (MsgCreatePair) GetCreator 

func (msg MsgCreatePair) GetCreator() sdk.AccAddress

func (MsgCreatePair) GetSignBytes 

func (msg MsgCreatePair) GetSignBytes() []byte

func (MsgCreatePair) GetSigners 

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

func (*MsgCreatePair) Marshal 

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

func (*MsgCreatePair) MarshalTo 

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

func (*MsgCreatePair) MarshalToSizedBuffer 

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

func (*MsgCreatePair) ProtoMessage 

func (*MsgCreatePair) ProtoMessage()

func (*MsgCreatePair) Reset 

func (m *MsgCreatePair) Reset()

func (MsgCreatePair) Route 

func (msg MsgCreatePair) Route() string

func (*MsgCreatePair) Size 

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

func (*MsgCreatePair) String 

func (m *MsgCreatePair) String() string

func (MsgCreatePair) Type 

func (msg MsgCreatePair) Type() string

func (*MsgCreatePair) Unmarshal 

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

func (MsgCreatePair) ValidateBasic 

func (msg MsgCreatePair) ValidateBasic() error

func (*MsgCreatePair) XXX_DiscardUnknown 

func (m *MsgCreatePair) XXX_DiscardUnknown()

func (*MsgCreatePair) XXX_Marshal 

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

func (*MsgCreatePair) XXX_Merge 

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

func (*MsgCreatePair) XXX_Size 

func (m *MsgCreatePair) XXX_Size() int

func (*MsgCreatePair) XXX_Unmarshal 

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

type MsgCreatePairResponse 

type MsgCreatePairResponse struct {
}

func (*MsgCreatePairResponse) Descriptor 

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

func (*MsgCreatePairResponse) Marshal 

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

func (*MsgCreatePairResponse) MarshalTo 

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

func (*MsgCreatePairResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePairResponse) ProtoMessage 

func (*MsgCreatePairResponse) ProtoMessage()

func (*MsgCreatePairResponse) Reset 

func (m *MsgCreatePairResponse) Reset()

func (*MsgCreatePairResponse) Size 

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

func (*MsgCreatePairResponse) String 

func (m *MsgCreatePairResponse) String() string

func (*MsgCreatePairResponse) Unmarshal 

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

func (*MsgCreatePairResponse) XXX_DiscardUnknown 

func (m *MsgCreatePairResponse) XXX_DiscardUnknown()

func (*MsgCreatePairResponse) XXX_Marshal 

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

func (*MsgCreatePairResponse) XXX_Merge 

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

func (*MsgCreatePairResponse) XXX_Size 

func (m *MsgCreatePairResponse) XXX_Size() int

func (*MsgCreatePairResponse) XXX_Unmarshal 

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

type MsgCreatePool 

type MsgCreatePool struct {
	// creator specifies the bech32-encoded address that is the pool creator
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// pair_id specifies the pair id.
	PairId uint64 `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	// deposit_coins specifies the amount of coins to deposit.
	DepositCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
}

MsgCreatePool defines an SDK message for creating a pool.

func NewMsgCreatePool 

func NewMsgCreatePool(
	creator sdk.AccAddress,
	pairId uint64,
	depositCoins sdk.Coins,
) *MsgCreatePool

NewMsgCreatePool creates a new MsgCreatePool.

func (*MsgCreatePool) Descriptor 

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

func (MsgCreatePool) GetCreator 

func (msg MsgCreatePool) GetCreator() sdk.AccAddress

func (MsgCreatePool) GetSignBytes 

func (msg MsgCreatePool) GetSignBytes() []byte

func (MsgCreatePool) GetSigners 

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

func (*MsgCreatePool) Marshal 

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

func (*MsgCreatePool) MarshalTo 

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

func (*MsgCreatePool) MarshalToSizedBuffer 

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

func (*MsgCreatePool) ProtoMessage 

func (*MsgCreatePool) ProtoMessage()

func (*MsgCreatePool) Reset 

func (m *MsgCreatePool) Reset()

func (MsgCreatePool) Route 

func (msg MsgCreatePool) Route() string

func (*MsgCreatePool) Size 

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

func (*MsgCreatePool) String 

func (m *MsgCreatePool) String() string

func (MsgCreatePool) Type 

func (msg MsgCreatePool) Type() string

func (*MsgCreatePool) Unmarshal 

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

func (MsgCreatePool) ValidateBasic 

func (msg MsgCreatePool) ValidateBasic() error

func (*MsgCreatePool) XXX_DiscardUnknown 

func (m *MsgCreatePool) XXX_DiscardUnknown()

func (*MsgCreatePool) XXX_Marshal 

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

func (*MsgCreatePool) XXX_Merge 

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

func (*MsgCreatePool) XXX_Size 

func (m *MsgCreatePool) XXX_Size() int

func (*MsgCreatePool) XXX_Unmarshal 

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

type MsgCreatePoolResponse 

type MsgCreatePoolResponse struct {
}

MsgCreatePoolResponse defines the Msg/CreatePool response type.

func (*MsgCreatePoolResponse) Descriptor 

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

func (*MsgCreatePoolResponse) Marshal 

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

func (*MsgCreatePoolResponse) MarshalTo 

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

func (*MsgCreatePoolResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePoolResponse) ProtoMessage 

func (*MsgCreatePoolResponse) ProtoMessage()

func (*MsgCreatePoolResponse) Reset 

func (m *MsgCreatePoolResponse) Reset()

func (*MsgCreatePoolResponse) Size 

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

func (*MsgCreatePoolResponse) String 

func (m *MsgCreatePoolResponse) String() string

func (*MsgCreatePoolResponse) Unmarshal 

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

func (*MsgCreatePoolResponse) XXX_DiscardUnknown 

func (m *MsgCreatePoolResponse) XXX_DiscardUnknown()

func (*MsgCreatePoolResponse) XXX_Marshal 

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

func (*MsgCreatePoolResponse) XXX_Merge 

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

func (*MsgCreatePoolResponse) XXX_Size 

func (m *MsgCreatePoolResponse) XXX_Size() int

func (*MsgCreatePoolResponse) XXX_Unmarshal 

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

type MsgCreateRangedPool 

type MsgCreateRangedPool struct {
	// creator specifies the bech32-encoded address that is the pool creator
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// pair_id specifies the pair id.
	PairId uint64 `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	// deposit_coins specifies the amount of coins to deposit.
	DepositCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
	MinPrice     github_com_cosmos_cosmos_sdk_types.Dec   `protobuf:"bytes,4,opt,name=min_price,json=minPrice,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"min_price"`
	MaxPrice     github_com_cosmos_cosmos_sdk_types.Dec   `protobuf:"bytes,5,opt,name=max_price,json=maxPrice,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"max_price"`
	InitialPrice github_com_cosmos_cosmos_sdk_types.Dec   `` /* 137-byte string literal not displayed */
}

MsgCreateRangedPool defines an SDK message for creating a ranged pool.

func NewMsgCreateRangedPool 

func NewMsgCreateRangedPool(
	creator sdk.AccAddress,
	pairId uint64,
	depositCoins sdk.Coins,
	minPrice sdk.Dec,
	maxPrice sdk.Dec,
	initialPrice sdk.Dec,
) *MsgCreateRangedPool

NewMsgCreateRangedPool creates a new MsgCreateRangedPool.

func (*MsgCreateRangedPool) Descriptor 

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

func (MsgCreateRangedPool) GetCreator 

func (msg MsgCreateRangedPool) GetCreator() sdk.AccAddress

func (MsgCreateRangedPool) GetSignBytes 

func (msg MsgCreateRangedPool) GetSignBytes() []byte

func (MsgCreateRangedPool) GetSigners 

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

func (*MsgCreateRangedPool) Marshal 

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

func (*MsgCreateRangedPool) MarshalTo 

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

func (*MsgCreateRangedPool) MarshalToSizedBuffer 

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

func (*MsgCreateRangedPool) ProtoMessage 

func (*MsgCreateRangedPool) ProtoMessage()

func (*MsgCreateRangedPool) Reset 

func (m *MsgCreateRangedPool) Reset()

func (MsgCreateRangedPool) Route 

func (msg MsgCreateRangedPool) Route() string

func (*MsgCreateRangedPool) Size 

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

func (*MsgCreateRangedPool) String 

func (m *MsgCreateRangedPool) String() string

func (MsgCreateRangedPool) Type 

func (msg MsgCreateRangedPool) Type() string

func (*MsgCreateRangedPool) Unmarshal 

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

func (MsgCreateRangedPool) ValidateBasic 

func (msg MsgCreateRangedPool) ValidateBasic() error

func (*MsgCreateRangedPool) XXX_DiscardUnknown 

func (m *MsgCreateRangedPool) XXX_DiscardUnknown()

func (*MsgCreateRangedPool) XXX_Marshal 

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

func (*MsgCreateRangedPool) XXX_Merge 

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

func (*MsgCreateRangedPool) XXX_Size 

func (m *MsgCreateRangedPool) XXX_Size() int

func (*MsgCreateRangedPool) XXX_Unmarshal 

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

type MsgCreateRangedPoolResponse 

type MsgCreateRangedPoolResponse struct {
}

MsgCreateRangedPoolResponse defines the Msg/CreateRangedPool response type.

func (*MsgCreateRangedPoolResponse) Descriptor 

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

func (*MsgCreateRangedPoolResponse) Marshal 

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

func (*MsgCreateRangedPoolResponse) MarshalTo 

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

func (*MsgCreateRangedPoolResponse) MarshalToSizedBuffer 

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

func (*MsgCreateRangedPoolResponse) ProtoMessage 

func (*MsgCreateRangedPoolResponse) ProtoMessage()

func (*MsgCreateRangedPoolResponse) Reset 

func (m *MsgCreateRangedPoolResponse) Reset()

func (*MsgCreateRangedPoolResponse) Size 

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

func (*MsgCreateRangedPoolResponse) String 

func (m *MsgCreateRangedPoolResponse) String() string

func (*MsgCreateRangedPoolResponse) Unmarshal 

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

func (*MsgCreateRangedPoolResponse) XXX_DiscardUnknown 

func (m *MsgCreateRangedPoolResponse) XXX_DiscardUnknown()

func (*MsgCreateRangedPoolResponse) XXX_Marshal 

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

func (*MsgCreateRangedPoolResponse) XXX_Merge 

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

func (*MsgCreateRangedPoolResponse) XXX_Size 

func (m *MsgCreateRangedPoolResponse) XXX_Size() int

func (*MsgCreateRangedPoolResponse) XXX_Unmarshal 

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

type MsgDeposit 

type MsgDeposit struct {
	// depositor specifies the bech32-encoded address that makes a deposit to the pool
	Depositor string `protobuf:"bytes,1,opt,name=depositor,proto3" json:"depositor,omitempty"`
	// pool_id specifies the pool id
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// deposit_coins specifies the amount of coins to deposit.
	DepositCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 141-byte string literal not displayed */
}

MsgDeposit defines an SDK message for depositing coins to the pool

func NewMsgDeposit 

func NewMsgDeposit(
	depositor sdk.AccAddress,
	poolId uint64,
	depositCoins sdk.Coins,
) *MsgDeposit

NewMsgDeposit creates a new MsgDeposit.

func (*MsgDeposit) Descriptor 

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

func (MsgDeposit) GetDepositor 

func (msg MsgDeposit) GetDepositor() sdk.AccAddress

func (MsgDeposit) GetSignBytes 

func (msg MsgDeposit) GetSignBytes() []byte

func (MsgDeposit) GetSigners 

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

func (*MsgDeposit) Marshal 

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

func (*MsgDeposit) MarshalTo 

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

func (*MsgDeposit) MarshalToSizedBuffer 

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

func (*MsgDeposit) ProtoMessage 

func (*MsgDeposit) ProtoMessage()

func (*MsgDeposit) Reset 

func (m *MsgDeposit) Reset()

func (MsgDeposit) Route 

func (msg MsgDeposit) Route() string

func (*MsgDeposit) Size 

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

func (*MsgDeposit) String 

func (m *MsgDeposit) String() string

func (MsgDeposit) Type 

func (msg MsgDeposit) Type() string

func (*MsgDeposit) Unmarshal 

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

func (MsgDeposit) ValidateBasic 

func (msg MsgDeposit) ValidateBasic() error

func (*MsgDeposit) XXX_DiscardUnknown 

func (m *MsgDeposit) XXX_DiscardUnknown()

func (*MsgDeposit) XXX_Marshal 

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

func (*MsgDeposit) XXX_Merge 

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

func (*MsgDeposit) XXX_Size 

func (m *MsgDeposit) XXX_Size() int

func (*MsgDeposit) XXX_Unmarshal 

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

type MsgDepositResponse 

type MsgDepositResponse struct {
}

MsgDepositResponse defines the Msg/Deposit response type.

func (*MsgDepositResponse) Descriptor 

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

func (*MsgDepositResponse) Marshal 

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

func (*MsgDepositResponse) MarshalTo 

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

func (*MsgDepositResponse) MarshalToSizedBuffer 

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

func (*MsgDepositResponse) ProtoMessage 

func (*MsgDepositResponse) ProtoMessage()

func (*MsgDepositResponse) Reset 

func (m *MsgDepositResponse) Reset()

func (*MsgDepositResponse) Size 

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

func (*MsgDepositResponse) String 

func (m *MsgDepositResponse) String() string

func (*MsgDepositResponse) Unmarshal 

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

func (*MsgDepositResponse) XXX_DiscardUnknown 

func (m *MsgDepositResponse) XXX_DiscardUnknown()

func (*MsgDepositResponse) XXX_Marshal 

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

func (*MsgDepositResponse) XXX_Merge 

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

func (*MsgDepositResponse) XXX_Size 

func (m *MsgDepositResponse) XXX_Size() int

func (*MsgDepositResponse) XXX_Unmarshal 

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

type MsgLimitOrder 

type MsgLimitOrder struct {
	// orderer specifies the bech32-encoded address that makes an order
	Orderer string `protobuf:"bytes,1,opt,name=orderer,proto3" json:"orderer,omitempty"`
	// pair_id specifies the pair id
	PairId uint64 `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	// direction specifies the order direction(buy or sell)
	Direction OrderDirection `protobuf:"varint,3,opt,name=direction,proto3,enum=crescent.liquidity.v1beta1.OrderDirection" json:"direction,omitempty"`
	// offer_coin specifies the amount of coin the orderer offers
	OfferCoin types.Coin `protobuf:"bytes,4,opt,name=offer_coin,json=offerCoin,proto3" json:"offer_coin"`
	// demand_coin_denom specifies the demand coin denom
	DemandCoinDenom string `protobuf:"bytes,5,opt,name=demand_coin_denom,json=demandCoinDenom,proto3" json:"demand_coin_denom,omitempty"`
	// price specifies the order price
	Price github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,6,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
	// amount specifies the amount of base coin the orderer wants to buy or sell
	Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,7,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	// order_lifespan specifies the order lifespan
	OrderLifespan time.Duration `protobuf:"bytes,8,opt,name=order_lifespan,json=orderLifespan,proto3,stdduration" json:"order_lifespan"`
}

MsgLimitOrder defines an SDK message for making a limit order

func NewMsgLimitOrder 

func NewMsgLimitOrder(
	orderer sdk.AccAddress,
	pairId uint64,
	dir OrderDirection,
	offerCoin sdk.Coin,
	demandCoinDenom string,
	price sdk.Dec,
	amt sdk.Int,
	orderLifespan time.Duration,
) *MsgLimitOrder

NewMsgLimitOrder creates a new MsgLimitOrder.

func (*MsgLimitOrder) Descriptor 

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

func (MsgLimitOrder) GetOrderer 

func (msg MsgLimitOrder) GetOrderer() sdk.AccAddress

func (MsgLimitOrder) GetSignBytes 

func (msg MsgLimitOrder) GetSignBytes() []byte

func (MsgLimitOrder) GetSigners 

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

func (*MsgLimitOrder) Marshal 

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

func (*MsgLimitOrder) MarshalTo 

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

func (*MsgLimitOrder) MarshalToSizedBuffer 

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

func (*MsgLimitOrder) ProtoMessage 

func (*MsgLimitOrder) ProtoMessage()

func (*MsgLimitOrder) Reset 

func (m *MsgLimitOrder) Reset()

func (MsgLimitOrder) Route 

func (msg MsgLimitOrder) Route() string

func (*MsgLimitOrder) Size 

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

func (*MsgLimitOrder) String 

func (m *MsgLimitOrder) String() string

func (MsgLimitOrder) Type 

func (msg MsgLimitOrder) Type() string

func (*MsgLimitOrder) Unmarshal 

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

func (MsgLimitOrder) ValidateBasic 

func (msg MsgLimitOrder) ValidateBasic() error

func (*MsgLimitOrder) XXX_DiscardUnknown 

func (m *MsgLimitOrder) XXX_DiscardUnknown()

func (*MsgLimitOrder) XXX_Marshal 

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

func (*MsgLimitOrder) XXX_Merge 

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

func (*MsgLimitOrder) XXX_Size 

func (m *MsgLimitOrder) XXX_Size() int

func (*MsgLimitOrder) XXX_Unmarshal 

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

type MsgLimitOrderResponse 

type MsgLimitOrderResponse struct {
}

MsgLimitOrderResponse defines the Msg/LimitOrder response type.

func (*MsgLimitOrderResponse) Descriptor 

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

func (*MsgLimitOrderResponse) Marshal 

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

func (*MsgLimitOrderResponse) MarshalTo 

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

func (*MsgLimitOrderResponse) MarshalToSizedBuffer 

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

func (*MsgLimitOrderResponse) ProtoMessage 

func (*MsgLimitOrderResponse) ProtoMessage()

func (*MsgLimitOrderResponse) Reset 

func (m *MsgLimitOrderResponse) Reset()

func (*MsgLimitOrderResponse) Size 

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

func (*MsgLimitOrderResponse) String 

func (m *MsgLimitOrderResponse) String() string

func (*MsgLimitOrderResponse) Unmarshal 

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

func (*MsgLimitOrderResponse) XXX_DiscardUnknown 

func (m *MsgLimitOrderResponse) XXX_DiscardUnknown()

func (*MsgLimitOrderResponse) XXX_Marshal 

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

func (*MsgLimitOrderResponse) XXX_Merge 

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

func (*MsgLimitOrderResponse) XXX_Size 

func (m *MsgLimitOrderResponse) XXX_Size() int

func (*MsgLimitOrderResponse) XXX_Unmarshal 

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

type MsgMMOrder 

type MsgMMOrder struct {
	// orderer specifies the bech32-encoded address that makes an order
	Orderer string `protobuf:"bytes,1,opt,name=orderer,proto3" json:"orderer,omitempty"`
	// pair_id specifies the pair id
	PairId uint64 `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	// max_sell_price specifies the maximum sell price
	MaxSellPrice github_com_cosmos_cosmos_sdk_types.Dec `` /* 139-byte string literal not displayed */
	// min_sell_price specifies the minimum sell price
	MinSellPrice github_com_cosmos_cosmos_sdk_types.Dec `` /* 139-byte string literal not displayed */
	// sell_amount specifies the total amount of base coin of sell orders
	SellAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 131-byte string literal not displayed */
	// max_buy_price specifies the maximum buy price
	MaxBuyPrice github_com_cosmos_cosmos_sdk_types.Dec `` /* 136-byte string literal not displayed */
	// min_buy_price specifies the minimum buy price
	MinBuyPrice github_com_cosmos_cosmos_sdk_types.Dec `` /* 136-byte string literal not displayed */
	// buy_amount specifies the total amount of base coin of buy orders
	BuyAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 128-byte string literal not displayed */
	// order_lifespan specifies the order lifespan
	OrderLifespan time.Duration `protobuf:"bytes,9,opt,name=order_lifespan,json=orderLifespan,proto3,stdduration" json:"order_lifespan"`
}

MsgMMOrder defines an SDK message for making a MM(market making) order.

func NewMsgMMOrder 

func NewMsgMMOrder(
	orderer sdk.AccAddress,
	pairId uint64,
	maxSellPrice, minSellPrice sdk.Dec, sellAmt sdk.Int,
	maxBuyPrice, minBuyPrice sdk.Dec, buyAmt sdk.Int,
	orderLifespan time.Duration,
) *MsgMMOrder

NewMsgMMOrder creates a new MsgMMOrder.

func (*MsgMMOrder) Descriptor 

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

func (MsgMMOrder) GetOrderer 

func (msg MsgMMOrder) GetOrderer() sdk.AccAddress

func (MsgMMOrder) GetSignBytes 

func (msg MsgMMOrder) GetSignBytes() []byte

func (MsgMMOrder) GetSigners 

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

func (*MsgMMOrder) Marshal 

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

func (*MsgMMOrder) MarshalTo 

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

func (*MsgMMOrder) MarshalToSizedBuffer 

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

func (*MsgMMOrder) ProtoMessage 

func (*MsgMMOrder) ProtoMessage()

func (*MsgMMOrder) Reset 

func (m *MsgMMOrder) Reset()

func (MsgMMOrder) Route 

func (msg MsgMMOrder) Route() string

func (*MsgMMOrder) Size 

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

func (*MsgMMOrder) String 

func (m *MsgMMOrder) String() string

func (MsgMMOrder) Type 

func (msg MsgMMOrder) Type() string

func (*MsgMMOrder) Unmarshal 

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

func (MsgMMOrder) ValidateBasic 

func (msg MsgMMOrder) ValidateBasic() error

func (*MsgMMOrder) XXX_DiscardUnknown 

func (m *MsgMMOrder) XXX_DiscardUnknown()

func (*MsgMMOrder) XXX_Marshal 

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

func (*MsgMMOrder) XXX_Merge 

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

func (*MsgMMOrder) XXX_Size 

func (m *MsgMMOrder) XXX_Size() int

func (*MsgMMOrder) XXX_Unmarshal 

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

type MsgMMOrderResponse 

type MsgMMOrderResponse struct {
}

MsgMMOrderResponse defines the Msg/MMOrder response type.

func (*MsgMMOrderResponse) Descriptor 

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

func (*MsgMMOrderResponse) Marshal 

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

func (*MsgMMOrderResponse) MarshalTo 

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

func (*MsgMMOrderResponse) MarshalToSizedBuffer 

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

func (*MsgMMOrderResponse) ProtoMessage 

func (*MsgMMOrderResponse) ProtoMessage()

func (*MsgMMOrderResponse) Reset 

func (m *MsgMMOrderResponse) Reset()

func (*MsgMMOrderResponse) Size 

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

func (*MsgMMOrderResponse) String 

func (m *MsgMMOrderResponse) String() string

func (*MsgMMOrderResponse) Unmarshal 

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

func (*MsgMMOrderResponse) XXX_DiscardUnknown 

func (m *MsgMMOrderResponse) XXX_DiscardUnknown()

func (*MsgMMOrderResponse) XXX_Marshal 

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

func (*MsgMMOrderResponse) XXX_Merge 

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

func (*MsgMMOrderResponse) XXX_Size 

func (m *MsgMMOrderResponse) XXX_Size() int

func (*MsgMMOrderResponse) XXX_Unmarshal 

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

type MsgMarketOrder 

type MsgMarketOrder struct {
	// orderer specifies the bech32-encoded address that makes an order
	Orderer string `protobuf:"bytes,1,opt,name=orderer,proto3" json:"orderer,omitempty"`
	// pair_id specifies the pair id
	PairId uint64 `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	// direction specifies the order direction(buy or sell)
	Direction OrderDirection `protobuf:"varint,3,opt,name=direction,proto3,enum=crescent.liquidity.v1beta1.OrderDirection" json:"direction,omitempty"`
	// offer_coin specifies the amount of coin the orderer offers
	OfferCoin types.Coin `protobuf:"bytes,4,opt,name=offer_coin,json=offerCoin,proto3" json:"offer_coin"`
	// demand_coin_denom specifies the demand coin denom
	DemandCoinDenom string `protobuf:"bytes,5,opt,name=demand_coin_denom,json=demandCoinDenom,proto3" json:"demand_coin_denom,omitempty"`
	// amount specifies the amount of base coin the orderer wants to buy or sell
	Amount github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,6,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	// order_lifespan specifies the order lifespan
	OrderLifespan time.Duration `protobuf:"bytes,7,opt,name=order_lifespan,json=orderLifespan,proto3,stdduration" json:"order_lifespan"`
}

MsgMarketOrder defines an SDK message for making a market order

func NewMsgMarketOrder 

func NewMsgMarketOrder(
	orderer sdk.AccAddress,
	pairId uint64,
	dir OrderDirection,
	offerCoin sdk.Coin,
	demandCoinDenom string,
	amt sdk.Int,
	orderLifespan time.Duration,
) *MsgMarketOrder

NewMsgMarketOrder creates a new MsgMarketOrder.

func (*MsgMarketOrder) Descriptor 

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

func (MsgMarketOrder) GetOrderer 

func (msg MsgMarketOrder) GetOrderer() sdk.AccAddress

func (MsgMarketOrder) GetSignBytes 

func (msg MsgMarketOrder) GetSignBytes() []byte

func (MsgMarketOrder) GetSigners 

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

func (*MsgMarketOrder) Marshal 

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

func (*MsgMarketOrder) MarshalTo 

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

func (*MsgMarketOrder) MarshalToSizedBuffer 

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

func (*MsgMarketOrder) ProtoMessage 

func (*MsgMarketOrder) ProtoMessage()

func (*MsgMarketOrder) Reset 

func (m *MsgMarketOrder) Reset()

func (MsgMarketOrder) Route 

func (msg MsgMarketOrder) Route() string

func (*MsgMarketOrder) Size 

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

func (*MsgMarketOrder) String 

func (m *MsgMarketOrder) String() string

func (MsgMarketOrder) Type 

func (msg MsgMarketOrder) Type() string

func (*MsgMarketOrder) Unmarshal 

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

func (MsgMarketOrder) ValidateBasic 

func (msg MsgMarketOrder) ValidateBasic() error

func (*MsgMarketOrder) XXX_DiscardUnknown 

func (m *MsgMarketOrder) XXX_DiscardUnknown()

func (*MsgMarketOrder) XXX_Marshal 

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

func (*MsgMarketOrder) XXX_Merge 

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

func (*MsgMarketOrder) XXX_Size 

func (m *MsgMarketOrder) XXX_Size() int

func (*MsgMarketOrder) XXX_Unmarshal 

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

type MsgMarketOrderResponse 

type MsgMarketOrderResponse struct {
}

MsgMarketOrderResponse defines the Msg/MarketOrder response type.

func (*MsgMarketOrderResponse) Descriptor 

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

func (*MsgMarketOrderResponse) Marshal 

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

func (*MsgMarketOrderResponse) MarshalTo 

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

func (*MsgMarketOrderResponse) MarshalToSizedBuffer 

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

func (*MsgMarketOrderResponse) ProtoMessage 

func (*MsgMarketOrderResponse) ProtoMessage()

func (*MsgMarketOrderResponse) Reset 

func (m *MsgMarketOrderResponse) Reset()

func (*MsgMarketOrderResponse) Size 

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

func (*MsgMarketOrderResponse) String 

func (m *MsgMarketOrderResponse) String() string

func (*MsgMarketOrderResponse) Unmarshal 

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

func (*MsgMarketOrderResponse) XXX_DiscardUnknown 

func (m *MsgMarketOrderResponse) XXX_DiscardUnknown()

func (*MsgMarketOrderResponse) XXX_Marshal 

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

func (*MsgMarketOrderResponse) XXX_Merge 

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

func (*MsgMarketOrderResponse) XXX_Size 

func (m *MsgMarketOrderResponse) XXX_Size() int

func (*MsgMarketOrderResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreatePair defines a method for creating a pair
	CreatePair(context.Context, *MsgCreatePair) (*MsgCreatePairResponse, error)
	// CreatePool defines a method for creating a pool
	CreatePool(context.Context, *MsgCreatePool) (*MsgCreatePoolResponse, error)
	// CreateRangePool defines a method for creating a ranged pool
	CreateRangedPool(context.Context, *MsgCreateRangedPool) (*MsgCreateRangedPoolResponse, error)
	// Deposit defines a method for depositing coins to the pool
	Deposit(context.Context, *MsgDeposit) (*MsgDepositResponse, error)
	// Withdraw defines a method for withdrawing pool coin from the pool
	Withdraw(context.Context, *MsgWithdraw) (*MsgWithdrawResponse, error)
	// LimitOrder defines a method for making a limit order
	LimitOrder(context.Context, *MsgLimitOrder) (*MsgLimitOrderResponse, error)
	// MarketOrder defines a method for making a market order
	MarketOrder(context.Context, *MsgMarketOrder) (*MsgMarketOrderResponse, error)
	// MsgMMOrder defines a method for making a MM(market making) order
	MMOrder(context.Context, *MsgMMOrder) (*MsgMMOrderResponse, error)
	// CancelOrder defines a method for cancelling an order
	CancelOrder(context.Context, *MsgCancelOrder) (*MsgCancelOrderResponse, error)
	// CancelAllOrders defines a method for cancelling all orders
	CancelAllOrders(context.Context, *MsgCancelAllOrders) (*MsgCancelAllOrdersResponse, error)
	// CancelMMOrder defines a method for cancelling previously placed market making orders
	CancelMMOrder(context.Context, *MsgCancelMMOrder) (*MsgCancelMMOrderResponse, error)
}

MsgServer is the server API for Msg service.

type MsgWithdraw 

type MsgWithdraw struct {
	// withdrawer specifies the bech32-encoded address that withdraws pool coin from the pool
	Withdrawer string `protobuf:"bytes,1,opt,name=withdrawer,proto3" json:"withdrawer,omitempty"`
	// pool_id specifies the pool id
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// pool_coin specifies the pool coin that is a proof of liquidity provider for the pool
	PoolCoin types.Coin `protobuf:"bytes,3,opt,name=pool_coin,json=poolCoin,proto3" json:"pool_coin"`
}

MsgWithdraw defines an SDK message for withdrawing pool coin from the pool

func NewMsgWithdraw 

func NewMsgWithdraw(
	withdrawer sdk.AccAddress,
	poolId uint64,
	poolCoin sdk.Coin,
) *MsgWithdraw

NewMsgWithdraw creates a new MsgWithdraw.

func (*MsgWithdraw) Descriptor 

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

func (MsgWithdraw) GetSignBytes 

func (msg MsgWithdraw) GetSignBytes() []byte

func (MsgWithdraw) GetSigners 

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

func (MsgWithdraw) GetWithdrawer 

func (msg MsgWithdraw) GetWithdrawer() sdk.AccAddress

func (*MsgWithdraw) Marshal 

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

func (*MsgWithdraw) MarshalTo 

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

func (*MsgWithdraw) MarshalToSizedBuffer 

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

func (*MsgWithdraw) ProtoMessage 

func (*MsgWithdraw) ProtoMessage()

func (*MsgWithdraw) Reset 

func (m *MsgWithdraw) Reset()

func (MsgWithdraw) Route 

func (msg MsgWithdraw) Route() string

func (*MsgWithdraw) Size 

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

func (*MsgWithdraw) String 

func (m *MsgWithdraw) String() string

func (MsgWithdraw) Type 

func (msg MsgWithdraw) Type() string

func (*MsgWithdraw) Unmarshal 

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

func (MsgWithdraw) ValidateBasic 

func (msg MsgWithdraw) ValidateBasic() error

func (*MsgWithdraw) XXX_DiscardUnknown 

func (m *MsgWithdraw) XXX_DiscardUnknown()

func (*MsgWithdraw) XXX_Marshal 

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

func (*MsgWithdraw) XXX_Merge 

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

func (*MsgWithdraw) XXX_Size 

func (m *MsgWithdraw) XXX_Size() int

func (*MsgWithdraw) XXX_Unmarshal 

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

type MsgWithdrawResponse 

type MsgWithdrawResponse struct {
}

MsgWithdrawResponse defines the Msg/Withdraw response type.

func (*MsgWithdrawResponse) Descriptor 

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

func (*MsgWithdrawResponse) Marshal 

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

func (*MsgWithdrawResponse) MarshalTo 

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

func (*MsgWithdrawResponse) MarshalToSizedBuffer 

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

func (*MsgWithdrawResponse) ProtoMessage 

func (*MsgWithdrawResponse) ProtoMessage()

func (*MsgWithdrawResponse) Reset 

func (m *MsgWithdrawResponse) Reset()

func (*MsgWithdrawResponse) Size 

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

func (*MsgWithdrawResponse) String 

func (m *MsgWithdrawResponse) String() string

func (*MsgWithdrawResponse) Unmarshal 

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

func (*MsgWithdrawResponse) XXX_DiscardUnknown 

func (m *MsgWithdrawResponse) XXX_DiscardUnknown()

func (*MsgWithdrawResponse) XXX_Marshal 

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

func (*MsgWithdrawResponse) XXX_Merge 

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

func (*MsgWithdrawResponse) XXX_Size 

func (m *MsgWithdrawResponse) XXX_Size() int

func (*MsgWithdrawResponse) XXX_Unmarshal 

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

type Order 

type Order struct {
	// type specifies the typo of the order
	Type OrderType `protobuf:"varint,1,opt,name=type,proto3,enum=crescent.liquidity.v1beta1.OrderType" json:"type,omitempty"`
	// id specifies the id of the order
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// pair_id specifies the pair id
	PairId uint64 `protobuf:"varint,3,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	// msg_height specifies the block height when the order is stored for the batch execution
	MsgHeight int64 `protobuf:"varint,4,opt,name=msg_height,json=msgHeight,proto3" json:"msg_height,omitempty"`
	// orderer specifies the bech32-encoded address that makes an order
	Orderer string `protobuf:"bytes,5,opt,name=orderer,proto3" json:"orderer,omitempty"`
	// direction specifies the order direction; either buy or sell
	Direction OrderDirection `protobuf:"varint,6,opt,name=direction,proto3,enum=crescent.liquidity.v1beta1.OrderDirection" json:"direction,omitempty"`
	OfferCoin types.Coin     `protobuf:"bytes,7,opt,name=offer_coin,json=offerCoin,proto3" json:"offer_coin"`
	// remaining_offer_coin specifies the remaining offer coin
	RemainingOfferCoin types.Coin `protobuf:"bytes,8,opt,name=remaining_offer_coin,json=remainingOfferCoin,proto3" json:"remaining_offer_coin"`
	// received_coin specifies the received coin after the swap
	ReceivedCoin types.Coin `protobuf:"bytes,9,opt,name=received_coin,json=receivedCoin,proto3" json:"received_coin"`
	// price specifies the price that an orderer is willing to swap
	Price      github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,10,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
	Amount     github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,11,opt,name=amount,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"amount"`
	OpenAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 132-byte string literal not displayed */
	// batch_id specifies the pair's batch id when the request is stored
	BatchId  uint64      `protobuf:"varint,13,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	ExpireAt time.Time   `protobuf:"bytes,14,opt,name=expire_at,json=expireAt,proto3,stdtime" json:"expire_at"`
	Status   OrderStatus `protobuf:"varint,15,opt,name=status,proto3,enum=crescent.liquidity.v1beta1.OrderStatus" json:"status,omitempty"`
}

Order defines an order.

func MustUnmarshalOrder 

func MustUnmarshalOrder(cdc codec.BinaryCodec, value []byte) Order

MustUnmarshalOrder returns the Order from bytes. It throws panic if it fails.

func NewOrder 

func NewOrder(
	typ OrderType, id uint64, pair Pair, orderer sdk.AccAddress,
	offerCoin sdk.Coin, price sdk.Dec, amt sdk.Int, expireAt time.Time, msgHeight int64) Order

func NewOrderForLimitOrder 

func NewOrderForLimitOrder(msg *MsgLimitOrder, id uint64, pair Pair, offerCoin sdk.Coin, price sdk.Dec, expireAt time.Time, msgHeight int64) Order

NewOrderForLimitOrder returns a new Order from MsgLimitOrder.

func NewOrderForMarketOrder 

func NewOrderForMarketOrder(msg *MsgMarketOrder, id uint64, pair Pair, offerCoin sdk.Coin, price sdk.Dec, expireAt time.Time, msgHeight int64) Order

NewOrderForMarketOrder returns a new Order from MsgMarketOrder.

func UnmarshalOrder 

func UnmarshalOrder(cdc codec.BinaryCodec, value []byte) (order Order, err error)

UnmarshalOrder returns the Order from bytes.

func (*Order) Descriptor 

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

func (Order) ExpiredAt 

func (order Order) ExpiredAt(t time.Time) bool

ExpiredAt returns whether the order should be deleted at given time.

func (Order) GetOrderer 

func (order Order) GetOrderer() sdk.AccAddress

func (*Order) Marshal 

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

func (*Order) MarshalTo 

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

func (*Order) MarshalToSizedBuffer 

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

func (*Order) ProtoMessage 

func (*Order) ProtoMessage()

func (*Order) Reset 

func (m *Order) Reset()

func (*Order) SetStatus 

func (order *Order) SetStatus(status OrderStatus)

SetStatus sets the order's status. SetStatus is to easily find locations where the status is changed.

func (*Order) Size 

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

func (*Order) String 

func (m *Order) String() string

func (*Order) Unmarshal 

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

func (Order) Validate 

func (order Order) Validate() error

Validate validates Order for genesis.

func (*Order) XXX_DiscardUnknown 

func (m *Order) XXX_DiscardUnknown()

func (*Order) XXX_Marshal 

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

func (*Order) XXX_Merge 

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

func (*Order) XXX_Size 

func (m *Order) XXX_Size() int

func (*Order) XXX_Unmarshal 

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

type OrderBookConfig 

type OrderBookConfig struct {
	PriceUnitPower int
	MaxNumTicks    int
}

OrderBookConfig defines configuration parameter for an order book response.

type OrderBookPairResponse 

type OrderBookPairResponse struct {
	PairId     uint64                                 `protobuf:"varint,1,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	BasePrice  github_com_cosmos_cosmos_sdk_types.Dec `` /* 128-byte string literal not displayed */
	OrderBooks []OrderBookResponse                    `protobuf:"bytes,3,rep,name=order_books,json=orderBooks,proto3" json:"order_books"`
}

func MakeOrderBookPairResponse 

func MakeOrderBookPairResponse(pairId uint64, ov *amm.OrderBookView, lowestPrice, highestPrice sdk.Dec, tickPrec int, configs ...OrderBookConfig) OrderBookPairResponse
Example 
ob := amm.NewOrderBook(
	newOrder(amm.Sell, utils.ParseDec("15.0"), sdk.NewInt(10000)),
	newOrder(amm.Sell, utils.ParseDec("13.0"), sdk.NewInt(10000)),
	newOrder(amm.Sell, utils.ParseDec("10.01"), sdk.NewInt(10000)),
	newOrder(amm.Sell, utils.ParseDec("10.0"), sdk.NewInt(10000)),
	newOrder(amm.Buy, utils.ParseDec("10.01"), sdk.NewInt(10000)),
	newOrder(amm.Buy, utils.ParseDec("10.0"), sdk.NewInt(10000)),
	newOrder(amm.Buy, utils.ParseDec("9.0"), sdk.NewInt(10000)),
	newOrder(amm.Buy, utils.ParseDec("3.0"), sdk.NewInt(10000)),
	newOrder(amm.Buy, utils.ParseDec("0.1"), sdk.NewInt(10000)),
)
ov := ob.MakeView()
ov.Match()
tickPrec := 1
lowestPrice := utils.ParseDec("0")
highestPrice := utils.ParseDec("20")
resp := types.MakeOrderBookPairResponse(1, ov, lowestPrice, highestPrice, tickPrec, types.OrderBookConfig{
	PriceUnitPower: 0,
	MaxNumTicks:    20,
})
types.PrintOrderBookResponse(resp.OrderBooks[0], resp.BasePrice)

Output:

+------------------------------------------------------------------------+
|              10000 |        15.000000000000000000 |                    |
|              10000 |        13.000000000000000000 |                    |
|              10000 |        11.000000000000000000 |                    |
|------------------------------------------------------------------------|
|                             10.000000000000000000                      |
|------------------------------------------------------------------------|
|                    |        10.000000000000000000 | 10000              |
|                    |         9.000000000000000000 | 10000              |
|                    |         3.000000000000000000 | 10000              |
|                    |         0.000000000000000000 | 10000              |
+------------------------------------------------------------------------+
Example (Edgecase1) 
package main

import (
	sdk "github.com/cosmos/cosmos-sdk/types"

	utils "github.com/crescent-network/crescent/v3/types"
	"github.com/crescent-network/crescent/v3/x/liquidity/amm"
	"github.com/crescent-network/crescent/v3/x/liquidity/types"
)

func main() {
	basicPool := amm.NewBasicPool(sdk.NewInt(2603170018), sdk.NewInt(2731547352), sdk.Int{})
	rangedPool := amm.NewRangedPool(sdk.NewInt(9204969), sdk.NewInt(292104465), sdk.Int{}, utils.ParseDec("0.95"), utils.ParseDec("1.05"))
	lastPrice := utils.ParseDec("0.95299")

	ob := amm.NewOrderBook()
	lowestPrice := lastPrice.Mul(utils.ParseDec("0.9"))
	highestPrice := lastPrice.Mul(utils.ParseDec("1.1"))
	ob.AddOrder(amm.PoolOrders(basicPool, amm.DefaultOrderer, lowestPrice, highestPrice, 4)...)
	ob.AddOrder(amm.PoolOrders(rangedPool, amm.DefaultOrderer, lowestPrice, highestPrice, 4)...)

	ov := ob.MakeView()
	ov.Match()

	basePrice, _ := types.OrderBookBasePrice(ov, 4)
	resp := types.MakeOrderBookPairResponse(1, ov, lowestPrice, highestPrice, 3, types.OrderBookConfig{
		PriceUnitPower: 0,
		MaxNumTicks:    10,
	})
	types.PrintOrderBookResponse(resp.OrderBooks[0], basePrice)

}

Output:

+------------------------------------------------------------------------+
|             424830 |         0.953900000000000000 |                    |
|             502738 |         0.953800000000000000 |                    |
|             436285 |         0.953700000000000000 |                    |
|             502809 |         0.953600000000000000 |                    |
|             425098 |         0.953500000000000000 |                    |
|             503055 |         0.953400000000000000 |                    |
|             436559 |         0.953300000000000000 |                    |
|             497509 |         0.953200000000000000 |                    |
|             495757 |         0.953100000000000000 |                    |
|              59171 |         0.953000000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.952980000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.952900000000000000 | 425397             |
|                    |         0.952800000000000000 | 415669             |
|                    |         0.952700000000000000 | 518993             |
|                    |         0.952600000000000000 | 503626             |
|                    |         0.952500000000000000 | 408371             |
|                    |         0.952400000000000000 | 503685             |
|                    |         0.952300000000000000 | 454527             |
|                    |         0.952200000000000000 | 503942             |
|                    |         0.952100000000000000 | 408638             |
|                    |         0.952000000000000000 | 504004             |
+------------------------------------------------------------------------+
Example (Edgecase2) 
ob := amm.NewOrderBook(
	newOrder(amm.Buy, utils.ParseDec("1.001"), sdk.NewInt(3000)),
	newOrder(amm.Buy, utils.ParseDec("1.000"), sdk.NewInt(10000)),
	newOrder(amm.Sell, utils.ParseDec("0.999"), sdk.NewInt(5000)),
	newOrder(amm.Sell, utils.ParseDec("0.998"), sdk.NewInt(3000)),
	newOrder(amm.Sell, utils.ParseDec("0.997"), sdk.NewInt(2000)),
)

ov := ob.MakeView()
ov.Match()

resp := types.MakeOrderBookPairResponse(1, ov, utils.ParseDec("0.9"), utils.ParseDec("1.1"), 3, types.OrderBookConfig{
	PriceUnitPower: 0,
	MaxNumTicks:    10,
})
types.PrintOrderBookResponse(resp.OrderBooks[0], resp.BasePrice)

Output:

+------------------------------------------------------------------------+
|------------------------------------------------------------------------|
|                              1.000000000000000000                      |
|------------------------------------------------------------------------|
|                    |         1.000000000000000000 | 3000               |
+------------------------------------------------------------------------+
Example (Edgecase3) 
ob := amm.NewOrderBook(
	newOrder(amm.Sell, utils.ParseDec("1.001"), sdk.NewInt(2000)),
	newOrder(amm.Sell, utils.ParseDec("1.000"), sdk.NewInt(2000)),
	newOrder(amm.Buy, utils.ParseDec("1.000"), sdk.NewInt(2000)),
	newOrder(amm.Buy, utils.ParseDec("0.999"), sdk.NewInt(2000)),
)

ov := ob.MakeView()
ov.Match()

resp := types.MakeOrderBookPairResponse(1, ov, utils.ParseDec("0.9"), utils.ParseDec("1.1"), 3, types.OrderBookConfig{
	PriceUnitPower: 0,
	MaxNumTicks:    10,
})
types.PrintOrderBookResponse(resp.OrderBooks[0], resp.BasePrice)

Output:

+------------------------------------------------------------------------+
|               2000 |         1.001000000000000000 |                    |
|------------------------------------------------------------------------|
|                              1.000000000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.999000000000000000 | 2000               |
+------------------------------------------------------------------------+
Example (Match) 
ob := amm.NewOrderBook(
	newOrder(amm.Buy, utils.ParseDec("1.000"), sdk.NewInt(3000)),
	newOrder(amm.Buy, utils.ParseDec("0.999"), sdk.NewInt(10000)),
	newOrder(amm.Sell, utils.ParseDec("1.001"), sdk.NewInt(10000)),
	newOrder(amm.Sell, utils.ParseDec("1.000"), sdk.NewInt(10000)),
)

ov := ob.MakeView()
ov.Match()
tickPrec := 3
resp := types.MakeOrderBookPairResponse(1, ov, utils.ParseDec("0.9"), utils.ParseDec("1.1"), tickPrec, types.OrderBookConfig{
	PriceUnitPower: 0,
	MaxNumTicks:    10,
})
basePrice, found := types.OrderBookBasePrice(ov, tickPrec)
if !found {
	panic("base price not found")
}
types.PrintOrderBookResponse(resp.OrderBooks[0], basePrice)

Output:

+------------------------------------------------------------------------+
|              10000 |         1.001000000000000000 |                    |
|               7000 |         1.000000000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.999500000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.999000000000000000 | 10000              |
+------------------------------------------------------------------------+
Example (Pool) 
package main

import (
	sdk "github.com/cosmos/cosmos-sdk/types"

	utils "github.com/crescent-network/crescent/v3/types"
	"github.com/crescent-network/crescent/v3/x/liquidity/amm"
	"github.com/crescent-network/crescent/v3/x/liquidity/types"
)

func main() {
	pool1 := amm.NewBasicPool(sdk.NewInt(1050_000000), sdk.NewInt(1000_000000), sdk.Int{})
	pool2, err := amm.CreateRangedPool(
		sdk.NewInt(1000_000000), sdk.NewInt(1000_000000),
		utils.ParseDec("0.1"), utils.ParseDec("5.0"), utils.ParseDec("0.95"))
	if err != nil {
		panic(err)
	}

	lastPrice := utils.ParseDec("1.0")
	lowestPrice := lastPrice.Mul(utils.ParseDec("0.9"))
	highestPrice := lastPrice.Mul(utils.ParseDec("1.1"))
	ob := amm.NewOrderBook()
	ob.AddOrder(amm.PoolOrders(pool1, amm.DefaultOrderer, lowestPrice, highestPrice, 4)...)
	ob.AddOrder(amm.PoolOrders(pool2, amm.DefaultOrderer, lowestPrice, highestPrice, 4)...)

	ov := ob.MakeView()
	ov.Match()
	tickPrec := 3
	resp := types.MakeOrderBookPairResponse(1, ov, lowestPrice, highestPrice, tickPrec, types.OrderBookConfig{
		PriceUnitPower: 0,
		MaxNumTicks:    10,
	})
	types.PrintOrderBookResponse(resp.OrderBooks[0], resp.BasePrice)

}

Output:

+------------------------------------------------------------------------+
|            2299835 |         1.011000000000000000 |                    |
|            2342262 |         1.008000000000000000 |                    |
|            2170367 |         1.005000000000000000 |                    |
|            2059733 |         1.003000000000000000 |                    |
|            1914496 |         1.000000000000000000 |                    |
|            1846587 |         0.998000000000000000 |                    |
|            1729430 |         0.995000000000000000 |                    |
|            1674921 |         0.993000000000000000 |                    |
|            1571324 |         0.991000000000000000 |                    |
|            1307011 |         0.989000000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.988400000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.988000000000000000 | 1521174            |
|                    |         0.985000000000000000 | 1520420            |
|                    |         0.982000000000000000 | 1671594            |
|                    |         0.979000000000000000 | 1672618            |
|                    |         0.975000000000000000 | 1836801            |
|                    |         0.972000000000000000 | 1839965            |
|                    |         0.968000000000000000 | 2017741            |
|                    |         0.965000000000000000 | 2023466            |
|                    |         0.961000000000000000 | 2215515            |
|                    |         0.957000000000000000 | 2224296            |
+------------------------------------------------------------------------+
Example (PriceUnits1) 
package main

import (
	sdk "github.com/cosmos/cosmos-sdk/types"

	utils "github.com/crescent-network/crescent/v3/types"
	"github.com/crescent-network/crescent/v3/x/liquidity/amm"
	"github.com/crescent-network/crescent/v3/x/liquidity/types"
)

func main() {
	ob := amm.NewOrderBook()

	lastPrice := utils.ParseDec("0.9995")
	lowestPrice, highestPrice := types.PriceLimits(lastPrice, utils.ParseDec("0.1"), 4)
	pool := amm.NewBasicPool(sdk.NewInt(9995_000000), sdk.NewInt(10000_000000), sdk.Int{})
	ob.AddOrder(amm.PoolOrders(pool, amm.DefaultOrderer, lowestPrice, highestPrice, 4)...)

	ov := ob.MakeView()
	ov.Match()

	resp := types.MakeOrderBookPairResponse(1, ov, lowestPrice, highestPrice, 4,
		types.OrderBookConfig{
			PriceUnitPower: 0,
			MaxNumTicks:    10,
		},
		types.OrderBookConfig{
			PriceUnitPower: 1,
			MaxNumTicks:    10,
		},
		types.OrderBookConfig{
			PriceUnitPower: 2,
			MaxNumTicks:    10,
		},
	)
	types.PrintOrderBookResponse(resp.OrderBooks[0], resp.BasePrice)
	types.PrintOrderBookResponse(resp.OrderBooks[1], resp.BasePrice)
	types.PrintOrderBookResponse(resp.OrderBooks[2], resp.BasePrice)

}

Output:

+------------------------------------------------------------------------+
|             300018 |         0.999870000000000000 |                    |
|              99970 |         0.999830000000000000 |                    |
|             300047 |         0.999790000000000000 |                    |
|              99989 |         0.999750000000000000 |                    |
|             300076 |         0.999710000000000000 |                    |
|             100009 |         0.999670000000000000 |                    |
|             300104 |         0.999630000000000000 |                    |
|             100029 |         0.999590000000000000 |                    |
|             300132 |         0.999550000000000000 |                    |
|             100049 |         0.999510000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.999500000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.999490000000000000 | 100051             |
|                    |         0.999450000000000000 | 300169             |
|                    |         0.999410000000000000 | 100071             |
|                    |         0.999370000000000000 | 300197             |
|                    |         0.999330000000000000 | 100091             |
|                    |         0.999290000000000000 | 300225             |
|                    |         0.999250000000000000 | 100111             |
|                    |         0.999210000000000000 | 300253             |
|                    |         0.999170000000000000 | 100132             |
|                    |         0.999130000000000000 | 300280             |
+------------------------------------------------------------------------+
+------------------------------------------------------------------------+
|             998495 |         1.000900000000000000 |                    |
|             998608 |         1.000700000000000000 |                    |
|             999095 |         1.000500000000000000 |                    |
|             999206 |         1.000300000000000000 |                    |
|             999695 |         1.000100000000000000 |                    |
|             499871 |         1.000000000000000000 |                    |
|             399988 |         0.999900000000000000 |                    |
|             700112 |         0.999800000000000000 |                    |
|             400113 |         0.999700000000000000 |                    |
|             500210 |         0.999600000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.999500000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.999400000000000000 | 500291             |
|                    |         0.999300000000000000 | 400288             |
|                    |         0.999200000000000000 | 700589             |
|                    |         0.999100000000000000 | 400412             |
|                    |         0.999000000000000000 | 500633             |
|                    |         0.998900000000000000 | 400528             |
|                    |         0.998800000000000000 | 700969             |
|                    |         0.998700000000000000 | 400653             |
|                    |         0.998600000000000000 | 500972             |
|                    |         0.998500000000000000 | 400768             |
+------------------------------------------------------------------------+
+------------------------------------------------------------------------+
|            4935785 |         1.009000000000000000 |                    |
|            4942943 |         1.008000000000000000 |                    |
|            4950502 |         1.007000000000000000 |                    |
|            4957699 |         1.006000000000000000 |                    |
|            4965293 |         1.005000000000000000 |                    |
|            4972529 |         1.004000000000000000 |                    |
|            4980159 |         1.003000000000000000 |                    |
|            4987432 |         1.002000000000000000 |                    |
|            4995099 |         1.001000000000000000 |                    |
|            2500294 |         1.000000000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.999500000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.999000000000000000 | 2502213            |
|                    |         0.998000000000000000 | 5210466            |
|                    |         0.997000000000000000 | 5017777            |
|                    |         0.996000000000000000 | 5025346            |
|                    |         0.995000000000000000 | 4932203            |
|                    |         0.994000000000000000 | 4939515            |
|                    |         0.993000000000000000 | 4947464            |
|                    |         0.992000000000000000 | 4954234            |
|                    |         0.991000000000000000 | 5163351            |
|                    |         0.990000000000000000 | 5274693            |
+------------------------------------------------------------------------+
Example (PriceUnits2) 
package main

import (
	sdk "github.com/cosmos/cosmos-sdk/types"

	utils "github.com/crescent-network/crescent/v3/types"
	"github.com/crescent-network/crescent/v3/x/liquidity/amm"
	"github.com/crescent-network/crescent/v3/x/liquidity/types"
)

func main() {
	ob := amm.NewOrderBook()

	lastPrice := utils.ParseDec("0.9999")
	lowestPrice, highestPrice := types.PriceLimits(lastPrice, utils.ParseDec("0.1"), 4)
	pool := amm.NewBasicPool(sdk.NewInt(9999_000000), sdk.NewInt(10000_000000), sdk.Int{})
	ob.AddOrder(amm.PoolOrders(pool, amm.DefaultOrderer, lowestPrice, highestPrice, 4)...)

	ov := ob.MakeView()
	ov.Match()

	resp := types.MakeOrderBookPairResponse(1, ov, lowestPrice, highestPrice, 4,
		types.OrderBookConfig{
			PriceUnitPower: 0,
			MaxNumTicks:    10,
		},
		types.OrderBookConfig{
			PriceUnitPower: 1,
			MaxNumTicks:    10,
		},
		types.OrderBookConfig{
			PriceUnitPower: 2,
			MaxNumTicks:    10,
		},
	)
	types.PrintOrderBookResponse(resp.OrderBooks[0], resp.BasePrice)
	types.PrintOrderBookResponse(resp.OrderBooks[1], resp.BasePrice)
	types.PrintOrderBookResponse(resp.OrderBooks[2], resp.BasePrice)

}

Output:

+------------------------------------------------------------------------+
|             997461 |         1.001700000000000000 |                    |
|             997650 |         1.001500000000000000 |                    |
|             998058 |         1.001300000000000000 |                    |
|             998247 |         1.001100000000000000 |                    |
|             998658 |         1.000900000000000000 |                    |
|             998845 |         1.000700000000000000 |                    |
|             999257 |         1.000500000000000000 |                    |
|             999444 |         1.000300000000000000 |                    |
|             999857 |         1.000100000000000000 |                    |
|             500010 |         1.000000000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.999900000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.999800000000000000 | 500091             |
|                    |         0.999700000000000000 | 400128             |
|                    |         0.999600000000000000 | 700309             |
|                    |         0.999500000000000000 | 400252             |
|                    |         0.999400000000000000 | 500431             |
|                    |         0.999300000000000000 | 400369             |
|                    |         0.999200000000000000 | 700688             |
|                    |         0.999100000000000000 | 400492             |
|                    |         0.999000000000000000 | 500773             |
|                    |         0.998900000000000000 | 400608             |
+------------------------------------------------------------------------+
+------------------------------------------------------------------------+
|            4936732 |         1.009000000000000000 |                    |
|            4943972 |         1.008000000000000000 |                    |
|            4951453 |         1.007000000000000000 |                    |
|            4958730 |         1.006000000000000000 |                    |
|            4966248 |         1.005000000000000000 |                    |
|            4973563 |         1.004000000000000000 |                    |
|            4981117 |         1.003000000000000000 |                    |
|            4988468 |         1.002000000000000000 |                    |
|            4996061 |         1.001000000000000000 |                    |
|             500010 |         1.000000000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.999900000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.999000000000000000 | 4503533            |
|                    |         0.998000000000000000 | 5211459            |
|                    |         0.997000000000000000 | 5018778            |
|                    |         0.996000000000000000 | 4825162            |
|                    |         0.995000000000000000 | 5235152            |
|                    |         0.994000000000000000 | 5041557            |
|                    |         0.993000000000000000 | 4847036            |
|                    |         0.992000000000000000 | 5258875            |
|                    |         0.991000000000000000 | 4964041            |
|                    |         0.990000000000000000 | 5072107            |
+------------------------------------------------------------------------+
+------------------------------------------------------------------------+
|           39884892 |         1.090000000000000000 |                    |
|           35872783 |         1.080000000000000000 |                    |
|           49088294 |         1.070000000000000000 |                    |
|           52603184 |         1.060000000000000000 |                    |
|           43083979 |         1.050000000000000000 |                    |
|           43657842 |         1.040000000000000000 |                    |
|           50064733 |         1.030000000000000000 |                    |
|           50835962 |         1.020000000000000000 |                    |
|           49625631 |         1.010000000000000000 |                    |
|             500010 |         1.000000000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.999900000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.990000000000000000 | 49977700           |
|                    |         0.980000000000000000 | 50524375           |
|                    |         0.970000000000000000 | 54863157           |
|                    |         0.960000000000000000 | 52675477           |
|                    |         0.950000000000000000 | 57485995           |
|                    |         0.940000000000000000 | 40941734           |
|                    |         0.930000000000000000 | 65324860           |
|                    |         0.920000000000000000 | 58141770           |
|                    |         0.910000000000000000 | 43270158           |
|                    |         0.900000000000000000 | 72707068           |
+------------------------------------------------------------------------+
Example (UserOrder) 
pool := amm.NewBasicPool(sdk.NewInt(895590740832), sdk.NewInt(675897553075), sdk.Int{})

lastPrice := utils.ParseDec("1.325")
lowestPrice := lastPrice.Mul(utils.ParseDec("0.9"))
highestPrice := lastPrice.Mul(utils.ParseDec("1.1"))
ob := amm.NewOrderBook()
ob.AddOrder(amm.PoolOrders(pool, amm.DefaultOrderer, lowestPrice, highestPrice, 4)...)
ob.AddOrder(
	newOrder(amm.Buy, utils.ParseDec("1.316"), sdk.NewInt(111000000)),
	newOrder(amm.Buy, utils.ParseDec("1.32"), sdk.NewInt(111000000)),
	newOrder(amm.Buy, utils.ParseDec("1.325"), sdk.NewInt(11000000)),
	newOrder(amm.Buy, utils.ParseDec("1.325"), sdk.NewInt(111000000)),
	newOrder(amm.Buy, utils.ParseDec("1.325"), sdk.NewInt(20000000)),
	newOrder(amm.Buy, utils.ParseDec("1.325"), sdk.NewInt(111000000)),
)

ov := ob.MakeView()
ov.Match()
tickPrec := 3
resp := types.MakeOrderBookPairResponse(1, ov, lowestPrice, highestPrice, tickPrec, types.OrderBookConfig{
	PriceUnitPower: 0,
	MaxNumTicks:    10,
})
basePrice, found := types.OrderBookBasePrice(ov, tickPrec)
if !found {
	panic("base price not found")
}
types.PrintOrderBookResponse(resp.OrderBooks[0], basePrice)

Output:

+------------------------------------------------------------------------+
|          283061445 |         1.335000000000000000 |                    |
|          252607703 |         1.334000000000000000 |                    |
|          252895894 |         1.333000000000000000 |                    |
|          253180839 |         1.332000000000000000 |                    |
|          253466318 |         1.331000000000000000 |                    |
|          253752331 |         1.330000000000000000 |                    |
|          254038885 |         1.329000000000000000 |                    |
|          254325976 |         1.328000000000000000 |                    |
|          254613613 |         1.327000000000000000 |                    |
|          254901787 |         1.326000000000000000 |                    |
|------------------------------------------------------------------------|
|                              1.326000000000000000                      |
|------------------------------------------------------------------------|
|                    |         1.325000000000000000 | 272987175          |
|                    |         1.324000000000000000 | 255217324          |
|                    |         1.323000000000000000 | 255506641          |
|                    |         1.322000000000000000 | 255796508          |
|                    |         1.321000000000000000 | 256086923          |
|                    |         1.320000000000000000 | 367377883          |
|                    |         1.319000000000000000 | 256669399          |
|                    |         1.318000000000000000 | 256961468          |
|                    |         1.317000000000000000 | 257254090          |
|                    |         1.316000000000000000 | 368543354          |
+------------------------------------------------------------------------+
Example (Zigzag) 
ob := amm.NewOrderBook(
	newOrder(amm.Sell, utils.ParseDec("1.002"), sdk.NewInt(10000)),
	newOrder(amm.Buy, utils.ParseDec("1.001"), sdk.NewInt(5000)),
	newOrder(amm.Sell, utils.ParseDec("1.000"), sdk.NewInt(50000)),
	newOrder(amm.Buy, utils.ParseDec("0.999"), sdk.NewInt(100000)),
)
ov := ob.MakeView()
ov.Match()

basePrice, _ := types.OrderBookBasePrice(ov, 4)
resp := types.MakeOrderBookPairResponse(1, ov, utils.ParseDec("0.9"), utils.ParseDec("1.1"), 3, types.OrderBookConfig{
	PriceUnitPower: 0,
	MaxNumTicks:    20,
})
types.PrintOrderBookResponse(resp.OrderBooks[0], basePrice)

Output:

+------------------------------------------------------------------------+
|              10000 |         1.002000000000000000 |                    |
|              45000 |         1.000000000000000000 |                    |
|------------------------------------------------------------------------|
|                              0.999500000000000000                      |
|------------------------------------------------------------------------|
|                    |         0.999000000000000000 | 100000             |
+------------------------------------------------------------------------+

func (*OrderBookPairResponse) Descriptor 

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

func (*OrderBookPairResponse) GetOrderBooks 

func (m *OrderBookPairResponse) GetOrderBooks() []OrderBookResponse

func (*OrderBookPairResponse) GetPairId 

func (m *OrderBookPairResponse) GetPairId() uint64

func (*OrderBookPairResponse) Marshal 

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

func (*OrderBookPairResponse) MarshalTo 

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

func (*OrderBookPairResponse) MarshalToSizedBuffer 

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

func (*OrderBookPairResponse) ProtoMessage 

func (*OrderBookPairResponse) ProtoMessage()

func (*OrderBookPairResponse) Reset 

func (m *OrderBookPairResponse) Reset()

func (*OrderBookPairResponse) Size 

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

func (*OrderBookPairResponse) String 

func (m *OrderBookPairResponse) String() string

func (*OrderBookPairResponse) Unmarshal 

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

func (*OrderBookPairResponse) XXX_DiscardUnknown 

func (m *OrderBookPairResponse) XXX_DiscardUnknown()

func (*OrderBookPairResponse) XXX_Marshal 

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

func (*OrderBookPairResponse) XXX_Merge 

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

func (*OrderBookPairResponse) XXX_Size 

func (m *OrderBookPairResponse) XXX_Size() int

func (*OrderBookPairResponse) XXX_Unmarshal 

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

type OrderBookResponse 

type OrderBookResponse struct {
	PriceUnit github_com_cosmos_cosmos_sdk_types.Dec `` /* 128-byte string literal not displayed */
	Sells     []OrderBookTickResponse                `protobuf:"bytes,2,rep,name=sells,proto3" json:"sells"`
	Buys      []OrderBookTickResponse                `protobuf:"bytes,3,rep,name=buys,proto3" json:"buys"`
}

func (*OrderBookResponse) Descriptor 

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

func (*OrderBookResponse) GetBuys 

func (m *OrderBookResponse) GetBuys() []OrderBookTickResponse

func (*OrderBookResponse) GetSells 

func (m *OrderBookResponse) GetSells() []OrderBookTickResponse

func (*OrderBookResponse) Marshal 

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

func (*OrderBookResponse) MarshalTo 

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

func (*OrderBookResponse) MarshalToSizedBuffer 

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

func (*OrderBookResponse) ProtoMessage 

func (*OrderBookResponse) ProtoMessage()

func (*OrderBookResponse) Reset 

func (m *OrderBookResponse) Reset()

func (*OrderBookResponse) Size 

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

func (*OrderBookResponse) String 

func (m *OrderBookResponse) String() string

func (*OrderBookResponse) Unmarshal 

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

func (*OrderBookResponse) XXX_DiscardUnknown 

func (m *OrderBookResponse) XXX_DiscardUnknown()

func (*OrderBookResponse) XXX_Marshal 

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

func (*OrderBookResponse) XXX_Merge 

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

func (*OrderBookResponse) XXX_Size 

func (m *OrderBookResponse) XXX_Size() int

func (*OrderBookResponse) XXX_Unmarshal 

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

type OrderBookTickResponse 

type OrderBookTickResponse struct {
	Price           github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,1,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price"`
	UserOrderAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 148-byte string literal not displayed */
	PoolOrderAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 148-byte string literal not displayed */
}

func (*OrderBookTickResponse) Descriptor 

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

func (*OrderBookTickResponse) Marshal 

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

func (*OrderBookTickResponse) MarshalTo 

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

func (*OrderBookTickResponse) MarshalToSizedBuffer 

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

func (*OrderBookTickResponse) ProtoMessage 

func (*OrderBookTickResponse) ProtoMessage()

func (*OrderBookTickResponse) Reset 

func (m *OrderBookTickResponse) Reset()

func (*OrderBookTickResponse) Size 

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

func (*OrderBookTickResponse) String 

func (m *OrderBookTickResponse) String() string

func (*OrderBookTickResponse) Unmarshal 

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

func (*OrderBookTickResponse) XXX_DiscardUnknown 

func (m *OrderBookTickResponse) XXX_DiscardUnknown()

func (*OrderBookTickResponse) XXX_Marshal 

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

func (*OrderBookTickResponse) XXX_Merge 

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

func (*OrderBookTickResponse) XXX_Size 

func (m *OrderBookTickResponse) XXX_Size() int

func (*OrderBookTickResponse) XXX_Unmarshal 

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

type OrderDirection 

type OrderDirection int32

OrderDirection enumerates order directions. 

const (
	// ORDER_DIRECTION_UNSPECIFIED specifies unknown order direction
	OrderDirectionUnspecified OrderDirection = 0
	// ORDER_DIRECTION_BUY specifies buy(swap quote coin to base coin) order direction
	OrderDirectionBuy OrderDirection = 1
	// ORDER_DIRECTION_SELL specifies sell(swap base coin to quote coin) order direction
	OrderDirectionSell OrderDirection = 2
)

func OrderDirectionFromAMM 

func OrderDirectionFromAMM(dir amm.OrderDirection) OrderDirection

OrderDirectionFromAMM converts amm.OrderDirection to liquidity module's OrderDirection.

func (OrderDirection) EnumDescriptor 

func (OrderDirection) EnumDescriptor() ([]byte, []int)

func (OrderDirection) String 

func (x OrderDirection) String() string

type OrderStatus 

type OrderStatus int32

OrderStatus enumerates order statuses. 

const (
	// ORDER_STATUS_UNSPECIFIED specifies unknown order status
	OrderStatusUnspecified OrderStatus = 0
	// ORDER_STATUS_NOT_EXECUTED indicates the order has not been executed yet
	OrderStatusNotExecuted OrderStatus = 1
	// ORDER_STATUS_NOT_MATCHED indicates the order has been executed but has no match
	OrderStatusNotMatched OrderStatus = 2
	// ORDER_STATUS_PARTIALLY_MATCHED indicates the order has been partially matched
	OrderStatusPartiallyMatched OrderStatus = 3
	// ORDER_STATUS_COMPLETED indicates the order has been fully matched and completed
	OrderStatusCompleted OrderStatus = 4
	// ORDER_STATUS_CANCELED indicates the order has been canceled
	OrderStatusCanceled OrderStatus = 5
	// ORDER_STATUS_EXPIRED indicates the order has been expired
	OrderStatusExpired OrderStatus = 6
)

func (OrderStatus) CanBeCanceled 

func (status OrderStatus) CanBeCanceled() bool

CanBeCanceled returns true if the OrderStatus is one of: OrderStatusNotExecuted, OrderStatusNotMatched, OrderStatusPartiallyMatched.

func (OrderStatus) CanBeExpired 

func (status OrderStatus) CanBeExpired() bool

CanBeExpired has the same condition as IsMatchable.

func (OrderStatus) EnumDescriptor 

func (OrderStatus) EnumDescriptor() ([]byte, []int)

func (OrderStatus) IsCanceledOrExpired 

func (status OrderStatus) IsCanceledOrExpired() bool

IsCanceledOrExpired returns true if the OrderStatus is one of: OrderStatusCanceled, OrderStatusExpired.

func (OrderStatus) IsMatchable 

func (status OrderStatus) IsMatchable() bool

IsMatchable returns true if the OrderStatus is one of: OrderStatusNotExecuted, OrderStatusNotMatched, OrderStatusPartiallyMatched.

func (OrderStatus) IsValid 

func (status OrderStatus) IsValid() bool

IsValid returns true if the OrderStatus is one of: OrderStatusNotExecuted, OrderStatusNotMatched, OrderStatusPartiallyMatched, OrderStatusCompleted, OrderStatusCanceled, OrderStatusExpired.

func (OrderStatus) ShouldBeDeleted 

func (status OrderStatus) ShouldBeDeleted() bool

ShouldBeDeleted returns true if the OrderStatus is one of: OrderStatusCompleted, OrderStatusCanceled, OrderStatusExpired.

func (OrderStatus) String 

func (x OrderStatus) String() string

type OrderType 

type OrderType int32

OrderType enumerates order types. 

const (
	// ORDER_TYPE_UNSPECIFIED specifies unknown order type.
	OrderTypeUnspecified OrderType = 0
	// ORDER_TYPE_LIMIT specifies limit order type.
	OrderTypeLimit OrderType = 1
	// ORDER_TYPE_MARKET specifies market order type.
	OrderTypeMarket OrderType = 2
	// ORDER_TYPE_MM specifies MM(market making) order type.
	OrderTypeMM OrderType = 3
)

func (OrderType) EnumDescriptor 

func (OrderType) EnumDescriptor() ([]byte, []int)

func (OrderType) String 

func (x OrderType) String() string

type Pair 

type Pair struct {
	Id             uint64                                  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	BaseCoinDenom  string                                  `protobuf:"bytes,2,opt,name=base_coin_denom,json=baseCoinDenom,proto3" json:"base_coin_denom,omitempty"`
	QuoteCoinDenom string                                  `protobuf:"bytes,3,opt,name=quote_coin_denom,json=quoteCoinDenom,proto3" json:"quote_coin_denom,omitempty"`
	EscrowAddress  string                                  `protobuf:"bytes,4,opt,name=escrow_address,json=escrowAddress,proto3" json:"escrow_address,omitempty"`
	LastOrderId    uint64                                  `protobuf:"varint,5,opt,name=last_order_id,json=lastOrderId,proto3" json:"last_order_id,omitempty"`
	LastPrice      *github_com_cosmos_cosmos_sdk_types.Dec `` /* 138-byte string literal not displayed */
	CurrentBatchId uint64                                  `protobuf:"varint,7,opt,name=current_batch_id,json=currentBatchId,proto3" json:"current_batch_id,omitempty"`
}

Pair defines a coin pair.

func MustUnmarshalPair 

func MustUnmarshalPair(cdc codec.BinaryCodec, value []byte) Pair

MustUnmarshalPair return the unmarshalled pair from bytes. It throws panic if it fails.

func NewPair 

func NewPair(id uint64, baseCoinDenom, quoteCoinDenom string) Pair

NewPair returns a new pair object.

func UnmarshalPair 

func UnmarshalPair(cdc codec.BinaryCodec, value []byte) (pair Pair, err error)

UnmarshalPair returns the pair from bytes.

func (*Pair) Descriptor 

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

func (Pair) GetEscrowAddress 

func (pair Pair) GetEscrowAddress() sdk.AccAddress

func (*Pair) Marshal 

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

func (*Pair) MarshalTo 

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

func (*Pair) MarshalToSizedBuffer 

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

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) Reset 

func (m *Pair) Reset()

func (*Pair) Size 

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

func (*Pair) String 

func (m *Pair) String() string

func (*Pair) Unmarshal 

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

func (Pair) Validate 

func (pair Pair) Validate() error

Validate validates Pair for genesis.

func (*Pair) XXX_DiscardUnknown 

func (m *Pair) XXX_DiscardUnknown()

func (*Pair) XXX_Marshal 

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

func (*Pair) XXX_Merge 

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

func (*Pair) XXX_Size 

func (m *Pair) XXX_Size() int

func (*Pair) XXX_Unmarshal 

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

type Params 

type Params struct {
	BatchSize                    uint32                                   `protobuf:"varint,1,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	TickPrecision                uint32                                   `protobuf:"varint,2,opt,name=tick_precision,json=tickPrecision,proto3" json:"tick_precision,omitempty"`
	FeeCollectorAddress          string                                   `protobuf:"bytes,3,opt,name=fee_collector_address,json=feeCollectorAddress,proto3" json:"fee_collector_address,omitempty"`
	DustCollectorAddress         string                                   `protobuf:"bytes,4,opt,name=dust_collector_address,json=dustCollectorAddress,proto3" json:"dust_collector_address,omitempty"`
	MinInitialPoolCoinSupply     github_com_cosmos_cosmos_sdk_types.Int   `` /* 179-byte string literal not displayed */
	PairCreationFee              github_com_cosmos_cosmos_sdk_types.Coins `` /* 152-byte string literal not displayed */
	PoolCreationFee              github_com_cosmos_cosmos_sdk_types.Coins `` /* 152-byte string literal not displayed */
	MinInitialDepositAmount      github_com_cosmos_cosmos_sdk_types.Int   `` /* 174-byte string literal not displayed */
	MaxPriceLimitRatio           github_com_cosmos_cosmos_sdk_types.Dec   `` /* 159-byte string literal not displayed */
	MaxNumMarketMakingOrderTicks uint32                                   `` /* 155-byte string literal not displayed */
	MaxOrderLifespan             time.Duration                            `protobuf:"bytes,11,opt,name=max_order_lifespan,json=maxOrderLifespan,proto3,stdduration" json:"max_order_lifespan"`
	SwapFeeRate                  github_com_cosmos_cosmos_sdk_types.Dec   `` /* 137-byte string literal not displayed */
	WithdrawFeeRate              github_com_cosmos_cosmos_sdk_types.Dec   `` /* 149-byte string literal not displayed */
	DepositExtraGas              github_com_cosmos_cosmos_sdk_types.Gas   `` /* 150-byte string literal not displayed */
	WithdrawExtraGas             github_com_cosmos_cosmos_sdk_types.Gas   `` /* 153-byte string literal not displayed */
	OrderExtraGas                github_com_cosmos_cosmos_sdk_types.Gas   `` /* 144-byte string literal not displayed */
	MaxNumActivePoolsPerPair     uint32                                   `` /* 143-byte string literal not displayed */
}

Params defines the parameters for the liquidity module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default params for the liquidity module.

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

ParamSetPairs implements ParamSet.

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 (params Params) Validate() error

Validate validates 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 Pool 

type Pool struct {
	Type                  PoolType                                `protobuf:"varint,1,opt,name=type,proto3,enum=crescent.liquidity.v1beta1.PoolType" json:"type,omitempty"`
	Id                    uint64                                  `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	PairId                uint64                                  `protobuf:"varint,3,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	Creator               string                                  `protobuf:"bytes,4,opt,name=creator,proto3" json:"creator,omitempty"`
	ReserveAddress        string                                  `protobuf:"bytes,5,opt,name=reserve_address,json=reserveAddress,proto3" json:"reserve_address,omitempty"`
	PoolCoinDenom         string                                  `protobuf:"bytes,6,opt,name=pool_coin_denom,json=poolCoinDenom,proto3" json:"pool_coin_denom,omitempty"`
	MinPrice              *github_com_cosmos_cosmos_sdk_types.Dec `` /* 135-byte string literal not displayed */
	MaxPrice              *github_com_cosmos_cosmos_sdk_types.Dec `` /* 135-byte string literal not displayed */
	LastDepositRequestId  uint64                                  `` /* 126-byte string literal not displayed */
	LastWithdrawRequestId uint64                                  `` /* 130-byte string literal not displayed */
	Disabled              bool                                    `protobuf:"varint,11,opt,name=disabled,proto3" json:"disabled,omitempty"`
}

Pool defines generic liquidity pool object which can be either a basic pool or a ranged pool.

func MustUnmarshalPool 

func MustUnmarshalPool(cdc codec.BinaryCodec, value []byte) Pool

MustUnmarshalPool return the unmarshalled pool from bytes. It throws panic if it fails.

func NewBasicPool 

func NewBasicPool(id, pairId uint64, creator sdk.AccAddress) Pool

NewBasicPool returns a new basic pool object.

func NewRangedPool 

func NewRangedPool(id, pairId uint64, creator sdk.AccAddress, minPrice, maxPrice sdk.Dec) Pool

NewRangedPool returns a new ranged pool object.

func UnmarshalPool 

func UnmarshalPool(cdc codec.BinaryCodec, value []byte) (pool Pool, err error)

UnmarshalPool returns the pool from bytes.

func (Pool) AMMPool 

func (pool Pool) AMMPool(rx, ry, ps sdk.Int) amm.Pool

AMMPool constructs amm.Pool interface from Pool.

func (*Pool) Descriptor 

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

func (Pool) GetCreator 

func (pool Pool) GetCreator() sdk.AccAddress

func (Pool) GetReserveAddress 

func (pool Pool) GetReserveAddress() sdk.AccAddress

func (*Pool) Marshal 

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

func (*Pool) MarshalTo 

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

func (*Pool) MarshalToSizedBuffer 

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

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) Size 

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

func (*Pool) String 

func (m *Pool) String() string

func (*Pool) Unmarshal 

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

func (Pool) Validate 

func (pool Pool) Validate() error

Validate validates Pool for genesis.

func (*Pool) XXX_DiscardUnknown 

func (m *Pool) XXX_DiscardUnknown()

func (*Pool) XXX_Marshal 

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

func (*Pool) XXX_Merge 

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

func (*Pool) XXX_Size 

func (m *Pool) XXX_Size() int

func (*Pool) XXX_Unmarshal 

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

type PoolBalances 

type PoolBalances struct {
	BaseCoin  types.Coin `protobuf:"bytes,1,opt,name=base_coin,json=baseCoin,proto3" json:"base_coin"`
	QuoteCoin types.Coin `protobuf:"bytes,2,opt,name=quote_coin,json=quoteCoin,proto3" json:"quote_coin"`
}

func (*PoolBalances) Descriptor 

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

func (*PoolBalances) GetBaseCoin 

func (m *PoolBalances) GetBaseCoin() types.Coin

func (*PoolBalances) GetQuoteCoin 

func (m *PoolBalances) GetQuoteCoin() types.Coin

func (*PoolBalances) Marshal 

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

func (*PoolBalances) MarshalTo 

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

func (*PoolBalances) MarshalToSizedBuffer 

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

func (*PoolBalances) ProtoMessage 

func (*PoolBalances) ProtoMessage()

func (*PoolBalances) Reset 

func (m *PoolBalances) Reset()

func (*PoolBalances) Size 

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

func (*PoolBalances) String 

func (m *PoolBalances) String() string

func (*PoolBalances) Unmarshal 

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

func (*PoolBalances) XXX_DiscardUnknown 

func (m *PoolBalances) XXX_DiscardUnknown()

func (*PoolBalances) XXX_Marshal 

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

func (*PoolBalances) XXX_Merge 

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

func (*PoolBalances) XXX_Size 

func (m *PoolBalances) XXX_Size() int

func (*PoolBalances) XXX_Unmarshal 

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

type PoolOrder 

type PoolOrder struct {
	*amm.BaseOrder
	PoolId                          uint64
	ReserveAddress                  sdk.AccAddress
	OfferCoinDenom, DemandCoinDenom string
}

func NewPoolOrder 

func NewPoolOrder(
	poolId uint64, reserveAddr sdk.AccAddress, dir amm.OrderDirection, price sdk.Dec, amt sdk.Int,
	offerCoinDenom, demandCoinDenom string) *PoolOrder

func (*PoolOrder) HasPriority 

func (order *PoolOrder) HasPriority(other amm.Order) bool

func (*PoolOrder) String 

func (order *PoolOrder) String() string

type PoolOrderer 

type PoolOrderer struct {
	amm.Pool
	Id                            uint64
	ReserveAddress                sdk.AccAddress
	BaseCoinDenom, QuoteCoinDenom string
}

func NewPoolOrderer 

func NewPoolOrderer(pool amm.Pool, id uint64, reserveAddr sdk.AccAddress, baseCoinDenom, quoteCoinDenom string) *PoolOrderer

func (*PoolOrderer) Order 

func (orderer *PoolOrderer) Order(dir amm.OrderDirection, price sdk.Dec, amt sdk.Int) amm.Order

type PoolResponse 

type PoolResponse struct {
	Type                  PoolType                                `protobuf:"varint,1,opt,name=type,proto3,enum=crescent.liquidity.v1beta1.PoolType" json:"type,omitempty"`
	Id                    uint64                                  `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	PairId                uint64                                  `protobuf:"varint,3,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	Creator               string                                  `protobuf:"bytes,4,opt,name=creator,proto3" json:"creator,omitempty"`
	ReserveAddress        string                                  `protobuf:"bytes,5,opt,name=reserve_address,json=reserveAddress,proto3" json:"reserve_address,omitempty"`
	PoolCoinDenom         string                                  `protobuf:"bytes,6,opt,name=pool_coin_denom,json=poolCoinDenom,proto3" json:"pool_coin_denom,omitempty"`
	PoolCoinSupply        github_com_cosmos_cosmos_sdk_types.Int  `` /* 145-byte string literal not displayed */
	MinPrice              *github_com_cosmos_cosmos_sdk_types.Dec `` /* 135-byte string literal not displayed */
	MaxPrice              *github_com_cosmos_cosmos_sdk_types.Dec `` /* 135-byte string literal not displayed */
	Price                 *github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,10,opt,name=price,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"price,omitempty"`
	Balances              PoolBalances                            `protobuf:"bytes,11,opt,name=balances,proto3" json:"balances"`
	LastDepositRequestId  uint64                                  `` /* 127-byte string literal not displayed */
	LastWithdrawRequestId uint64                                  `` /* 130-byte string literal not displayed */
	Disabled              bool                                    `protobuf:"varint,14,opt,name=disabled,proto3" json:"disabled,omitempty"`
}

PoolResponse defines a custom pool response message.

func NewPoolResponse 

func NewPoolResponse(pool Pool, rx, ry sdk.Coin, poolCoinSupply sdk.Int) PoolResponse

NewPoolResponse returns a new PoolResponse from given information.

func (*PoolResponse) Descriptor 

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

func (*PoolResponse) GetBalances 

func (m *PoolResponse) GetBalances() PoolBalances

func (*PoolResponse) GetCreator 

func (m *PoolResponse) GetCreator() string

func (*PoolResponse) GetDisabled 

func (m *PoolResponse) GetDisabled() bool

func (*PoolResponse) GetId 

func (m *PoolResponse) GetId() uint64

func (*PoolResponse) GetLastDepositRequestId 

func (m *PoolResponse) GetLastDepositRequestId() uint64

func (*PoolResponse) GetLastWithdrawRequestId 

func (m *PoolResponse) GetLastWithdrawRequestId() uint64

func (*PoolResponse) GetPairId 

func (m *PoolResponse) GetPairId() uint64

func (*PoolResponse) GetPoolCoinDenom 

func (m *PoolResponse) GetPoolCoinDenom() string

func (*PoolResponse) GetReserveAddress 

func (m *PoolResponse) GetReserveAddress() string

func (*PoolResponse) GetType 

func (m *PoolResponse) GetType() PoolType

func (*PoolResponse) Marshal 

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

func (*PoolResponse) MarshalTo 

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

func (*PoolResponse) MarshalToSizedBuffer 

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

func (*PoolResponse) ProtoMessage 

func (*PoolResponse) ProtoMessage()

func (*PoolResponse) Reset 

func (m *PoolResponse) Reset()

func (*PoolResponse) Size 

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

func (*PoolResponse) String 

func (m *PoolResponse) String() string

func (*PoolResponse) Unmarshal 

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

func (*PoolResponse) XXX_DiscardUnknown 

func (m *PoolResponse) XXX_DiscardUnknown()

func (*PoolResponse) XXX_Marshal 

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

func (*PoolResponse) XXX_Merge 

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

func (*PoolResponse) XXX_Size 

func (m *PoolResponse) XXX_Size() int

func (*PoolResponse) XXX_Unmarshal 

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

type PoolType 

type PoolType int32

PoolType enumerates pool types. 

const (
	// POOL_TYPE_UNSPECIFIED specifies unknown pool type
	PoolTypeUnspecified PoolType = 0
	// POOL_TYPE_BASIC specifies the basic pool type
	PoolTypeBasic PoolType = 1
	// POOL_TYPE_RANGED specifies the ranged pool type
	PoolTypeRanged PoolType = 2
)

func (PoolType) EnumDescriptor 

func (PoolType) EnumDescriptor() ([]byte, []int)

func (PoolType) String 

func (x PoolType) String() string

type QueryClient 

type QueryClient interface {
	// Params returns parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Pools returns all liquidity pools.
	Pools(ctx context.Context, in *QueryPoolsRequest, opts ...grpc.CallOption) (*QueryPoolsResponse, error)
	// Pool returns the specific liquidity pool.
	Pool(ctx context.Context, in *QueryPoolRequest, opts ...grpc.CallOption) (*QueryPoolResponse, error)
	// PoolByReserveAddress returns all pools that correspond to the reserve account.
	PoolByReserveAddress(ctx context.Context, in *QueryPoolByReserveAddressRequest, opts ...grpc.CallOption) (*QueryPoolResponse, error)
	// PoolByPoolCoinDenom returns all pools that correspond to the pool coin denom.
	PoolByPoolCoinDenom(ctx context.Context, in *QueryPoolByPoolCoinDenomRequest, opts ...grpc.CallOption) (*QueryPoolResponse, error)
	// Pairs returns all liquidity pairs.
	Pairs(ctx context.Context, in *QueryPairsRequest, opts ...grpc.CallOption) (*QueryPairsResponse, error)
	// Pair returns the specific pair.
	Pair(ctx context.Context, in *QueryPairRequest, opts ...grpc.CallOption) (*QueryPairResponse, error)
	// DepositRequests returns all deposit requests.
	DepositRequests(ctx context.Context, in *QueryDepositRequestsRequest, opts ...grpc.CallOption) (*QueryDepositRequestsResponse, error)
	// DepositRequest returns the specific deposit request.
	DepositRequest(ctx context.Context, in *QueryDepositRequestRequest, opts ...grpc.CallOption) (*QueryDepositRequestResponse, error)
	// WithdrawRequests returns all withdraw requests.
	WithdrawRequests(ctx context.Context, in *QueryWithdrawRequestsRequest, opts ...grpc.CallOption) (*QueryWithdrawRequestsResponse, error)
	// WithdrawRequest returns the specific withdraw request.
	WithdrawRequest(ctx context.Context, in *QueryWithdrawRequestRequest, opts ...grpc.CallOption) (*QueryWithdrawRequestResponse, error)
	// Orders returns all orders within the pair.
	Orders(ctx context.Context, in *QueryOrdersRequest, opts ...grpc.CallOption) (*QueryOrdersResponse, error)
	// Order returns the specific order.
	Order(ctx context.Context, in *QueryOrderRequest, opts ...grpc.CallOption) (*QueryOrderResponse, error)
	// OrdersByOrderer returns orders made by an orderer.
	OrdersByOrderer(ctx context.Context, in *QueryOrdersByOrdererRequest, opts ...grpc.CallOption) (*QueryOrdersResponse, error)
	OrderBooks(ctx context.Context, in *QueryOrderBooksRequest, opts ...grpc.CallOption) (*QueryOrderBooksResponse, 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 QueryDepositRequestRequest 

type QueryDepositRequestRequest struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Id     uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

QueryDepositRequestRequest is request type for the Query/DepositRequest RPC method.

func (*QueryDepositRequestRequest) Descriptor 

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

func (*QueryDepositRequestRequest) GetId 

func (m *QueryDepositRequestRequest) GetId() uint64

func (*QueryDepositRequestRequest) GetPoolId 

func (m *QueryDepositRequestRequest) GetPoolId() uint64

func (*QueryDepositRequestRequest) Marshal 

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

func (*QueryDepositRequestRequest) MarshalTo 

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

func (*QueryDepositRequestRequest) MarshalToSizedBuffer 

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

func (*QueryDepositRequestRequest) ProtoMessage 

func (*QueryDepositRequestRequest) ProtoMessage()

func (*QueryDepositRequestRequest) Reset 

func (m *QueryDepositRequestRequest) Reset()

func (*QueryDepositRequestRequest) Size 

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

func (*QueryDepositRequestRequest) String 

func (m *QueryDepositRequestRequest) String() string

func (*QueryDepositRequestRequest) Unmarshal 

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

func (*QueryDepositRequestRequest) XXX_DiscardUnknown 

func (m *QueryDepositRequestRequest) XXX_DiscardUnknown()

func (*QueryDepositRequestRequest) XXX_Marshal 

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

func (*QueryDepositRequestRequest) XXX_Merge 

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

func (*QueryDepositRequestRequest) XXX_Size 

func (m *QueryDepositRequestRequest) XXX_Size() int

func (*QueryDepositRequestRequest) XXX_Unmarshal 

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

type QueryDepositRequestResponse 

type QueryDepositRequestResponse struct {
	DepositRequest DepositRequest `protobuf:"bytes,1,opt,name=deposit_request,json=depositRequest,proto3" json:"deposit_request"`
}

QueryDepositRequestResponse is response type for the Query/DepositRequest RPC method.

func (*QueryDepositRequestResponse) Descriptor 

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

func (*QueryDepositRequestResponse) GetDepositRequest 

func (m *QueryDepositRequestResponse) GetDepositRequest() DepositRequest

func (*QueryDepositRequestResponse) Marshal 

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

func (*QueryDepositRequestResponse) MarshalTo 

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

func (*QueryDepositRequestResponse) MarshalToSizedBuffer 

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

func (*QueryDepositRequestResponse) ProtoMessage 

func (*QueryDepositRequestResponse) ProtoMessage()

func (*QueryDepositRequestResponse) Reset 

func (m *QueryDepositRequestResponse) Reset()

func (*QueryDepositRequestResponse) Size 

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

func (*QueryDepositRequestResponse) String 

func (m *QueryDepositRequestResponse) String() string

func (*QueryDepositRequestResponse) Unmarshal 

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

func (*QueryDepositRequestResponse) XXX_DiscardUnknown 

func (m *QueryDepositRequestResponse) XXX_DiscardUnknown()

func (*QueryDepositRequestResponse) XXX_Marshal 

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

func (*QueryDepositRequestResponse) XXX_Merge 

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

func (*QueryDepositRequestResponse) XXX_Size 

func (m *QueryDepositRequestResponse) XXX_Size() int

func (*QueryDepositRequestResponse) XXX_Unmarshal 

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

type QueryDepositRequestsRequest 

type QueryDepositRequestsRequest struct {
	PoolId     uint64             `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDepositRequestsRequest is request type for the Query/DepositRequests RPC method.

func (*QueryDepositRequestsRequest) Descriptor 

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

func (*QueryDepositRequestsRequest) GetPagination 

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

func (*QueryDepositRequestsRequest) GetPoolId 

func (m *QueryDepositRequestsRequest) GetPoolId() uint64

func (*QueryDepositRequestsRequest) Marshal 

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

func (*QueryDepositRequestsRequest) MarshalTo 

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

func (*QueryDepositRequestsRequest) MarshalToSizedBuffer 

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

func (*QueryDepositRequestsRequest) ProtoMessage 

func (*QueryDepositRequestsRequest) ProtoMessage()

func (*QueryDepositRequestsRequest) Reset 

func (m *QueryDepositRequestsRequest) Reset()

func (*QueryDepositRequestsRequest) Size 

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

func (*QueryDepositRequestsRequest) String 

func (m *QueryDepositRequestsRequest) String() string

func (*QueryDepositRequestsRequest) Unmarshal 

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

func (*QueryDepositRequestsRequest) XXX_DiscardUnknown 

func (m *QueryDepositRequestsRequest) XXX_DiscardUnknown()

func (*QueryDepositRequestsRequest) XXX_Marshal 

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

func (*QueryDepositRequestsRequest) XXX_Merge 

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

func (*QueryDepositRequestsRequest) XXX_Size 

func (m *QueryDepositRequestsRequest) XXX_Size() int

func (*QueryDepositRequestsRequest) XXX_Unmarshal 

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

type QueryDepositRequestsResponse 

type QueryDepositRequestsResponse struct {
	DepositRequests []DepositRequest    `protobuf:"bytes,1,rep,name=deposit_requests,json=depositRequests,proto3" json:"deposit_requests"`
	Pagination      *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDepositRequestsResponse is response type for the Query/DepositRequests RPC method.

func (*QueryDepositRequestsResponse) Descriptor 

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

func (*QueryDepositRequestsResponse) GetDepositRequests 

func (m *QueryDepositRequestsResponse) GetDepositRequests() []DepositRequest

func (*QueryDepositRequestsResponse) GetPagination 

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

func (*QueryDepositRequestsResponse) Marshal 

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

func (*QueryDepositRequestsResponse) MarshalTo 

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

func (*QueryDepositRequestsResponse) MarshalToSizedBuffer 

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

func (*QueryDepositRequestsResponse) ProtoMessage 

func (*QueryDepositRequestsResponse) ProtoMessage()

func (*QueryDepositRequestsResponse) Reset 

func (m *QueryDepositRequestsResponse) Reset()

func (*QueryDepositRequestsResponse) Size 

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

func (*QueryDepositRequestsResponse) String 

func (m *QueryDepositRequestsResponse) String() string

func (*QueryDepositRequestsResponse) Unmarshal 

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

func (*QueryDepositRequestsResponse) XXX_DiscardUnknown 

func (m *QueryDepositRequestsResponse) XXX_DiscardUnknown()

func (*QueryDepositRequestsResponse) XXX_Marshal 

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

func (*QueryDepositRequestsResponse) XXX_Merge 

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

func (*QueryDepositRequestsResponse) XXX_Size 

func (m *QueryDepositRequestsResponse) XXX_Size() int

func (*QueryDepositRequestsResponse) XXX_Unmarshal 

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

type QueryOrderBooksRequest 

type QueryOrderBooksRequest struct {
	PairIds         []uint64 `protobuf:"varint,1,rep,packed,name=pair_ids,json=pairIds,proto3" json:"pair_ids,omitempty"`
	PriceUnitPowers []uint32 `protobuf:"varint,2,rep,packed,name=price_unit_powers,json=priceUnitPowers,proto3" json:"price_unit_powers,omitempty"`
	NumTicks        uint32   `protobuf:"varint,3,opt,name=num_ticks,json=numTicks,proto3" json:"num_ticks,omitempty"`
}

QueryOrderBooksRequest is request type for the Query/OrderBooks RPC method.

func (*QueryOrderBooksRequest) Descriptor 

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

func (*QueryOrderBooksRequest) GetNumTicks 

func (m *QueryOrderBooksRequest) GetNumTicks() uint32

func (*QueryOrderBooksRequest) GetPairIds 

func (m *QueryOrderBooksRequest) GetPairIds() []uint64

func (*QueryOrderBooksRequest) GetPriceUnitPowers 

func (m *QueryOrderBooksRequest) GetPriceUnitPowers() []uint32

func (*QueryOrderBooksRequest) Marshal 

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

func (*QueryOrderBooksRequest) MarshalTo 

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

func (*QueryOrderBooksRequest) MarshalToSizedBuffer 

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

func (*QueryOrderBooksRequest) ProtoMessage 

func (*QueryOrderBooksRequest) ProtoMessage()

func (*QueryOrderBooksRequest) Reset 

func (m *QueryOrderBooksRequest) Reset()

func (*QueryOrderBooksRequest) Size 

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

func (*QueryOrderBooksRequest) String 

func (m *QueryOrderBooksRequest) String() string

func (*QueryOrderBooksRequest) Unmarshal 

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

func (*QueryOrderBooksRequest) XXX_DiscardUnknown 

func (m *QueryOrderBooksRequest) XXX_DiscardUnknown()

func (*QueryOrderBooksRequest) XXX_Marshal 

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

func (*QueryOrderBooksRequest) XXX_Merge 

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

func (*QueryOrderBooksRequest) XXX_Size 

func (m *QueryOrderBooksRequest) XXX_Size() int

func (*QueryOrderBooksRequest) XXX_Unmarshal 

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

type QueryOrderBooksResponse 

type QueryOrderBooksResponse struct {
	Pairs []OrderBookPairResponse `protobuf:"bytes,2,rep,name=pairs,proto3" json:"pairs"`
}

QueryOrderBooksResponse is response type for Query/OrderBooks RPC method.

func (*QueryOrderBooksResponse) Descriptor 

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

func (*QueryOrderBooksResponse) GetPairs 

func (m *QueryOrderBooksResponse) GetPairs() []OrderBookPairResponse

func (*QueryOrderBooksResponse) Marshal 

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

func (*QueryOrderBooksResponse) MarshalTo 

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

func (*QueryOrderBooksResponse) MarshalToSizedBuffer 

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

func (*QueryOrderBooksResponse) ProtoMessage 

func (*QueryOrderBooksResponse) ProtoMessage()

func (*QueryOrderBooksResponse) Reset 

func (m *QueryOrderBooksResponse) Reset()

func (*QueryOrderBooksResponse) Size 

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

func (*QueryOrderBooksResponse) String 

func (m *QueryOrderBooksResponse) String() string

func (*QueryOrderBooksResponse) Unmarshal 

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

func (*QueryOrderBooksResponse) XXX_DiscardUnknown 

func (m *QueryOrderBooksResponse) XXX_DiscardUnknown()

func (*QueryOrderBooksResponse) XXX_Marshal 

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

func (*QueryOrderBooksResponse) XXX_Merge 

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

func (*QueryOrderBooksResponse) XXX_Size 

func (m *QueryOrderBooksResponse) XXX_Size() int

func (*QueryOrderBooksResponse) XXX_Unmarshal 

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

type QueryOrderRequest 

type QueryOrderRequest struct {
	PairId uint64 `protobuf:"varint,1,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	Id     uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

QueryOrderRequest is request type for the Query/Order RPC method.

func (*QueryOrderRequest) Descriptor 

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

func (*QueryOrderRequest) GetId 

func (m *QueryOrderRequest) GetId() uint64

func (*QueryOrderRequest) GetPairId 

func (m *QueryOrderRequest) GetPairId() uint64

func (*QueryOrderRequest) Marshal 

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

func (*QueryOrderRequest) MarshalTo 

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

func (*QueryOrderRequest) MarshalToSizedBuffer 

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

func (*QueryOrderRequest) ProtoMessage 

func (*QueryOrderRequest) ProtoMessage()

func (*QueryOrderRequest) Reset 

func (m *QueryOrderRequest) Reset()

func (*QueryOrderRequest) Size 

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

func (*QueryOrderRequest) String 

func (m *QueryOrderRequest) String() string

func (*QueryOrderRequest) Unmarshal 

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

func (*QueryOrderRequest) XXX_DiscardUnknown 

func (m *QueryOrderRequest) XXX_DiscardUnknown()

func (*QueryOrderRequest) XXX_Marshal 

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

func (*QueryOrderRequest) XXX_Merge 

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

func (*QueryOrderRequest) XXX_Size 

func (m *QueryOrderRequest) XXX_Size() int

func (*QueryOrderRequest) XXX_Unmarshal 

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

type QueryOrderResponse 

type QueryOrderResponse struct {
	Order Order `protobuf:"bytes,1,opt,name=order,proto3" json:"order"`
}

QueryOrderResponse is response type for the Query/Order RPC method.

func (*QueryOrderResponse) Descriptor 

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

func (*QueryOrderResponse) GetOrder 

func (m *QueryOrderResponse) GetOrder() Order

func (*QueryOrderResponse) Marshal 

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

func (*QueryOrderResponse) MarshalTo 

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

func (*QueryOrderResponse) MarshalToSizedBuffer 

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

func (*QueryOrderResponse) ProtoMessage 

func (*QueryOrderResponse) ProtoMessage()

func (*QueryOrderResponse) Reset 

func (m *QueryOrderResponse) Reset()

func (*QueryOrderResponse) Size 

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

func (*QueryOrderResponse) String 

func (m *QueryOrderResponse) String() string

func (*QueryOrderResponse) Unmarshal 

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

func (*QueryOrderResponse) XXX_DiscardUnknown 

func (m *QueryOrderResponse) XXX_DiscardUnknown()

func (*QueryOrderResponse) XXX_Marshal 

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

func (*QueryOrderResponse) XXX_Merge 

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

func (*QueryOrderResponse) XXX_Size 

func (m *QueryOrderResponse) XXX_Size() int

func (*QueryOrderResponse) XXX_Unmarshal 

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

type QueryOrdersByOrdererRequest 

type QueryOrdersByOrdererRequest struct {
	Orderer    string             `protobuf:"bytes,1,opt,name=orderer,proto3" json:"orderer,omitempty"`
	PairId     uint64             `protobuf:"varint,2,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryOrdersByOrdererRequest is request type for the Query/OrdersByOrderer RPC method.

func (*QueryOrdersByOrdererRequest) Descriptor 

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

func (*QueryOrdersByOrdererRequest) GetOrderer 

func (m *QueryOrdersByOrdererRequest) GetOrderer() string

func (*QueryOrdersByOrdererRequest) GetPagination 

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

func (*QueryOrdersByOrdererRequest) GetPairId 

func (m *QueryOrdersByOrdererRequest) GetPairId() uint64

func (*QueryOrdersByOrdererRequest) Marshal 

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

func (*QueryOrdersByOrdererRequest) MarshalTo 

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

func (*QueryOrdersByOrdererRequest) MarshalToSizedBuffer 

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

func (*QueryOrdersByOrdererRequest) ProtoMessage 

func (*QueryOrdersByOrdererRequest) ProtoMessage()

func (*QueryOrdersByOrdererRequest) Reset 

func (m *QueryOrdersByOrdererRequest) Reset()

func (*QueryOrdersByOrdererRequest) Size 

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

func (*QueryOrdersByOrdererRequest) String 

func (m *QueryOrdersByOrdererRequest) String() string

func (*QueryOrdersByOrdererRequest) Unmarshal 

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

func (*QueryOrdersByOrdererRequest) XXX_DiscardUnknown 

func (m *QueryOrdersByOrdererRequest) XXX_DiscardUnknown()

func (*QueryOrdersByOrdererRequest) XXX_Marshal 

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

func (*QueryOrdersByOrdererRequest) XXX_Merge 

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

func (*QueryOrdersByOrdererRequest) XXX_Size 

func (m *QueryOrdersByOrdererRequest) XXX_Size() int

func (*QueryOrdersByOrdererRequest) XXX_Unmarshal 

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

type QueryOrdersRequest 

type QueryOrdersRequest struct {
	PairId     uint64             `protobuf:"varint,1,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryOrdersRequest is request type for the Query/Orders RPC method.

func (*QueryOrdersRequest) Descriptor 

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

func (*QueryOrdersRequest) GetPagination 

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

func (*QueryOrdersRequest) GetPairId 

func (m *QueryOrdersRequest) GetPairId() uint64

func (*QueryOrdersRequest) Marshal 

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

func (*QueryOrdersRequest) MarshalTo 

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

func (*QueryOrdersRequest) MarshalToSizedBuffer 

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

func (*QueryOrdersRequest) ProtoMessage 

func (*QueryOrdersRequest) ProtoMessage()

func (*QueryOrdersRequest) Reset 

func (m *QueryOrdersRequest) Reset()

func (*QueryOrdersRequest) Size 

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

func (*QueryOrdersRequest) String 

func (m *QueryOrdersRequest) String() string

func (*QueryOrdersRequest) Unmarshal 

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

func (*QueryOrdersRequest) XXX_DiscardUnknown 

func (m *QueryOrdersRequest) XXX_DiscardUnknown()

func (*QueryOrdersRequest) XXX_Marshal 

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

func (*QueryOrdersRequest) XXX_Merge 

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

func (*QueryOrdersRequest) XXX_Size 

func (m *QueryOrdersRequest) XXX_Size() int

func (*QueryOrdersRequest) XXX_Unmarshal 

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

type QueryOrdersResponse 

type QueryOrdersResponse struct {
	Orders     []Order             `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryOrdersResponse is response type for the Query/Orders RPC method.

func (*QueryOrdersResponse) Descriptor 

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

func (*QueryOrdersResponse) GetOrders 

func (m *QueryOrdersResponse) GetOrders() []Order

func (*QueryOrdersResponse) GetPagination 

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

func (*QueryOrdersResponse) Marshal 

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

func (*QueryOrdersResponse) MarshalTo 

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

func (*QueryOrdersResponse) MarshalToSizedBuffer 

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

func (*QueryOrdersResponse) ProtoMessage 

func (*QueryOrdersResponse) ProtoMessage()

func (*QueryOrdersResponse) Reset 

func (m *QueryOrdersResponse) Reset()

func (*QueryOrdersResponse) Size 

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

func (*QueryOrdersResponse) String 

func (m *QueryOrdersResponse) String() string

func (*QueryOrdersResponse) Unmarshal 

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

func (*QueryOrdersResponse) XXX_DiscardUnknown 

func (m *QueryOrdersResponse) XXX_DiscardUnknown()

func (*QueryOrdersResponse) XXX_Marshal 

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

func (*QueryOrdersResponse) XXX_Merge 

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

func (*QueryOrdersResponse) XXX_Size 

func (m *QueryOrdersResponse) XXX_Size() int

func (*QueryOrdersResponse) XXX_Unmarshal 

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

type QueryPairRequest 

type QueryPairRequest struct {
	PairId uint64 `protobuf:"varint,1,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
}

QueryPairRequest is request type for the Query/Pair RPC method.

func (*QueryPairRequest) Descriptor 

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

func (*QueryPairRequest) GetPairId 

func (m *QueryPairRequest) GetPairId() uint64

func (*QueryPairRequest) Marshal 

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

func (*QueryPairRequest) MarshalTo 

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

func (*QueryPairRequest) MarshalToSizedBuffer 

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

func (*QueryPairRequest) ProtoMessage 

func (*QueryPairRequest) ProtoMessage()

func (*QueryPairRequest) Reset 

func (m *QueryPairRequest) Reset()

func (*QueryPairRequest) Size 

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

func (*QueryPairRequest) String 

func (m *QueryPairRequest) String() string

func (*QueryPairRequest) Unmarshal 

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

func (*QueryPairRequest) XXX_DiscardUnknown 

func (m *QueryPairRequest) XXX_DiscardUnknown()

func (*QueryPairRequest) XXX_Marshal 

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

func (*QueryPairRequest) XXX_Merge 

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

func (*QueryPairRequest) XXX_Size 

func (m *QueryPairRequest) XXX_Size() int

func (*QueryPairRequest) XXX_Unmarshal 

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

type QueryPairResponse 

type QueryPairResponse struct {
	Pair Pair `protobuf:"bytes,1,opt,name=pair,proto3" json:"pair"`
}

QueryPairResponse is response type for the Query/Pair RPC method.

func (*QueryPairResponse) Descriptor 

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

func (*QueryPairResponse) GetPair 

func (m *QueryPairResponse) GetPair() Pair

func (*QueryPairResponse) Marshal 

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

func (*QueryPairResponse) MarshalTo 

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

func (*QueryPairResponse) MarshalToSizedBuffer 

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

func (*QueryPairResponse) ProtoMessage 

func (*QueryPairResponse) ProtoMessage()

func (*QueryPairResponse) Reset 

func (m *QueryPairResponse) Reset()

func (*QueryPairResponse) Size 

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

func (*QueryPairResponse) String 

func (m *QueryPairResponse) String() string

func (*QueryPairResponse) Unmarshal 

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

func (*QueryPairResponse) XXX_DiscardUnknown 

func (m *QueryPairResponse) XXX_DiscardUnknown()

func (*QueryPairResponse) XXX_Marshal 

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

func (*QueryPairResponse) XXX_Merge 

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

func (*QueryPairResponse) XXX_Size 

func (m *QueryPairResponse) XXX_Size() int

func (*QueryPairResponse) XXX_Unmarshal 

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

type QueryPairsRequest 

type QueryPairsRequest struct {
	Denoms     []string           `protobuf:"bytes,1,rep,name=denoms,proto3" json:"denoms,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

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

func (*QueryPairsRequest) Descriptor 

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

func (*QueryPairsRequest) GetDenoms 

func (m *QueryPairsRequest) GetDenoms() []string

func (*QueryPairsRequest) GetPagination 

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

func (*QueryPairsRequest) Marshal 

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

func (*QueryPairsRequest) MarshalTo 

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

func (*QueryPairsRequest) MarshalToSizedBuffer 

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

func (*QueryPairsRequest) ProtoMessage 

func (*QueryPairsRequest) ProtoMessage()

func (*QueryPairsRequest) Reset 

func (m *QueryPairsRequest) Reset()

func (*QueryPairsRequest) Size 

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

func (*QueryPairsRequest) String 

func (m *QueryPairsRequest) String() string

func (*QueryPairsRequest) Unmarshal 

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

func (*QueryPairsRequest) XXX_DiscardUnknown 

func (m *QueryPairsRequest) XXX_DiscardUnknown()

func (*QueryPairsRequest) XXX_Marshal 

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

func (*QueryPairsRequest) XXX_Merge 

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

func (*QueryPairsRequest) XXX_Size 

func (m *QueryPairsRequest) XXX_Size() int

func (*QueryPairsRequest) XXX_Unmarshal 

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

type QueryPairsResponse 

type QueryPairsResponse struct {
	Pairs      []Pair              `protobuf:"bytes,1,rep,name=pairs,proto3" json:"pairs"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

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

func (*QueryPairsResponse) Descriptor 

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

func (*QueryPairsResponse) GetPagination 

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

func (*QueryPairsResponse) GetPairs 

func (m *QueryPairsResponse) GetPairs() []Pair

func (*QueryPairsResponse) Marshal 

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

func (*QueryPairsResponse) MarshalTo 

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

func (*QueryPairsResponse) MarshalToSizedBuffer 

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

func (*QueryPairsResponse) ProtoMessage 

func (*QueryPairsResponse) ProtoMessage()

func (*QueryPairsResponse) Reset 

func (m *QueryPairsResponse) Reset()

func (*QueryPairsResponse) Size 

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

func (*QueryPairsResponse) String 

func (m *QueryPairsResponse) String() string

func (*QueryPairsResponse) Unmarshal 

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

func (*QueryPairsResponse) XXX_DiscardUnknown 

func (m *QueryPairsResponse) XXX_DiscardUnknown()

func (*QueryPairsResponse) XXX_Marshal 

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

func (*QueryPairsResponse) XXX_Merge 

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

func (*QueryPairsResponse) XXX_Size 

func (m *QueryPairsResponse) XXX_Size() int

func (*QueryPairsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is 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 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 QueryPoolByPoolCoinDenomRequest 

type QueryPoolByPoolCoinDenomRequest struct {
	PoolCoinDenom string `protobuf:"bytes,1,opt,name=pool_coin_denom,json=poolCoinDenom,proto3" json:"pool_coin_denom,omitempty"`
}

QueryPoolByPoolCoinDenomRequest is request type for the Query/PoolByPoolCoinDenom RPC method.

func (*QueryPoolByPoolCoinDenomRequest) Descriptor 

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

func (*QueryPoolByPoolCoinDenomRequest) GetPoolCoinDenom 

func (m *QueryPoolByPoolCoinDenomRequest) GetPoolCoinDenom() string

func (*QueryPoolByPoolCoinDenomRequest) Marshal 

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

func (*QueryPoolByPoolCoinDenomRequest) MarshalTo 

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

func (*QueryPoolByPoolCoinDenomRequest) MarshalToSizedBuffer 

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

func (*QueryPoolByPoolCoinDenomRequest) ProtoMessage 

func (*QueryPoolByPoolCoinDenomRequest) ProtoMessage()

func (*QueryPoolByPoolCoinDenomRequest) Reset 

func (m *QueryPoolByPoolCoinDenomRequest) Reset()

func (*QueryPoolByPoolCoinDenomRequest) Size 

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

func (*QueryPoolByPoolCoinDenomRequest) String 

func (m *QueryPoolByPoolCoinDenomRequest) String() string

func (*QueryPoolByPoolCoinDenomRequest) Unmarshal 

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

func (*QueryPoolByPoolCoinDenomRequest) XXX_DiscardUnknown 

func (m *QueryPoolByPoolCoinDenomRequest) XXX_DiscardUnknown()

func (*QueryPoolByPoolCoinDenomRequest) XXX_Marshal 

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

func (*QueryPoolByPoolCoinDenomRequest) XXX_Merge 

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

func (*QueryPoolByPoolCoinDenomRequest) XXX_Size 

func (m *QueryPoolByPoolCoinDenomRequest) XXX_Size() int

func (*QueryPoolByPoolCoinDenomRequest) XXX_Unmarshal 

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

type QueryPoolByReserveAddressRequest 

type QueryPoolByReserveAddressRequest struct {
	ReserveAddress string `protobuf:"bytes,1,opt,name=reserve_address,json=reserveAddress,proto3" json:"reserve_address,omitempty"`
}

QueryPoolByReserveAddressRequest is request type for the Query/PoolByReserveAddress RPC method.

func (*QueryPoolByReserveAddressRequest) Descriptor 

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

func (*QueryPoolByReserveAddressRequest) GetReserveAddress 

func (m *QueryPoolByReserveAddressRequest) GetReserveAddress() string

func (*QueryPoolByReserveAddressRequest) Marshal 

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

func (*QueryPoolByReserveAddressRequest) MarshalTo 

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

func (*QueryPoolByReserveAddressRequest) MarshalToSizedBuffer 

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

func (*QueryPoolByReserveAddressRequest) ProtoMessage 

func (*QueryPoolByReserveAddressRequest) ProtoMessage()

func (*QueryPoolByReserveAddressRequest) Reset 

func (m *QueryPoolByReserveAddressRequest) Reset()

func (*QueryPoolByReserveAddressRequest) Size 

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

func (*QueryPoolByReserveAddressRequest) String 

func (m *QueryPoolByReserveAddressRequest) String() string

func (*QueryPoolByReserveAddressRequest) Unmarshal 

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

func (*QueryPoolByReserveAddressRequest) XXX_DiscardUnknown 

func (m *QueryPoolByReserveAddressRequest) XXX_DiscardUnknown()

func (*QueryPoolByReserveAddressRequest) XXX_Marshal 

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

func (*QueryPoolByReserveAddressRequest) XXX_Merge 

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

func (*QueryPoolByReserveAddressRequest) XXX_Size 

func (m *QueryPoolByReserveAddressRequest) XXX_Size() int

func (*QueryPoolByReserveAddressRequest) XXX_Unmarshal 

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

type QueryPoolRequest 

type QueryPoolRequest struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

QueryPoolRequest is request type for the Query/Pool RPC method.

func (*QueryPoolRequest) Descriptor 

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

func (*QueryPoolRequest) GetPoolId 

func (m *QueryPoolRequest) GetPoolId() uint64

func (*QueryPoolRequest) Marshal 

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

func (*QueryPoolRequest) MarshalTo 

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

func (*QueryPoolRequest) MarshalToSizedBuffer 

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

func (*QueryPoolRequest) ProtoMessage 

func (*QueryPoolRequest) ProtoMessage()

func (*QueryPoolRequest) Reset 

func (m *QueryPoolRequest) Reset()

func (*QueryPoolRequest) Size 

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

func (*QueryPoolRequest) String 

func (m *QueryPoolRequest) String() string

func (*QueryPoolRequest) Unmarshal 

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

func (*QueryPoolRequest) XXX_DiscardUnknown 

func (m *QueryPoolRequest) XXX_DiscardUnknown()

func (*QueryPoolRequest) XXX_Marshal 

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

func (*QueryPoolRequest) XXX_Merge 

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

func (*QueryPoolRequest) XXX_Size 

func (m *QueryPoolRequest) XXX_Size() int

func (*QueryPoolRequest) XXX_Unmarshal 

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

type QueryPoolResponse 

type QueryPoolResponse struct {
	Pool PoolResponse `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool"`
}

QueryPoolResponse is response type for the Query/Pool RPC method.

func (*QueryPoolResponse) Descriptor 

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

func (*QueryPoolResponse) GetPool 

func (m *QueryPoolResponse) GetPool() PoolResponse

func (*QueryPoolResponse) Marshal 

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

func (*QueryPoolResponse) MarshalTo 

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

func (*QueryPoolResponse) MarshalToSizedBuffer 

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

func (*QueryPoolResponse) ProtoMessage 

func (*QueryPoolResponse) ProtoMessage()

func (*QueryPoolResponse) Reset 

func (m *QueryPoolResponse) Reset()

func (*QueryPoolResponse) Size 

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

func (*QueryPoolResponse) String 

func (m *QueryPoolResponse) String() string

func (*QueryPoolResponse) Unmarshal 

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

func (*QueryPoolResponse) XXX_DiscardUnknown 

func (m *QueryPoolResponse) XXX_DiscardUnknown()

func (*QueryPoolResponse) XXX_Marshal 

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

func (*QueryPoolResponse) XXX_Merge 

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

func (*QueryPoolResponse) XXX_Size 

func (m *QueryPoolResponse) XXX_Size() int

func (*QueryPoolResponse) XXX_Unmarshal 

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

type QueryPoolsRequest 

type QueryPoolsRequest struct {
	PairId     uint64             `protobuf:"varint,1,opt,name=pair_id,json=pairId,proto3" json:"pair_id,omitempty"`
	Disabled   string             `protobuf:"bytes,2,opt,name=disabled,proto3" json:"disabled,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPoolsRequest is request type for the Query/Pools RPC method.

func (*QueryPoolsRequest) Descriptor 

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

func (*QueryPoolsRequest) GetDisabled 

func (m *QueryPoolsRequest) GetDisabled() string

func (*QueryPoolsRequest) GetPagination 

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

func (*QueryPoolsRequest) GetPairId 

func (m *QueryPoolsRequest) GetPairId() uint64

func (*QueryPoolsRequest) Marshal 

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

func (*QueryPoolsRequest) MarshalTo 

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

func (*QueryPoolsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolsRequest) ProtoMessage 

func (*QueryPoolsRequest) ProtoMessage()

func (*QueryPoolsRequest) Reset 

func (m *QueryPoolsRequest) Reset()

func (*QueryPoolsRequest) Size 

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

func (*QueryPoolsRequest) String 

func (m *QueryPoolsRequest) String() string

func (*QueryPoolsRequest) Unmarshal 

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

func (*QueryPoolsRequest) XXX_DiscardUnknown 

func (m *QueryPoolsRequest) XXX_DiscardUnknown()

func (*QueryPoolsRequest) XXX_Marshal 

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

func (*QueryPoolsRequest) XXX_Merge 

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

func (*QueryPoolsRequest) XXX_Size 

func (m *QueryPoolsRequest) XXX_Size() int

func (*QueryPoolsRequest) XXX_Unmarshal 

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

type QueryPoolsResponse 

type QueryPoolsResponse struct {
	Pools      []PoolResponse      `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPoolsResponse is response type for the Query/Pools RPC method.

func (*QueryPoolsResponse) Descriptor 

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

func (*QueryPoolsResponse) GetPagination 

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

func (*QueryPoolsResponse) GetPools 

func (m *QueryPoolsResponse) GetPools() []PoolResponse

func (*QueryPoolsResponse) Marshal 

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

func (*QueryPoolsResponse) MarshalTo 

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

func (*QueryPoolsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolsResponse) ProtoMessage 

func (*QueryPoolsResponse) ProtoMessage()

func (*QueryPoolsResponse) Reset 

func (m *QueryPoolsResponse) Reset()

func (*QueryPoolsResponse) Size 

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

func (*QueryPoolsResponse) String 

func (m *QueryPoolsResponse) String() string

func (*QueryPoolsResponse) Unmarshal 

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

func (*QueryPoolsResponse) XXX_DiscardUnknown 

func (m *QueryPoolsResponse) XXX_DiscardUnknown()

func (*QueryPoolsResponse) XXX_Marshal 

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

func (*QueryPoolsResponse) XXX_Merge 

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

func (*QueryPoolsResponse) XXX_Size 

func (m *QueryPoolsResponse) XXX_Size() int

func (*QueryPoolsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params returns parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Pools returns all liquidity pools.
	Pools(context.Context, *QueryPoolsRequest) (*QueryPoolsResponse, error)
	// Pool returns the specific liquidity pool.
	Pool(context.Context, *QueryPoolRequest) (*QueryPoolResponse, error)
	// PoolByReserveAddress returns all pools that correspond to the reserve account.
	PoolByReserveAddress(context.Context, *QueryPoolByReserveAddressRequest) (*QueryPoolResponse, error)
	// PoolByPoolCoinDenom returns all pools that correspond to the pool coin denom.
	PoolByPoolCoinDenom(context.Context, *QueryPoolByPoolCoinDenomRequest) (*QueryPoolResponse, error)
	// Pairs returns all liquidity pairs.
	Pairs(context.Context, *QueryPairsRequest) (*QueryPairsResponse, error)
	// Pair returns the specific pair.
	Pair(context.Context, *QueryPairRequest) (*QueryPairResponse, error)
	// DepositRequests returns all deposit requests.
	DepositRequests(context.Context, *QueryDepositRequestsRequest) (*QueryDepositRequestsResponse, error)
	// DepositRequest returns the specific deposit request.
	DepositRequest(context.Context, *QueryDepositRequestRequest) (*QueryDepositRequestResponse, error)
	// WithdrawRequests returns all withdraw requests.
	WithdrawRequests(context.Context, *QueryWithdrawRequestsRequest) (*QueryWithdrawRequestsResponse, error)
	// WithdrawRequest returns the specific withdraw request.
	WithdrawRequest(context.Context, *QueryWithdrawRequestRequest) (*QueryWithdrawRequestResponse, error)
	// Orders returns all orders within the pair.
	Orders(context.Context, *QueryOrdersRequest) (*QueryOrdersResponse, error)
	// Order returns the specific order.
	Order(context.Context, *QueryOrderRequest) (*QueryOrderResponse, error)
	// OrdersByOrderer returns orders made by an orderer.
	OrdersByOrderer(context.Context, *QueryOrdersByOrdererRequest) (*QueryOrdersResponse, error)
	OrderBooks(context.Context, *QueryOrderBooksRequest) (*QueryOrderBooksResponse, error)
}

QueryServer is the server API for Query service.

type QueryWithdrawRequestRequest 

type QueryWithdrawRequestRequest struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Id     uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

QueryWithdrawRequestRequest is request type for the Query/WithdrawRequest RPC method.

func (*QueryWithdrawRequestRequest) Descriptor 

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

func (*QueryWithdrawRequestRequest) GetId 

func (m *QueryWithdrawRequestRequest) GetId() uint64

func (*QueryWithdrawRequestRequest) GetPoolId 

func (m *QueryWithdrawRequestRequest) GetPoolId() uint64

func (*QueryWithdrawRequestRequest) Marshal 

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

func (*QueryWithdrawRequestRequest) MarshalTo 

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

func (*QueryWithdrawRequestRequest) MarshalToSizedBuffer 

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

func (*QueryWithdrawRequestRequest) ProtoMessage 

func (*QueryWithdrawRequestRequest) ProtoMessage()

func (*QueryWithdrawRequestRequest) Reset 

func (m *QueryWithdrawRequestRequest) Reset()

func (*QueryWithdrawRequestRequest) Size 

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

func (*QueryWithdrawRequestRequest) String 

func (m *QueryWithdrawRequestRequest) String() string

func (*QueryWithdrawRequestRequest) Unmarshal 

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

func (*QueryWithdrawRequestRequest) XXX_DiscardUnknown 

func (m *QueryWithdrawRequestRequest) XXX_DiscardUnknown()

func (*QueryWithdrawRequestRequest) XXX_Marshal 

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

func (*QueryWithdrawRequestRequest) XXX_Merge 

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

func (*QueryWithdrawRequestRequest) XXX_Size 

func (m *QueryWithdrawRequestRequest) XXX_Size() int

func (*QueryWithdrawRequestRequest) XXX_Unmarshal 

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

type QueryWithdrawRequestResponse 

type QueryWithdrawRequestResponse struct {
	WithdrawRequest WithdrawRequest `protobuf:"bytes,1,opt,name=withdraw_request,json=withdrawRequest,proto3" json:"withdraw_request"`
}

QueryWithdrawRequestResponse is response type for the Query/WithdrawRequest RPC method.

func (*QueryWithdrawRequestResponse) Descriptor 

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

func (*QueryWithdrawRequestResponse) GetWithdrawRequest 

func (m *QueryWithdrawRequestResponse) GetWithdrawRequest() WithdrawRequest

func (*QueryWithdrawRequestResponse) Marshal 

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

func (*QueryWithdrawRequestResponse) MarshalTo 

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

func (*QueryWithdrawRequestResponse) MarshalToSizedBuffer 

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

func (*QueryWithdrawRequestResponse) ProtoMessage 

func (*QueryWithdrawRequestResponse) ProtoMessage()

func (*QueryWithdrawRequestResponse) Reset 

func (m *QueryWithdrawRequestResponse) Reset()

func (*QueryWithdrawRequestResponse) Size 

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

func (*QueryWithdrawRequestResponse) String 

func (m *QueryWithdrawRequestResponse) String() string

func (*QueryWithdrawRequestResponse) Unmarshal 

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

func (*QueryWithdrawRequestResponse) XXX_DiscardUnknown 

func (m *QueryWithdrawRequestResponse) XXX_DiscardUnknown()

func (*QueryWithdrawRequestResponse) XXX_Marshal 

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

func (*QueryWithdrawRequestResponse) XXX_Merge 

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

func (*QueryWithdrawRequestResponse) XXX_Size 

func (m *QueryWithdrawRequestResponse) XXX_Size() int

func (*QueryWithdrawRequestResponse) XXX_Unmarshal 

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

type QueryWithdrawRequestsRequest 

type QueryWithdrawRequestsRequest struct {
	PoolId     uint64             `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryWithdrawRequestsRequest is request type for the Query/WithdrawRequests RPC method.

func (*QueryWithdrawRequestsRequest) Descriptor 

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

func (*QueryWithdrawRequestsRequest) GetPagination 

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

func (*QueryWithdrawRequestsRequest) GetPoolId 

func (m *QueryWithdrawRequestsRequest) GetPoolId() uint64

func (*QueryWithdrawRequestsRequest) Marshal 

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

func (*QueryWithdrawRequestsRequest) MarshalTo 

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

func (*QueryWithdrawRequestsRequest) MarshalToSizedBuffer 

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

func (*QueryWithdrawRequestsRequest) ProtoMessage 

func (*QueryWithdrawRequestsRequest) ProtoMessage()

func (*QueryWithdrawRequestsRequest) Reset 

func (m *QueryWithdrawRequestsRequest) Reset()

func (*QueryWithdrawRequestsRequest) Size 

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

func (*QueryWithdrawRequestsRequest) String 

func (m *QueryWithdrawRequestsRequest) String() string

func (*QueryWithdrawRequestsRequest) Unmarshal 

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

func (*QueryWithdrawRequestsRequest) XXX_DiscardUnknown 

func (m *QueryWithdrawRequestsRequest) XXX_DiscardUnknown()

func (*QueryWithdrawRequestsRequest) XXX_Marshal 

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

func (*QueryWithdrawRequestsRequest) XXX_Merge 

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

func (*QueryWithdrawRequestsRequest) XXX_Size 

func (m *QueryWithdrawRequestsRequest) XXX_Size() int

func (*QueryWithdrawRequestsRequest) XXX_Unmarshal 

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

type QueryWithdrawRequestsResponse 

type QueryWithdrawRequestsResponse struct {
	WithdrawRequests []WithdrawRequest   `protobuf:"bytes,1,rep,name=withdraw_requests,json=withdrawRequests,proto3" json:"withdraw_requests"`
	Pagination       *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryWithdrawRequestsResponse is response type for the Query/WithdrawRequests RPC method.

func (*QueryWithdrawRequestsResponse) Descriptor 

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

func (*QueryWithdrawRequestsResponse) GetPagination 

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

func (*QueryWithdrawRequestsResponse) GetWithdrawRequests 

func (m *QueryWithdrawRequestsResponse) GetWithdrawRequests() []WithdrawRequest

func (*QueryWithdrawRequestsResponse) Marshal 

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

func (*QueryWithdrawRequestsResponse) MarshalTo 

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

func (*QueryWithdrawRequestsResponse) MarshalToSizedBuffer 

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

func (*QueryWithdrawRequestsResponse) ProtoMessage 

func (*QueryWithdrawRequestsResponse) ProtoMessage()

func (*QueryWithdrawRequestsResponse) Reset 

func (m *QueryWithdrawRequestsResponse) Reset()

func (*QueryWithdrawRequestsResponse) Size 

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

func (*QueryWithdrawRequestsResponse) String 

func (m *QueryWithdrawRequestsResponse) String() string

func (*QueryWithdrawRequestsResponse) Unmarshal 

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

func (*QueryWithdrawRequestsResponse) XXX_DiscardUnknown 

func (m *QueryWithdrawRequestsResponse) XXX_DiscardUnknown()

func (*QueryWithdrawRequestsResponse) XXX_Marshal 

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

func (*QueryWithdrawRequestsResponse) XXX_Merge 

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

func (*QueryWithdrawRequestsResponse) XXX_Size 

func (m *QueryWithdrawRequestsResponse) XXX_Size() int

func (*QueryWithdrawRequestsResponse) XXX_Unmarshal 

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

type RequestStatus 

type RequestStatus int32

RequestStatus enumerates request statuses. 

const (
	// REQUEST_STATUS_UNSPECIFIED specifies unknown request status
	RequestStatusUnspecified RequestStatus = 0
	// REQUEST_STATUS_NOT_EXECUTED indicates the request is not executed yet
	RequestStatusNotExecuted RequestStatus = 1
	// REQUEST_STATUS_SUCCEEDED indicates the request has been succeeded
	RequestStatusSucceeded RequestStatus = 2
	// REQUEST_STATUS_FAILED indicates the request is failed
	RequestStatusFailed RequestStatus = 3
)

func (RequestStatus) EnumDescriptor 

func (RequestStatus) EnumDescriptor() ([]byte, []int)

func (RequestStatus) IsValid 

func (status RequestStatus) IsValid() bool

IsValid returns true if the RequestStatus is one of: RequestStatusNotExecuted, RequestStatusSucceeded, RequestStatusFailed.

func (RequestStatus) ShouldBeDeleted 

func (status RequestStatus) ShouldBeDeleted() bool

ShouldBeDeleted returns true if the RequestStatus is one of: RequestStatusSucceeded, RequestStatusFailed.

func (RequestStatus) String 

func (x RequestStatus) String() string

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CancelAllOrders 

func (*UnimplementedMsgServer) CancelAllOrders(ctx context.Context, req *MsgCancelAllOrders) (*MsgCancelAllOrdersResponse, error)

func (*UnimplementedMsgServer) CancelMMOrder 

func (*UnimplementedMsgServer) CancelMMOrder(ctx context.Context, req *MsgCancelMMOrder) (*MsgCancelMMOrderResponse, error)

func (*UnimplementedMsgServer) CancelOrder 

func (*UnimplementedMsgServer) CancelOrder(ctx context.Context, req *MsgCancelOrder) (*MsgCancelOrderResponse, error)

func (*UnimplementedMsgServer) CreatePair 

func (*UnimplementedMsgServer) CreatePair(ctx context.Context, req *MsgCreatePair) (*MsgCreatePairResponse, error)

func (*UnimplementedMsgServer) CreatePool 

func (*UnimplementedMsgServer) CreatePool(ctx context.Context, req *MsgCreatePool) (*MsgCreatePoolResponse, error)

func (*UnimplementedMsgServer) CreateRangedPool 

func (*UnimplementedMsgServer) CreateRangedPool(ctx context.Context, req *MsgCreateRangedPool) (*MsgCreateRangedPoolResponse, error)

func (*UnimplementedMsgServer) Deposit 

func (*UnimplementedMsgServer) Deposit(ctx context.Context, req *MsgDeposit) (*MsgDepositResponse, error)

func (*UnimplementedMsgServer) LimitOrder 

func (*UnimplementedMsgServer) LimitOrder(ctx context.Context, req *MsgLimitOrder) (*MsgLimitOrderResponse, error)

func (*UnimplementedMsgServer) MMOrder 

func (*UnimplementedMsgServer) MMOrder(ctx context.Context, req *MsgMMOrder) (*MsgMMOrderResponse, error)

func (*UnimplementedMsgServer) MarketOrder 

func (*UnimplementedMsgServer) MarketOrder(ctx context.Context, req *MsgMarketOrder) (*MsgMarketOrderResponse, error)

func (*UnimplementedMsgServer) Withdraw 

func (*UnimplementedMsgServer) Withdraw(ctx context.Context, req *MsgWithdraw) (*MsgWithdrawResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) DepositRequest 

func (*UnimplementedQueryServer) DepositRequest(ctx context.Context, req *QueryDepositRequestRequest) (*QueryDepositRequestResponse, error)

func (*UnimplementedQueryServer) DepositRequests 

func (*UnimplementedQueryServer) DepositRequests(ctx context.Context, req *QueryDepositRequestsRequest) (*QueryDepositRequestsResponse, error)

func (*UnimplementedQueryServer) Order 

func (*UnimplementedQueryServer) Order(ctx context.Context, req *QueryOrderRequest) (*QueryOrderResponse, error)

func (*UnimplementedQueryServer) OrderBooks 

func (*UnimplementedQueryServer) OrderBooks(ctx context.Context, req *QueryOrderBooksRequest) (*QueryOrderBooksResponse, error)

func (*UnimplementedQueryServer) Orders 

func (*UnimplementedQueryServer) Orders(ctx context.Context, req *QueryOrdersRequest) (*QueryOrdersResponse, error)

func (*UnimplementedQueryServer) OrdersByOrderer 

func (*UnimplementedQueryServer) OrdersByOrderer(ctx context.Context, req *QueryOrdersByOrdererRequest) (*QueryOrdersResponse, error)

func (*UnimplementedQueryServer) Pair 

func (*UnimplementedQueryServer) Pair(ctx context.Context, req *QueryPairRequest) (*QueryPairResponse, error)

func (*UnimplementedQueryServer) Pairs 

func (*UnimplementedQueryServer) Pairs(ctx context.Context, req *QueryPairsRequest) (*QueryPairsResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) Pool 

func (*UnimplementedQueryServer) Pool(ctx context.Context, req *QueryPoolRequest) (*QueryPoolResponse, error)

func (*UnimplementedQueryServer) PoolByPoolCoinDenom 

func (*UnimplementedQueryServer) PoolByPoolCoinDenom(ctx context.Context, req *QueryPoolByPoolCoinDenomRequest) (*QueryPoolResponse, error)

func (*UnimplementedQueryServer) PoolByReserveAddress 

func (*UnimplementedQueryServer) PoolByReserveAddress(ctx context.Context, req *QueryPoolByReserveAddressRequest) (*QueryPoolResponse, error)

func (*UnimplementedQueryServer) Pools 

func (*UnimplementedQueryServer) Pools(ctx context.Context, req *QueryPoolsRequest) (*QueryPoolsResponse, error)

func (*UnimplementedQueryServer) WithdrawRequest 

func (*UnimplementedQueryServer) WithdrawRequest(ctx context.Context, req *QueryWithdrawRequestRequest) (*QueryWithdrawRequestResponse, error)

func (*UnimplementedQueryServer) WithdrawRequests 

func (*UnimplementedQueryServer) WithdrawRequests(ctx context.Context, req *QueryWithdrawRequestsRequest) (*QueryWithdrawRequestsResponse, error)

type UserOrder 

type UserOrder struct {
	*amm.BaseOrder
	Orderer                         sdk.AccAddress
	OrderId                         uint64
	BatchId                         uint64
	OfferCoinDenom, DemandCoinDenom string
}

func NewUserOrder 

func NewUserOrder(order Order) *UserOrder

NewUserOrder returns a new user order.

func (*UserOrder) GetBatchId 

func (order *UserOrder) GetBatchId() uint64

func (*UserOrder) HasPriority 

func (order *UserOrder) HasPriority(other amm.Order) bool

func (*UserOrder) String 

func (order *UserOrder) String() string

type WithdrawRequest 

type WithdrawRequest struct {
	// id specifies the id for the request
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// pool_id specifies the pool id
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// msg_height specifies the block height when the request is stored for the batch execution
	MsgHeight int64 `protobuf:"varint,3,opt,name=msg_height,json=msgHeight,proto3" json:"msg_height,omitempty"`
	// withdrawer specifies the bech32-encoded address that withdraws pool coin from the pool
	Withdrawer string `protobuf:"bytes,4,opt,name=withdrawer,proto3" json:"withdrawer,omitempty"`
	// pool_coin specifies the pool coin that is a proof of liquidity provider for the pool
	PoolCoin types.Coin `protobuf:"bytes,5,opt,name=pool_coin,json=poolCoin,proto3" json:"pool_coin"`
	// withdrawn_coins specifies the amount of coins that are withdrawn.
	WithdrawnCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 147-byte string literal not displayed */
	Status         RequestStatus                            `protobuf:"varint,7,opt,name=status,proto3,enum=crescent.liquidity.v1beta1.RequestStatus" json:"status,omitempty"`
}

WithdrawRequest defines a withdraw request.

func MustUnmarshalWithdrawRequest 

func MustUnmarshalWithdrawRequest(cdc codec.BinaryCodec, value []byte) WithdrawRequest

MustUnmarshalWithdrawRequest returns the WithdrawRequest from bytes. It throws panic if it fails.

func NewWithdrawRequest 

func NewWithdrawRequest(msg *MsgWithdraw, id uint64, msgHeight int64) WithdrawRequest

NewWithdrawRequest returns a new WithdrawRequest.

func UnmarshalWithdrawRequest 

func UnmarshalWithdrawRequest(cdc codec.BinaryCodec, value []byte) (msg WithdrawRequest, err error)

UnmarshalWithdrawRequest returns the WithdrawRequest from bytes.

func (*WithdrawRequest) Descriptor 

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

func (WithdrawRequest) GetWithdrawer 

func (req WithdrawRequest) GetWithdrawer() sdk.AccAddress

func (*WithdrawRequest) Marshal 

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

func (*WithdrawRequest) MarshalTo 

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

func (*WithdrawRequest) MarshalToSizedBuffer 

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

func (*WithdrawRequest) ProtoMessage 

func (*WithdrawRequest) ProtoMessage()

func (*WithdrawRequest) Reset 

func (m *WithdrawRequest) Reset()

func (*WithdrawRequest) SetStatus 

func (req *WithdrawRequest) SetStatus(status RequestStatus)

SetStatus sets the request's status. SetStatus is to easily find locations where the status is changed.

func (*WithdrawRequest) Size 

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

func (*WithdrawRequest) String 

func (m *WithdrawRequest) String() string

func (*WithdrawRequest) Unmarshal 

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

func (WithdrawRequest) Validate 

func (req WithdrawRequest) Validate() error

Validate validates WithdrawRequest for genesis.

func (*WithdrawRequest) XXX_DiscardUnknown 

func (m *WithdrawRequest) XXX_DiscardUnknown()

func (*WithdrawRequest) XXX_Marshal 

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

func (*WithdrawRequest) XXX_Merge 

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

func (*WithdrawRequest) XXX_Size 

func (m *WithdrawRequest) XXX_Size() int

func (*WithdrawRequest) XXX_Unmarshal 

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