types

package
v1.2.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2021 License: Apache-2.0 Imports: 36 Imported by: 31

Documentation

Overview

nolint

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeCreateLiquidityPool              = "create_liquidity_pool"
	EventTypeDepositToLiquidityPoolToBatch    = "deposit_to_liquidity_pool_to_batch"
	EventTypeWithdrawFromLiquidityPoolToBatch = "withdraw_from_liquidity_pool_to_batch"
	EventTypeSwapToBatch                      = "swap_to_batch"
	EventTypeDepositToLiquidityPool           = "deposit_to_liquidity_pool"
	EventTypeWithdrawFromLiquidityPool        = "withdraw_from_liquidity_pool"
	EventTypeSwap                             = "swap"
	EventTypeSwapTransacted                   = "swap_transacted"

	AttributeValueLiquidityPoolId        = "liquidity_pool_id"
	AttributeValueLiquidityPoolTypeIndex = "liquidity_pool_type_index"
	AttributeValueLiquidityPoolFeeRate   = "liquidity_pool_fee_rate"
	//AttributeValueSwapPriceFunction      = "swap_price_function"
	AttributeValueLiquidityPoolKey  = "liquidity_pool_key"
	AttributeValueReserveCoinDenoms = "reserve_coin_denoms"
	AttributeValueReserveAccount    = "reserve_account"
	AttributeValuePoolCoinDenom     = "pool_coin_denom"
	AttributeValuePoolCoinAmount    = "pool_coin_amount"
	AttributeValueSwapFeeRate       = "swap_fee_rate"
	AttributeValueBatchSize         = "batch_size"
	AttributeValueBatchIndex        = "batch_index"
	AttributeValueMsgIndex          = "msg_index"

	AttributeValueDepositCoins = "deposit_coins"

	AttributeValueOfferCoinDenom     = "offer_coin_denom"
	AttributeValueOfferCoinAmount    = "offer_coin_amount"
	AttributeValueOfferCoinFeeAmount = "offer_coin_fee_amount"
	AttributeValueDemandCoinDenom    = "demand_coin_denom"
	AttributeValueOrderPrice         = "order_price"

	AttributeValueDepositor            = "depositor"
	AttributeValueRefundedCoins        = "refunded_coins"
	AttributeValueAcceptedCoins        = "accepted_coins"
	AttributeValueSuccess              = "success"
	AttributeValueWithdrawer           = "withdrawer"
	AttributeValuePoolCoin             = "pool_coin"
	AttributeValueWithdrawCoins        = "withdraw_coins"
	AttributeValueSwapRequester        = "swap_requester"
	AttributeValueSwapType             = "swap_type"
	AttributeValueAcceptedOfferCoin    = "accepted_offer_coin"
	AttributeValueRefundedOfferCoin    = "refunded_offer_coin"
	AttributeValueReceivedDemandCoin   = "received_demand_coin"
	AttributeValueSwapPrice            = "swap_price"
	AttributeValuePaidSwapFee          = "paid_swap_fee"
	AttributeValuePaidLiquidityPoolFee = "paid_liquidity_pool_fee"

	AttributeValueTransactedCoinAmount      = "transacted_coin_amount"
	AttributeValueRemainingOfferCoinAmount  = "remaining_offer_coin_amount"
	AttributeValueExchangedOfferCoinAmount  = "exchanged_offer_coin_amount"
	AttributeValueOfferCoinFeeReserveAmount = "offer_coin_fee_reserve_amount"
	AttributeValueOrderExpiryHeight         = "order_expiry_height"

	AttributeValueCategory = ModuleName

	Success = "success"
	Failure = "failure"
)

liquidity module event types, it will be improve the completeness of Milestone 2.

View Source 
const (
	// ModuleName is the name of the module.
	ModuleName = "liquidity"

	// RouterKey is the message route for the liquidity module.
	RouterKey = ModuleName

	// StoreKey is the default store key for the liquidity module.
	StoreKey = ModuleName

	// QuerierRoute is the querier route for the liquidity module.
	QuerierRoute = ModuleName

	// PoolCoinDenomPrefix is the prefix used for liquidity pool coin representation.
	PoolCoinDenomPrefix = "pool"
)

Routes, Keys for liquidity module

View Source 
const (
	TypeMsgCreateLiquidityPool       = "create_liquidity_pool"
	TypeMsgDepositToLiquidityPool    = "deposit_to_liquidity_pool"
	TypeMsgWithdrawFromLiquidityPool = "withdraw_from_liquidity_pool"
	TypeMsgSwap                      = "swap"
)

Messages Type of Liquidity module

View Source 
const (
	CancelOrderLifeSpan int64 = 0

	// min number of reserveCoins for LiquidityPoolType only 2 is allowed on this spec
	MinReserveCoinNum uint32 = 2

	// max number of reserveCoins for LiquidityPoolType only 2 is allowed on this spec
	MaxReserveCoinNum uint32 = 2

	// Number of blocks in one batch
	DefaultUnitBatchSize uint32 = 1

	// index of target pool type, only 1 is allowed on this version.
	DefaultPoolTypeIndex uint32 = 1

	// swap type of available swap request, only 1 is allowed on this version.
	DefaultSwapType uint32 = 1
)

Const value of liquidity module

View Source 
const (
	QueryLiquidityPool  = "liquidityPool"
	QueryLiquidityPools = "liquidityPools"
)

QueryLiquidityPool liquidity query endpoint supported by the liquidity querier

View Source 
const (
	// Match Types
	ExactMatch      = 1
	NoMatch         = 2
	FractionalMatch = 3

	// Price Directions
	Increase = 1
	Decrease = 2
	Stay     = 3

	// Order Directions
	DirectionXtoY = 1
	DirectionYtoX = 2
)

liquidity module const types for swap

Variables

View Source 
var (
	ErrPoolNotExists                = sdkerrors.Register(ModuleName, 1, "pool not exists")
	ErrPoolTypeNotExists            = sdkerrors.Register(ModuleName, 2, "pool type not exists")
	ErrEqualDenom                   = sdkerrors.Register(ModuleName, 3, "reserve coin denomination are equal")
	ErrInvalidDenom                 = sdkerrors.Register(ModuleName, 4, "invalid denom")
	ErrNumOfReserveCoin             = sdkerrors.Register(ModuleName, 5, "invalid number of reserve coin")
	ErrNumOfPoolCoin                = sdkerrors.Register(ModuleName, 6, "invalid number of pool coin")
	ErrInsufficientPool             = sdkerrors.Register(ModuleName, 7, "insufficient pool")
	ErrInsufficientBalance          = sdkerrors.Register(ModuleName, 8, "insufficient coin balance to escrow")
	ErrLessThanMinInitDeposit       = sdkerrors.Register(ModuleName, 9, "deposit coin less than MinInitDepositToPool")
	ErrNotImplementedYet            = sdkerrors.Register(ModuleName, 10, "not implemented yet")
	ErrPoolAlreadyExists            = sdkerrors.Register(ModuleName, 11, "the pool already exists")
	ErrPoolBatchNotExists           = sdkerrors.Register(ModuleName, 12, "pool batch not exists")
	ErrOrderBookInvalidity          = sdkerrors.Register(ModuleName, 13, "orderbook is not validity")
	ErrBatchNotExecuted             = sdkerrors.Register(ModuleName, 14, "the liquidity pool batch is not executed")
	ErrEmptyPoolCreatorAddr         = sdkerrors.Register(ModuleName, 15, "empty pool creator address")
	ErrEmptyDepositorAddr           = sdkerrors.Register(ModuleName, 16, "empty pool depositor address")
	ErrEmptyWithdrawerAddr          = sdkerrors.Register(ModuleName, 17, "empty pool withdrawer address")
	ErrEmptySwapRequesterAddr       = sdkerrors.Register(ModuleName, 18, "empty pool swap requester address")
	ErrBadPoolCoinAmount            = sdkerrors.Register(ModuleName, 19, "invalid pool coin amount")
	ErrBadDepositCoinsAmount        = sdkerrors.Register(ModuleName, 20, "invalid deposit coins amount")
	ErrBadOfferCoinAmount           = sdkerrors.Register(ModuleName, 21, "invalid offer coin amount")
	ErrBadOrderingReserveCoin       = sdkerrors.Register(ModuleName, 22, "reserve coin denoms not ordered alphabetical")
	ErrBadOrderPrice                = sdkerrors.Register(ModuleName, 23, "invalid order price")
	ErrNumOfReserveCoinDenoms       = sdkerrors.Register(ModuleName, 24, "invalid reserve coin denoms")
	ErrEmptyReserveAccountAddress   = sdkerrors.Register(ModuleName, 25, "empty reserve account address")
	ErrEmptyPoolCoinDenom           = sdkerrors.Register(ModuleName, 26, "empty pool coin denom")
	ErrBadOrderingReserveCoinDenoms = sdkerrors.Register(ModuleName, 27, "bad ordering reserve coin denoms")
	ErrBadReserveAccountAddress     = sdkerrors.Register(ModuleName, 28, "bad reserve account address")
	ErrBadPoolCoinDenom             = sdkerrors.Register(ModuleName, 29, "bad pool coin denom")
	ErrInsufficientPoolCreationFee  = sdkerrors.Register(ModuleName, 30, "insufficient balances for pool creation fee")
	ErrExceededMaxOrderable         = sdkerrors.Register(ModuleName, 31, "can not exceed max order ratio of reserve coins that can be ordered at a order")
	ErrBadBatchMsgIndex             = sdkerrors.Register(ModuleName, 32, "bad msg index of the batch")
	ErrSwapTypeNotExists            = sdkerrors.Register(ModuleName, 33, "swap type not exists")
	ErrLessThanMinOfferAmount       = sdkerrors.Register(ModuleName, 34, "offer amount should over 100 micro")
	ErrBadOfferCoinFee              = sdkerrors.Register(ModuleName, 35, "bad offer coin fee")
	ErrNotMatchedReserveCoin        = sdkerrors.Register(ModuleName, 36, "does not match the reserve coin of the pool")
	ErrBadPoolTypeIndex             = sdkerrors.Register(ModuleName, 37, "invalid index of the pooltype")
	ErrExceededReserveCoinLimit     = sdkerrors.Register(ModuleName, 38, "can not exceed reserve coin limit amount")
)

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 (
	// param key for global Liquidity Pool IDs
	GlobalLiquidityPoolIdKey = []byte("globalLiquidityPoolId")

	LiquidityPoolKeyPrefix               = []byte{0x11}
	LiquidityPoolByReserveIndexKeyPrefix = []byte{0x12}

	LiquidityPoolBatchIndexKeyPrefix = []byte{0x21} // LastLiquidityPoolBatchIndex
	LiquidityPoolBatchKeyPrefix      = []byte{0x22}

	LiquidityPoolBatchDepositMsgIndexKeyPrefix  = []byte{0x31}
	LiquidityPoolBatchWithdrawMsgIndexKeyPrefix = []byte{0x32}
	LiquidityPoolBatchSwapMsgIndexKeyPrefix     = []byte{0x33}
)

prefix key of liquidity states for indexing when kvstore

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 (
	KeyLiquidityPoolTypes       = []byte("LiquidityPoolTypes")
	KeyMinInitDepositToPool     = []byte("MinInitDepositToPool")
	KeyInitPoolCoinMintAmount   = []byte("InitPoolCoinMintAmount")
	KeyReserveCoinLimitAmount   = []byte("ReserveCoinLimitAmount")
	KeySwapFeeRate              = []byte("SwapFeeRate")
	KeyLiquidityPoolCreationFee = []byte("LiquidityPoolCreationFee")
	KeyUnitBatchSize            = []byte("UnitBatchSize")
	KeyWithdrawFeeRate          = []byte("WithdrawFeeRate")
	KeyMaxOrderAmountRatio      = []byte("MaxOrderAmountRatio")

	DefaultMinInitDepositToPool     = sdk.NewInt(1000000)
	DefaultInitPoolCoinMintAmount   = sdk.NewInt(1000000)
	DefaultReserveCoinLimitAmount   = sdk.ZeroInt()
	DefaultSwapFeeRate              = sdk.NewDecWithPrec(3, 3) // "0.003000000000000000"
	DefaultWithdrawFeeRate          = sdk.NewDecWithPrec(3, 3) // "0.003000000000000000"
	DefaultMaxOrderAmountRatio      = sdk.NewDecWithPrec(1, 1) // "0.100000000000000000"
	DefaultLiquidityPoolCreationFee = sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdk.NewInt(100000000)))
	MinOfferCoinAmount              = sdk.NewInt(100)

	HalfRatio = halfRatio

	DecimalErrThreshold3  = sdk.NewDecFromIntWithPrec(sdk.OneInt(), 3)
	DecimalErrThreshold10 = sdk.NewDecFromIntWithPrec(sdk.OneInt(), 10)

	DefaultLiquidityPoolType = LiquidityPoolType{
		PoolTypeIndex:     1,
		Name:              "DefaultPoolType",
		MinReserveCoinNum: MinReserveCoinNum,
		MaxReserveCoinNum: MaxReserveCoinNum,
	}
)

Parameter store keys

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 (

	// ModuleCdc references the global x/staking module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/staking and
	// defined at the application level.
	ModuleCdc = codec.NewAminoCodec(amino)
)

legacy amino codecs

Functions

func AlphabeticalDenomPair 

func AlphabeticalDenomPair(denom1, denom2 string) (resDenom1, resDenom2 string)

Get denom pair alphabetical ordered

func CheckDecApproxEqual 

func CheckDecApproxEqual(a, b, threshold sdk.Dec) bool

Check the decimals equal approximately

func CheckSwapPrice 

func CheckSwapPrice(matchResultXtoY, matchResultYtoX []MatchResult, swapPrice sdk.Dec) bool

Check swap price validity using list of match result.

func CheckValidityOrderBook 

func CheckValidityOrderBook(orderBook OrderBook, currentPrice sdk.Dec) bool

Check orderbook validity

func CoinSafeSubAmount 

func CoinSafeSubAmount(coinA sdk.Coin, coinBamt sdk.Int) sdk.Coin

Safe Sub function for Coin with subtracting amount

func FindOrderMatch 

func FindOrderMatch(direction int, swapList []*BatchPoolSwapMsg, executableAmt sdk.Int,
	swapPrice sdk.Dec, height int64) (
	matchResultList []MatchResult, swapListExecuted []*BatchPoolSwapMsg, poolXdelta, poolYdelta sdk.Int)

Find matched orders and set status for msgs

func GetCoinsTotalAmount 

func GetCoinsTotalAmount(coins sdk.Coins) sdk.Int

Get Total amount of the coins

func GetExecutableAmt 

func GetExecutableAmt(swapPrice sdk.Dec, orderBook OrderBook) (executableBuyAmtX, executableSellAmtY sdk.Int)

calculate the executable amount of the orderbook for each X, Y

func GetLiquidityPoolBatchDepositMsgIndexKey 

func GetLiquidityPoolBatchDepositMsgIndexKey(poolId, msgIndex uint64) []byte

return kv indexing key of the latest index value of the msg index

func GetLiquidityPoolBatchDepositMsgsPrefix 

func GetLiquidityPoolBatchDepositMsgsPrefix(poolId uint64) []byte

Get prefix of the deposit batch messages that given pool for iteration

func GetLiquidityPoolBatchIndexKey 

func GetLiquidityPoolBatchIndexKey(poolId uint64) []byte

return kv indexing key of the latest index value of the pool batch

func GetLiquidityPoolBatchKey 

func GetLiquidityPoolBatchKey(poolId uint64) []byte

return kv indexing key of the pool batch indexed by pool id

func GetLiquidityPoolBatchSwapMsgIndexKey 

func GetLiquidityPoolBatchSwapMsgIndexKey(poolId, msgIndex uint64) []byte

return kv indexing key of the latest index value of the msg index

func GetLiquidityPoolBatchSwapMsgsPrefix 

func GetLiquidityPoolBatchSwapMsgsPrefix(poolId uint64) []byte

Get prefix of the swap batch messages that given pool for iteration

func GetLiquidityPoolBatchWithdrawMsgIndexKey 

func GetLiquidityPoolBatchWithdrawMsgIndexKey(poolId, msgIndex uint64) []byte

return kv indexing key of the latest index value of the msg index

func GetLiquidityPoolBatchWithdrawMsgsPrefix 

func GetLiquidityPoolBatchWithdrawMsgsPrefix(poolId uint64) []byte

Get prefix of the withdraw batch messages that given pool for iteration

func GetLiquidityPoolByReserveAccIndexKey 

func GetLiquidityPoolByReserveAccIndexKey(reserveAcc sdk.AccAddress) []byte

return kv indexing key of the pool indexed by reserve account

func GetLiquidityPoolKey 

func GetLiquidityPoolKey(poolId uint64) []byte

return kv indexing key of the pool

func GetMustExecutableAmt 

func GetMustExecutableAmt(swapPrice sdk.Dec, orderBook OrderBook) (mustExecutableBuyAmtX, mustExecutableSellAmtY sdk.Int)

Check swap executable amount validity of the orderbook

func GetOfferCoinFee 

func GetOfferCoinFee(offerCoin sdk.Coin, swapFeeRate sdk.Dec) sdk.Coin

func GetOrderMap 

func GetOrderMap(swapMsgs []*BatchPoolSwapMsg, denomX, denomY string, onlyNotMatched bool) (OrderMap, []*BatchPoolSwapMsg, []*BatchPoolSwapMsg)

make orderMap key as swap price, value as Buy, Sell Amount from swap msgs, with split as Buy XtoY, Sell YtoX msg list.

func GetPoolCoinDenom 

func GetPoolCoinDenom(poolKey string) string

Generation absolute denomination of the Pool Coin. This rule will be changed on next milestone

func GetPoolKey 

func GetPoolKey(reserveCoinDenoms []string, poolTypeIndex uint32) string

Calculate unique Pool key of the liquidity pool

func GetPoolReserveAcc 

func GetPoolReserveAcc(poolKey string) sdk.AccAddress

GetPoolReserveAcc returns the poor account for the provided poolKey (reserve denoms + poolType)

func GetPriceDirection 

func GetPriceDirection(currentPrice sdk.Dec, orderBook OrderBook) int

Get Price direction of the orderbook with current Price

func IsPoolCoinDenom 

func IsPoolCoinDenom(denom string) bool

check is the denom poolcoin or not, need to additional checking the reserve account is existed

func MaxDec 

func MaxDec(a, b sdk.Dec) sdk.Dec

Return maximum Decimal

func MaxInt 

func MaxInt(a, b sdk.Int) sdk.Int

Return Maximum Int

func MinDec 

func MinDec(a, b sdk.Dec) sdk.Dec

Return minimum Decimal

func MinInt 

func MinInt(a, b sdk.Int) sdk.Int

Return minimum Int

func MustMarshalBatchPoolDepositMsg 

func MustMarshalBatchPoolDepositMsg(cdc codec.BinaryMarshaler, msg BatchPoolDepositMsg) []byte

MustMarshalBatchPoolDepositMsg returns the BatchPoolDepositMsg bytes. Panics if fails

func MustMarshalBatchPoolSwapMsg 

func MustMarshalBatchPoolSwapMsg(cdc codec.BinaryMarshaler, msg BatchPoolSwapMsg) []byte

MustMarshalBatchPoolSwapMsg returns the BatchPoolSwapMsg bytes. Panics if fails

func MustMarshalBatchPoolWithdrawMsg 

func MustMarshalBatchPoolWithdrawMsg(cdc codec.BinaryMarshaler, msg BatchPoolWithdrawMsg) []byte

MustMarshalBatchPoolWithdrawMsg returns the BatchPoolWithdrawMsg bytes. Panics if fails

func MustMarshalLiquidityPool 

func MustMarshalLiquidityPool(cdc codec.BinaryMarshaler, liquidityPool LiquidityPool) []byte

MustMarshalLiquidityPool returns the liquidityPool bytes. Panics if fails

func MustMarshalLiquidityPoolBatch 

func MustMarshalLiquidityPoolBatch(cdc codec.BinaryMarshaler, liquidityPoolBatch LiquidityPoolBatch) []byte

MustMarshalLiquidityPoolBatch returns the LiquidityPoolBatch bytes. Panics if fails

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamTypeTable returns the TypeTable for liquidity module

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

RegisterInterfaces registers the sdk.Tx interface.

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers concrete types on the codec.

func RegisterMsgApiHandler 

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

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

func RegisterMsgApiHandlerClient 

func RegisterMsgApiHandlerClient(ctx context.Context, mux *runtime.ServeMux, client MsgApiClient) error

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

func RegisterMsgApiHandlerFromEndpoint 

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

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

func RegisterMsgApiHandlerServer 

func RegisterMsgApiHandlerServer(ctx context.Context, mux *runtime.ServeMux, server MsgApiServer) error

RegisterMsgApiHandlerServer registers the http handlers for service MsgApi to "mux". UnaryRPC :call MsgApiServer 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 RegisterMsgApiHandlerFromEndpoint instead.

func RegisterMsgApiServer 

func RegisterMsgApiServer(s grpc1.Server, srv MsgApiServer)

func RegisterMsgHandler 

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

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

func RegisterMsgHandlerClient 

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

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

func RegisterMsgHandlerFromEndpoint 

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

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

func RegisterMsgHandlerServer 

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

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func StringInSlice 

func StringInSlice(a string, list []string) bool

Find A string is exists in the given list

func ValidateGenesis 

func ValidateGenesis(data GenesisState) error

ValidateGenesis - placeholder function

func ValidateReserveCoinLimit 

func ValidateReserveCoinLimit(reserveCoinLimitAmount sdk.Int, depositCoins sdk.Coins) error

Check Validity of the depositCoins exceed reserveCoinLimitAmount TODO: Get balance of pool, check with

func ValidateStateAndExpireOrders 

func ValidateStateAndExpireOrders(msgList []*BatchPoolSwapMsg, currentHeight int64, expireThisHeight bool)

check validity state of the batch swap messages, and set to delete state to height timeout expired order

Types

type AccountKeeper 

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

AccountKeeper defines the expected account keeper

type BankKeeper 

type BankKeeper interface {
	InputOutputCoins(ctx sdk.Context, inputs []banktypes.Input, outputs []banktypes.Output) error
	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin

	GetSupply(ctx sdk.Context) bankexported.SupplyI
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, name string, amt sdk.Coins) error
	MintCoins(ctx sdk.Context, name string, amt sdk.Coins) error
}

BankKeeper defines the expected bank send keeper

type BaseReq 

type BaseReq struct {
	// Sender address or Keybase name to generate a transaction
	From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty" yaml:"from"`
	// Memo to send along with transaction
	Memo string `protobuf:"bytes,2,opt,name=memo,proto3" json:"memo,omitempty" yaml:"memo"`
	// Name or address of private key with which to sign
	ChainId string `protobuf:"bytes,3,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty" yaml:"chain_id"`
	// The account number of the signing account (offline mode only)
	AccountNumber uint64 `protobuf:"varint,4,opt,name=account_number,json=accountNumber,proto3" json:"account_number,omitempty" yaml:"account_number"`
	// The sequence number of the signing account (offline mode only)
	Sequence uint64 `protobuf:"varint,5,opt,name=sequence,proto3" json:"sequence,omitempty" yaml:"sequence"`
	// Set a block timeout height to prevent the tx from being committed past a certain height
	TimeoutHeight uint64 `protobuf:"varint,6,opt,name=timeout_height,json=timeoutHeight,proto3" json:"timeout_height,omitempty" yaml:"timeout_height"`
	// Fees to pay along with transaction
	Fees github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,7,rep,name=fees,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"fees"`
	// Gas prices in decimal format to determine the transaction fee
	GasPrices github_com_cosmos_cosmos_sdk_types.DecCoins `` /* 153-byte string literal not displayed */
	// Gas amount to determine the transaction fee
	Gas uint64 `protobuf:"varint,9,opt,name=gas,proto3" json:"gas,omitempty" yaml:"gas"`
	// adjustment factor to be multiplied against the estimate returned by the tx simulation; if the gas limit is set manually this flag is ignored
	GasAdjustment string `protobuf:"bytes,10,opt,name=gas_adjustment,json=gasAdjustment,proto3" json:"gas_adjustment,omitempty" yaml:"gas_adjustment"`
	// Estimate gas for a transaction (cannot be used in conjunction with generate_only)
	Simulate bool `protobuf:"varint,11,opt,name=simulate,proto3" json:"simulate,omitempty" yaml:"simulate"`
}

Base Request struct for Post Tx, standard of tendermint/cosmos-sdk

func (*BaseReq) Descriptor 

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

func (*BaseReq) Marshal 

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

func (*BaseReq) MarshalTo 

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

func (*BaseReq) MarshalToSizedBuffer 

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

func (*BaseReq) ProtoMessage 

func (*BaseReq) ProtoMessage()

func (*BaseReq) Reset 

func (m *BaseReq) Reset()

func (*BaseReq) Size 

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

func (*BaseReq) String 

func (m *BaseReq) String() string

func (*BaseReq) Unmarshal 

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

func (*BaseReq) XXX_DiscardUnknown 

func (m *BaseReq) XXX_DiscardUnknown()

func (*BaseReq) XXX_Marshal 

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

func (*BaseReq) XXX_Merge 

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

func (*BaseReq) XXX_Size 

func (m *BaseReq) XXX_Size() int

func (*BaseReq) XXX_Unmarshal 

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

type BatchPoolDepositMsg 

type BatchPoolDepositMsg struct {
	// height where this message is appended to the batch
	MsgHeight int64 `protobuf:"varint,1,opt,name=msg_height,json=msgHeight,proto3" json:"msg_height,omitempty" yaml:"msg_height"`
	// index of this deposit message in this liquidity pool
	MsgIndex uint64 `protobuf:"varint,2,opt,name=msg_index,json=msgIndex,proto3" json:"msg_index,omitempty" yaml:"msg_index"`
	// true if executed on this batch, false if not executed yet
	Executed bool `protobuf:"varint,3,opt,name=executed,proto3" json:"executed,omitempty" yaml:"executed"`
	// true if executed successfully on this batch, false if failed
	Succeeded bool `protobuf:"varint,4,opt,name=succeeded,proto3" json:"succeeded,omitempty" yaml:"succeeded"`
	// true if ready to be deleted on kvstore, false if not ready to be deleted
	ToBeDeleted bool `protobuf:"varint,5,opt,name=to_be_deleted,json=toBeDeleted,proto3" json:"to_be_deleted,omitempty" yaml:"to_be_deleted"`
	// MsgDepositToLiquidityPool
	Msg *MsgDepositToLiquidityPool `protobuf:"bytes,6,opt,name=msg,proto3" json:"msg,omitempty" yaml:"msg"`
}

func MustUnmarshalBatchPoolDepositMsg 

func MustUnmarshalBatchPoolDepositMsg(cdc codec.BinaryMarshaler, value []byte) BatchPoolDepositMsg

MustUnmarshalBatchPoolDepositMsg return the unmarshalled BatchPoolDepositMsg from bytes. Panics if fails.

func UnmarshalBatchPoolDepositMsg 

func UnmarshalBatchPoolDepositMsg(cdc codec.BinaryMarshaler, value []byte) (msg BatchPoolDepositMsg, err error)

return the BatchPoolDepositMsg

func (*BatchPoolDepositMsg) Descriptor 

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

func (*BatchPoolDepositMsg) Marshal 

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

func (*BatchPoolDepositMsg) MarshalTo 

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

func (*BatchPoolDepositMsg) MarshalToSizedBuffer 

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

func (*BatchPoolDepositMsg) ProtoMessage 

func (*BatchPoolDepositMsg) ProtoMessage()

func (*BatchPoolDepositMsg) Reset 

func (m *BatchPoolDepositMsg) Reset()

func (*BatchPoolDepositMsg) Size 

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

func (*BatchPoolDepositMsg) String 

func (m *BatchPoolDepositMsg) String() string

func (*BatchPoolDepositMsg) Unmarshal 

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

func (*BatchPoolDepositMsg) XXX_DiscardUnknown 

func (m *BatchPoolDepositMsg) XXX_DiscardUnknown()

func (*BatchPoolDepositMsg) XXX_Marshal 

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

func (*BatchPoolDepositMsg) XXX_Merge 

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

func (*BatchPoolDepositMsg) XXX_Size 

func (m *BatchPoolDepositMsg) XXX_Size() int

func (*BatchPoolDepositMsg) XXX_Unmarshal 

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

type BatchPoolSwapMsg 

type BatchPoolSwapMsg struct {
	// height where this message is appended to the batch
	MsgHeight int64 `protobuf:"varint,1,opt,name=msg_height,json=msgHeight,proto3" json:"msg_height,omitempty" yaml:"msg_height"`
	// index of this swap message in this liquidity pool
	MsgIndex uint64 `protobuf:"varint,2,opt,name=msg_index,json=msgIndex,proto3" json:"msg_index,omitempty" yaml:"msg_index"`
	// true if executed on this batch, false if not executed yet
	Executed bool `protobuf:"varint,3,opt,name=executed,proto3" json:"executed,omitempty" yaml:"executed"`
	// true if executed successfully on this batch, false if failed
	Succeeded bool `protobuf:"varint,4,opt,name=succeeded,proto3" json:"succeeded,omitempty" yaml:"succeeded"`
	// true if ready to be deleted on kvstore, false if not ready to be deleted
	ToBeDeleted bool `protobuf:"varint,5,opt,name=to_be_deleted,json=toBeDeleted,proto3" json:"to_be_deleted,omitempty" yaml:"to_be_deleted"`
	// swap orders are cancelled when current height is equal or higher than ExpiryHeight
	OrderExpiryHeight int64 `` /* 142-byte string literal not displayed */
	// offer coin exchanged until now
	ExchangedOfferCoin types.Coin `` /* 135-byte string literal not displayed */
	// offer coin currently remaining to be exchanged
	RemainingOfferCoin types.Coin `` /* 135-byte string literal not displayed */
	// reserve fee for pays fee in half offer coin
	OfferCoinFeeReserve types.Coin `protobuf:"bytes,9,opt,name=OfferCoinFeeReserve,proto3" json:"OfferCoinFeeReserve" yaml:"offer_coin_fee_reserve"`
	// MsgSwap
	Msg *MsgSwap `protobuf:"bytes,10,opt,name=Msg,proto3" json:"Msg,omitempty" yaml:"msg"`
}

func MustUnmarshalBatchPoolSwapMsg 

func MustUnmarshalBatchPoolSwapMsg(cdc codec.BinaryMarshaler, value []byte) BatchPoolSwapMsg

MustUnmarshalBatchPoolSwapMsg return the unmarshalled BatchPoolSwapMsg from bytes. Panics if fails.

func UnmarshalBatchPoolSwapMsg 

func UnmarshalBatchPoolSwapMsg(cdc codec.BinaryMarshaler, value []byte) (msg BatchPoolSwapMsg, err error)

return the UnmarshalBatchPoolSwapMsg

func (*BatchPoolSwapMsg) Descriptor 

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

func (*BatchPoolSwapMsg) Marshal 

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

func (*BatchPoolSwapMsg) MarshalTo 

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

func (*BatchPoolSwapMsg) MarshalToSizedBuffer 

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

func (*BatchPoolSwapMsg) ProtoMessage 

func (*BatchPoolSwapMsg) ProtoMessage()

func (*BatchPoolSwapMsg) Reset 

func (m *BatchPoolSwapMsg) Reset()

func (*BatchPoolSwapMsg) Size 

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

func (*BatchPoolSwapMsg) String 

func (m *BatchPoolSwapMsg) String() string

func (*BatchPoolSwapMsg) Unmarshal 

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

func (*BatchPoolSwapMsg) XXX_DiscardUnknown 

func (m *BatchPoolSwapMsg) XXX_DiscardUnknown()

func (*BatchPoolSwapMsg) XXX_Marshal 

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

func (*BatchPoolSwapMsg) XXX_Merge 

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

func (*BatchPoolSwapMsg) XXX_Size 

func (m *BatchPoolSwapMsg) XXX_Size() int

func (*BatchPoolSwapMsg) XXX_Unmarshal 

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

type BatchPoolWithdrawMsg 

type BatchPoolWithdrawMsg struct {
	// height where this message is appended to the batch
	MsgHeight int64 `protobuf:"varint,1,opt,name=msg_height,json=msgHeight,proto3" json:"msg_height,omitempty" yaml:"msg_height"`
	// index of this withdraw message in this liquidity pool
	MsgIndex uint64 `protobuf:"varint,2,opt,name=msg_index,json=msgIndex,proto3" json:"msg_index,omitempty" yaml:"msg_index"`
	// true if executed on this batch, false if not executed yet
	Executed bool `protobuf:"varint,3,opt,name=executed,proto3" json:"executed,omitempty" yaml:"executed"`
	// true if executed successfully on this batch, false if failed
	Succeeded bool `protobuf:"varint,4,opt,name=succeeded,proto3" json:"succeeded,omitempty" yaml:"succeeded"`
	// true if ready to be deleted on kvstore, false if not ready to be deleted
	ToBeDeleted bool `protobuf:"varint,5,opt,name=to_be_deleted,json=toBeDeleted,proto3" json:"to_be_deleted,omitempty" yaml:"to_be_deleted"`
	// MsgWithdrawFromLiquidityPool
	Msg *MsgWithdrawFromLiquidityPool `protobuf:"bytes,6,opt,name=msg,proto3" json:"msg,omitempty" yaml:"msg"`
}

func MustUnmarshalBatchPoolWithdrawMsg 

func MustUnmarshalBatchPoolWithdrawMsg(cdc codec.BinaryMarshaler, value []byte) BatchPoolWithdrawMsg

MustUnmarshalBatchPoolWithdrawMsg return the unmarshalled BatchPoolWithdrawMsg from bytes. Panics if fails.

func UnmarshalBatchPoolWithdrawMsg 

func UnmarshalBatchPoolWithdrawMsg(cdc codec.BinaryMarshaler, value []byte) (msg BatchPoolWithdrawMsg, err error)

return the BatchPoolWithdrawMsg

func (*BatchPoolWithdrawMsg) Descriptor 

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

func (*BatchPoolWithdrawMsg) Marshal 

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

func (*BatchPoolWithdrawMsg) MarshalTo 

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

func (*BatchPoolWithdrawMsg) MarshalToSizedBuffer 

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

func (*BatchPoolWithdrawMsg) ProtoMessage 

func (*BatchPoolWithdrawMsg) ProtoMessage()

func (*BatchPoolWithdrawMsg) Reset 

func (m *BatchPoolWithdrawMsg) Reset()

func (*BatchPoolWithdrawMsg) Size 

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

func (*BatchPoolWithdrawMsg) String 

func (m *BatchPoolWithdrawMsg) String() string

func (*BatchPoolWithdrawMsg) Unmarshal 

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

func (*BatchPoolWithdrawMsg) XXX_DiscardUnknown 

func (m *BatchPoolWithdrawMsg) XXX_DiscardUnknown()

func (*BatchPoolWithdrawMsg) XXX_Marshal 

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

func (*BatchPoolWithdrawMsg) XXX_Merge 

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

func (*BatchPoolWithdrawMsg) XXX_Size 

func (m *BatchPoolWithdrawMsg) XXX_Size() int

func (*BatchPoolWithdrawMsg) XXX_Unmarshal 

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

type BatchResult 

type BatchResult struct {
	MatchType      int
	PriceDirection int
	SwapPrice      sdk.Dec
	EX             sdk.Int
	EY             sdk.Int
	OriginalEX     sdk.Int
	OriginalEY     sdk.Int
	PoolX          sdk.Int
	PoolY          sdk.Int
	TransactAmt    sdk.Int
}

struct of swap matching result of the batch

func CalculateMatch 

func CalculateMatch(direction int, X, Y, currentPrice sdk.Dec, orderBook OrderBook) (maxScenario BatchResult)

Calculates the batch results with the logic for each direction

func CalculateMatchStay 

func CalculateMatchStay(currentPrice sdk.Dec, orderBook OrderBook) (r BatchResult)

Calculate results for orderbook matching with unchanged price case

func CalculateSwap 

func CalculateSwap(direction int, X, Y, orderPrice, lastOrderPrice sdk.Dec, orderBook OrderBook) (r BatchResult)

Calculates the batch results with the processing logic for each direction

func MatchOrderbook 

func MatchOrderbook(X, Y, currentPrice sdk.Dec, orderBook OrderBook) BatchResult

The price and coins of swap messages in orderbook are calculated to derive match result with the price direction.

func NewBatchResult 

func NewBatchResult() BatchResult

return of zero object, to avoid nil

type Fee 

type Fee struct {
	Gas uint64 `protobuf:"varint,1,opt,name=gas,proto3" json:"gas,omitempty" yaml:"gas"`
	// amount is the amount of coins to be paid as a fee
	Amount github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=amount,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"amount"`
}

Fee struct of cosmos-sdk

func (*Fee) Descriptor 

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

func (*Fee) GetAmount 

func (m *Fee) GetAmount() github_com_cosmos_cosmos_sdk_types.Coins

func (*Fee) GetGas 

func (m *Fee) GetGas() uint64

func (*Fee) Marshal 

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

func (*Fee) MarshalTo 

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

func (*Fee) MarshalToSizedBuffer 

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

func (*Fee) ProtoMessage 

func (*Fee) ProtoMessage()

func (*Fee) Reset 

func (m *Fee) Reset()

func (*Fee) Size 

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

func (*Fee) String 

func (m *Fee) String() string

func (*Fee) Unmarshal 

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

func (*Fee) XXX_DiscardUnknown 

func (m *Fee) XXX_DiscardUnknown()

func (*Fee) XXX_Marshal 

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

func (*Fee) XXX_Merge 

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

func (*Fee) XXX_Size 

func (m *Fee) XXX_Size() int

func (*Fee) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// params defines all the parameters of related to liquidity.
	Params               Params                `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	LiquidityPoolRecords []LiquidityPoolRecord `` /* 136-byte string literal not displayed */
}

GenesisState defines the liquidity module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState creates a default GenesisState object

func NewGenesisState 

func NewGenesisState(params Params, liquidityPoolRecords []LiquidityPoolRecord) *GenesisState

NewGenesisState is the constructor function for GenesisState

func (*GenesisState) Descriptor 

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

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type LiquidityPool 

type LiquidityPool struct {
	// id of the pool
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// index of the pool type
	PoolTypeIndex uint32 `` /* 126-byte string literal not displayed */
	// denoms of reserve coin pair of the pool
	ReserveCoinDenoms []string `` /* 141-byte string literal not displayed */
	// reserve account address of the pool
	ReserveAccountAddress string `` /* 157-byte string literal not displayed */
	// denom of pool coin of the pool
	PoolCoinDenom string `protobuf:"bytes,5,opt,name=pool_coin_denom,json=poolCoinDenom,proto3" json:"pool_coin_denom,omitempty" yaml:"pool_coin_denom"`
}

func MustUnmarshalLiquidityPool 

func MustUnmarshalLiquidityPool(cdc codec.BinaryMarshaler, value []byte) LiquidityPool

MustUnmarshalLiquidityPool return the unmarshalled liquidityPool from bytes. Panics if fails.

func UnmarshalLiquidityPool 

func UnmarshalLiquidityPool(cdc codec.BinaryMarshaler, value []byte) (liquidityPool LiquidityPool, err error)

return the liquidityPool

func (*LiquidityPool) Descriptor 

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

func (*LiquidityPool) Equal 

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

func (LiquidityPool) GetPoolCoinDenom 

func (lp LiquidityPool) GetPoolCoinDenom() string

return pool coin denom of the liquidity pool

func (LiquidityPool) GetPoolId 

func (lp LiquidityPool) GetPoolId() uint64

return pool id of the liquidity pool

func (LiquidityPool) GetPoolKey 

func (lp LiquidityPool) GetPoolKey() string

Calculate unique Pool key of the liquidity pool need to validate alphabetical ordering of ReserveCoinDenoms when New() and Store Denominations can be 3 ~ 128 characters long and support letters, followed by either a letter, a number or a separator ('/'). reDnmString = `[a-zA-Z][a-zA-Z0-9/]{2,127}`.

func (LiquidityPool) GetReserveAccount 

func (lp LiquidityPool) GetReserveAccount() sdk.AccAddress

return sdk.AccAddress object of the address saved as string because of protobuf

func (*LiquidityPool) Marshal 

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

func (*LiquidityPool) MarshalTo 

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

func (*LiquidityPool) MarshalToSizedBuffer 

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

func (*LiquidityPool) ProtoMessage 

func (*LiquidityPool) ProtoMessage()

func (*LiquidityPool) Reset 

func (m *LiquidityPool) Reset()

func (*LiquidityPool) Size 

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

func (*LiquidityPool) String 

func (m *LiquidityPool) String() string

func (*LiquidityPool) Unmarshal 

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

func (LiquidityPool) Validate 

func (lp LiquidityPool) Validate() error

Validate each constraint of the liquidity pool

func (*LiquidityPool) XXX_DiscardUnknown 

func (m *LiquidityPool) XXX_DiscardUnknown()

func (*LiquidityPool) XXX_Marshal 

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

func (*LiquidityPool) XXX_Merge 

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

func (*LiquidityPool) XXX_Size 

func (m *LiquidityPool) XXX_Size() int

func (*LiquidityPool) XXX_Unmarshal 

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

type LiquidityPoolBatch 

type LiquidityPoolBatch struct {
	// id of the pool
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// index of this batch
	BatchIndex uint64 `protobuf:"varint,2,opt,name=batch_index,json=batchIndex,proto3" json:"batch_index,omitempty" yaml:"batch_index"`
	// height where this batch is begun
	BeginHeight int64 `protobuf:"varint,3,opt,name=begin_height,json=beginHeight,proto3" json:"begin_height,omitempty" yaml:"begin_height"`
	// last index of BatchPoolDepositMsgs
	DepositMsgIndex uint64 `` /* 134-byte string literal not displayed */
	// last index of BatchPoolWithdrawMsgs
	WithdrawMsgIndex uint64 `` /* 138-byte string literal not displayed */
	// last index of BatchPoolSwapMsgs
	SwapMsgIndex uint64 `protobuf:"varint,6,opt,name=swap_msg_index,json=swapMsgIndex,proto3" json:"swap_msg_index,omitempty" yaml:"swap_msg_index"`
	// true if executed, false if not executed yet
	Executed bool `protobuf:"varint,7,opt,name=executed,proto3" json:"executed,omitempty" yaml:"executed"`
}

func MustUnmarshalLiquidityPoolBatch 

func MustUnmarshalLiquidityPoolBatch(cdc codec.BinaryMarshaler, value []byte) LiquidityPoolBatch

MustUnmarshalLiquidityPool return the unmarshalled LiquidityPoolBatch from bytes. Panics if fails.

func NewLiquidityPoolBatch 

func NewLiquidityPoolBatch(poolId, batchIndex uint64) LiquidityPoolBatch

func UnmarshalLiquidityPoolBatch 

func UnmarshalLiquidityPoolBatch(cdc codec.BinaryMarshaler, value []byte) (liquidityPoolBatch LiquidityPoolBatch, err error)

return the liquidityPoolBatch

func (*LiquidityPoolBatch) Descriptor 

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

func (*LiquidityPoolBatch) Equal 

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

func (*LiquidityPoolBatch) Marshal 

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

func (*LiquidityPoolBatch) MarshalTo 

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

func (*LiquidityPoolBatch) MarshalToSizedBuffer 

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

func (*LiquidityPoolBatch) ProtoMessage 

func (*LiquidityPoolBatch) ProtoMessage()

func (*LiquidityPoolBatch) Reset 

func (m *LiquidityPoolBatch) Reset()

func (*LiquidityPoolBatch) Size 

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

func (*LiquidityPoolBatch) String 

func (m *LiquidityPoolBatch) String() string

func (*LiquidityPoolBatch) Unmarshal 

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

func (*LiquidityPoolBatch) XXX_DiscardUnknown 

func (m *LiquidityPoolBatch) XXX_DiscardUnknown()

func (*LiquidityPoolBatch) XXX_Marshal 

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

func (*LiquidityPoolBatch) XXX_Merge 

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

func (*LiquidityPoolBatch) XXX_Size 

func (m *LiquidityPoolBatch) XXX_Size() int

func (*LiquidityPoolBatch) XXX_Unmarshal 

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

type LiquidityPoolMetadata 

type LiquidityPoolMetadata struct {
	// id of the pool
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// pool coin issued at the pool
	PoolCoinTotalSupply types.Coin `` /* 142-byte string literal not displayed */
	// reserve coins deposited in the pool
	ReserveCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 162-byte string literal not displayed */
}

func (*LiquidityPoolMetadata) Descriptor 

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

func (*LiquidityPoolMetadata) Equal 

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

func (*LiquidityPoolMetadata) Marshal 

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

func (*LiquidityPoolMetadata) MarshalTo 

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

func (*LiquidityPoolMetadata) MarshalToSizedBuffer 

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

func (*LiquidityPoolMetadata) ProtoMessage 

func (*LiquidityPoolMetadata) ProtoMessage()

func (*LiquidityPoolMetadata) Reset 

func (m *LiquidityPoolMetadata) Reset()

func (*LiquidityPoolMetadata) Size 

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

func (*LiquidityPoolMetadata) String 

func (m *LiquidityPoolMetadata) String() string

func (*LiquidityPoolMetadata) Unmarshal 

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

func (*LiquidityPoolMetadata) XXX_DiscardUnknown 

func (m *LiquidityPoolMetadata) XXX_DiscardUnknown()

func (*LiquidityPoolMetadata) XXX_Marshal 

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

func (*LiquidityPoolMetadata) XXX_Merge 

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

func (*LiquidityPoolMetadata) XXX_Size 

func (m *LiquidityPoolMetadata) XXX_Size() int

func (*LiquidityPoolMetadata) XXX_Unmarshal 

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

type LiquidityPoolRecord 

type LiquidityPoolRecord struct {
	LiquidityPool         LiquidityPool          `protobuf:"bytes,1,opt,name=liquidity_pool,json=liquidityPool,proto3" json:"liquidity_pool" yaml:"liquidity_pool"`
	LiquidityPoolMetadata LiquidityPoolMetadata  `` /* 147-byte string literal not displayed */
	LiquidityPoolBatch    LiquidityPoolBatch     `` /* 135-byte string literal not displayed */
	BatchPoolDepositMsgs  []BatchPoolDepositMsg  `` /* 146-byte string literal not displayed */
	BatchPoolWithdrawMsgs []BatchPoolWithdrawMsg `` /* 150-byte string literal not displayed */
	BatchPoolSwapMsgs     []BatchPoolSwapMsg     `` /* 134-byte string literal not displayed */
}

func (*LiquidityPoolRecord) Descriptor 

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

func (*LiquidityPoolRecord) GetBatchPoolDepositMsgs 

func (m *LiquidityPoolRecord) GetBatchPoolDepositMsgs() []BatchPoolDepositMsg

func (*LiquidityPoolRecord) GetBatchPoolSwapMsgs 

func (m *LiquidityPoolRecord) GetBatchPoolSwapMsgs() []BatchPoolSwapMsg

func (*LiquidityPoolRecord) GetBatchPoolWithdrawMsgs 

func (m *LiquidityPoolRecord) GetBatchPoolWithdrawMsgs() []BatchPoolWithdrawMsg

func (*LiquidityPoolRecord) GetLiquidityPool 

func (m *LiquidityPoolRecord) GetLiquidityPool() LiquidityPool

func (*LiquidityPoolRecord) GetLiquidityPoolBatch 

func (m *LiquidityPoolRecord) GetLiquidityPoolBatch() LiquidityPoolBatch

func (*LiquidityPoolRecord) GetLiquidityPoolMetadata 

func (m *LiquidityPoolRecord) GetLiquidityPoolMetadata() LiquidityPoolMetadata

func (*LiquidityPoolRecord) Marshal 

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

func (*LiquidityPoolRecord) MarshalTo 

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

func (*LiquidityPoolRecord) MarshalToSizedBuffer 

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

func (*LiquidityPoolRecord) ProtoMessage 

func (*LiquidityPoolRecord) ProtoMessage()

func (*LiquidityPoolRecord) Reset 

func (m *LiquidityPoolRecord) Reset()

func (*LiquidityPoolRecord) Size 

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

func (*LiquidityPoolRecord) String 

func (m *LiquidityPoolRecord) String() string

func (*LiquidityPoolRecord) Unmarshal 

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

func (LiquidityPoolRecord) Validate 

func (record LiquidityPoolRecord) Validate() error

Validate Liquidity Pool Record after init or after export

func (*LiquidityPoolRecord) XXX_DiscardUnknown 

func (m *LiquidityPoolRecord) XXX_DiscardUnknown()

func (*LiquidityPoolRecord) XXX_Marshal 

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

func (*LiquidityPoolRecord) XXX_Merge 

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

func (*LiquidityPoolRecord) XXX_Size 

func (m *LiquidityPoolRecord) XXX_Size() int

func (*LiquidityPoolRecord) XXX_Unmarshal 

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

type LiquidityPoolType 

type LiquidityPoolType struct {
	// index of target pool type, only 1 is allowed on this version.
	PoolTypeIndex uint32 `` /* 126-byte string literal not displayed */
	// name of the pool type
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" yaml:"name"`
	// min number of reserveCoins for LiquidityPoolType only 2 is allowed on this spec
	MinReserveCoinNum uint32 `` /* 145-byte string literal not displayed */
	// max number of reserveCoins for LiquidityPoolType only 2 is allowed on this spec
	MaxReserveCoinNum uint32 `` /* 145-byte string literal not displayed */
	// description of the pool type
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty" yaml:"description"`
}

func (*LiquidityPoolType) Descriptor 

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

func (*LiquidityPoolType) Equal 

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

func (*LiquidityPoolType) Marshal 

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

func (*LiquidityPoolType) MarshalTo 

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

func (*LiquidityPoolType) MarshalToSizedBuffer 

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

func (*LiquidityPoolType) ProtoMessage 

func (*LiquidityPoolType) ProtoMessage()

func (*LiquidityPoolType) Reset 

func (m *LiquidityPoolType) Reset()

func (*LiquidityPoolType) Size 

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

func (*LiquidityPoolType) String 

func (m *LiquidityPoolType) String() string

func (*LiquidityPoolType) Unmarshal 

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

func (*LiquidityPoolType) XXX_DiscardUnknown 

func (m *LiquidityPoolType) XXX_DiscardUnknown()

func (*LiquidityPoolType) XXX_Marshal 

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

func (*LiquidityPoolType) XXX_Merge 

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

func (*LiquidityPoolType) XXX_Size 

func (m *LiquidityPoolType) XXX_Size() int

func (*LiquidityPoolType) XXX_Unmarshal 

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

type LiquidityPools 

type LiquidityPools []LiquidityPool

LiquidityPools is a collection of liquidityPools

func (LiquidityPools) String 

func (lps LiquidityPools) String() (out string)

get string of list of liquidity pool

type LiquidityPoolsBatch 

type LiquidityPoolsBatch []LiquidityPoolBatch

LiquidityPoolsBatch is a collection of liquidityPoolBatch

type MatchResult 

type MatchResult struct {
	OrderHeight            int64
	OrderExpiryHeight      int64
	OrderMsgIndex          uint64
	OrderPrice             sdk.Dec
	OfferCoinAmt           sdk.Int
	TransactedCoinAmt      sdk.Int
	ExchangedDemandCoinAmt sdk.Int
	OfferCoinFeeAmt        sdk.Int
	ExchangedCoinFeeAmt    sdk.Int
	BatchMsg               *BatchPoolSwapMsg
}

struct of swap matching result of each Batch swap message

type MsgApiClient 

type MsgApiClient interface {
	// Submit create liquidity pool message.
	CreateLiquidityPoolApi(ctx context.Context, in *MsgCreateLiquidityPoolRequest, opts ...grpc.CallOption) (*MsgCreateLiquidityPoolResponse, error)
	// Submit deposit to the liquidity pool batch
	DepositToLiquidityPoolApi(ctx context.Context, in *MsgDepositToLiquidityPoolRequest, opts ...grpc.CallOption) (*MsgDepositToLiquidityPoolResponse, error)
	// Submit withdraw from to the liquidity pool batch
	WithdrawFromLiquidityPoolApi(ctx context.Context, in *MsgWithdrawFromLiquidityPoolRequest, opts ...grpc.CallOption) (*MsgWithdrawFromLiquidityPoolResponse, error)
	// Submit swap to the liquidity pool batch
	SwapApi(ctx context.Context, in *MsgSwapRequest, opts ...grpc.CallOption) (*MsgSwapResponse, error)
}

MsgApiClient is the client API for MsgApi service.

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

func NewMsgApiClient 

func NewMsgApiClient(cc grpc1.ClientConn) MsgApiClient

type MsgApiServer 

type MsgApiServer interface {
	// Submit create liquidity pool message.
	CreateLiquidityPoolApi(context.Context, *MsgCreateLiquidityPoolRequest) (*MsgCreateLiquidityPoolResponse, error)
	// Submit deposit to the liquidity pool batch
	DepositToLiquidityPoolApi(context.Context, *MsgDepositToLiquidityPoolRequest) (*MsgDepositToLiquidityPoolResponse, error)
	// Submit withdraw from to the liquidity pool batch
	WithdrawFromLiquidityPoolApi(context.Context, *MsgWithdrawFromLiquidityPoolRequest) (*MsgWithdrawFromLiquidityPoolResponse, error)
	// Submit swap to the liquidity pool batch
	SwapApi(context.Context, *MsgSwapRequest) (*MsgSwapResponse, error)
}

MsgApiServer is the server API for MsgApi service.

type MsgClient 

type MsgClient interface {
	// Submit create liquidity pool message.
	CreateLiquidityPool(ctx context.Context, in *MsgCreateLiquidityPool, opts ...grpc.CallOption) (*MsgCreateLiquidityPoolResponse, error)
	// Submit deposit to the liquidity pool batch.
	DepositToLiquidityPool(ctx context.Context, in *MsgDepositToLiquidityPool, opts ...grpc.CallOption) (*MsgDepositToLiquidityPoolResponse, error)
	// Submit withdraw from to the liquidity pool batch.
	WithdrawFromLiquidityPool(ctx context.Context, in *MsgWithdrawFromLiquidityPool, opts ...grpc.CallOption) (*MsgWithdrawFromLiquidityPoolResponse, error)
	// Submit swap to the liquidity pool batch.
	Swap(ctx context.Context, in *MsgSwap, opts ...grpc.CallOption) (*MsgSwapResponse, 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 MsgCreateLiquidityPool 

type MsgCreateLiquidityPool struct {
	PoolCreatorAddress string `` /* 145-byte string literal not displayed */
	// index of target pool type, only 1 is allowed on this version, Must match the value in the pool.
	PoolTypeIndex uint32 `` /* 126-byte string literal not displayed */
	// reserve coin pair of the pool to deposit
	DepositCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 162-byte string literal not displayed */
}

MsgCreateLiquidityPool defines an sdk.Msg type that supports submitting create liquidity pool

func NewMsgCreateLiquidityPool 

func NewMsgCreateLiquidityPool(
	poolCreator sdk.AccAddress,
	poolTypeIndex uint32,
	depositCoins sdk.Coins,
) *MsgCreateLiquidityPool

NewMsgSwap creates a new MsgSwap object.

func (*MsgCreateLiquidityPool) Descriptor 

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

func (MsgCreateLiquidityPool) GetPoolCreator 

func (msg MsgCreateLiquidityPool) GetPoolCreator() sdk.AccAddress

func (MsgCreateLiquidityPool) GetSignBytes 

func (msg MsgCreateLiquidityPool) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgCreateLiquidityPool) GetSigners 

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

GetSigners implements Msg.

func (*MsgCreateLiquidityPool) Marshal 

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

func (*MsgCreateLiquidityPool) MarshalTo 

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

func (*MsgCreateLiquidityPool) MarshalToSizedBuffer 

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

func (*MsgCreateLiquidityPool) ProtoMessage 

func (*MsgCreateLiquidityPool) ProtoMessage()

func (*MsgCreateLiquidityPool) Reset 

func (m *MsgCreateLiquidityPool) Reset()

func (MsgCreateLiquidityPool) Route 

func (msg MsgCreateLiquidityPool) Route() string

Route implements Msg.

func (*MsgCreateLiquidityPool) Size 

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

func (*MsgCreateLiquidityPool) String 

func (m *MsgCreateLiquidityPool) String() string

func (MsgCreateLiquidityPool) Type 

func (msg MsgCreateLiquidityPool) Type() string

Type implements Msg.

func (*MsgCreateLiquidityPool) Unmarshal 

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

func (MsgCreateLiquidityPool) ValidateBasic 

func (msg MsgCreateLiquidityPool) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgCreateLiquidityPool) XXX_DiscardUnknown 

func (m *MsgCreateLiquidityPool) XXX_DiscardUnknown()

func (*MsgCreateLiquidityPool) XXX_Marshal 

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

func (*MsgCreateLiquidityPool) XXX_Merge 

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

func (*MsgCreateLiquidityPool) XXX_Size 

func (m *MsgCreateLiquidityPool) XXX_Size() int

func (*MsgCreateLiquidityPool) XXX_Unmarshal 

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

type MsgCreateLiquidityPoolRequest 

type MsgCreateLiquidityPoolRequest struct {
	BaseReq *BaseReq `protobuf:"bytes,1,opt,name=base_req,json=baseReq,proto3" json:"base_req,omitempty"`
	// MsgCreateLiquidityPool
	Msg *MsgCreateLiquidityPool `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

MsgCreateLiquidityPoolRequest is the request type for the Msg/MsgCreateLiquidityPoolRequest RPC method.

func (*MsgCreateLiquidityPoolRequest) Descriptor 

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

func (*MsgCreateLiquidityPoolRequest) GetBaseReq 

func (m *MsgCreateLiquidityPoolRequest) GetBaseReq() *BaseReq

func (*MsgCreateLiquidityPoolRequest) GetMsg 

func (m *MsgCreateLiquidityPoolRequest) GetMsg() *MsgCreateLiquidityPool

func (*MsgCreateLiquidityPoolRequest) Marshal 

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

func (*MsgCreateLiquidityPoolRequest) MarshalTo 

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

func (*MsgCreateLiquidityPoolRequest) MarshalToSizedBuffer 

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

func (*MsgCreateLiquidityPoolRequest) ProtoMessage 

func (*MsgCreateLiquidityPoolRequest) ProtoMessage()

func (*MsgCreateLiquidityPoolRequest) Reset 

func (m *MsgCreateLiquidityPoolRequest) Reset()

func (*MsgCreateLiquidityPoolRequest) Size 

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

func (*MsgCreateLiquidityPoolRequest) String 

func (m *MsgCreateLiquidityPoolRequest) String() string

func (*MsgCreateLiquidityPoolRequest) Unmarshal 

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

func (*MsgCreateLiquidityPoolRequest) XXX_DiscardUnknown 

func (m *MsgCreateLiquidityPoolRequest) XXX_DiscardUnknown()

func (*MsgCreateLiquidityPoolRequest) XXX_Marshal 

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

func (*MsgCreateLiquidityPoolRequest) XXX_Merge 

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

func (*MsgCreateLiquidityPoolRequest) XXX_Size 

func (m *MsgCreateLiquidityPoolRequest) XXX_Size() int

func (*MsgCreateLiquidityPoolRequest) XXX_Unmarshal 

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

type MsgCreateLiquidityPoolResponse 

type MsgCreateLiquidityPoolResponse struct {
	StdTx *StdTx `protobuf:"bytes,1,opt,name=std_tx,json=stdTx,proto3" json:"std_tx,omitempty" yaml:"std_tx"`
}

MsgCreateLiquidityPoolResponse defines the Msg/CreateLiquidityPool response type.

func (*MsgCreateLiquidityPoolResponse) Descriptor 

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

func (*MsgCreateLiquidityPoolResponse) GetStdTx 

func (m *MsgCreateLiquidityPoolResponse) GetStdTx() *StdTx

func (*MsgCreateLiquidityPoolResponse) Marshal 

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

func (*MsgCreateLiquidityPoolResponse) MarshalTo 

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

func (*MsgCreateLiquidityPoolResponse) MarshalToSizedBuffer 

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

func (*MsgCreateLiquidityPoolResponse) ProtoMessage 

func (*MsgCreateLiquidityPoolResponse) ProtoMessage()

func (*MsgCreateLiquidityPoolResponse) Reset 

func (m *MsgCreateLiquidityPoolResponse) Reset()

func (*MsgCreateLiquidityPoolResponse) Size 

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

func (*MsgCreateLiquidityPoolResponse) String 

func (m *MsgCreateLiquidityPoolResponse) String() string

func (*MsgCreateLiquidityPoolResponse) Unmarshal 

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

func (*MsgCreateLiquidityPoolResponse) XXX_DiscardUnknown 

func (m *MsgCreateLiquidityPoolResponse) XXX_DiscardUnknown()

func (*MsgCreateLiquidityPoolResponse) XXX_Marshal 

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

func (*MsgCreateLiquidityPoolResponse) XXX_Merge 

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

func (*MsgCreateLiquidityPoolResponse) XXX_Size 

func (m *MsgCreateLiquidityPoolResponse) XXX_Size() int

func (*MsgCreateLiquidityPoolResponse) XXX_Unmarshal 

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

type MsgDepositToLiquidityPool 

type MsgDepositToLiquidityPool struct {
	// The publisher in which to create the book.
	//
	// Format: `publishers/{publisher}`
	//
	// Example: `publishers/1257894000000000000`
	DepositorAddress string `` /* 134-byte string literal not displayed */
	// id of the target pool
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// reserve coin pair of the pool to deposit
	DepositCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 162-byte string literal not displayed */
}

`MsgDepositToLiquidityPool defines` an `sdk.Msg` type that supports submitting deposit request to the batch of the liquidity pool Deposit submit to the batch of the Liquidity pool with the specified `pool_id`, deposit coins for reserve this requests are stacked in the batch of the liquidity pool, not immediately processed and processed in the `endblock` at once with other requests.

See: https://github.com/tendermint/liquidity/blob/develop/x/liquidity/spec/04_messages.md

func NewMsgDepositToLiquidityPool 

func NewMsgDepositToLiquidityPool(
	depositor sdk.AccAddress,
	poolId uint64,
	depositCoins sdk.Coins,
) *MsgDepositToLiquidityPool

NewMsgSwap creates a new MsgSwap object.

func (*MsgDepositToLiquidityPool) Descriptor 

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

func (MsgDepositToLiquidityPool) GetDepositor 

func (msg MsgDepositToLiquidityPool) GetDepositor() sdk.AccAddress

func (MsgDepositToLiquidityPool) GetSignBytes 

func (msg MsgDepositToLiquidityPool) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgDepositToLiquidityPool) GetSigners 

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

GetSigners implements Msg.

func (*MsgDepositToLiquidityPool) Marshal 

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

func (*MsgDepositToLiquidityPool) MarshalTo 

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

func (*MsgDepositToLiquidityPool) MarshalToSizedBuffer 

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

func (*MsgDepositToLiquidityPool) ProtoMessage 

func (*MsgDepositToLiquidityPool) ProtoMessage()

func (*MsgDepositToLiquidityPool) Reset 

func (m *MsgDepositToLiquidityPool) Reset()

func (MsgDepositToLiquidityPool) Route 

func (msg MsgDepositToLiquidityPool) Route() string

Route implements Msg.

func (*MsgDepositToLiquidityPool) Size 

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

func (*MsgDepositToLiquidityPool) String 

func (m *MsgDepositToLiquidityPool) String() string

func (MsgDepositToLiquidityPool) Type 

func (msg MsgDepositToLiquidityPool) Type() string

Type implements Msg.

func (*MsgDepositToLiquidityPool) Unmarshal 

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

func (MsgDepositToLiquidityPool) ValidateBasic 

func (msg MsgDepositToLiquidityPool) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgDepositToLiquidityPool) XXX_DiscardUnknown 

func (m *MsgDepositToLiquidityPool) XXX_DiscardUnknown()

func (*MsgDepositToLiquidityPool) XXX_Marshal 

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

func (*MsgDepositToLiquidityPool) XXX_Merge 

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

func (*MsgDepositToLiquidityPool) XXX_Size 

func (m *MsgDepositToLiquidityPool) XXX_Size() int

func (*MsgDepositToLiquidityPool) XXX_Unmarshal 

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

type MsgDepositToLiquidityPoolRequest 

type MsgDepositToLiquidityPoolRequest struct {
	BaseReq *BaseReq `protobuf:"bytes,1,opt,name=base_req,json=baseReq,proto3" json:"base_req,omitempty"`
	// id of the target pool
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// MsgDepositToLiquidityPool
	Msg *MsgDepositToLiquidityPool `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
}

MsgDepositToLiquidityPoolRequest is the request type for the Msg/DepositToLiquidityPool RPC method.

func (*MsgDepositToLiquidityPoolRequest) Descriptor 

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

func (*MsgDepositToLiquidityPoolRequest) GetBaseReq 

func (m *MsgDepositToLiquidityPoolRequest) GetBaseReq() *BaseReq

func (*MsgDepositToLiquidityPoolRequest) GetMsg 

func (m *MsgDepositToLiquidityPoolRequest) GetMsg() *MsgDepositToLiquidityPool

func (*MsgDepositToLiquidityPoolRequest) GetPoolId 

func (m *MsgDepositToLiquidityPoolRequest) GetPoolId() uint64

func (*MsgDepositToLiquidityPoolRequest) Marshal 

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

func (*MsgDepositToLiquidityPoolRequest) MarshalTo 

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

func (*MsgDepositToLiquidityPoolRequest) MarshalToSizedBuffer 

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

func (*MsgDepositToLiquidityPoolRequest) ProtoMessage 

func (*MsgDepositToLiquidityPoolRequest) ProtoMessage()

func (*MsgDepositToLiquidityPoolRequest) Reset 

func (m *MsgDepositToLiquidityPoolRequest) Reset()

func (*MsgDepositToLiquidityPoolRequest) Size 

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

func (*MsgDepositToLiquidityPoolRequest) String 

func (m *MsgDepositToLiquidityPoolRequest) String() string

func (*MsgDepositToLiquidityPoolRequest) Unmarshal 

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

func (*MsgDepositToLiquidityPoolRequest) XXX_DiscardUnknown 

func (m *MsgDepositToLiquidityPoolRequest) XXX_DiscardUnknown()

func (*MsgDepositToLiquidityPoolRequest) XXX_Marshal 

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

func (*MsgDepositToLiquidityPoolRequest) XXX_Merge 

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

func (*MsgDepositToLiquidityPoolRequest) XXX_Size 

func (m *MsgDepositToLiquidityPoolRequest) XXX_Size() int

func (*MsgDepositToLiquidityPoolRequest) XXX_Unmarshal 

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

type MsgDepositToLiquidityPoolResponse 

type MsgDepositToLiquidityPoolResponse struct {
	StdTx *StdTx `protobuf:"bytes,1,opt,name=std_tx,json=stdTx,proto3" json:"std_tx,omitempty" yaml:"std_tx"`
}

MsgDepositToLiquidityPoolResponse defines the Msg/DepositToLiquidityPool response type.

func (*MsgDepositToLiquidityPoolResponse) Descriptor 

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

func (*MsgDepositToLiquidityPoolResponse) GetStdTx 

func (m *MsgDepositToLiquidityPoolResponse) GetStdTx() *StdTx

func (*MsgDepositToLiquidityPoolResponse) Marshal 

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

func (*MsgDepositToLiquidityPoolResponse) MarshalTo 

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

func (*MsgDepositToLiquidityPoolResponse) MarshalToSizedBuffer 

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

func (*MsgDepositToLiquidityPoolResponse) ProtoMessage 

func (*MsgDepositToLiquidityPoolResponse) ProtoMessage()

func (*MsgDepositToLiquidityPoolResponse) Reset 

func (m *MsgDepositToLiquidityPoolResponse) Reset()

func (*MsgDepositToLiquidityPoolResponse) Size 

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

func (*MsgDepositToLiquidityPoolResponse) String 

func (m *MsgDepositToLiquidityPoolResponse) String() string

func (*MsgDepositToLiquidityPoolResponse) Unmarshal 

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

func (*MsgDepositToLiquidityPoolResponse) XXX_DiscardUnknown 

func (m *MsgDepositToLiquidityPoolResponse) XXX_DiscardUnknown()

func (*MsgDepositToLiquidityPoolResponse) XXX_Marshal 

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

func (*MsgDepositToLiquidityPoolResponse) XXX_Merge 

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

func (*MsgDepositToLiquidityPoolResponse) XXX_Size 

func (m *MsgDepositToLiquidityPoolResponse) XXX_Size() int

func (*MsgDepositToLiquidityPoolResponse) XXX_Unmarshal 

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

type MsgList 

type MsgList []*BatchPoolSwapMsg

The pointer list of the swap batch message.

func (MsgList) CountFractionalMatchedMsgs 

func (msgList MsgList) CountFractionalMatchedMsgs() int

Get number of fractional matched messages on the list.

func (MsgList) CountNotMatchedMsgs 

func (msgList MsgList) CountNotMatchedMsgs() int

Get number of not matched messages on the list.

type MsgServer 

type MsgServer interface {
	// Submit create liquidity pool message.
	CreateLiquidityPool(context.Context, *MsgCreateLiquidityPool) (*MsgCreateLiquidityPoolResponse, error)
	// Submit deposit to the liquidity pool batch.
	DepositToLiquidityPool(context.Context, *MsgDepositToLiquidityPool) (*MsgDepositToLiquidityPoolResponse, error)
	// Submit withdraw from to the liquidity pool batch.
	WithdrawFromLiquidityPool(context.Context, *MsgWithdrawFromLiquidityPool) (*MsgWithdrawFromLiquidityPoolResponse, error)
	// Submit swap to the liquidity pool batch.
	Swap(context.Context, *MsgSwap) (*MsgSwapResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSwap 

type MsgSwap struct {
	// address of swap requester
	SwapRequesterAddress string `` /* 153-byte string literal not displayed */
	// id of the target pool
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// id of swap type type, only 1 is allowed on this version, Must match the value in the pool.
	SwapType uint32 `protobuf:"varint,3,opt,name=swap_type,json=swapType,proto3" json:"swap_type,omitempty" yaml:"swap_type"`
	// offer sdk.coin for the swap request, Must match the denom in the pool.
	OfferCoin types.Coin `protobuf:"bytes,4,opt,name=offer_coin,json=offerCoin,proto3" json:"offer_coin" yaml:"offer_coin"`
	// denom of demand coin to be exchanged on the swap request, Must match the denom in the pool.
	DemandCoinDenom string `` /* 133-byte string literal not displayed */
	// offer coin fee for pay fees in half offer coin
	OfferCoinFee types.Coin `protobuf:"bytes,6,opt,name=offer_coin_fee,json=offerCoinFee,proto3" json:"offer_coin_fee" yaml:"offer_coin_fee"`
	// limit order price for this offer
	OrderPrice github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
}

`MsgSwap` defines an sdk.Msg type that supports submitting swap offer request to the batch of the liquidity pool Swap offer to the Liquidity pool with the specified `pool_id`, `pool_type_index`, `swap_type`, `demand_coin_denom` with the coin and the price you're offering this requests are stacked in the batch of the liquidity pool, not immediately processed and processed in the `endblock` at once with other requests You should request the same each field as the pool Currently, only the default `swap_type`1 is available on this version The detailed swap algorithm can be found here.

See: https://github.com/tendermint/liquidity/tree/develop/doc https://github.com/tendermint/liquidity/blob/develop/x/liquidity/spec/04_messages.md

func NewMsgSwap 

func NewMsgSwap(
	swapRequester sdk.AccAddress,
	poolId uint64,
	swapType uint32,
	offerCoin sdk.Coin,
	demandCoinDenom string,
	orderPrice sdk.Dec,
	swapFeeRate sdk.Dec,
) *MsgSwap

NewMsgSwap creates a new MsgSwap object.

func (*MsgSwap) Descriptor 

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

func (MsgSwap) GetSignBytes 

func (msg MsgSwap) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgSwap) GetSigners 

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

GetSigners implements Msg.

func (MsgSwap) GetSwapRequester 

func (msg MsgSwap) GetSwapRequester() sdk.AccAddress

func (*MsgSwap) Marshal 

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

func (*MsgSwap) MarshalTo 

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

func (*MsgSwap) MarshalToSizedBuffer 

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

func (*MsgSwap) ProtoMessage 

func (*MsgSwap) ProtoMessage()

func (*MsgSwap) Reset 

func (m *MsgSwap) Reset()

func (MsgSwap) Route 

func (msg MsgSwap) Route() string

Route implements Msg.

func (*MsgSwap) Size 

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

func (*MsgSwap) String 

func (m *MsgSwap) String() string

func (MsgSwap) Type 

func (msg MsgSwap) Type() string

Type implements Msg.

func (*MsgSwap) Unmarshal 

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

func (MsgSwap) ValidateBasic 

func (msg MsgSwap) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgSwap) XXX_DiscardUnknown 

func (m *MsgSwap) XXX_DiscardUnknown()

func (*MsgSwap) XXX_Marshal 

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

func (*MsgSwap) XXX_Merge 

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

func (*MsgSwap) XXX_Size 

func (m *MsgSwap) XXX_Size() int

func (*MsgSwap) XXX_Unmarshal 

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

type MsgSwapRequest 

type MsgSwapRequest struct {
	BaseReq *BaseReq `protobuf:"bytes,1,opt,name=base_req,json=baseReq,proto3" json:"base_req,omitempty"`
	// id of the target pool
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// MsgSwap
	Msg *MsgSwap `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
}

MsgSwapRequest is the request type for the Query/Swap RPC method.

func (*MsgSwapRequest) Descriptor 

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

func (*MsgSwapRequest) GetBaseReq 

func (m *MsgSwapRequest) GetBaseReq() *BaseReq

func (*MsgSwapRequest) GetMsg 

func (m *MsgSwapRequest) GetMsg() *MsgSwap

func (*MsgSwapRequest) GetPoolId 

func (m *MsgSwapRequest) GetPoolId() uint64

func (*MsgSwapRequest) Marshal 

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

func (*MsgSwapRequest) MarshalTo 

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

func (*MsgSwapRequest) MarshalToSizedBuffer 

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

func (*MsgSwapRequest) ProtoMessage 

func (*MsgSwapRequest) ProtoMessage()

func (*MsgSwapRequest) Reset 

func (m *MsgSwapRequest) Reset()

func (*MsgSwapRequest) Size 

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

func (*MsgSwapRequest) String 

func (m *MsgSwapRequest) String() string

func (*MsgSwapRequest) Unmarshal 

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

func (*MsgSwapRequest) XXX_DiscardUnknown 

func (m *MsgSwapRequest) XXX_DiscardUnknown()

func (*MsgSwapRequest) XXX_Marshal 

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

func (*MsgSwapRequest) XXX_Merge 

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

func (*MsgSwapRequest) XXX_Size 

func (m *MsgSwapRequest) XXX_Size() int

func (*MsgSwapRequest) XXX_Unmarshal 

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

type MsgSwapResponse 

type MsgSwapResponse struct {
	StdTx *StdTx `protobuf:"bytes,1,opt,name=std_tx,json=stdTx,proto3" json:"std_tx,omitempty" yaml:"std_tx"`
}

MsgSwapResponse defines the Msg/Swap response type.

func (*MsgSwapResponse) Descriptor 

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

func (*MsgSwapResponse) GetStdTx 

func (m *MsgSwapResponse) GetStdTx() *StdTx

func (*MsgSwapResponse) Marshal 

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

func (*MsgSwapResponse) MarshalTo 

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

func (*MsgSwapResponse) MarshalToSizedBuffer 

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

func (*MsgSwapResponse) ProtoMessage 

func (*MsgSwapResponse) ProtoMessage()

func (*MsgSwapResponse) Reset 

func (m *MsgSwapResponse) Reset()

func (*MsgSwapResponse) Size 

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

func (*MsgSwapResponse) String 

func (m *MsgSwapResponse) String() string

func (*MsgSwapResponse) Unmarshal 

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

func (*MsgSwapResponse) XXX_DiscardUnknown 

func (m *MsgSwapResponse) XXX_DiscardUnknown()

func (*MsgSwapResponse) XXX_Marshal 

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

func (*MsgSwapResponse) XXX_Merge 

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

func (*MsgSwapResponse) XXX_Size 

func (m *MsgSwapResponse) XXX_Size() int

func (*MsgSwapResponse) XXX_Unmarshal 

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

type MsgWithdrawFromLiquidityPool 

type MsgWithdrawFromLiquidityPool struct {
	WithdrawerAddress string `` /* 138-byte string literal not displayed */
	// id of the target pool
	PoolId   uint64     `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	PoolCoin types.Coin `protobuf:"bytes,3,opt,name=pool_coin,json=poolCoin,proto3" json:"pool_coin" yaml:"pool_coin"`
}

`MsgWithdrawFromLiquidityPool` defines an `sdk.Msg` type that supports submitting withdraw request to the batch of the liquidity pool Withdraw submit to the batch from the Liquidity pool with the specified `pool_id`, `pool_coin` of the pool this requests are stacked in the batch of the liquidity pool, not immediately processed and processed in the `endblock` at once with other requests.

See: https://github.com/tendermint/liquidity/blob/develop/x/liquidity/spec/04_messages.md

func NewMsgWithdrawFromLiquidityPool 

func NewMsgWithdrawFromLiquidityPool(
	withdrawer sdk.AccAddress,
	poolId uint64,
	poolCoin sdk.Coin,
) *MsgWithdrawFromLiquidityPool

NewMsgWithdraw creates a new MsgWithdraw object.

func (*MsgWithdrawFromLiquidityPool) Descriptor 

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

func (MsgWithdrawFromLiquidityPool) GetSignBytes 

func (msg MsgWithdrawFromLiquidityPool) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgWithdrawFromLiquidityPool) GetSigners 

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

GetSigners implements Msg.

func (MsgWithdrawFromLiquidityPool) GetWithdrawer 

func (msg MsgWithdrawFromLiquidityPool) GetWithdrawer() sdk.AccAddress

func (*MsgWithdrawFromLiquidityPool) Marshal 

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

func (*MsgWithdrawFromLiquidityPool) MarshalTo 

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

func (*MsgWithdrawFromLiquidityPool) MarshalToSizedBuffer 

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

func (*MsgWithdrawFromLiquidityPool) ProtoMessage 

func (*MsgWithdrawFromLiquidityPool) ProtoMessage()

func (*MsgWithdrawFromLiquidityPool) Reset 

func (m *MsgWithdrawFromLiquidityPool) Reset()

func (MsgWithdrawFromLiquidityPool) Route 

func (msg MsgWithdrawFromLiquidityPool) Route() string

Route implements Msg.

func (*MsgWithdrawFromLiquidityPool) Size 

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

func (*MsgWithdrawFromLiquidityPool) String 

func (m *MsgWithdrawFromLiquidityPool) String() string

func (MsgWithdrawFromLiquidityPool) Type 

func (msg MsgWithdrawFromLiquidityPool) Type() string

Type implements Msg.

func (*MsgWithdrawFromLiquidityPool) Unmarshal 

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

func (MsgWithdrawFromLiquidityPool) ValidateBasic 

func (msg MsgWithdrawFromLiquidityPool) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgWithdrawFromLiquidityPool) XXX_DiscardUnknown 

func (m *MsgWithdrawFromLiquidityPool) XXX_DiscardUnknown()

func (*MsgWithdrawFromLiquidityPool) XXX_Marshal 

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

func (*MsgWithdrawFromLiquidityPool) XXX_Merge 

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

func (*MsgWithdrawFromLiquidityPool) XXX_Size 

func (m *MsgWithdrawFromLiquidityPool) XXX_Size() int

func (*MsgWithdrawFromLiquidityPool) XXX_Unmarshal 

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

type MsgWithdrawFromLiquidityPoolRequest 

type MsgWithdrawFromLiquidityPoolRequest struct {
	BaseReq *BaseReq `protobuf:"bytes,1,opt,name=base_req,json=baseReq,proto3" json:"base_req,omitempty"`
	// id of the target pool
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// MsgWithdrawFromLiquidityPool
	Msg *MsgWithdrawFromLiquidityPool `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
}

MsgWithdrawFromLiquidityPoolRequest is the request type for the Query/WithdrawFromLiquidityPool RPC method.

func (*MsgWithdrawFromLiquidityPoolRequest) Descriptor 

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

func (*MsgWithdrawFromLiquidityPoolRequest) GetBaseReq 

func (m *MsgWithdrawFromLiquidityPoolRequest) GetBaseReq() *BaseReq

func (*MsgWithdrawFromLiquidityPoolRequest) GetMsg 

func (m *MsgWithdrawFromLiquidityPoolRequest) GetMsg() *MsgWithdrawFromLiquidityPool

func (*MsgWithdrawFromLiquidityPoolRequest) GetPoolId 

func (m *MsgWithdrawFromLiquidityPoolRequest) GetPoolId() uint64

func (*MsgWithdrawFromLiquidityPoolRequest) Marshal 

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

func (*MsgWithdrawFromLiquidityPoolRequest) MarshalTo 

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

func (*MsgWithdrawFromLiquidityPoolRequest) MarshalToSizedBuffer 

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

func (*MsgWithdrawFromLiquidityPoolRequest) ProtoMessage 

func (*MsgWithdrawFromLiquidityPoolRequest) ProtoMessage()

func (*MsgWithdrawFromLiquidityPoolRequest) Reset 

func (m *MsgWithdrawFromLiquidityPoolRequest) Reset()

func (*MsgWithdrawFromLiquidityPoolRequest) Size 

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

func (*MsgWithdrawFromLiquidityPoolRequest) String 

func (m *MsgWithdrawFromLiquidityPoolRequest) String() string

func (*MsgWithdrawFromLiquidityPoolRequest) Unmarshal 

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

func (*MsgWithdrawFromLiquidityPoolRequest) XXX_DiscardUnknown 

func (m *MsgWithdrawFromLiquidityPoolRequest) XXX_DiscardUnknown()

func (*MsgWithdrawFromLiquidityPoolRequest) XXX_Marshal 

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

func (*MsgWithdrawFromLiquidityPoolRequest) XXX_Merge 

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

func (*MsgWithdrawFromLiquidityPoolRequest) XXX_Size 

func (m *MsgWithdrawFromLiquidityPoolRequest) XXX_Size() int

func (*MsgWithdrawFromLiquidityPoolRequest) XXX_Unmarshal 

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

type MsgWithdrawFromLiquidityPoolResponse 

type MsgWithdrawFromLiquidityPoolResponse struct {
	StdTx *StdTx `protobuf:"bytes,1,opt,name=std_tx,json=stdTx,proto3" json:"std_tx,omitempty" yaml:"std_tx"`
}

MsgWithdrawFromLiquidityPoolResponse defines the Msg/WithdrawFromLiquidityPool response type.

func (*MsgWithdrawFromLiquidityPoolResponse) Descriptor 

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

func (*MsgWithdrawFromLiquidityPoolResponse) GetStdTx 

func (m *MsgWithdrawFromLiquidityPoolResponse) GetStdTx() *StdTx

func (*MsgWithdrawFromLiquidityPoolResponse) Marshal 

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

func (*MsgWithdrawFromLiquidityPoolResponse) MarshalTo 

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

func (*MsgWithdrawFromLiquidityPoolResponse) MarshalToSizedBuffer 

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

func (*MsgWithdrawFromLiquidityPoolResponse) ProtoMessage 

func (*MsgWithdrawFromLiquidityPoolResponse) ProtoMessage()

func (*MsgWithdrawFromLiquidityPoolResponse) Reset 

func (m *MsgWithdrawFromLiquidityPoolResponse) Reset()

func (*MsgWithdrawFromLiquidityPoolResponse) Size 

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

func (*MsgWithdrawFromLiquidityPoolResponse) String 

func (m *MsgWithdrawFromLiquidityPoolResponse) String() string

func (*MsgWithdrawFromLiquidityPoolResponse) Unmarshal 

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

func (*MsgWithdrawFromLiquidityPoolResponse) XXX_DiscardUnknown 

func (m *MsgWithdrawFromLiquidityPoolResponse) XXX_DiscardUnknown()

func (*MsgWithdrawFromLiquidityPoolResponse) XXX_Marshal 

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

func (*MsgWithdrawFromLiquidityPoolResponse) XXX_Merge 

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

func (*MsgWithdrawFromLiquidityPoolResponse) XXX_Size 

func (m *MsgWithdrawFromLiquidityPoolResponse) XXX_Size() int

func (*MsgWithdrawFromLiquidityPoolResponse) XXX_Unmarshal 

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

type OrderBook 

type OrderBook []OrderByPrice

list of orderByPrice

func (OrderBook) Len 

func (orderBook OrderBook) Len() int

Len implements sort.Interface for OrderBook

func (OrderBook) Less 

func (orderBook OrderBook) Less(i, j int) bool

Less implements sort.Interface for OrderBook

func (OrderBook) Reverse 

func (orderBook OrderBook) Reverse()

decreasing sort orderbook by order price

func (OrderBook) Sort 

func (orderBook OrderBook) Sort()

increasing sort orderbook by order price

func (OrderBook) Swap 

func (orderBook OrderBook) Swap(i, j int)

Swap implements sort.Interface for OrderBook

type OrderByPrice 

type OrderByPrice struct {
	OrderPrice   sdk.Dec
	BuyOfferAmt  sdk.Int
	SellOfferAmt sdk.Int
	MsgList      []*BatchPoolSwapMsg
}

Type of order map to index at price, having the pointer list of the swap batch message.

type OrderMap 

type OrderMap map[string]OrderByPrice

Order map type indexed by order price at price

func (OrderMap) SortOrderBook 

func (orderMap OrderMap) SortOrderBook() (orderBook OrderBook)

Make orderbook by sort orderMap.

type Params 

type Params struct {
	// list of available pool types
	LiquidityPoolTypes []LiquidityPoolType `` /* 135-byte string literal not displayed */
	// Minimum number of coins to be deposited to the liquidity pool upon pool creation
	MinInitDepositToPool github_com_cosmos_cosmos_sdk_types.Int `` /* 199-byte string literal not displayed */
	// Initial mint amount of pool coin upon pool creation
	InitPoolCoinMintAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 207-byte string literal not displayed */
	// Limit the size of each liquidity pool in the beginning phase of Liquidity Module adoption to minimize risk, 0 means no limit
	ReserveCoinLimitAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 204-byte string literal not displayed */
	// Fee paid for new LiquidityPool creation to prevent spamming
	LiquidityPoolCreationFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 216-byte string literal not displayed */
	// Swap fee rate for every executed swap
	SwapFeeRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 157-byte string literal not displayed */
	// Reserve coin withdrawal with less proportion by withdrawFeeRate
	WithdrawFeeRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 173-byte string literal not displayed */
	// Maximum ratio of reserve coins that can be ordered at a swap order
	MaxOrderAmountRatio github_com_cosmos_cosmos_sdk_types.Dec `` /* 192-byte string literal not displayed */
	// The smallest unit batch size for every liquidity pool
	UnitBatchSize uint32 `` /* 126-byte string literal not displayed */
}

func DefaultParams 

func DefaultParams() Params

DefaultParams returns the default liquidity module parameters

func NewParams 

func NewParams(liquidityPoolTypes []LiquidityPoolType, minInitDeposit, initPoolCoinMint, reserveCoinLimit sdk.Int, creationFee sdk.Coins,
	swapFeeRate, withdrawFeeRate, maxOrderAmtRatio sdk.Dec, unitBatchSize uint32) Params

NewParams liquidity paramtypes constructor

func (*Params) Descriptor 

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

func (*Params) Equal 

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

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

KeyValuePairs implements paramtypes.KeyValuePairs

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 (p Params) String() string

String returns a human readable string representation of the parameters.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate returns err if Params is invalid

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 PubKey 

type PubKey struct {
	// type of pubkey algorithm
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty" yaml:"type"`
	// value of pubkey
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty" yaml:"value"`
}

PubKey struct of tendermint/cosmos-sdk

func (*PubKey) Descriptor 

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

func (*PubKey) GetType 

func (m *PubKey) GetType() string

func (*PubKey) GetValue 

func (m *PubKey) GetValue() string

func (*PubKey) Marshal 

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

func (*PubKey) MarshalTo 

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

func (*PubKey) MarshalToSizedBuffer 

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

func (*PubKey) ProtoMessage 

func (*PubKey) ProtoMessage()

func (*PubKey) Reset 

func (m *PubKey) Reset()

func (*PubKey) Size 

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

func (*PubKey) String 

func (m *PubKey) String() string

func (*PubKey) Unmarshal 

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

func (*PubKey) XXX_DiscardUnknown 

func (m *PubKey) XXX_DiscardUnknown()

func (*PubKey) XXX_Marshal 

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

func (*PubKey) XXX_Merge 

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

func (*PubKey) XXX_Size 

func (m *PubKey) XXX_Size() int

func (*PubKey) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Get all liquidity pools currently existed with each liquidity pool with batch and metadata
	LiquidityPools(ctx context.Context, in *QueryLiquidityPoolsRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolsResponse, error)
	// Get all liquidity pools batch
	LiquidityPoolsBatch(ctx context.Context, in *QueryLiquidityPoolsBatchRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolsBatchResponse, error)
	// Get a liquidity pool with liquidity pool batch by pool_id
	LiquidityPool(ctx context.Context, in *QueryLiquidityPoolRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolResponse, error)
	// Get a liquidity pool batch by pool_id
	LiquidityPoolBatch(ctx context.Context, in *QueryLiquidityPoolBatchRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolBatchResponse, error)
	// Get all pool batch swap messages of the liquidity pool
	PoolBatchSwapMsgs(ctx context.Context, in *QueryPoolBatchSwapMsgsRequest, opts ...grpc.CallOption) (*QueryPoolBatchSwapMsgsResponse, error)
	// Get the pool batch swap message with msg_index of the liquidity pool
	PoolBatchSwapMsg(ctx context.Context, in *QueryPoolBatchSwapMsgRequest, opts ...grpc.CallOption) (*QueryPoolBatchSwapMsgResponse, error)
	// Get all pool batch deposit messages of the liquidity pool
	PoolBatchDepositMsgs(ctx context.Context, in *QueryPoolBatchDepositMsgsRequest, opts ...grpc.CallOption) (*QueryPoolBatchDepositMsgsResponse, error)
	// Get the pool batch deposit message with msg_index of the liquidity pool
	PoolBatchDepositMsg(ctx context.Context, in *QueryPoolBatchDepositMsgRequest, opts ...grpc.CallOption) (*QueryPoolBatchDepositMsgResponse, error)
	// Get all pool batch withdraw messages of the liquidity pool
	PoolBatchWithdrawMsgs(ctx context.Context, in *QueryPoolBatchWithdrawMsgsRequest, opts ...grpc.CallOption) (*QueryPoolBatchWithdrawMsgsResponse, error)
	// Get the pool batch withdraw message with msg_index of the liquidity pool
	PoolBatchWithdrawMsg(ctx context.Context, in *QueryPoolBatchWithdrawMsgRequest, opts ...grpc.CallOption) (*QueryPoolBatchWithdrawMsgResponse, error)
	// Parameters queries the liquidity parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, 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 QueryLiquidityPoolBatchRequest 

type QueryLiquidityPoolBatchRequest struct {
	// id of the target pool for query
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

the request type for the QueryLiquidityPoolBatch RPC method. requestable including specified pool_id.

func (*QueryLiquidityPoolBatchRequest) Descriptor 

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

func (*QueryLiquidityPoolBatchRequest) GetPoolId 

func (m *QueryLiquidityPoolBatchRequest) GetPoolId() uint64

func (*QueryLiquidityPoolBatchRequest) Marshal 

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

func (*QueryLiquidityPoolBatchRequest) MarshalTo 

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

func (*QueryLiquidityPoolBatchRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolBatchRequest) ProtoMessage 

func (*QueryLiquidityPoolBatchRequest) ProtoMessage()

func (*QueryLiquidityPoolBatchRequest) Reset 

func (m *QueryLiquidityPoolBatchRequest) Reset()

func (*QueryLiquidityPoolBatchRequest) Size 

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

func (*QueryLiquidityPoolBatchRequest) String 

func (m *QueryLiquidityPoolBatchRequest) String() string

func (*QueryLiquidityPoolBatchRequest) Unmarshal 

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

func (*QueryLiquidityPoolBatchRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolBatchRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolBatchRequest) XXX_Marshal 

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

func (*QueryLiquidityPoolBatchRequest) XXX_Merge 

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

func (*QueryLiquidityPoolBatchRequest) XXX_Size 

func (m *QueryLiquidityPoolBatchRequest) XXX_Size() int

func (*QueryLiquidityPoolBatchRequest) XXX_Unmarshal 

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

type QueryLiquidityPoolBatchResponse 

type QueryLiquidityPoolBatchResponse struct {
	Batch LiquidityPoolBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch"`
}

the response type for the QueryLiquidityPoolBatchResponse RPC method. It returns the liquidity pool batch corresponding to the requested pool_id.

func (*QueryLiquidityPoolBatchResponse) Descriptor 

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

func (*QueryLiquidityPoolBatchResponse) GetBatch 

func (m *QueryLiquidityPoolBatchResponse) GetBatch() LiquidityPoolBatch

func (*QueryLiquidityPoolBatchResponse) Marshal 

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

func (*QueryLiquidityPoolBatchResponse) MarshalTo 

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

func (*QueryLiquidityPoolBatchResponse) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolBatchResponse) ProtoMessage 

func (*QueryLiquidityPoolBatchResponse) ProtoMessage()

func (*QueryLiquidityPoolBatchResponse) Reset 

func (m *QueryLiquidityPoolBatchResponse) Reset()

func (*QueryLiquidityPoolBatchResponse) Size 

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

func (*QueryLiquidityPoolBatchResponse) String 

func (m *QueryLiquidityPoolBatchResponse) String() string

func (*QueryLiquidityPoolBatchResponse) Unmarshal 

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

func (*QueryLiquidityPoolBatchResponse) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolBatchResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolBatchResponse) XXX_Marshal 

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

func (*QueryLiquidityPoolBatchResponse) XXX_Merge 

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

func (*QueryLiquidityPoolBatchResponse) XXX_Size 

func (m *QueryLiquidityPoolBatchResponse) XXX_Size() int

func (*QueryLiquidityPoolBatchResponse) XXX_Unmarshal 

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

type QueryLiquidityPoolParams 

type QueryLiquidityPoolParams struct {
	PoolId uint64 `json:"pool_id" yaml:"pool_id"`
}

QueryLiquidityPoolParams is the query parameters for 'custom/liquidity'

func NewQueryLiquidityPoolParams 

func NewQueryLiquidityPoolParams(poolId uint64) QueryLiquidityPoolParams

return params of Liquidity Pool Query

type QueryLiquidityPoolRequest 

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

the request type for the QueryLiquidityPool RPC method. requestable specified pool_id.

func (*QueryLiquidityPoolRequest) Descriptor 

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

func (*QueryLiquidityPoolRequest) GetPoolId 

func (m *QueryLiquidityPoolRequest) GetPoolId() uint64

func (*QueryLiquidityPoolRequest) Marshal 

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

func (*QueryLiquidityPoolRequest) MarshalTo 

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

func (*QueryLiquidityPoolRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolRequest) ProtoMessage 

func (*QueryLiquidityPoolRequest) ProtoMessage()

func (*QueryLiquidityPoolRequest) Reset 

func (m *QueryLiquidityPoolRequest) Reset()

func (*QueryLiquidityPoolRequest) Size 

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

func (*QueryLiquidityPoolRequest) String 

func (m *QueryLiquidityPoolRequest) String() string

func (*QueryLiquidityPoolRequest) Unmarshal 

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

func (*QueryLiquidityPoolRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolRequest) XXX_Marshal 

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

func (*QueryLiquidityPoolRequest) XXX_Merge 

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

func (*QueryLiquidityPoolRequest) XXX_Size 

func (m *QueryLiquidityPoolRequest) XXX_Size() int

func (*QueryLiquidityPoolRequest) XXX_Unmarshal 

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

type QueryLiquidityPoolResponse 

type QueryLiquidityPoolResponse struct {
	LiquidityPool         LiquidityPool         `protobuf:"bytes,1,opt,name=liquidity_pool,json=liquidityPool,proto3" json:"liquidity_pool"`
	LiquidityPoolMetadata LiquidityPoolMetadata `protobuf:"bytes,2,opt,name=liquidity_pool_metadata,json=liquidityPoolMetadata,proto3" json:"liquidity_pool_metadata"`
	LiquidityPoolBatch    LiquidityPoolBatch    `protobuf:"bytes,3,opt,name=liquidity_pool_batch,json=liquidityPoolBatch,proto3" json:"liquidity_pool_batch"`
}

the response type for the QueryLiquidityPoolResponse RPC method. It returns the liquidity pool with batch and metadata containing total pool coin supply and reserved coins corresponding to the requested pool_id.

func (*QueryLiquidityPoolResponse) Descriptor 

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

func (*QueryLiquidityPoolResponse) GetLiquidityPool 

func (m *QueryLiquidityPoolResponse) GetLiquidityPool() LiquidityPool

func (*QueryLiquidityPoolResponse) GetLiquidityPoolBatch 

func (m *QueryLiquidityPoolResponse) GetLiquidityPoolBatch() LiquidityPoolBatch

func (*QueryLiquidityPoolResponse) GetLiquidityPoolMetadata 

func (m *QueryLiquidityPoolResponse) GetLiquidityPoolMetadata() LiquidityPoolMetadata

func (*QueryLiquidityPoolResponse) Marshal 

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

func (*QueryLiquidityPoolResponse) MarshalTo 

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

func (*QueryLiquidityPoolResponse) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolResponse) ProtoMessage 

func (*QueryLiquidityPoolResponse) ProtoMessage()

func (*QueryLiquidityPoolResponse) Reset 

func (m *QueryLiquidityPoolResponse) Reset()

func (*QueryLiquidityPoolResponse) Size 

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

func (*QueryLiquidityPoolResponse) String 

func (m *QueryLiquidityPoolResponse) String() string

func (*QueryLiquidityPoolResponse) Unmarshal 

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

func (*QueryLiquidityPoolResponse) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolResponse) XXX_Marshal 

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

func (*QueryLiquidityPoolResponse) XXX_Merge 

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

func (*QueryLiquidityPoolResponse) XXX_Size 

func (m *QueryLiquidityPoolResponse) XXX_Size() int

func (*QueryLiquidityPoolResponse) XXX_Unmarshal 

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

type QueryLiquidityPoolsBatchRequest 

type QueryLiquidityPoolsBatchRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the request type for the QueryLiquidityPoolsBatch RPC method, requestable including pagination offset, limit, key.

func (*QueryLiquidityPoolsBatchRequest) Descriptor 

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

func (*QueryLiquidityPoolsBatchRequest) GetPagination 

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

func (*QueryLiquidityPoolsBatchRequest) Marshal 

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

func (*QueryLiquidityPoolsBatchRequest) MarshalTo 

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

func (*QueryLiquidityPoolsBatchRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolsBatchRequest) ProtoMessage 

func (*QueryLiquidityPoolsBatchRequest) ProtoMessage()

func (*QueryLiquidityPoolsBatchRequest) Reset 

func (m *QueryLiquidityPoolsBatchRequest) Reset()

func (*QueryLiquidityPoolsBatchRequest) Size 

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

func (*QueryLiquidityPoolsBatchRequest) String 

func (m *QueryLiquidityPoolsBatchRequest) String() string

func (*QueryLiquidityPoolsBatchRequest) Unmarshal 

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

func (*QueryLiquidityPoolsBatchRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolsBatchRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolsBatchRequest) XXX_Marshal 

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

func (*QueryLiquidityPoolsBatchRequest) XXX_Merge 

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

func (*QueryLiquidityPoolsBatchRequest) XXX_Size 

func (m *QueryLiquidityPoolsBatchRequest) XXX_Size() int

func (*QueryLiquidityPoolsBatchRequest) XXX_Unmarshal 

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

type QueryLiquidityPoolsBatchResponse 

type QueryLiquidityPoolsBatchResponse struct {
	PoolsBatch []QueryLiquidityPoolBatchResponse `protobuf:"bytes,1,rep,name=pools_batch,json=poolsBatch,proto3" json:"pools_batch"`
	// pagination defines the pagination in the response. not working on this version.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the response type for the QueryLiquidityPoolsBatchResponse RPC method. This includes list of all batches that all currently existing pools and paging results containing next_key and total count.

func (*QueryLiquidityPoolsBatchResponse) Descriptor 

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

func (*QueryLiquidityPoolsBatchResponse) GetPagination 

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

func (*QueryLiquidityPoolsBatchResponse) GetPoolsBatch 

func (m *QueryLiquidityPoolsBatchResponse) GetPoolsBatch() []QueryLiquidityPoolBatchResponse

func (*QueryLiquidityPoolsBatchResponse) Marshal 

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

func (*QueryLiquidityPoolsBatchResponse) MarshalTo 

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

func (*QueryLiquidityPoolsBatchResponse) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolsBatchResponse) ProtoMessage 

func (*QueryLiquidityPoolsBatchResponse) ProtoMessage()

func (*QueryLiquidityPoolsBatchResponse) Reset 

func (m *QueryLiquidityPoolsBatchResponse) Reset()

func (*QueryLiquidityPoolsBatchResponse) Size 

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

func (*QueryLiquidityPoolsBatchResponse) String 

func (m *QueryLiquidityPoolsBatchResponse) String() string

func (*QueryLiquidityPoolsBatchResponse) Unmarshal 

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

func (*QueryLiquidityPoolsBatchResponse) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolsBatchResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolsBatchResponse) XXX_Marshal 

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

func (*QueryLiquidityPoolsBatchResponse) XXX_Merge 

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

func (*QueryLiquidityPoolsBatchResponse) XXX_Size 

func (m *QueryLiquidityPoolsBatchResponse) XXX_Size() int

func (*QueryLiquidityPoolsBatchResponse) XXX_Unmarshal 

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

type QueryLiquidityPoolsParams 

type QueryLiquidityPoolsParams struct {
	Page, Limit int
}

QueryValidatorsParams defines the params for the following queries: - 'custom/liquidity/liquidityPools'

func NewQueryLiquidityPoolsParams 

func NewQueryLiquidityPoolsParams(page, limit int) QueryLiquidityPoolsParams

return params of Liquidity Pools Query

type QueryLiquidityPoolsRequest 

type QueryLiquidityPoolsRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the request type for the QueryLiquidityPools RPC method. requestable including pagination offset, limit, key.

func (*QueryLiquidityPoolsRequest) Descriptor 

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

func (*QueryLiquidityPoolsRequest) GetPagination 

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

func (*QueryLiquidityPoolsRequest) Marshal 

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

func (*QueryLiquidityPoolsRequest) MarshalTo 

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

func (*QueryLiquidityPoolsRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolsRequest) ProtoMessage 

func (*QueryLiquidityPoolsRequest) ProtoMessage()

func (*QueryLiquidityPoolsRequest) Reset 

func (m *QueryLiquidityPoolsRequest) Reset()

func (*QueryLiquidityPoolsRequest) Size 

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

func (*QueryLiquidityPoolsRequest) String 

func (m *QueryLiquidityPoolsRequest) String() string

func (*QueryLiquidityPoolsRequest) Unmarshal 

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

func (*QueryLiquidityPoolsRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolsRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolsRequest) XXX_Marshal 

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

func (*QueryLiquidityPoolsRequest) XXX_Merge 

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

func (*QueryLiquidityPoolsRequest) XXX_Size 

func (m *QueryLiquidityPoolsRequest) XXX_Size() int

func (*QueryLiquidityPoolsRequest) XXX_Unmarshal 

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

type QueryLiquidityPoolsResponse 

type QueryLiquidityPoolsResponse struct {
	Pools []QueryLiquidityPoolResponse `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools"`
	// pagination defines the pagination in the response. not working on this version.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the response type for the QueryLiquidityPoolsResponse RPC method. This includes list of all liquidity pools currently existed and paging results containing next_key and total count.

func (*QueryLiquidityPoolsResponse) Descriptor 

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

func (*QueryLiquidityPoolsResponse) GetPagination 

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

func (*QueryLiquidityPoolsResponse) GetPools 

func (m *QueryLiquidityPoolsResponse) GetPools() []QueryLiquidityPoolResponse

func (*QueryLiquidityPoolsResponse) Marshal 

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

func (*QueryLiquidityPoolsResponse) MarshalTo 

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

func (*QueryLiquidityPoolsResponse) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolsResponse) ProtoMessage 

func (*QueryLiquidityPoolsResponse) ProtoMessage()

func (*QueryLiquidityPoolsResponse) Reset 

func (m *QueryLiquidityPoolsResponse) Reset()

func (*QueryLiquidityPoolsResponse) Size 

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

func (*QueryLiquidityPoolsResponse) String 

func (m *QueryLiquidityPoolsResponse) String() string

func (*QueryLiquidityPoolsResponse) Unmarshal 

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

func (*QueryLiquidityPoolsResponse) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolsResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolsResponse) XXX_Marshal 

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

func (*QueryLiquidityPoolsResponse) XXX_Merge 

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

func (*QueryLiquidityPoolsResponse) XXX_Size 

func (m *QueryLiquidityPoolsResponse) XXX_Size() int

func (*QueryLiquidityPoolsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the QueryParams 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 holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

the response type for the QueryParamsResponse RPC method. This includes current parameter of the liquidity module.

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 QueryPoolBatchDepositMsgRequest 

type QueryPoolBatchDepositMsgRequest struct {
	// id of the target pool for query
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// target msg_index of the pool
	MsgIndex uint64 `protobuf:"varint,2,opt,name=msg_index,json=msgIndex,proto3" json:"msg_index,omitempty"`
}

the request type for the QueryPoolBatchDeposit RPC method. requestable including specified pool_id and msg_index

func (*QueryPoolBatchDepositMsgRequest) Descriptor 

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

func (*QueryPoolBatchDepositMsgRequest) GetMsgIndex 

func (m *QueryPoolBatchDepositMsgRequest) GetMsgIndex() uint64

func (*QueryPoolBatchDepositMsgRequest) GetPoolId 

func (m *QueryPoolBatchDepositMsgRequest) GetPoolId() uint64

func (*QueryPoolBatchDepositMsgRequest) Marshal 

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

func (*QueryPoolBatchDepositMsgRequest) MarshalTo 

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

func (*QueryPoolBatchDepositMsgRequest) MarshalToSizedBuffer 

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

func (*QueryPoolBatchDepositMsgRequest) ProtoMessage 

func (*QueryPoolBatchDepositMsgRequest) ProtoMessage()

func (*QueryPoolBatchDepositMsgRequest) Reset 

func (m *QueryPoolBatchDepositMsgRequest) Reset()

func (*QueryPoolBatchDepositMsgRequest) Size 

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

func (*QueryPoolBatchDepositMsgRequest) String 

func (m *QueryPoolBatchDepositMsgRequest) String() string

func (*QueryPoolBatchDepositMsgRequest) Unmarshal 

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

func (*QueryPoolBatchDepositMsgRequest) XXX_DiscardUnknown 

func (m *QueryPoolBatchDepositMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchDepositMsgRequest) XXX_Marshal 

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

func (*QueryPoolBatchDepositMsgRequest) XXX_Merge 

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

func (*QueryPoolBatchDepositMsgRequest) XXX_Size 

func (m *QueryPoolBatchDepositMsgRequest) XXX_Size() int

func (*QueryPoolBatchDepositMsgRequest) XXX_Unmarshal 

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

type QueryPoolBatchDepositMsgResponse 

type QueryPoolBatchDepositMsgResponse struct {
	Deposits BatchPoolDepositMsg `protobuf:"bytes,1,opt,name=deposits,proto3" json:"deposits"`
}

the response type for the QueryPoolBatchDepositMsg RPC method. This includes a batch swap message of the batch

func (*QueryPoolBatchDepositMsgResponse) Descriptor 

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

func (*QueryPoolBatchDepositMsgResponse) GetDeposits 

func (m *QueryPoolBatchDepositMsgResponse) GetDeposits() BatchPoolDepositMsg

func (*QueryPoolBatchDepositMsgResponse) Marshal 

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

func (*QueryPoolBatchDepositMsgResponse) MarshalTo 

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

func (*QueryPoolBatchDepositMsgResponse) MarshalToSizedBuffer 

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

func (*QueryPoolBatchDepositMsgResponse) ProtoMessage 

func (*QueryPoolBatchDepositMsgResponse) ProtoMessage()

func (*QueryPoolBatchDepositMsgResponse) Reset 

func (m *QueryPoolBatchDepositMsgResponse) Reset()

func (*QueryPoolBatchDepositMsgResponse) Size 

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

func (*QueryPoolBatchDepositMsgResponse) String 

func (m *QueryPoolBatchDepositMsgResponse) String() string

func (*QueryPoolBatchDepositMsgResponse) Unmarshal 

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

func (*QueryPoolBatchDepositMsgResponse) XXX_DiscardUnknown 

func (m *QueryPoolBatchDepositMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchDepositMsgResponse) XXX_Marshal 

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

func (*QueryPoolBatchDepositMsgResponse) XXX_Merge 

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

func (*QueryPoolBatchDepositMsgResponse) XXX_Size 

func (m *QueryPoolBatchDepositMsgResponse) XXX_Size() int

func (*QueryPoolBatchDepositMsgResponse) XXX_Unmarshal 

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

type QueryPoolBatchDepositMsgsRequest 

type QueryPoolBatchDepositMsgsRequest struct {
	// id of the target pool for query
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the request type for the QueryPoolBatchDeposit RPC method. requestable including specified pool_id and pagination offset, limit, key.

func (*QueryPoolBatchDepositMsgsRequest) Descriptor 

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

func (*QueryPoolBatchDepositMsgsRequest) GetPagination 

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

func (*QueryPoolBatchDepositMsgsRequest) GetPoolId 

func (m *QueryPoolBatchDepositMsgsRequest) GetPoolId() uint64

func (*QueryPoolBatchDepositMsgsRequest) Marshal 

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

func (*QueryPoolBatchDepositMsgsRequest) MarshalTo 

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

func (*QueryPoolBatchDepositMsgsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolBatchDepositMsgsRequest) ProtoMessage 

func (*QueryPoolBatchDepositMsgsRequest) ProtoMessage()

func (*QueryPoolBatchDepositMsgsRequest) Reset 

func (m *QueryPoolBatchDepositMsgsRequest) Reset()

func (*QueryPoolBatchDepositMsgsRequest) Size 

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

func (*QueryPoolBatchDepositMsgsRequest) String 

func (m *QueryPoolBatchDepositMsgsRequest) String() string

func (*QueryPoolBatchDepositMsgsRequest) Unmarshal 

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

func (*QueryPoolBatchDepositMsgsRequest) XXX_DiscardUnknown 

func (m *QueryPoolBatchDepositMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchDepositMsgsRequest) XXX_Marshal 

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

func (*QueryPoolBatchDepositMsgsRequest) XXX_Merge 

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

func (*QueryPoolBatchDepositMsgsRequest) XXX_Size 

func (m *QueryPoolBatchDepositMsgsRequest) XXX_Size() int

func (*QueryPoolBatchDepositMsgsRequest) XXX_Unmarshal 

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

type QueryPoolBatchDepositMsgsResponse 

type QueryPoolBatchDepositMsgsResponse struct {
	Deposits []BatchPoolDepositMsg `protobuf:"bytes,1,rep,name=deposits,proto3" json:"deposits"`
	// pagination defines the pagination in the response. not working on this version.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the response type for the QueryPoolBatchDeposit RPC method. This includes a list of all currently existing deposit messages of the batch and paging results containing next_key and total count.

func (*QueryPoolBatchDepositMsgsResponse) Descriptor 

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

func (*QueryPoolBatchDepositMsgsResponse) GetDeposits 

func (m *QueryPoolBatchDepositMsgsResponse) GetDeposits() []BatchPoolDepositMsg

func (*QueryPoolBatchDepositMsgsResponse) GetPagination 

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

func (*QueryPoolBatchDepositMsgsResponse) Marshal 

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

func (*QueryPoolBatchDepositMsgsResponse) MarshalTo 

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

func (*QueryPoolBatchDepositMsgsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolBatchDepositMsgsResponse) ProtoMessage 

func (*QueryPoolBatchDepositMsgsResponse) ProtoMessage()

func (*QueryPoolBatchDepositMsgsResponse) Reset 

func (m *QueryPoolBatchDepositMsgsResponse) Reset()

func (*QueryPoolBatchDepositMsgsResponse) Size 

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

func (*QueryPoolBatchDepositMsgsResponse) String 

func (m *QueryPoolBatchDepositMsgsResponse) String() string

func (*QueryPoolBatchDepositMsgsResponse) Unmarshal 

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

func (*QueryPoolBatchDepositMsgsResponse) XXX_DiscardUnknown 

func (m *QueryPoolBatchDepositMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchDepositMsgsResponse) XXX_Marshal 

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

func (*QueryPoolBatchDepositMsgsResponse) XXX_Merge 

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

func (*QueryPoolBatchDepositMsgsResponse) XXX_Size 

func (m *QueryPoolBatchDepositMsgsResponse) XXX_Size() int

func (*QueryPoolBatchDepositMsgsResponse) XXX_Unmarshal 

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

type QueryPoolBatchSwapMsgRequest 

type QueryPoolBatchSwapMsgRequest struct {
	// id of the target pool for query
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// target msg_index of the pool
	MsgIndex uint64 `protobuf:"varint,2,opt,name=msg_index,json=msgIndex,proto3" json:"msg_index,omitempty"`
}

the request type for the QueryPoolBatchSwap RPC method. requestable including specified pool_id and msg_index

func (*QueryPoolBatchSwapMsgRequest) Descriptor 

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

func (*QueryPoolBatchSwapMsgRequest) GetMsgIndex 

func (m *QueryPoolBatchSwapMsgRequest) GetMsgIndex() uint64

func (*QueryPoolBatchSwapMsgRequest) GetPoolId 

func (m *QueryPoolBatchSwapMsgRequest) GetPoolId() uint64

func (*QueryPoolBatchSwapMsgRequest) Marshal 

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

func (*QueryPoolBatchSwapMsgRequest) MarshalTo 

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

func (*QueryPoolBatchSwapMsgRequest) MarshalToSizedBuffer 

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

func (*QueryPoolBatchSwapMsgRequest) ProtoMessage 

func (*QueryPoolBatchSwapMsgRequest) ProtoMessage()

func (*QueryPoolBatchSwapMsgRequest) Reset 

func (m *QueryPoolBatchSwapMsgRequest) Reset()

func (*QueryPoolBatchSwapMsgRequest) Size 

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

func (*QueryPoolBatchSwapMsgRequest) String 

func (m *QueryPoolBatchSwapMsgRequest) String() string

func (*QueryPoolBatchSwapMsgRequest) Unmarshal 

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

func (*QueryPoolBatchSwapMsgRequest) XXX_DiscardUnknown 

func (m *QueryPoolBatchSwapMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchSwapMsgRequest) XXX_Marshal 

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

func (*QueryPoolBatchSwapMsgRequest) XXX_Merge 

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

func (*QueryPoolBatchSwapMsgRequest) XXX_Size 

func (m *QueryPoolBatchSwapMsgRequest) XXX_Size() int

func (*QueryPoolBatchSwapMsgRequest) XXX_Unmarshal 

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

type QueryPoolBatchSwapMsgResponse 

type QueryPoolBatchSwapMsgResponse struct {
	Swaps BatchPoolSwapMsg `protobuf:"bytes,1,opt,name=swaps,proto3" json:"swaps"`
}

the response type for the QueryPoolBatchSwapMsg RPC method. This includes a batch swap message of the batch

func (*QueryPoolBatchSwapMsgResponse) Descriptor 

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

func (*QueryPoolBatchSwapMsgResponse) GetSwaps 

func (m *QueryPoolBatchSwapMsgResponse) GetSwaps() BatchPoolSwapMsg

func (*QueryPoolBatchSwapMsgResponse) Marshal 

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

func (*QueryPoolBatchSwapMsgResponse) MarshalTo 

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

func (*QueryPoolBatchSwapMsgResponse) MarshalToSizedBuffer 

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

func (*QueryPoolBatchSwapMsgResponse) ProtoMessage 

func (*QueryPoolBatchSwapMsgResponse) ProtoMessage()

func (*QueryPoolBatchSwapMsgResponse) Reset 

func (m *QueryPoolBatchSwapMsgResponse) Reset()

func (*QueryPoolBatchSwapMsgResponse) Size 

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

func (*QueryPoolBatchSwapMsgResponse) String 

func (m *QueryPoolBatchSwapMsgResponse) String() string

func (*QueryPoolBatchSwapMsgResponse) Unmarshal 

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

func (*QueryPoolBatchSwapMsgResponse) XXX_DiscardUnknown 

func (m *QueryPoolBatchSwapMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchSwapMsgResponse) XXX_Marshal 

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

func (*QueryPoolBatchSwapMsgResponse) XXX_Merge 

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

func (*QueryPoolBatchSwapMsgResponse) XXX_Size 

func (m *QueryPoolBatchSwapMsgResponse) XXX_Size() int

func (*QueryPoolBatchSwapMsgResponse) XXX_Unmarshal 

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

type QueryPoolBatchSwapMsgsRequest 

type QueryPoolBatchSwapMsgsRequest struct {
	// id of the target pool for query
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the request type for the QueryPoolBatchSwapMsgs RPC method. requestable including specified pool_id and pagination offset, limit, key.

func (*QueryPoolBatchSwapMsgsRequest) Descriptor 

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

func (*QueryPoolBatchSwapMsgsRequest) GetPagination 

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

func (*QueryPoolBatchSwapMsgsRequest) GetPoolId 

func (m *QueryPoolBatchSwapMsgsRequest) GetPoolId() uint64

func (*QueryPoolBatchSwapMsgsRequest) Marshal 

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

func (*QueryPoolBatchSwapMsgsRequest) MarshalTo 

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

func (*QueryPoolBatchSwapMsgsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolBatchSwapMsgsRequest) ProtoMessage 

func (*QueryPoolBatchSwapMsgsRequest) ProtoMessage()

func (*QueryPoolBatchSwapMsgsRequest) Reset 

func (m *QueryPoolBatchSwapMsgsRequest) Reset()

func (*QueryPoolBatchSwapMsgsRequest) Size 

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

func (*QueryPoolBatchSwapMsgsRequest) String 

func (m *QueryPoolBatchSwapMsgsRequest) String() string

func (*QueryPoolBatchSwapMsgsRequest) Unmarshal 

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

func (*QueryPoolBatchSwapMsgsRequest) XXX_DiscardUnknown 

func (m *QueryPoolBatchSwapMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchSwapMsgsRequest) XXX_Marshal 

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

func (*QueryPoolBatchSwapMsgsRequest) XXX_Merge 

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

func (*QueryPoolBatchSwapMsgsRequest) XXX_Size 

func (m *QueryPoolBatchSwapMsgsRequest) XXX_Size() int

func (*QueryPoolBatchSwapMsgsRequest) XXX_Unmarshal 

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

type QueryPoolBatchSwapMsgsResponse 

type QueryPoolBatchSwapMsgsResponse struct {
	Swaps []BatchPoolSwapMsg `protobuf:"bytes,1,rep,name=swaps,proto3" json:"swaps"`
	// pagination defines the pagination in the response. not working on this version.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the response type for the QueryPoolBatchSwapMsgs RPC method. This includes list of all currently existing swap messages of the batch and paging results containing next_key and total count.

func (*QueryPoolBatchSwapMsgsResponse) Descriptor 

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

func (*QueryPoolBatchSwapMsgsResponse) GetPagination 

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

func (*QueryPoolBatchSwapMsgsResponse) GetSwaps 

func (m *QueryPoolBatchSwapMsgsResponse) GetSwaps() []BatchPoolSwapMsg

func (*QueryPoolBatchSwapMsgsResponse) Marshal 

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

func (*QueryPoolBatchSwapMsgsResponse) MarshalTo 

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

func (*QueryPoolBatchSwapMsgsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolBatchSwapMsgsResponse) ProtoMessage 

func (*QueryPoolBatchSwapMsgsResponse) ProtoMessage()

func (*QueryPoolBatchSwapMsgsResponse) Reset 

func (m *QueryPoolBatchSwapMsgsResponse) Reset()

func (*QueryPoolBatchSwapMsgsResponse) Size 

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

func (*QueryPoolBatchSwapMsgsResponse) String 

func (m *QueryPoolBatchSwapMsgsResponse) String() string

func (*QueryPoolBatchSwapMsgsResponse) Unmarshal 

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

func (*QueryPoolBatchSwapMsgsResponse) XXX_DiscardUnknown 

func (m *QueryPoolBatchSwapMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchSwapMsgsResponse) XXX_Marshal 

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

func (*QueryPoolBatchSwapMsgsResponse) XXX_Merge 

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

func (*QueryPoolBatchSwapMsgsResponse) XXX_Size 

func (m *QueryPoolBatchSwapMsgsResponse) XXX_Size() int

func (*QueryPoolBatchSwapMsgsResponse) XXX_Unmarshal 

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

type QueryPoolBatchWithdrawMsgRequest 

type QueryPoolBatchWithdrawMsgRequest struct {
	// id of the target pool for query
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// target msg_index of the pool
	MsgIndex uint64 `protobuf:"varint,2,opt,name=msg_index,json=msgIndex,proto3" json:"msg_index,omitempty"`
}

the request type for the QueryPoolBatchWithdraw RPC method. requestable including specified pool_id and msg_index

func (*QueryPoolBatchWithdrawMsgRequest) Descriptor 

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

func (*QueryPoolBatchWithdrawMsgRequest) GetMsgIndex 

func (m *QueryPoolBatchWithdrawMsgRequest) GetMsgIndex() uint64

func (*QueryPoolBatchWithdrawMsgRequest) GetPoolId 

func (m *QueryPoolBatchWithdrawMsgRequest) GetPoolId() uint64

func (*QueryPoolBatchWithdrawMsgRequest) Marshal 

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

func (*QueryPoolBatchWithdrawMsgRequest) MarshalTo 

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

func (*QueryPoolBatchWithdrawMsgRequest) MarshalToSizedBuffer 

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

func (*QueryPoolBatchWithdrawMsgRequest) ProtoMessage 

func (*QueryPoolBatchWithdrawMsgRequest) ProtoMessage()

func (*QueryPoolBatchWithdrawMsgRequest) Reset 

func (m *QueryPoolBatchWithdrawMsgRequest) Reset()

func (*QueryPoolBatchWithdrawMsgRequest) Size 

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

func (*QueryPoolBatchWithdrawMsgRequest) String 

func (m *QueryPoolBatchWithdrawMsgRequest) String() string

func (*QueryPoolBatchWithdrawMsgRequest) Unmarshal 

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

func (*QueryPoolBatchWithdrawMsgRequest) XXX_DiscardUnknown 

func (m *QueryPoolBatchWithdrawMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchWithdrawMsgRequest) XXX_Marshal 

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

func (*QueryPoolBatchWithdrawMsgRequest) XXX_Merge 

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

func (*QueryPoolBatchWithdrawMsgRequest) XXX_Size 

func (m *QueryPoolBatchWithdrawMsgRequest) XXX_Size() int

func (*QueryPoolBatchWithdrawMsgRequest) XXX_Unmarshal 

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

type QueryPoolBatchWithdrawMsgResponse 

type QueryPoolBatchWithdrawMsgResponse struct {
	Withdraws BatchPoolWithdrawMsg `protobuf:"bytes,1,opt,name=withdraws,proto3" json:"withdraws"`
}

the response type for the QueryPoolBatchWithdrawMsg RPC method. This includes a batch swap message of the batch

func (*QueryPoolBatchWithdrawMsgResponse) Descriptor 

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

func (*QueryPoolBatchWithdrawMsgResponse) GetWithdraws 

func (m *QueryPoolBatchWithdrawMsgResponse) GetWithdraws() BatchPoolWithdrawMsg

func (*QueryPoolBatchWithdrawMsgResponse) Marshal 

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

func (*QueryPoolBatchWithdrawMsgResponse) MarshalTo 

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

func (*QueryPoolBatchWithdrawMsgResponse) MarshalToSizedBuffer 

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

func (*QueryPoolBatchWithdrawMsgResponse) ProtoMessage 

func (*QueryPoolBatchWithdrawMsgResponse) ProtoMessage()

func (*QueryPoolBatchWithdrawMsgResponse) Reset 

func (m *QueryPoolBatchWithdrawMsgResponse) Reset()

func (*QueryPoolBatchWithdrawMsgResponse) Size 

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

func (*QueryPoolBatchWithdrawMsgResponse) String 

func (m *QueryPoolBatchWithdrawMsgResponse) String() string

func (*QueryPoolBatchWithdrawMsgResponse) Unmarshal 

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

func (*QueryPoolBatchWithdrawMsgResponse) XXX_DiscardUnknown 

func (m *QueryPoolBatchWithdrawMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchWithdrawMsgResponse) XXX_Marshal 

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

func (*QueryPoolBatchWithdrawMsgResponse) XXX_Merge 

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

func (*QueryPoolBatchWithdrawMsgResponse) XXX_Size 

func (m *QueryPoolBatchWithdrawMsgResponse) XXX_Size() int

func (*QueryPoolBatchWithdrawMsgResponse) XXX_Unmarshal 

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

type QueryPoolBatchWithdrawMsgsRequest 

type QueryPoolBatchWithdrawMsgsRequest struct {
	// id of the target pool for query
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the request type for the QueryPoolBatchWithdraw RPC method. requestable including specified pool_id and pagination offset, limit, key.

func (*QueryPoolBatchWithdrawMsgsRequest) Descriptor 

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

func (*QueryPoolBatchWithdrawMsgsRequest) GetPagination 

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

func (*QueryPoolBatchWithdrawMsgsRequest) GetPoolId 

func (m *QueryPoolBatchWithdrawMsgsRequest) GetPoolId() uint64

func (*QueryPoolBatchWithdrawMsgsRequest) Marshal 

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

func (*QueryPoolBatchWithdrawMsgsRequest) MarshalTo 

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

func (*QueryPoolBatchWithdrawMsgsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolBatchWithdrawMsgsRequest) ProtoMessage 

func (*QueryPoolBatchWithdrawMsgsRequest) ProtoMessage()

func (*QueryPoolBatchWithdrawMsgsRequest) Reset 

func (m *QueryPoolBatchWithdrawMsgsRequest) Reset()

func (*QueryPoolBatchWithdrawMsgsRequest) Size 

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

func (*QueryPoolBatchWithdrawMsgsRequest) String 

func (m *QueryPoolBatchWithdrawMsgsRequest) String() string

func (*QueryPoolBatchWithdrawMsgsRequest) Unmarshal 

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

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_DiscardUnknown 

func (m *QueryPoolBatchWithdrawMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_Marshal 

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

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_Merge 

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

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_Size 

func (m *QueryPoolBatchWithdrawMsgsRequest) XXX_Size() int

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_Unmarshal 

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

type QueryPoolBatchWithdrawMsgsResponse 

type QueryPoolBatchWithdrawMsgsResponse struct {
	Withdraws []BatchPoolWithdrawMsg `protobuf:"bytes,1,rep,name=withdraws,proto3" json:"withdraws"`
	// pagination defines the pagination in the response. not working on this version.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

the response type for the QueryPoolBatchWithdraw RPC method. This includes a list of all currently existing withdraw messages of the batch and paging results containing next_key and total count.

func (*QueryPoolBatchWithdrawMsgsResponse) Descriptor 

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

func (*QueryPoolBatchWithdrawMsgsResponse) GetPagination 

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

func (*QueryPoolBatchWithdrawMsgsResponse) GetWithdraws 

func (m *QueryPoolBatchWithdrawMsgsResponse) GetWithdraws() []BatchPoolWithdrawMsg

func (*QueryPoolBatchWithdrawMsgsResponse) Marshal 

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

func (*QueryPoolBatchWithdrawMsgsResponse) MarshalTo 

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

func (*QueryPoolBatchWithdrawMsgsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolBatchWithdrawMsgsResponse) ProtoMessage 

func (*QueryPoolBatchWithdrawMsgsResponse) ProtoMessage()

func (*QueryPoolBatchWithdrawMsgsResponse) Reset 

func (m *QueryPoolBatchWithdrawMsgsResponse) Reset()

func (*QueryPoolBatchWithdrawMsgsResponse) Size 

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

func (*QueryPoolBatchWithdrawMsgsResponse) String 

func (m *QueryPoolBatchWithdrawMsgsResponse) String() string

func (*QueryPoolBatchWithdrawMsgsResponse) Unmarshal 

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

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_DiscardUnknown 

func (m *QueryPoolBatchWithdrawMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_Marshal 

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

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_Merge 

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

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_Size 

func (m *QueryPoolBatchWithdrawMsgsResponse) XXX_Size() int

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Get all liquidity pools currently existed with each liquidity pool with batch and metadata
	LiquidityPools(context.Context, *QueryLiquidityPoolsRequest) (*QueryLiquidityPoolsResponse, error)
	// Get all liquidity pools batch
	LiquidityPoolsBatch(context.Context, *QueryLiquidityPoolsBatchRequest) (*QueryLiquidityPoolsBatchResponse, error)
	// Get a liquidity pool with liquidity pool batch by pool_id
	LiquidityPool(context.Context, *QueryLiquidityPoolRequest) (*QueryLiquidityPoolResponse, error)
	// Get a liquidity pool batch by pool_id
	LiquidityPoolBatch(context.Context, *QueryLiquidityPoolBatchRequest) (*QueryLiquidityPoolBatchResponse, error)
	// Get all pool batch swap messages of the liquidity pool
	PoolBatchSwapMsgs(context.Context, *QueryPoolBatchSwapMsgsRequest) (*QueryPoolBatchSwapMsgsResponse, error)
	// Get the pool batch swap message with msg_index of the liquidity pool
	PoolBatchSwapMsg(context.Context, *QueryPoolBatchSwapMsgRequest) (*QueryPoolBatchSwapMsgResponse, error)
	// Get all pool batch deposit messages of the liquidity pool
	PoolBatchDepositMsgs(context.Context, *QueryPoolBatchDepositMsgsRequest) (*QueryPoolBatchDepositMsgsResponse, error)
	// Get the pool batch deposit message with msg_index of the liquidity pool
	PoolBatchDepositMsg(context.Context, *QueryPoolBatchDepositMsgRequest) (*QueryPoolBatchDepositMsgResponse, error)
	// Get all pool batch withdraw messages of the liquidity pool
	PoolBatchWithdrawMsgs(context.Context, *QueryPoolBatchWithdrawMsgsRequest) (*QueryPoolBatchWithdrawMsgsResponse, error)
	// Get the pool batch withdraw message with msg_index of the liquidity pool
	PoolBatchWithdrawMsg(context.Context, *QueryPoolBatchWithdrawMsgRequest) (*QueryPoolBatchWithdrawMsgResponse, error)
	// Parameters queries the liquidity parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type Signature 

type Signature struct {
	// signature base64
	Signature string `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty" yaml:"signature"`
	// PubKey
	PubKey *PubKey `protobuf:"bytes,2,opt,name=pub_key,json=pubKey,proto3" json:"pub_key,omitempty" yaml:"pub_key"`
	// The account number of the signing account (offline mode only)
	AccountNumber uint64 `protobuf:"varint,3,opt,name=account_number,json=accountNumber,proto3" json:"account_number,omitempty" yaml:"account_number"`
	// The sequence number of the signing account (offline mode only)
	Sequence uint64 `protobuf:"varint,4,opt,name=sequence,proto3" json:"sequence,omitempty" yaml:"sequence"`
}

signature struct of tendermint/cosmos-sdk

func (*Signature) Descriptor 

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

func (*Signature) GetAccountNumber 

func (m *Signature) GetAccountNumber() uint64

func (*Signature) GetPubKey 

func (m *Signature) GetPubKey() *PubKey

func (*Signature) GetSequence 

func (m *Signature) GetSequence() uint64

func (*Signature) GetSignature 

func (m *Signature) GetSignature() string

func (*Signature) Marshal 

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

func (*Signature) MarshalTo 

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

func (*Signature) MarshalToSizedBuffer 

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

func (*Signature) ProtoMessage 

func (*Signature) ProtoMessage()

func (*Signature) Reset 

func (m *Signature) Reset()

func (*Signature) Size 

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

func (*Signature) String 

func (m *Signature) String() string

func (*Signature) Unmarshal 

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

func (*Signature) XXX_DiscardUnknown 

func (m *Signature) XXX_DiscardUnknown()

func (*Signature) XXX_Marshal 

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

func (*Signature) XXX_Merge 

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

func (*Signature) XXX_Size 

func (m *Signature) XXX_Size() int

func (*Signature) XXX_Unmarshal 

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

type StdTx 

type StdTx struct {
	// Msgs
	Msg []string `protobuf:"bytes,1,rep,name=msg,proto3" json:"msg,omitempty" yaml:"msg"`
	// Fee
	Fee *Fee `protobuf:"bytes,2,opt,name=fee,proto3" json:"fee,omitempty" yaml:"fee"`
	// Memo of the transaction
	Memo string `protobuf:"bytes,3,opt,name=memo,proto3" json:"memo,omitempty" yaml:"memo"`
	// Signature
	Signature *Signature `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty" yaml:"signature"`
}

Base response struct of result of the requested Tx, standard of tendermint/cosmos-sdk

func (*StdTx) Descriptor 

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

func (*StdTx) GetFee 

func (m *StdTx) GetFee() *Fee

func (*StdTx) GetMemo 

func (m *StdTx) GetMemo() string

func (*StdTx) GetMsg 

func (m *StdTx) GetMsg() []string

func (*StdTx) GetSignature 

func (m *StdTx) GetSignature() *Signature

func (*StdTx) Marshal 

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

func (*StdTx) MarshalTo 

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

func (*StdTx) MarshalToSizedBuffer 

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

func (*StdTx) ProtoMessage 

func (*StdTx) ProtoMessage()

func (*StdTx) Reset 

func (m *StdTx) Reset()

func (*StdTx) Size 

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

func (*StdTx) String 

func (m *StdTx) String() string

func (*StdTx) Unmarshal 

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

func (*StdTx) XXX_DiscardUnknown 

func (m *StdTx) XXX_DiscardUnknown()

func (*StdTx) XXX_Marshal 

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

func (*StdTx) XXX_Merge 

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

func (*StdTx) XXX_Size 

func (m *StdTx) XXX_Size() int

func (*StdTx) XXX_Unmarshal 

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

type UnimplementedMsgApiServer 

type UnimplementedMsgApiServer struct {
}

UnimplementedMsgApiServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgApiServer) CreateLiquidityPoolApi 

func (*UnimplementedMsgApiServer) CreateLiquidityPoolApi(ctx context.Context, req *MsgCreateLiquidityPoolRequest) (*MsgCreateLiquidityPoolResponse, error)

func (*UnimplementedMsgApiServer) DepositToLiquidityPoolApi 

func (*UnimplementedMsgApiServer) DepositToLiquidityPoolApi(ctx context.Context, req *MsgDepositToLiquidityPoolRequest) (*MsgDepositToLiquidityPoolResponse, error)

func (*UnimplementedMsgApiServer) SwapApi 

func (*UnimplementedMsgApiServer) SwapApi(ctx context.Context, req *MsgSwapRequest) (*MsgSwapResponse, error)

func (*UnimplementedMsgApiServer) WithdrawFromLiquidityPoolApi 

func (*UnimplementedMsgApiServer) WithdrawFromLiquidityPoolApi(ctx context.Context, req *MsgWithdrawFromLiquidityPoolRequest) (*MsgWithdrawFromLiquidityPoolResponse, error)

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreateLiquidityPool 

func (*UnimplementedMsgServer) CreateLiquidityPool(ctx context.Context, req *MsgCreateLiquidityPool) (*MsgCreateLiquidityPoolResponse, error)

func (*UnimplementedMsgServer) DepositToLiquidityPool 

func (*UnimplementedMsgServer) DepositToLiquidityPool(ctx context.Context, req *MsgDepositToLiquidityPool) (*MsgDepositToLiquidityPoolResponse, error)

func (*UnimplementedMsgServer) Swap 

func (*UnimplementedMsgServer) Swap(ctx context.Context, req *MsgSwap) (*MsgSwapResponse, error)

func (*UnimplementedMsgServer) WithdrawFromLiquidityPool 

func (*UnimplementedMsgServer) WithdrawFromLiquidityPool(ctx context.Context, req *MsgWithdrawFromLiquidityPool) (*MsgWithdrawFromLiquidityPoolResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) LiquidityPool 

func (*UnimplementedQueryServer) LiquidityPool(ctx context.Context, req *QueryLiquidityPoolRequest) (*QueryLiquidityPoolResponse, error)

func (*UnimplementedQueryServer) LiquidityPoolBatch 

func (*UnimplementedQueryServer) LiquidityPoolBatch(ctx context.Context, req *QueryLiquidityPoolBatchRequest) (*QueryLiquidityPoolBatchResponse, error)

func (*UnimplementedQueryServer) LiquidityPools 

func (*UnimplementedQueryServer) LiquidityPools(ctx context.Context, req *QueryLiquidityPoolsRequest) (*QueryLiquidityPoolsResponse, error)

func (*UnimplementedQueryServer) LiquidityPoolsBatch 

func (*UnimplementedQueryServer) LiquidityPoolsBatch(ctx context.Context, req *QueryLiquidityPoolsBatchRequest) (*QueryLiquidityPoolsBatchResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) PoolBatchDepositMsg 

func (*UnimplementedQueryServer) PoolBatchDepositMsg(ctx context.Context, req *QueryPoolBatchDepositMsgRequest) (*QueryPoolBatchDepositMsgResponse, error)

func (*UnimplementedQueryServer) PoolBatchDepositMsgs 

func (*UnimplementedQueryServer) PoolBatchDepositMsgs(ctx context.Context, req *QueryPoolBatchDepositMsgsRequest) (*QueryPoolBatchDepositMsgsResponse, error)

func (*UnimplementedQueryServer) PoolBatchSwapMsg 

func (*UnimplementedQueryServer) PoolBatchSwapMsg(ctx context.Context, req *QueryPoolBatchSwapMsgRequest) (*QueryPoolBatchSwapMsgResponse, error)

func (*UnimplementedQueryServer) PoolBatchSwapMsgs 

func (*UnimplementedQueryServer) PoolBatchSwapMsgs(ctx context.Context, req *QueryPoolBatchSwapMsgsRequest) (*QueryPoolBatchSwapMsgsResponse, error)

func (*UnimplementedQueryServer) PoolBatchWithdrawMsg 

func (*UnimplementedQueryServer) PoolBatchWithdrawMsg(ctx context.Context, req *QueryPoolBatchWithdrawMsgRequest) (*QueryPoolBatchWithdrawMsgResponse, error)

func (*UnimplementedQueryServer) PoolBatchWithdrawMsgs 

func (*UnimplementedQueryServer) PoolBatchWithdrawMsgs(ctx context.Context, req *QueryPoolBatchWithdrawMsgsRequest) (*QueryPoolBatchWithdrawMsgsResponse, 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.