coinswap

package
v0.1.12-test Latest Latest
Warning

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

 Go to latest Published: May 19, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ModuleName = "coinswap"
)

Variables

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 (
	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 (
	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 = codec.NewAminoCodec(amino)
)

Functions

func GetLiquidityDenomFrom 

func GetLiquidityDenomFrom(denom string) (string, error)

func GetTokenDenomFrom 

func GetTokenDenomFrom(liquidityDenom string) (string, error)

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AddLiquidityRequest 

type AddLiquidityRequest struct {
	BaseToken sdk.Coin
	Token     sdk.Coin
}

type Client 

type Client interface {
	sdk.Module
	AddLiquidity(request AddLiquidityRequest,
		baseTx sdk.BaseTx) (sdk.ResultTx, error)
	DepositWithinBatch(request DepositWithinBatchRequest,
		baseTx sdk.BaseTx) (sdk.ResultTx, error)
	WithdrawWithin(request WithdrawWithinRequest,
		baseTx sdk.BaseTx) (sdk.ResultTx, error)
	//RemoveLiquidity(request RemoveLiquidityRequest,
	//	baseTx sdk.BaseTx) (*RemoveLiquidityResponse, error)
	SwapCoin(request SwapCoinRequest,
		baseTx sdk.BaseTx) (sdk.ResultTx, error)

	WithdrawWithinBatch(request WithdrawWithinBatchRequest) (interface{}, error)

	PoolBatchDeposit(request PoolBatchDepositMsg) (interface{}, error)
	QueryPool(poolId uint64) (*QueryPoolResponse, error)
	QueryAllPools(pageReq sdk.PageRequest) (interface{}, error)
	QueryDepositFinish(poolId, msgIndex uint64) (interface{}, error)
	QueryDepositsFinish(poolId uint64) (interface{}, error)
	QuerySwapFinish(poolId, msgIndex uint64) (interface{}, error)
	QuerySwapsFinish(poolId uint64) (interface{}, error)
	QueryWithdrawFinish(poolId, msgIndex uint64) (interface{}, error)
	QueryWithdrawsFinish(poolId uint64) (interface{}, error)
}

expose Record module api for user

func NewClient 

func NewClient(bc sdk.BaseClient, cdc codec.Marshaler, queryTotalSupply totalSupply) Client

type DepositMsgState 

type DepositMsgState 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
	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"`
	// MsgDepositWithinBatch
	Msg *MsgDepositWithinBatch `protobuf:"bytes,6,opt,name=msg,proto3" json:"msg,omitempty" yaml:"msg"`
}

DepositMsgState defines the state of deposit message that contains state information as it is processed in the next batch or batches.

func (*DepositMsgState) Descriptor 

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

func (*DepositMsgState) Marshal 

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

func (*DepositMsgState) MarshalTo 

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

func (*DepositMsgState) MarshalToSizedBuffer 

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

func (*DepositMsgState) ProtoMessage 

func (*DepositMsgState) ProtoMessage()

func (*DepositMsgState) Reset 

func (m *DepositMsgState) Reset()

func (*DepositMsgState) Size 

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

func (*DepositMsgState) String 

func (m *DepositMsgState) String() string

func (*DepositMsgState) Unmarshal 

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

func (*DepositMsgState) XXX_DiscardUnknown 

func (m *DepositMsgState) XXX_DiscardUnknown()

func (*DepositMsgState) XXX_Marshal 

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

func (*DepositMsgState) XXX_Merge 

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

func (*DepositMsgState) XXX_Size 

func (m *DepositMsgState) XXX_Size() int

func (*DepositMsgState) XXX_Unmarshal 

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

type DepositSuccessMsg 

type DepositSuccessMsg struct {
	// height where this message is appended to the success deposit
	MsgHeight        int64  `protobuf:"varint,1,opt,name=msg_height,json=msgHeight,proto3" json:"msg_height,omitempty" yaml:"msg_height"`
	DepositorAddress string `` /* 134-byte string literal not displayed */
	// id of the target pool
	PoolId uint64 `protobuf:"varint,3,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// index of this deposit message in this liquidity pool
	MsgIndex uint64 `protobuf:"varint,4,opt,name=msg_index,json=msgIndex,proto3" json:"msg_index,omitempty" yaml:"msg_index"`
	// Successfully deposit quantity
	DepositCoins github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Coins `` /* 183-byte string literal not displayed */
	// Deposit quantity
	InputCoins github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Coins `` /* 175-byte string literal not displayed */
	// Return deposit
	OutputCoins github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Coins `` /* 179-byte string literal not displayed */
}

func (*DepositSuccessMsg) Descriptor 

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

func (*DepositSuccessMsg) Marshal 

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

func (*DepositSuccessMsg) MarshalTo 

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

func (*DepositSuccessMsg) MarshalToSizedBuffer 

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

func (*DepositSuccessMsg) ProtoMessage 

func (*DepositSuccessMsg) ProtoMessage()

func (*DepositSuccessMsg) Reset 

func (m *DepositSuccessMsg) Reset()

func (*DepositSuccessMsg) Size 

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

func (*DepositSuccessMsg) String 

func (m *DepositSuccessMsg) String() string

func (*DepositSuccessMsg) Unmarshal 

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

func (*DepositSuccessMsg) XXX_DiscardUnknown 

func (m *DepositSuccessMsg) XXX_DiscardUnknown()

func (*DepositSuccessMsg) XXX_Marshal 

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

func (*DepositSuccessMsg) XXX_Merge 

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

func (*DepositSuccessMsg) XXX_Size 

func (m *DepositSuccessMsg) XXX_Size() int

func (*DepositSuccessMsg) XXX_Unmarshal 

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

type DepositWithinBatchRequest 

type DepositWithinBatchRequest struct {
	PoolId    uint64
	BaseToken sdk.Coin
	Token     sdk.Coin
}

type GenesisState 

type GenesisState struct {
	// params defines all the parameters for the liquidity module.
	Params      Params       `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	PoolRecords []PoolRecord `protobuf:"bytes,2,rep,name=pool_records,json=poolRecords,proto3" json:"pool_records" yaml:"pools"`
}

GenesisState defines the liquidity module's genesis state.

func (*GenesisState) Descriptor 

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

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) 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 MsgClient 

type MsgClient interface {
	// Submit a create liquidity pool message.
	CreatePool(ctx context.Context, in *MsgCreatePool, opts ...grpc.CallOption) (*MsgCreatePoolResponse, error)
	// Submit a deposit to the liquidity pool batch.
	DepositWithinBatch(ctx context.Context, in *MsgDepositWithinBatch, opts ...grpc.CallOption) (*MsgDepositWithinBatchResponse, error)
	// Submit a withdraw from the liquidity pool batch.
	WithdrawWithinBatch(ctx context.Context, in *MsgWithdrawWithinBatch, opts ...grpc.CallOption) (*MsgWithdrawWithinBatchResponse, error)
	// Submit a swap to the liquidity pool batch.
	Swap(ctx context.Context, in *MsgSwapWithinBatch, opts ...grpc.CallOption) (*MsgSwapWithinBatchResponse, 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 MsgCreatePool 

type MsgCreatePool struct {
	PoolCreatorAddress string `` /* 145-byte string literal not displayed */
	// id of the target pool type, must match the value in the pool. Only pool-type-id 1 is supported.
	PoolTypeId uint32 `protobuf:"varint,2,opt,name=pool_type_id,json=poolTypeId,proto3" json:"pool_type_id,omitempty" yaml:"pool_type_id"`
	// reserve coin pair of the pool to deposit.
	DepositCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 162-byte string literal not displayed */
}

MsgCreatePool defines an sdk.Msg type that supports submitting a create liquidity pool tx.

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

func (*MsgCreatePool) Descriptor 

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

func (MsgCreatePool) GetSignBytes 

func (msg MsgCreatePool) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgCreatePool) GetSigners 

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

GetSigners implements Msg.

func (*MsgCreatePool) Marshal 

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

func (*MsgCreatePool) MarshalTo 

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

func (*MsgCreatePool) MarshalToSizedBuffer 

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

func (*MsgCreatePool) ProtoMessage 

func (*MsgCreatePool) ProtoMessage()

func (*MsgCreatePool) Reset 

func (m *MsgCreatePool) Reset()

func (MsgCreatePool) Route 

func (msg MsgCreatePool) Route() string

Route implements Msg.

func (*MsgCreatePool) Size 

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

func (*MsgCreatePool) String 

func (m *MsgCreatePool) String() string

func (MsgCreatePool) Type 

func (msg MsgCreatePool) Type() string

Type implements Msg.

func (*MsgCreatePool) Unmarshal 

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

func (MsgCreatePool) ValidateBasic 

func (msg MsgCreatePool) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgCreatePool) XXX_DiscardUnknown 

func (m *MsgCreatePool) XXX_DiscardUnknown()

func (*MsgCreatePool) XXX_Marshal 

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

func (*MsgCreatePool) XXX_Merge 

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

func (*MsgCreatePool) XXX_Size 

func (m *MsgCreatePool) XXX_Size() int

func (*MsgCreatePool) XXX_Unmarshal 

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

type MsgCreatePoolResponse 

type MsgCreatePoolResponse struct {
}

MsgCreatePoolResponse defines the Msg/CreatePool response type.

func (*MsgCreatePoolResponse) Descriptor 

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

func (*MsgCreatePoolResponse) Marshal 

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

func (*MsgCreatePoolResponse) MarshalTo 

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

func (*MsgCreatePoolResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePoolResponse) ProtoMessage 

func (*MsgCreatePoolResponse) ProtoMessage()

func (*MsgCreatePoolResponse) Reset 

func (m *MsgCreatePoolResponse) Reset()

func (*MsgCreatePoolResponse) Size 

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

func (*MsgCreatePoolResponse) String 

func (m *MsgCreatePoolResponse) String() string

func (*MsgCreatePoolResponse) Unmarshal 

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

func (*MsgCreatePoolResponse) XXX_DiscardUnknown 

func (m *MsgCreatePoolResponse) XXX_DiscardUnknown()

func (*MsgCreatePoolResponse) XXX_Marshal 

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

func (*MsgCreatePoolResponse) XXX_Merge 

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

func (*MsgCreatePoolResponse) XXX_Size 

func (m *MsgCreatePoolResponse) XXX_Size() int

func (*MsgCreatePoolResponse) XXX_Unmarshal 

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

type MsgDepositWithinBatch 

type MsgDepositWithinBatch struct {
	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 */
}

`MsgDepositWithinBatch defines` an `sdk.Msg` type that supports submitting a deposit request to the batch of the liquidity pool. Deposit is submitted to the batch of the Liquidity pool with the specified `pool_id`, `deposit_coins` for reserve. This request is stacked in the batch of the liquidity pool, is not processed immediately, and is processed in the `endblock` at the same time as other requests.

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

func (*MsgDepositWithinBatch) Descriptor 

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

func (MsgDepositWithinBatch) GetSignBytes 

func (msg MsgDepositWithinBatch) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgDepositWithinBatch) GetSigners 

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

GetSigners implements Msg.

func (*MsgDepositWithinBatch) Marshal 

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

func (*MsgDepositWithinBatch) MarshalTo 

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

func (*MsgDepositWithinBatch) MarshalToSizedBuffer 

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

func (*MsgDepositWithinBatch) ProtoMessage 

func (*MsgDepositWithinBatch) ProtoMessage()

func (*MsgDepositWithinBatch) Reset 

func (m *MsgDepositWithinBatch) Reset()

func (MsgDepositWithinBatch) Route 

func (msg MsgDepositWithinBatch) Route() string

Route implements Msg.

func (*MsgDepositWithinBatch) Size 

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

func (*MsgDepositWithinBatch) String 

func (m *MsgDepositWithinBatch) String() string

func (MsgDepositWithinBatch) Type 

func (msg MsgDepositWithinBatch) Type() string

Type implements Msg.

func (*MsgDepositWithinBatch) Unmarshal 

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

func (MsgDepositWithinBatch) ValidateBasic 

func (msg MsgDepositWithinBatch) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgDepositWithinBatch) XXX_DiscardUnknown 

func (m *MsgDepositWithinBatch) XXX_DiscardUnknown()

func (*MsgDepositWithinBatch) XXX_Marshal 

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

func (*MsgDepositWithinBatch) XXX_Merge 

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

func (*MsgDepositWithinBatch) XXX_Size 

func (m *MsgDepositWithinBatch) XXX_Size() int

func (*MsgDepositWithinBatch) XXX_Unmarshal 

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

type MsgDepositWithinBatchResponse 

type MsgDepositWithinBatchResponse struct {
}

MsgDepositWithinBatchResponse defines the Msg/DepositWithinBatch response type.

func (*MsgDepositWithinBatchResponse) Descriptor 

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

func (*MsgDepositWithinBatchResponse) Marshal 

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

func (*MsgDepositWithinBatchResponse) MarshalTo 

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

func (*MsgDepositWithinBatchResponse) MarshalToSizedBuffer 

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

func (*MsgDepositWithinBatchResponse) ProtoMessage 

func (*MsgDepositWithinBatchResponse) ProtoMessage()

func (*MsgDepositWithinBatchResponse) Reset 

func (m *MsgDepositWithinBatchResponse) Reset()

func (*MsgDepositWithinBatchResponse) Size 

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

func (*MsgDepositWithinBatchResponse) String 

func (m *MsgDepositWithinBatchResponse) String() string

func (*MsgDepositWithinBatchResponse) Unmarshal 

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

func (*MsgDepositWithinBatchResponse) XXX_DiscardUnknown 

func (m *MsgDepositWithinBatchResponse) XXX_DiscardUnknown()

func (*MsgDepositWithinBatchResponse) XXX_Marshal 

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

func (*MsgDepositWithinBatchResponse) XXX_Merge 

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

func (*MsgDepositWithinBatchResponse) XXX_Size 

func (m *MsgDepositWithinBatchResponse) XXX_Size() int

func (*MsgDepositWithinBatchResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// Submit a create liquidity pool message.
	CreatePool(context.Context, *MsgCreatePool) (*MsgCreatePoolResponse, error)
	// Submit a deposit to the liquidity pool batch.
	DepositWithinBatch(context.Context, *MsgDepositWithinBatch) (*MsgDepositWithinBatchResponse, error)
	// Submit a withdraw from the liquidity pool batch.
	WithdrawWithinBatch(context.Context, *MsgWithdrawWithinBatch) (*MsgWithdrawWithinBatchResponse, error)
	// Submit a swap to the liquidity pool batch.
	Swap(context.Context, *MsgSwapWithinBatch) (*MsgSwapWithinBatchResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSwapWithinBatch 

type MsgSwapWithinBatch struct {
	// address of swap requester
	SwapRequesterAddress string `` /* 153-byte string literal not displayed */
	// id of swap type, must match the value in the pool. Only `swap_type_id` 1 is supported.
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id" yaml:"pool_id"`
	// id of swap type. Must match the value in the pool.
	SwapTypeId uint32 `protobuf:"varint,3,opt,name=swap_type_id,json=swapTypeId,proto3" json:"swap_type_id,omitempty" yaml:"swap_type_id"`
	// 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 */
	// half of offer coin amount * params.swap_fee_rate and ceil for reservation to pay fees.
	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 the order, the price is the exchange ratio of X/Y
	// where X is the amount of the first coin and Y is the amount
	// of the second coin when their denoms are sorted alphabetically.
	OrderPrice github_com_cosmos_cosmos_sdk_types.Dec `` /* 150-byte string literal not displayed */
}

`MsgSwapWithinBatch` defines an sdk.Msg type that supports submitting a swap offer request to the batch of the liquidity pool. Submit swap offer to the liquidity pool batch with the specified the `pool_id`, `swap_type_id`, `demand_coin_denom` with the coin and the price you're offering and `offer_coin_fee` must be half of offer coin amount * current `params.swap_fee_rate` and ceil for reservation to pay fees. This request is stacked in the batch of the liquidity pool, is not processed immediately, and is processed in the `endblock` at the same time as other requests. You must request the same fields as the pool. Only the default `swap_type_id` 1 is supported.

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

func (*MsgSwapWithinBatch) Descriptor 

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

func (MsgSwapWithinBatch) GetSignBytes 

func (msg MsgSwapWithinBatch) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgSwapWithinBatch) GetSigners 

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

GetSigners implements Msg.

func (*MsgSwapWithinBatch) Marshal 

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

func (*MsgSwapWithinBatch) MarshalTo 

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

func (*MsgSwapWithinBatch) MarshalToSizedBuffer 

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

func (*MsgSwapWithinBatch) ProtoMessage 

func (*MsgSwapWithinBatch) ProtoMessage()

func (*MsgSwapWithinBatch) Reset 

func (m *MsgSwapWithinBatch) Reset()

func (MsgSwapWithinBatch) Route 

func (msg MsgSwapWithinBatch) Route() string

Route implements Msg.

func (*MsgSwapWithinBatch) Size 

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

func (*MsgSwapWithinBatch) String 

func (m *MsgSwapWithinBatch) String() string

func (MsgSwapWithinBatch) Type 

func (msg MsgSwapWithinBatch) Type() string

Type implements Msg.

func (*MsgSwapWithinBatch) Unmarshal 

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

func (MsgSwapWithinBatch) ValidateBasic 

func (msg MsgSwapWithinBatch) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgSwapWithinBatch) XXX_DiscardUnknown 

func (m *MsgSwapWithinBatch) XXX_DiscardUnknown()

func (*MsgSwapWithinBatch) XXX_Marshal 

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

func (*MsgSwapWithinBatch) XXX_Merge 

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

func (*MsgSwapWithinBatch) XXX_Size 

func (m *MsgSwapWithinBatch) XXX_Size() int

func (*MsgSwapWithinBatch) XXX_Unmarshal 

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

type MsgSwapWithinBatchResponse 

type MsgSwapWithinBatchResponse struct {
}

MsgSwapWithinBatchResponse defines the Msg/Swap response type.

func (*MsgSwapWithinBatchResponse) Descriptor 

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

func (*MsgSwapWithinBatchResponse) Marshal 

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

func (*MsgSwapWithinBatchResponse) MarshalTo 

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

func (*MsgSwapWithinBatchResponse) MarshalToSizedBuffer 

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

func (*MsgSwapWithinBatchResponse) ProtoMessage 

func (*MsgSwapWithinBatchResponse) ProtoMessage()

func (*MsgSwapWithinBatchResponse) Reset 

func (m *MsgSwapWithinBatchResponse) Reset()

func (*MsgSwapWithinBatchResponse) Size 

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

func (*MsgSwapWithinBatchResponse) String 

func (m *MsgSwapWithinBatchResponse) String() string

func (*MsgSwapWithinBatchResponse) Unmarshal 

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

func (*MsgSwapWithinBatchResponse) XXX_DiscardUnknown 

func (m *MsgSwapWithinBatchResponse) XXX_DiscardUnknown()

func (*MsgSwapWithinBatchResponse) XXX_Marshal 

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

func (*MsgSwapWithinBatchResponse) XXX_Merge 

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

func (*MsgSwapWithinBatchResponse) XXX_Size 

func (m *MsgSwapWithinBatchResponse) XXX_Size() int

func (*MsgSwapWithinBatchResponse) XXX_Unmarshal 

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

type MsgWithdrawWithinBatch 

type MsgWithdrawWithinBatch 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"`
}

`MsgWithdrawWithinBatch` defines an `sdk.Msg` type that supports submitting a withdraw request to the batch of the liquidity pool. Withdraw is submitted to the batch from the Liquidity pool with the specified `pool_id`, `pool_coin` of the pool. This request is stacked in the batch of the liquidity pool, is not processed immediately, and is processed in the `endblock` at the same time as other requests.

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

func (*MsgWithdrawWithinBatch) Descriptor 

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

func (MsgWithdrawWithinBatch) GetSignBytes 

func (msg MsgWithdrawWithinBatch) GetSignBytes() []byte

GetSignBytes implements Msg.

func (MsgWithdrawWithinBatch) GetSigners 

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

GetSigners implements Msg.

func (*MsgWithdrawWithinBatch) Marshal 

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

func (*MsgWithdrawWithinBatch) MarshalTo 

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

func (*MsgWithdrawWithinBatch) MarshalToSizedBuffer 

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

func (*MsgWithdrawWithinBatch) ProtoMessage 

func (*MsgWithdrawWithinBatch) ProtoMessage()

func (*MsgWithdrawWithinBatch) Reset 

func (m *MsgWithdrawWithinBatch) Reset()

func (MsgWithdrawWithinBatch) Route 

func (msg MsgWithdrawWithinBatch) Route() string

Route implements Msg.

func (*MsgWithdrawWithinBatch) Size 

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

func (*MsgWithdrawWithinBatch) String 

func (m *MsgWithdrawWithinBatch) String() string

func (MsgWithdrawWithinBatch) Type 

func (msg MsgWithdrawWithinBatch) Type() string

Type implements Msg.

func (*MsgWithdrawWithinBatch) Unmarshal 

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

func (MsgWithdrawWithinBatch) ValidateBasic 

func (msg MsgWithdrawWithinBatch) ValidateBasic() error

ValidateBasic implements Msg.

func (*MsgWithdrawWithinBatch) XXX_DiscardUnknown 

func (m *MsgWithdrawWithinBatch) XXX_DiscardUnknown()

func (*MsgWithdrawWithinBatch) XXX_Marshal 

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

func (*MsgWithdrawWithinBatch) XXX_Merge 

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

func (*MsgWithdrawWithinBatch) XXX_Size 

func (m *MsgWithdrawWithinBatch) XXX_Size() int

func (*MsgWithdrawWithinBatch) XXX_Unmarshal 

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

type MsgWithdrawWithinBatchResponse 

type MsgWithdrawWithinBatchResponse struct {
}

MsgWithdrawWithinBatchResponse defines the Msg/WithdrawWithinBatch response type.

func (*MsgWithdrawWithinBatchResponse) Descriptor 

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

func (*MsgWithdrawWithinBatchResponse) Marshal 

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

func (*MsgWithdrawWithinBatchResponse) MarshalTo 

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

func (*MsgWithdrawWithinBatchResponse) MarshalToSizedBuffer 

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

func (*MsgWithdrawWithinBatchResponse) ProtoMessage 

func (*MsgWithdrawWithinBatchResponse) ProtoMessage()

func (*MsgWithdrawWithinBatchResponse) Reset 

func (m *MsgWithdrawWithinBatchResponse) Reset()

func (*MsgWithdrawWithinBatchResponse) Size 

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

func (*MsgWithdrawWithinBatchResponse) String 

func (m *MsgWithdrawWithinBatchResponse) String() string

func (*MsgWithdrawWithinBatchResponse) Unmarshal 

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

func (*MsgWithdrawWithinBatchResponse) XXX_DiscardUnknown 

func (m *MsgWithdrawWithinBatchResponse) XXX_DiscardUnknown()

func (*MsgWithdrawWithinBatchResponse) XXX_Marshal 

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

func (*MsgWithdrawWithinBatchResponse) XXX_Merge 

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

func (*MsgWithdrawWithinBatchResponse) XXX_Size 

func (m *MsgWithdrawWithinBatchResponse) XXX_Size() int

func (*MsgWithdrawWithinBatchResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// list of available pool types
	PoolTypes []PoolType `protobuf:"bytes,1,rep,name=pool_types,json=poolTypes,proto3" json:"pool_types" yaml:"pool_types"`
	// Minimum number of coins to be deposited to the liquidity pool on pool creation.
	MinInitDepositAmount github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Int `` /* 217-byte string literal not displayed */
	// Initial mint amount of pool coins upon pool creation.
	InitPoolCoinMintAmount github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Int `` /* 228-byte string literal not displayed */
	// Limit the size of each liquidity pool to minimize risk. In development, set to 0 for no limit. In production, set a limit.
	MaxReserveCoinAmount github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Int `` /* 217-byte string literal not displayed */
	// Fee paid to create a Liquidity Pool. Set a fee to prevent spamming.
	PoolCreationFee github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Coins `` /* 198-byte string literal not displayed */
	// Swap fee rate for every executed swap.
	SwapFeeRate github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Dec `` /* 178-byte string literal not displayed */
	// Reserve coin withdrawal with less proportion by withdrawFeeRate.
	WithdrawFeeRate github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Dec `` /* 194-byte string literal not displayed */
	// Maximum ratio of reserve coins that can be ordered at a swap order.
	MaxOrderAmountRatio github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Dec `` /* 213-byte string literal not displayed */
	// The smallest unit batch height for every liquidity pool.
	UnitBatchHeight uint32 `` /* 134-byte string literal not displayed */
	// Circuit breaker enables or disables transaction messages in liquidity module.
	CircuitBreakerEnabled bool `` /* 159-byte string literal not displayed */
}

Params defines the parameters for the liquidity module.

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

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type Pool 

type Pool struct {
	// id of the pool
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id" yaml:"id"`
	// id of the pool_type
	TypeId uint32 `protobuf:"varint,2,opt,name=type_id,json=typeId,proto3" json:"type_id,omitempty" yaml:"type_id"`
	// 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"`
}

Pool defines the liquidity pool that contains pool information.

func (*Pool) Descriptor 

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

func (*Pool) Equal 

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

func (*Pool) Marshal 

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

func (*Pool) MarshalTo 

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

func (*Pool) MarshalToSizedBuffer 

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

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) Size 

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

func (*Pool) String 

func (m *Pool) String() string

func (*Pool) Unmarshal 

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

func (*Pool) XXX_DiscardUnknown 

func (m *Pool) XXX_DiscardUnknown()

func (*Pool) XXX_Marshal 

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

func (*Pool) XXX_Merge 

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

func (*Pool) XXX_Size 

func (m *Pool) XXX_Size() int

func (*Pool) XXX_Unmarshal 

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

type PoolBatch 

type PoolBatch 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
	Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty" yaml:"index"`
	// height where this batch is started
	BeginHeight int64 `protobuf:"varint,3,opt,name=begin_height,json=beginHeight,proto3" json:"begin_height,omitempty" yaml:"begin_height"`
	// last index of DepositMsgStates
	DepositMsgIndex uint64 `` /* 134-byte string literal not displayed */
	// last index of WithdrawMsgStates
	WithdrawMsgIndex uint64 `` /* 138-byte string literal not displayed */
	// last index of SwapMsgStates
	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
	Executed bool `protobuf:"varint,7,opt,name=executed,proto3" json:"executed,omitempty" yaml:"executed"`
}

PoolBatch defines the batch or batches of a given liquidity pool that contains indexes of deposit, withdraw, and swap messages. Index param increments by 1 if the pool id is same.

func (*PoolBatch) Descriptor 

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

func (*PoolBatch) Equal 

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

func (*PoolBatch) Marshal 

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

func (*PoolBatch) MarshalTo 

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

func (*PoolBatch) MarshalToSizedBuffer 

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

func (*PoolBatch) ProtoMessage 

func (*PoolBatch) ProtoMessage()

func (*PoolBatch) Reset 

func (m *PoolBatch) Reset()

func (*PoolBatch) Size 

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

func (*PoolBatch) String 

func (m *PoolBatch) String() string

func (*PoolBatch) Unmarshal 

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

func (*PoolBatch) XXX_DiscardUnknown 

func (m *PoolBatch) XXX_DiscardUnknown()

func (*PoolBatch) XXX_Marshal 

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

func (*PoolBatch) XXX_Merge 

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

func (*PoolBatch) XXX_Size 

func (m *PoolBatch) XXX_Size() int

func (*PoolBatch) XXX_Unmarshal 

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

type PoolBatchDepositMsg 

type PoolBatchDepositMsg struct {
	PoolId   uint64
	MsgIndex uint64
}

type PoolMetadata 

type PoolMetadata 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_oracleNetworkProtocol_plugchain_sdk_go_types.Coins `` /* 183-byte string literal not displayed */
}

Metadata for the state of each pool for invariant checking after genesis export or import.

func (*PoolMetadata) Descriptor 

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

func (*PoolMetadata) Equal 

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

func (*PoolMetadata) Marshal 

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

func (*PoolMetadata) MarshalTo 

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

func (*PoolMetadata) MarshalToSizedBuffer 

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

func (*PoolMetadata) ProtoMessage 

func (*PoolMetadata) ProtoMessage()

func (*PoolMetadata) Reset 

func (m *PoolMetadata) Reset()

func (*PoolMetadata) Size 

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

func (*PoolMetadata) String 

func (m *PoolMetadata) String() string

func (*PoolMetadata) Unmarshal 

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

func (*PoolMetadata) XXX_DiscardUnknown 

func (m *PoolMetadata) XXX_DiscardUnknown()

func (*PoolMetadata) XXX_Marshal 

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

func (*PoolMetadata) XXX_Merge 

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

func (*PoolMetadata) XXX_Size 

func (m *PoolMetadata) XXX_Size() int

func (*PoolMetadata) XXX_Unmarshal 

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

type PoolRecord 

type PoolRecord struct {
	Pool              Pool               `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool" yaml:"pool"`
	PoolMetadata      PoolMetadata       `protobuf:"bytes,2,opt,name=pool_metadata,json=poolMetadata,proto3" json:"pool_metadata" yaml:"pool_metadata"`
	PoolBatch         PoolBatch          `protobuf:"bytes,3,opt,name=pool_batch,json=poolBatch,proto3" json:"pool_batch" yaml:"pool_batch"`
	DepositMsgStates  []DepositMsgState  `` /* 127-byte string literal not displayed */
	WithdrawMsgStates []WithdrawMsgState `` /* 131-byte string literal not displayed */
	SwapMsgStates     []SwapMsgState     `protobuf:"bytes,6,rep,name=swap_msg_states,json=swapMsgStates,proto3" json:"swap_msg_states" yaml:"swap_msg_states"`
}

records the state of each pool after genesis export or import, used to check variables

func (*PoolRecord) Descriptor 

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

func (*PoolRecord) GetDepositMsgStates 

func (m *PoolRecord) GetDepositMsgStates() []DepositMsgState

func (*PoolRecord) GetPool 

func (m *PoolRecord) GetPool() Pool

func (*PoolRecord) GetPoolBatch 

func (m *PoolRecord) GetPoolBatch() PoolBatch

func (*PoolRecord) GetPoolMetadata 

func (m *PoolRecord) GetPoolMetadata() PoolMetadata

func (*PoolRecord) GetSwapMsgStates 

func (m *PoolRecord) GetSwapMsgStates() []SwapMsgState

func (*PoolRecord) GetWithdrawMsgStates 

func (m *PoolRecord) GetWithdrawMsgStates() []WithdrawMsgState

func (*PoolRecord) Marshal 

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

func (*PoolRecord) MarshalTo 

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

func (*PoolRecord) MarshalToSizedBuffer 

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

func (*PoolRecord) ProtoMessage 

func (*PoolRecord) ProtoMessage()

func (*PoolRecord) Reset 

func (m *PoolRecord) Reset()

func (*PoolRecord) Size 

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

func (*PoolRecord) String 

func (m *PoolRecord) String() string

func (*PoolRecord) Unmarshal 

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

func (*PoolRecord) XXX_DiscardUnknown 

func (m *PoolRecord) XXX_DiscardUnknown()

func (*PoolRecord) XXX_Marshal 

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

func (*PoolRecord) XXX_Merge 

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

func (*PoolRecord) XXX_Size 

func (m *PoolRecord) XXX_Size() int

func (*PoolRecord) XXX_Unmarshal 

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

type PoolType 

type PoolType struct {
	// This is the id of the pool_type that is used as pool_type_id for pool creation.
	// In this version, only pool-type-id 1 is supported.
	// {"id":1,"name":"ConstantProductLiquidityPool","min_reserve_coin_num":2,"max_reserve_coin_num":2,"description":""}
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id"`
	// name of the pool type.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" yaml:"name"`
	// minimum number of reserveCoins for LiquidityPoolType, only 2 reserve coins are supported.
	MinReserveCoinNum uint32 `` /* 145-byte string literal not displayed */
	// maximum number of reserveCoins for LiquidityPoolType, only 2 reserve coins are supported.
	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"`
}

Structure for the pool type to distinguish the characteristics of the reserve pools.

func (*PoolType) Descriptor 

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

func (*PoolType) Equal 

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

func (*PoolType) Marshal 

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

func (*PoolType) MarshalTo 

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

func (*PoolType) MarshalToSizedBuffer 

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

func (*PoolType) ProtoMessage 

func (*PoolType) ProtoMessage()

func (*PoolType) Reset 

func (m *PoolType) Reset()

func (*PoolType) Size 

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

func (*PoolType) String 

func (m *PoolType) String() string

func (*PoolType) Unmarshal 

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

func (*PoolType) XXX_DiscardUnknown 

func (m *PoolType) XXX_DiscardUnknown()

func (*PoolType) XXX_Marshal 

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

func (*PoolType) XXX_Merge 

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

func (*PoolType) XXX_Size 

func (m *PoolType) XXX_Size() int

func (*PoolType) XXX_Unmarshal 

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

type QueryAllPoolsResponse 

type QueryAllPoolsResponse struct {
	Pools      []sdk.PoolInfo
	Pagination *query.PageResponse
}

type QueryClient 

type QueryClient interface {
	// Get existing liquidity pools.
	LiquidityPools(ctx context.Context, in *QueryLiquidityPoolsRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolsResponse, error)
	// Get specific liquidity pool.
	LiquidityPool(ctx context.Context, in *QueryLiquidityPoolRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolResponse, error)
	// Get specific liquidity pool corresponding to the pool_coin_denom.
	LiquidityPoolByPoolCoinDenom(ctx context.Context, in *QueryLiquidityPoolByPoolCoinDenomRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolResponse, error)
	// Get specific liquidity pool corresponding to the reserve account.
	LiquidityPoolByReserveAcc(ctx context.Context, in *QueryLiquidityPoolByReserveAccRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolResponse, error)
	// Get the pool's current batch.
	LiquidityPoolBatch(ctx context.Context, in *QueryLiquidityPoolBatchRequest, opts ...grpc.CallOption) (*QueryLiquidityPoolBatchResponse, error)
	// Get all swap messages in the pool's current batch.
	PoolBatchSwapMsgs(ctx context.Context, in *QueryPoolBatchSwapMsgsRequest, opts ...grpc.CallOption) (*QueryPoolBatchSwapMsgsResponse, error)
	// Get a specific swap message in the pool's current batch.
	PoolBatchSwapMsg(ctx context.Context, in *QueryPoolBatchSwapMsgRequest, opts ...grpc.CallOption) (*QueryPoolBatchSwapMsgResponse, error)
	// Get all deposit messages in the pool's current batch.
	PoolBatchDepositMsgs(ctx context.Context, in *QueryPoolBatchDepositMsgsRequest, opts ...grpc.CallOption) (*QueryPoolBatchDepositMsgsResponse, error)
	// Get a specific deposit message in the pool's current batch.
	PoolBatchDepositMsg(ctx context.Context, in *QueryPoolBatchDepositMsgRequest, opts ...grpc.CallOption) (*QueryPoolBatchDepositMsgResponse, error)
	// Get all withdraw messages in the pool's current batch.
	PoolBatchWithdrawMsgs(ctx context.Context, in *QueryPoolBatchWithdrawMsgsRequest, opts ...grpc.CallOption) (*QueryPoolBatchWithdrawMsgsResponse, error)
	// Get a specific withdraw message in the pool's current batch.
	PoolBatchWithdrawMsg(ctx context.Context, in *QueryPoolBatchWithdrawMsgRequest, opts ...grpc.CallOption) (*QueryPoolBatchWithdrawMsgResponse, error)
	// Get all parameters of the liquidity module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// ==============================finish deposit msg===============================//
	// Get deposit finish messages in the pool's current by msg_index.
	PoolDepositSuccessMsg(ctx context.Context, in *QueryPoolDepositSuccessMsgRequest, opts ...grpc.CallOption) (*QueryPoolDepositSuccessMsgResponse, error)
	// Get all deposit finish messages in the pool's current.
	PoolDepositSuccessMsgs(ctx context.Context, in *QueryPoolDepositSuccessMsgsRequest, opts ...grpc.CallOption) (*QueryPoolDepositSuccessMsgsResponse, error)
	// ==============================finish swap msg===============================//
	PoolSwapSuccessMsg(ctx context.Context, in *QueryPoolSwapSuccessMsgRequest, opts ...grpc.CallOption) (*QueryPoolSwapSuccessMsgResponse, error)
	// Get all swap finish messages in the pool's current.
	PoolSwapSuccessMsgs(ctx context.Context, in *QueryPoolSwapSuccessMsgsRequest, opts ...grpc.CallOption) (*QueryPoolSwapSuccessMsgsResponse, error)
	// ==============================finish withdraw msg===============================//
	PoolWithdrawSuccessMsg(ctx context.Context, in *QueryPoolWithdrawSuccessMsgRequest, opts ...grpc.CallOption) (*QueryPoolWithdrawSuccessMsgResponse, error)
	// Get all withdraw finish messages in the pool's current.
	PoolWithdrawSuccessMsgs(ctx context.Context, in *QueryPoolWithdrawSuccessMsgsRequest, opts ...grpc.CallOption) (*QueryPoolWithdrawSuccessMsgsResponse, 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 PoolBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch"`
}

the response type for the QueryLiquidityPoolBatchResponse RPC method. Returns the liquidity pool batch that corresponds to the requested pool_id.

func (*QueryLiquidityPoolBatchResponse) Descriptor 

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

func (*QueryLiquidityPoolBatchResponse) GetBatch 

func (m *QueryLiquidityPoolBatchResponse) GetBatch() PoolBatch

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 QueryLiquidityPoolByPoolCoinDenomRequest 

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

the request type for the QueryLiquidityByPoolCoinDenomPool RPC method. Requestable specified pool_coin_denom.

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Descriptor 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) GetPoolCoinDenom 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) GetPoolCoinDenom() string

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Marshal 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) MarshalTo 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) ProtoMessage 

func (*QueryLiquidityPoolByPoolCoinDenomRequest) ProtoMessage()

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Reset 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) Reset()

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Size 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) String 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) String() string

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Unmarshal 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Marshal 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Merge 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Size 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Size() int

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Unmarshal 

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

type QueryLiquidityPoolByReserveAccRequest 

type QueryLiquidityPoolByReserveAccRequest struct {
	ReserveAcc string `protobuf:"bytes,1,opt,name=reserve_acc,json=reserveAcc,proto3" json:"reserve_acc,omitempty"`
}

the request type for the QueryLiquidityByReserveAcc RPC method. Requestable specified reserve_acc.

func (*QueryLiquidityPoolByReserveAccRequest) Descriptor 

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

func (*QueryLiquidityPoolByReserveAccRequest) GetReserveAcc 

func (m *QueryLiquidityPoolByReserveAccRequest) GetReserveAcc() string

func (*QueryLiquidityPoolByReserveAccRequest) Marshal 

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

func (*QueryLiquidityPoolByReserveAccRequest) MarshalTo 

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

func (*QueryLiquidityPoolByReserveAccRequest) MarshalToSizedBuffer 

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

func (*QueryLiquidityPoolByReserveAccRequest) ProtoMessage 

func (*QueryLiquidityPoolByReserveAccRequest) ProtoMessage()

func (*QueryLiquidityPoolByReserveAccRequest) Reset 

func (m *QueryLiquidityPoolByReserveAccRequest) Reset()

func (*QueryLiquidityPoolByReserveAccRequest) Size 

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

func (*QueryLiquidityPoolByReserveAccRequest) String 

func (m *QueryLiquidityPoolByReserveAccRequest) String() string

func (*QueryLiquidityPoolByReserveAccRequest) Unmarshal 

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

func (*QueryLiquidityPoolByReserveAccRequest) XXX_DiscardUnknown 

func (m *QueryLiquidityPoolByReserveAccRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolByReserveAccRequest) XXX_Marshal 

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

func (*QueryLiquidityPoolByReserveAccRequest) XXX_Merge 

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

func (*QueryLiquidityPoolByReserveAccRequest) XXX_Size 

func (m *QueryLiquidityPoolByReserveAccRequest) XXX_Size() int

func (*QueryLiquidityPoolByReserveAccRequest) XXX_Unmarshal 

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

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 {
	Pool Pool `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool"`
}

the response type for the QueryLiquidityPoolResponse RPC method. Returns the liquidity pool that corresponds to the requested pool_id.

func (QueryLiquidityPoolResponse) Convert 

func (m QueryLiquidityPoolResponse) Convert() interface{}

func (*QueryLiquidityPoolResponse) Descriptor 

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

func (*QueryLiquidityPoolResponse) GetPool 

func (m *QueryLiquidityPoolResponse) GetPool() Pool

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 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 []Pool `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 a list of all existing liquidity pools and paging results that contain next_key and total count.

func (QueryLiquidityPoolsResponse) Convert 

func (m QueryLiquidityPoolsResponse) Convert() interface{}

func (*QueryLiquidityPoolsResponse) Descriptor 

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

func (*QueryLiquidityPoolsResponse) GetPagination 

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

func (*QueryLiquidityPoolsResponse) GetPools 

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

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 {
	Deposit DepositMsgState `protobuf:"bytes,1,opt,name=deposit,proto3" json:"deposit"`
}

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

func (m *QueryPoolBatchDepositMsgResponse) GetDeposit() DepositMsgState

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 []DepositMsgState `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 that contain next_key and total count.

func (*QueryPoolBatchDepositMsgsResponse) Descriptor 

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

func (*QueryPoolBatchDepositMsgsResponse) GetDeposits 

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

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 {
	Swap SwapMsgState `protobuf:"bytes,1,opt,name=swap,proto3" json:"swap"`
}

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

func (m *QueryPoolBatchSwapMsgResponse) GetSwap() SwapMsgState

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 []SwapMsgState `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 that contain 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() []SwapMsgState

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 {
	Withdraw WithdrawMsgState `protobuf:"bytes,1,opt,name=withdraw,proto3" json:"withdraw"`
}

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

func (m *QueryPoolBatchWithdrawMsgResponse) GetWithdraw() WithdrawMsgState

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 []WithdrawMsgState `protobuf:"bytes,1,rep,name=withdraws,proto3" json:"withdraws"`
	// pagination defines the pagination in the response. Not supported 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 that contain 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() []WithdrawMsgState

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 QueryPoolDepositSuccessMsgRequest 

type QueryPoolDepositSuccessMsgRequest 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 QueryPoolDepositSuccessMsgRequest RPC method. requestable including specified pool_id and msg_index.

func (*QueryPoolDepositSuccessMsgRequest) Descriptor 

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

func (*QueryPoolDepositSuccessMsgRequest) GetMsgIndex 

func (m *QueryPoolDepositSuccessMsgRequest) GetMsgIndex() uint64

func (*QueryPoolDepositSuccessMsgRequest) GetPoolId 

func (m *QueryPoolDepositSuccessMsgRequest) GetPoolId() uint64

func (*QueryPoolDepositSuccessMsgRequest) Marshal 

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

func (*QueryPoolDepositSuccessMsgRequest) MarshalTo 

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

func (*QueryPoolDepositSuccessMsgRequest) MarshalToSizedBuffer 

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

func (*QueryPoolDepositSuccessMsgRequest) ProtoMessage 

func (*QueryPoolDepositSuccessMsgRequest) ProtoMessage()

func (*QueryPoolDepositSuccessMsgRequest) Reset 

func (m *QueryPoolDepositSuccessMsgRequest) Reset()

func (*QueryPoolDepositSuccessMsgRequest) Size 

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

func (*QueryPoolDepositSuccessMsgRequest) String 

func (m *QueryPoolDepositSuccessMsgRequest) String() string

func (*QueryPoolDepositSuccessMsgRequest) Unmarshal 

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

func (*QueryPoolDepositSuccessMsgRequest) XXX_DiscardUnknown 

func (m *QueryPoolDepositSuccessMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolDepositSuccessMsgRequest) XXX_Marshal 

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

func (*QueryPoolDepositSuccessMsgRequest) XXX_Merge 

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

func (*QueryPoolDepositSuccessMsgRequest) XXX_Size 

func (m *QueryPoolDepositSuccessMsgRequest) XXX_Size() int

func (*QueryPoolDepositSuccessMsgRequest) XXX_Unmarshal 

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

type QueryPoolDepositSuccessMsgResponse 

type QueryPoolDepositSuccessMsgResponse struct {
	Deposit DepositSuccessMsg `protobuf:"bytes,1,opt,name=deposit,proto3" json:"deposit"`
}

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

func (*QueryPoolDepositSuccessMsgResponse) Descriptor 

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

func (*QueryPoolDepositSuccessMsgResponse) GetDeposit 

func (m *QueryPoolDepositSuccessMsgResponse) GetDeposit() DepositSuccessMsg

func (*QueryPoolDepositSuccessMsgResponse) Marshal 

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

func (*QueryPoolDepositSuccessMsgResponse) MarshalTo 

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

func (*QueryPoolDepositSuccessMsgResponse) MarshalToSizedBuffer 

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

func (*QueryPoolDepositSuccessMsgResponse) ProtoMessage 

func (*QueryPoolDepositSuccessMsgResponse) ProtoMessage()

func (*QueryPoolDepositSuccessMsgResponse) Reset 

func (m *QueryPoolDepositSuccessMsgResponse) Reset()

func (*QueryPoolDepositSuccessMsgResponse) Size 

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

func (*QueryPoolDepositSuccessMsgResponse) String 

func (m *QueryPoolDepositSuccessMsgResponse) String() string

func (*QueryPoolDepositSuccessMsgResponse) Unmarshal 

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

func (*QueryPoolDepositSuccessMsgResponse) XXX_DiscardUnknown 

func (m *QueryPoolDepositSuccessMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolDepositSuccessMsgResponse) XXX_Marshal 

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

func (*QueryPoolDepositSuccessMsgResponse) XXX_Merge 

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

func (*QueryPoolDepositSuccessMsgResponse) XXX_Size 

func (m *QueryPoolDepositSuccessMsgResponse) XXX_Size() int

func (*QueryPoolDepositSuccessMsgResponse) XXX_Unmarshal 

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

type QueryPoolDepositSuccessMsgsRequest 

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

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

func (*QueryPoolDepositSuccessMsgsRequest) Descriptor 

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

func (*QueryPoolDepositSuccessMsgsRequest) GetDepositorAddress 

func (m *QueryPoolDepositSuccessMsgsRequest) GetDepositorAddress() string

func (*QueryPoolDepositSuccessMsgsRequest) GetPagination 

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

func (*QueryPoolDepositSuccessMsgsRequest) GetPoolId 

func (m *QueryPoolDepositSuccessMsgsRequest) GetPoolId() uint64

func (*QueryPoolDepositSuccessMsgsRequest) Marshal 

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

func (*QueryPoolDepositSuccessMsgsRequest) MarshalTo 

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

func (*QueryPoolDepositSuccessMsgsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolDepositSuccessMsgsRequest) ProtoMessage 

func (*QueryPoolDepositSuccessMsgsRequest) ProtoMessage()

func (*QueryPoolDepositSuccessMsgsRequest) Reset 

func (m *QueryPoolDepositSuccessMsgsRequest) Reset()

func (*QueryPoolDepositSuccessMsgsRequest) Size 

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

func (*QueryPoolDepositSuccessMsgsRequest) String 

func (m *QueryPoolDepositSuccessMsgsRequest) String() string

func (*QueryPoolDepositSuccessMsgsRequest) Unmarshal 

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

func (*QueryPoolDepositSuccessMsgsRequest) XXX_DiscardUnknown 

func (m *QueryPoolDepositSuccessMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolDepositSuccessMsgsRequest) XXX_Marshal 

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

func (*QueryPoolDepositSuccessMsgsRequest) XXX_Merge 

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

func (*QueryPoolDepositSuccessMsgsRequest) XXX_Size 

func (m *QueryPoolDepositSuccessMsgsRequest) XXX_Size() int

func (*QueryPoolDepositSuccessMsgsRequest) XXX_Unmarshal 

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

type QueryPoolDepositSuccessMsgsResponse 

type QueryPoolDepositSuccessMsgsResponse struct {
	Deposits []DepositSuccessMsg `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 QueryPoolDepositSuccessMsgs RPC method. This includes a list of all currently existing deposit messages of the finish and paging results that contain next_key and total count.

func (*QueryPoolDepositSuccessMsgsResponse) Descriptor 

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

func (*QueryPoolDepositSuccessMsgsResponse) GetDeposits 

func (m *QueryPoolDepositSuccessMsgsResponse) GetDeposits() []DepositSuccessMsg

func (*QueryPoolDepositSuccessMsgsResponse) GetPagination 

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

func (*QueryPoolDepositSuccessMsgsResponse) Marshal 

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

func (*QueryPoolDepositSuccessMsgsResponse) MarshalTo 

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

func (*QueryPoolDepositSuccessMsgsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolDepositSuccessMsgsResponse) ProtoMessage 

func (*QueryPoolDepositSuccessMsgsResponse) ProtoMessage()

func (*QueryPoolDepositSuccessMsgsResponse) Reset 

func (m *QueryPoolDepositSuccessMsgsResponse) Reset()

func (*QueryPoolDepositSuccessMsgsResponse) Size 

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

func (*QueryPoolDepositSuccessMsgsResponse) String 

func (m *QueryPoolDepositSuccessMsgsResponse) String() string

func (*QueryPoolDepositSuccessMsgsResponse) Unmarshal 

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

func (*QueryPoolDepositSuccessMsgsResponse) XXX_DiscardUnknown 

func (m *QueryPoolDepositSuccessMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolDepositSuccessMsgsResponse) XXX_Marshal 

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

func (*QueryPoolDepositSuccessMsgsResponse) XXX_Merge 

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

func (*QueryPoolDepositSuccessMsgsResponse) XXX_Size 

func (m *QueryPoolDepositSuccessMsgsResponse) XXX_Size() int

func (*QueryPoolDepositSuccessMsgsResponse) XXX_Unmarshal 

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

type QueryPoolResponse 

type QueryPoolResponse struct {
	Pool sdk.PoolInfo
}

type QueryPoolSwapSuccessMsgRequest 

type QueryPoolSwapSuccessMsgRequest 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 QueryPoolSwapSuccessMsgRequest RPC method. requestable including specified pool_id and msg_index.

func (*QueryPoolSwapSuccessMsgRequest) Descriptor 

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

func (*QueryPoolSwapSuccessMsgRequest) GetMsgIndex 

func (m *QueryPoolSwapSuccessMsgRequest) GetMsgIndex() uint64

func (*QueryPoolSwapSuccessMsgRequest) GetPoolId 

func (m *QueryPoolSwapSuccessMsgRequest) GetPoolId() uint64

func (*QueryPoolSwapSuccessMsgRequest) Marshal 

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

func (*QueryPoolSwapSuccessMsgRequest) MarshalTo 

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

func (*QueryPoolSwapSuccessMsgRequest) MarshalToSizedBuffer 

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

func (*QueryPoolSwapSuccessMsgRequest) ProtoMessage 

func (*QueryPoolSwapSuccessMsgRequest) ProtoMessage()

func (*QueryPoolSwapSuccessMsgRequest) Reset 

func (m *QueryPoolSwapSuccessMsgRequest) Reset()

func (*QueryPoolSwapSuccessMsgRequest) Size 

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

func (*QueryPoolSwapSuccessMsgRequest) String 

func (m *QueryPoolSwapSuccessMsgRequest) String() string

func (*QueryPoolSwapSuccessMsgRequest) Unmarshal 

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

func (*QueryPoolSwapSuccessMsgRequest) XXX_DiscardUnknown 

func (m *QueryPoolSwapSuccessMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolSwapSuccessMsgRequest) XXX_Marshal 

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

func (*QueryPoolSwapSuccessMsgRequest) XXX_Merge 

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

func (*QueryPoolSwapSuccessMsgRequest) XXX_Size 

func (m *QueryPoolSwapSuccessMsgRequest) XXX_Size() int

func (*QueryPoolSwapSuccessMsgRequest) XXX_Unmarshal 

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

type QueryPoolSwapSuccessMsgResponse 

type QueryPoolSwapSuccessMsgResponse struct {
	Swap SwapSuccessMsg `protobuf:"bytes,1,opt,name=swap,proto3" json:"swap"`
}

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

func (*QueryPoolSwapSuccessMsgResponse) Descriptor 

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

func (*QueryPoolSwapSuccessMsgResponse) GetSwap 

func (m *QueryPoolSwapSuccessMsgResponse) GetSwap() SwapSuccessMsg

func (*QueryPoolSwapSuccessMsgResponse) Marshal 

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

func (*QueryPoolSwapSuccessMsgResponse) MarshalTo 

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

func (*QueryPoolSwapSuccessMsgResponse) MarshalToSizedBuffer 

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

func (*QueryPoolSwapSuccessMsgResponse) ProtoMessage 

func (*QueryPoolSwapSuccessMsgResponse) ProtoMessage()

func (*QueryPoolSwapSuccessMsgResponse) Reset 

func (m *QueryPoolSwapSuccessMsgResponse) Reset()

func (*QueryPoolSwapSuccessMsgResponse) Size 

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

func (*QueryPoolSwapSuccessMsgResponse) String 

func (m *QueryPoolSwapSuccessMsgResponse) String() string

func (*QueryPoolSwapSuccessMsgResponse) Unmarshal 

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

func (*QueryPoolSwapSuccessMsgResponse) XXX_DiscardUnknown 

func (m *QueryPoolSwapSuccessMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolSwapSuccessMsgResponse) XXX_Marshal 

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

func (*QueryPoolSwapSuccessMsgResponse) XXX_Merge 

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

func (*QueryPoolSwapSuccessMsgResponse) XXX_Size 

func (m *QueryPoolSwapSuccessMsgResponse) XXX_Size() int

func (*QueryPoolSwapSuccessMsgResponse) XXX_Unmarshal 

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

type QueryPoolSwapSuccessMsgsRequest 

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

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

func (*QueryPoolSwapSuccessMsgsRequest) Descriptor 

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

func (*QueryPoolSwapSuccessMsgsRequest) GetPagination 

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

func (*QueryPoolSwapSuccessMsgsRequest) GetPoolId 

func (m *QueryPoolSwapSuccessMsgsRequest) GetPoolId() uint64

func (*QueryPoolSwapSuccessMsgsRequest) GetSwapAddress 

func (m *QueryPoolSwapSuccessMsgsRequest) GetSwapAddress() string

func (*QueryPoolSwapSuccessMsgsRequest) Marshal 

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

func (*QueryPoolSwapSuccessMsgsRequest) MarshalTo 

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

func (*QueryPoolSwapSuccessMsgsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolSwapSuccessMsgsRequest) ProtoMessage 

func (*QueryPoolSwapSuccessMsgsRequest) ProtoMessage()

func (*QueryPoolSwapSuccessMsgsRequest) Reset 

func (m *QueryPoolSwapSuccessMsgsRequest) Reset()

func (*QueryPoolSwapSuccessMsgsRequest) Size 

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

func (*QueryPoolSwapSuccessMsgsRequest) String 

func (m *QueryPoolSwapSuccessMsgsRequest) String() string

func (*QueryPoolSwapSuccessMsgsRequest) Unmarshal 

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

func (*QueryPoolSwapSuccessMsgsRequest) XXX_DiscardUnknown 

func (m *QueryPoolSwapSuccessMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolSwapSuccessMsgsRequest) XXX_Marshal 

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

func (*QueryPoolSwapSuccessMsgsRequest) XXX_Merge 

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

func (*QueryPoolSwapSuccessMsgsRequest) XXX_Size 

func (m *QueryPoolSwapSuccessMsgsRequest) XXX_Size() int

func (*QueryPoolSwapSuccessMsgsRequest) XXX_Unmarshal 

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

type QueryPoolSwapSuccessMsgsResponse 

type QueryPoolSwapSuccessMsgsResponse struct {
	Swaps []SwapSuccessMsg `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 QueryPoolSwapSuccessMsgs RPC method. This includes a list of all currently existing deposit messages of the finish and paging results that contain next_key and total count.

func (*QueryPoolSwapSuccessMsgsResponse) Descriptor 

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

func (*QueryPoolSwapSuccessMsgsResponse) GetPagination 

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

func (*QueryPoolSwapSuccessMsgsResponse) GetSwaps 

func (m *QueryPoolSwapSuccessMsgsResponse) GetSwaps() []SwapSuccessMsg

func (*QueryPoolSwapSuccessMsgsResponse) Marshal 

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

func (*QueryPoolSwapSuccessMsgsResponse) MarshalTo 

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

func (*QueryPoolSwapSuccessMsgsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolSwapSuccessMsgsResponse) ProtoMessage 

func (*QueryPoolSwapSuccessMsgsResponse) ProtoMessage()

func (*QueryPoolSwapSuccessMsgsResponse) Reset 

func (m *QueryPoolSwapSuccessMsgsResponse) Reset()

func (*QueryPoolSwapSuccessMsgsResponse) Size 

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

func (*QueryPoolSwapSuccessMsgsResponse) String 

func (m *QueryPoolSwapSuccessMsgsResponse) String() string

func (*QueryPoolSwapSuccessMsgsResponse) Unmarshal 

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

func (*QueryPoolSwapSuccessMsgsResponse) XXX_DiscardUnknown 

func (m *QueryPoolSwapSuccessMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolSwapSuccessMsgsResponse) XXX_Marshal 

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

func (*QueryPoolSwapSuccessMsgsResponse) XXX_Merge 

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

func (*QueryPoolSwapSuccessMsgsResponse) XXX_Size 

func (m *QueryPoolSwapSuccessMsgsResponse) XXX_Size() int

func (*QueryPoolSwapSuccessMsgsResponse) XXX_Unmarshal 

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

type QueryPoolWithdrawSuccessMsgRequest 

type QueryPoolWithdrawSuccessMsgRequest 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 QueryPoolWithdrawSuccessMsgRequest RPC method. requestable including specified pool_id and msg_index.

func (*QueryPoolWithdrawSuccessMsgRequest) Descriptor 

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

func (*QueryPoolWithdrawSuccessMsgRequest) GetMsgIndex 

func (m *QueryPoolWithdrawSuccessMsgRequest) GetMsgIndex() uint64

func (*QueryPoolWithdrawSuccessMsgRequest) GetPoolId 

func (m *QueryPoolWithdrawSuccessMsgRequest) GetPoolId() uint64

func (*QueryPoolWithdrawSuccessMsgRequest) Marshal 

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

func (*QueryPoolWithdrawSuccessMsgRequest) MarshalTo 

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

func (*QueryPoolWithdrawSuccessMsgRequest) MarshalToSizedBuffer 

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

func (*QueryPoolWithdrawSuccessMsgRequest) ProtoMessage 

func (*QueryPoolWithdrawSuccessMsgRequest) ProtoMessage()

func (*QueryPoolWithdrawSuccessMsgRequest) Reset 

func (m *QueryPoolWithdrawSuccessMsgRequest) Reset()

func (*QueryPoolWithdrawSuccessMsgRequest) Size 

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

func (*QueryPoolWithdrawSuccessMsgRequest) String 

func (m *QueryPoolWithdrawSuccessMsgRequest) String() string

func (*QueryPoolWithdrawSuccessMsgRequest) Unmarshal 

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

func (*QueryPoolWithdrawSuccessMsgRequest) XXX_DiscardUnknown 

func (m *QueryPoolWithdrawSuccessMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolWithdrawSuccessMsgRequest) XXX_Marshal 

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

func (*QueryPoolWithdrawSuccessMsgRequest) XXX_Merge 

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

func (*QueryPoolWithdrawSuccessMsgRequest) XXX_Size 

func (m *QueryPoolWithdrawSuccessMsgRequest) XXX_Size() int

func (*QueryPoolWithdrawSuccessMsgRequest) XXX_Unmarshal 

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

type QueryPoolWithdrawSuccessMsgResponse 

type QueryPoolWithdrawSuccessMsgResponse struct {
	Withdraw WithdrawSuccessMsg `protobuf:"bytes,1,opt,name=withdraw,proto3" json:"withdraw"`
}

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

func (*QueryPoolWithdrawSuccessMsgResponse) Descriptor 

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

func (*QueryPoolWithdrawSuccessMsgResponse) GetWithdraw 

func (m *QueryPoolWithdrawSuccessMsgResponse) GetWithdraw() WithdrawSuccessMsg

func (*QueryPoolWithdrawSuccessMsgResponse) Marshal 

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

func (*QueryPoolWithdrawSuccessMsgResponse) MarshalTo 

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

func (*QueryPoolWithdrawSuccessMsgResponse) MarshalToSizedBuffer 

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

func (*QueryPoolWithdrawSuccessMsgResponse) ProtoMessage 

func (*QueryPoolWithdrawSuccessMsgResponse) ProtoMessage()

func (*QueryPoolWithdrawSuccessMsgResponse) Reset 

func (m *QueryPoolWithdrawSuccessMsgResponse) Reset()

func (*QueryPoolWithdrawSuccessMsgResponse) Size 

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

func (*QueryPoolWithdrawSuccessMsgResponse) String 

func (m *QueryPoolWithdrawSuccessMsgResponse) String() string

func (*QueryPoolWithdrawSuccessMsgResponse) Unmarshal 

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

func (*QueryPoolWithdrawSuccessMsgResponse) XXX_DiscardUnknown 

func (m *QueryPoolWithdrawSuccessMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolWithdrawSuccessMsgResponse) XXX_Marshal 

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

func (*QueryPoolWithdrawSuccessMsgResponse) XXX_Merge 

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

func (*QueryPoolWithdrawSuccessMsgResponse) XXX_Size 

func (m *QueryPoolWithdrawSuccessMsgResponse) XXX_Size() int

func (*QueryPoolWithdrawSuccessMsgResponse) XXX_Unmarshal 

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

type QueryPoolWithdrawSuccessMsgsRequest 

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

==============================finish withdraw msg===============================// the request type for the QueryPoolWithdrawSuccessMsgsRequest RPC method. Requestable including specified pool_id and pagination offset, limit, key.

func (*QueryPoolWithdrawSuccessMsgsRequest) Descriptor 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) GetPagination 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) GetPoolId 

func (m *QueryPoolWithdrawSuccessMsgsRequest) GetPoolId() uint64

func (*QueryPoolWithdrawSuccessMsgsRequest) GetWithdrawAddress 

func (m *QueryPoolWithdrawSuccessMsgsRequest) GetWithdrawAddress() string

func (*QueryPoolWithdrawSuccessMsgsRequest) Marshal 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) MarshalTo 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) ProtoMessage 

func (*QueryPoolWithdrawSuccessMsgsRequest) ProtoMessage()

func (*QueryPoolWithdrawSuccessMsgsRequest) Reset 

func (m *QueryPoolWithdrawSuccessMsgsRequest) Reset()

func (*QueryPoolWithdrawSuccessMsgsRequest) Size 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) String 

func (m *QueryPoolWithdrawSuccessMsgsRequest) String() string

func (*QueryPoolWithdrawSuccessMsgsRequest) Unmarshal 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) XXX_DiscardUnknown 

func (m *QueryPoolWithdrawSuccessMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolWithdrawSuccessMsgsRequest) XXX_Marshal 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) XXX_Merge 

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

func (*QueryPoolWithdrawSuccessMsgsRequest) XXX_Size 

func (m *QueryPoolWithdrawSuccessMsgsRequest) XXX_Size() int

func (*QueryPoolWithdrawSuccessMsgsRequest) XXX_Unmarshal 

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

type QueryPoolWithdrawSuccessMsgsResponse 

type QueryPoolWithdrawSuccessMsgsResponse struct {
	Withdraws []WithdrawSuccessMsg `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 QueryPoolWithdrawSuccessMsgs RPC method. This includes a list of all currently existing deposit messages of the finish and paging results that contain next_key and total count.

func (*QueryPoolWithdrawSuccessMsgsResponse) Descriptor 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) GetPagination 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) GetWithdraws 

func (m *QueryPoolWithdrawSuccessMsgsResponse) GetWithdraws() []WithdrawSuccessMsg

func (*QueryPoolWithdrawSuccessMsgsResponse) Marshal 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) MarshalTo 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) ProtoMessage 

func (*QueryPoolWithdrawSuccessMsgsResponse) ProtoMessage()

func (*QueryPoolWithdrawSuccessMsgsResponse) Reset 

func (m *QueryPoolWithdrawSuccessMsgsResponse) Reset()

func (*QueryPoolWithdrawSuccessMsgsResponse) Size 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) String 

func (m *QueryPoolWithdrawSuccessMsgsResponse) String() string

func (*QueryPoolWithdrawSuccessMsgsResponse) Unmarshal 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) XXX_DiscardUnknown 

func (m *QueryPoolWithdrawSuccessMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolWithdrawSuccessMsgsResponse) XXX_Marshal 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) XXX_Merge 

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

func (*QueryPoolWithdrawSuccessMsgsResponse) XXX_Size 

func (m *QueryPoolWithdrawSuccessMsgsResponse) XXX_Size() int

func (*QueryPoolWithdrawSuccessMsgsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Get existing liquidity pools.
	LiquidityPools(context.Context, *QueryLiquidityPoolsRequest) (*QueryLiquidityPoolsResponse, error)
	// Get specific liquidity pool.
	LiquidityPool(context.Context, *QueryLiquidityPoolRequest) (*QueryLiquidityPoolResponse, error)
	// Get specific liquidity pool corresponding to the pool_coin_denom.
	LiquidityPoolByPoolCoinDenom(context.Context, *QueryLiquidityPoolByPoolCoinDenomRequest) (*QueryLiquidityPoolResponse, error)
	// Get specific liquidity pool corresponding to the reserve account.
	LiquidityPoolByReserveAcc(context.Context, *QueryLiquidityPoolByReserveAccRequest) (*QueryLiquidityPoolResponse, error)
	// Get the pool's current batch.
	LiquidityPoolBatch(context.Context, *QueryLiquidityPoolBatchRequest) (*QueryLiquidityPoolBatchResponse, error)
	// Get all swap messages in the pool's current batch.
	PoolBatchSwapMsgs(context.Context, *QueryPoolBatchSwapMsgsRequest) (*QueryPoolBatchSwapMsgsResponse, error)
	// Get a specific swap message in the pool's current batch.
	PoolBatchSwapMsg(context.Context, *QueryPoolBatchSwapMsgRequest) (*QueryPoolBatchSwapMsgResponse, error)
	// Get all deposit messages in the pool's current batch.
	PoolBatchDepositMsgs(context.Context, *QueryPoolBatchDepositMsgsRequest) (*QueryPoolBatchDepositMsgsResponse, error)
	// Get a specific deposit message in the pool's current batch.
	PoolBatchDepositMsg(context.Context, *QueryPoolBatchDepositMsgRequest) (*QueryPoolBatchDepositMsgResponse, error)
	// Get all withdraw messages in the pool's current batch.
	PoolBatchWithdrawMsgs(context.Context, *QueryPoolBatchWithdrawMsgsRequest) (*QueryPoolBatchWithdrawMsgsResponse, error)
	// Get a specific withdraw message in the pool's current batch.
	PoolBatchWithdrawMsg(context.Context, *QueryPoolBatchWithdrawMsgRequest) (*QueryPoolBatchWithdrawMsgResponse, error)
	// Get all parameters of the liquidity module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// ==============================finish deposit msg===============================//
	// Get deposit finish messages in the pool's current by msg_index.
	PoolDepositSuccessMsg(context.Context, *QueryPoolDepositSuccessMsgRequest) (*QueryPoolDepositSuccessMsgResponse, error)
	// Get all deposit finish messages in the pool's current.
	PoolDepositSuccessMsgs(context.Context, *QueryPoolDepositSuccessMsgsRequest) (*QueryPoolDepositSuccessMsgsResponse, error)
	// ==============================finish swap msg===============================//
	PoolSwapSuccessMsg(context.Context, *QueryPoolSwapSuccessMsgRequest) (*QueryPoolSwapSuccessMsgResponse, error)
	// Get all swap finish messages in the pool's current.
	PoolSwapSuccessMsgs(context.Context, *QueryPoolSwapSuccessMsgsRequest) (*QueryPoolSwapSuccessMsgsResponse, error)
	// ==============================finish withdraw msg===============================//
	PoolWithdrawSuccessMsg(context.Context, *QueryPoolWithdrawSuccessMsgRequest) (*QueryPoolWithdrawSuccessMsgResponse, error)
	// Get all withdraw finish messages in the pool's current.
	PoolWithdrawSuccessMsgs(context.Context, *QueryPoolWithdrawSuccessMsgsRequest) (*QueryPoolWithdrawSuccessMsgsResponse, error)
}

QueryServer is the server API for Query service.

type RemoveLiquidityRequest 

type RemoveLiquidityRequest struct {
	MinTokenAmt sdk.Int
	MinBaseAmt  sdk.Int
	Liquidity   sdk.Coin
	Deadline    int64
}

type RemoveLiquidityResponse 

type RemoveLiquidityResponse struct {
	TokenAmt  sdk.Int
	BaseAmt   sdk.Int
	Liquidity sdk.Coin
	TxHash    string
}

type SwapCoinRequest 

type SwapCoinRequest struct {
	PoolId          uint64
	OfferCoin       sdk.Coin
	DemandCoinDenom string
	SwapFeeRate     string
	OrderPrice      string
}

type SwapCoinResponse 

type SwapCoinResponse struct {
	InputAmt  sdk.Int
	OutputAmt sdk.Int
	TxHash    string
}

type SwapMsgState 

type SwapMsgState 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
	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 to 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
	ReservedOfferCoinFee types.Coin `` /* 146-byte string literal not displayed */
	// MsgSwapWithinBatch
	Msg *MsgSwapWithinBatch `protobuf:"bytes,10,opt,name=msg,proto3" json:"msg,omitempty" yaml:"msg"`
}

SwapMsgState defines the state of the swap message that contains state information as the message is processed in the next batch or batches.

func (*SwapMsgState) Descriptor 

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

func (*SwapMsgState) Marshal 

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

func (*SwapMsgState) MarshalTo 

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

func (*SwapMsgState) MarshalToSizedBuffer 

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

func (*SwapMsgState) ProtoMessage 

func (*SwapMsgState) ProtoMessage()

func (*SwapMsgState) Reset 

func (m *SwapMsgState) Reset()

func (*SwapMsgState) Size 

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

func (*SwapMsgState) String 

func (m *SwapMsgState) String() string

func (*SwapMsgState) Unmarshal 

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

func (*SwapMsgState) XXX_DiscardUnknown 

func (m *SwapMsgState) XXX_DiscardUnknown()

func (*SwapMsgState) XXX_Marshal 

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

func (*SwapMsgState) XXX_Merge 

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

func (*SwapMsgState) XXX_Size 

func (m *SwapMsgState) XXX_Size() int

func (*SwapMsgState) XXX_Unmarshal 

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

type SwapSuccessMsg 

type SwapSuccessMsg struct {
	// height where this message is appended to the success swap
	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"`
	// 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
	ReservedOfferCoinFee types.Coin `` /* 146-byte string literal not displayed */
	// Limit the size of each liquidity pool to minimize risk. In development, set to 0 for no limit. In production, set a limit.
	SwapPrice github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Dec `` /* 167-byte string literal not displayed */
	// reserve fee for pays fee in half offer coin
	GetCoin types.Coin `protobuf:"bytes,7,opt,name=get_coin,json=getCoin,proto3" json:"get_coin" yaml:"get_coin"`
	// MsgSwapWithinBatch
	Msg *MsgSwapWithinBatch `protobuf:"bytes,8,opt,name=msg,proto3" json:"msg,omitempty" yaml:"msg"`
}

func (*SwapSuccessMsg) Descriptor 

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

func (*SwapSuccessMsg) Marshal 

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

func (*SwapSuccessMsg) MarshalTo 

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

func (*SwapSuccessMsg) MarshalToSizedBuffer 

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

func (*SwapSuccessMsg) ProtoMessage 

func (*SwapSuccessMsg) ProtoMessage()

func (*SwapSuccessMsg) Reset 

func (m *SwapSuccessMsg) Reset()

func (*SwapSuccessMsg) Size 

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

func (*SwapSuccessMsg) String 

func (m *SwapSuccessMsg) String() string

func (*SwapSuccessMsg) Unmarshal 

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

func (*SwapSuccessMsg) XXX_DiscardUnknown 

func (m *SwapSuccessMsg) XXX_DiscardUnknown()

func (*SwapSuccessMsg) XXX_Marshal 

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

func (*SwapSuccessMsg) XXX_Merge 

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

func (*SwapSuccessMsg) XXX_Size 

func (m *SwapSuccessMsg) XXX_Size() int

func (*SwapSuccessMsg) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreatePool 

func (*UnimplementedMsgServer) CreatePool(ctx context.Context, req *MsgCreatePool) (*MsgCreatePoolResponse, error)

func (*UnimplementedMsgServer) DepositWithinBatch 

func (*UnimplementedMsgServer) DepositWithinBatch(ctx context.Context, req *MsgDepositWithinBatch) (*MsgDepositWithinBatchResponse, error)

func (*UnimplementedMsgServer) Swap 

func (*UnimplementedMsgServer) Swap(ctx context.Context, req *MsgSwapWithinBatch) (*MsgSwapWithinBatchResponse, error)

func (*UnimplementedMsgServer) WithdrawWithinBatch 

func (*UnimplementedMsgServer) WithdrawWithinBatch(ctx context.Context, req *MsgWithdrawWithinBatch) (*MsgWithdrawWithinBatchResponse, 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) LiquidityPoolByPoolCoinDenom 

func (*UnimplementedQueryServer) LiquidityPoolByPoolCoinDenom(ctx context.Context, req *QueryLiquidityPoolByPoolCoinDenomRequest) (*QueryLiquidityPoolResponse, error)

func (*UnimplementedQueryServer) LiquidityPoolByReserveAcc 

func (*UnimplementedQueryServer) LiquidityPoolByReserveAcc(ctx context.Context, req *QueryLiquidityPoolByReserveAccRequest) (*QueryLiquidityPoolResponse, error)

func (*UnimplementedQueryServer) LiquidityPools 

func (*UnimplementedQueryServer) LiquidityPools(ctx context.Context, req *QueryLiquidityPoolsRequest) (*QueryLiquidityPoolsResponse, 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)

func (*UnimplementedQueryServer) PoolDepositSuccessMsg 

func (*UnimplementedQueryServer) PoolDepositSuccessMsg(ctx context.Context, req *QueryPoolDepositSuccessMsgRequest) (*QueryPoolDepositSuccessMsgResponse, error)

func (*UnimplementedQueryServer) PoolDepositSuccessMsgs 

func (*UnimplementedQueryServer) PoolDepositSuccessMsgs(ctx context.Context, req *QueryPoolDepositSuccessMsgsRequest) (*QueryPoolDepositSuccessMsgsResponse, error)

func (*UnimplementedQueryServer) PoolSwapSuccessMsg 

func (*UnimplementedQueryServer) PoolSwapSuccessMsg(ctx context.Context, req *QueryPoolSwapSuccessMsgRequest) (*QueryPoolSwapSuccessMsgResponse, error)

func (*UnimplementedQueryServer) PoolSwapSuccessMsgs 

func (*UnimplementedQueryServer) PoolSwapSuccessMsgs(ctx context.Context, req *QueryPoolSwapSuccessMsgsRequest) (*QueryPoolSwapSuccessMsgsResponse, error)

func (*UnimplementedQueryServer) PoolWithdrawSuccessMsg 

func (*UnimplementedQueryServer) PoolWithdrawSuccessMsg(ctx context.Context, req *QueryPoolWithdrawSuccessMsgRequest) (*QueryPoolWithdrawSuccessMsgResponse, error)

func (*UnimplementedQueryServer) PoolWithdrawSuccessMsgs 

func (*UnimplementedQueryServer) PoolWithdrawSuccessMsgs(ctx context.Context, req *QueryPoolWithdrawSuccessMsgsRequest) (*QueryPoolWithdrawSuccessMsgsResponse, error)

type WithdrawMsgState 

type WithdrawMsgState 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
	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"`
	// MsgWithdrawWithinBatch
	Msg *MsgWithdrawWithinBatch `protobuf:"bytes,6,opt,name=msg,proto3" json:"msg,omitempty" yaml:"msg"`
}

WithdrawMsgState defines the state of the withdraw message that contains state information as the message is processed in the next batch or batches.

func (*WithdrawMsgState) Descriptor 

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

func (*WithdrawMsgState) Marshal 

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

func (*WithdrawMsgState) MarshalTo 

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

func (*WithdrawMsgState) MarshalToSizedBuffer 

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

func (*WithdrawMsgState) ProtoMessage 

func (*WithdrawMsgState) ProtoMessage()

func (*WithdrawMsgState) Reset 

func (m *WithdrawMsgState) Reset()

func (*WithdrawMsgState) Size 

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

func (*WithdrawMsgState) String 

func (m *WithdrawMsgState) String() string

func (*WithdrawMsgState) Unmarshal 

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

func (*WithdrawMsgState) XXX_DiscardUnknown 

func (m *WithdrawMsgState) XXX_DiscardUnknown()

func (*WithdrawMsgState) XXX_Marshal 

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

func (*WithdrawMsgState) XXX_Merge 

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

func (*WithdrawMsgState) XXX_Size 

func (m *WithdrawMsgState) XXX_Size() int

func (*WithdrawMsgState) XXX_Unmarshal 

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

type WithdrawSuccessMsg 

type WithdrawSuccessMsg 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"`
	// Successfully withdraw quantity
	WithdrawCoins github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Coins `` /* 187-byte string literal not displayed */
	// Successfully withdraw quantity
	WithdrawFeeCoins github_com_oracleNetworkProtocol_plugchain_sdk_go_types.Coins `` /* 202-byte string literal not displayed */
	// MsgWithdrawWithinBatch
	Msg *MsgWithdrawWithinBatch `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty" yaml:"msg"`
}

WithdrawSuccessMsg withdraw success record.

func (*WithdrawSuccessMsg) Descriptor 

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

func (*WithdrawSuccessMsg) Marshal 

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

func (*WithdrawSuccessMsg) MarshalTo 

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

func (*WithdrawSuccessMsg) MarshalToSizedBuffer 

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

func (*WithdrawSuccessMsg) ProtoMessage 

func (*WithdrawSuccessMsg) ProtoMessage()

func (*WithdrawSuccessMsg) Reset 

func (m *WithdrawSuccessMsg) Reset()

func (*WithdrawSuccessMsg) Size 

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

func (*WithdrawSuccessMsg) String 

func (m *WithdrawSuccessMsg) String() string

func (*WithdrawSuccessMsg) Unmarshal 

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

func (*WithdrawSuccessMsg) XXX_DiscardUnknown 

func (m *WithdrawSuccessMsg) XXX_DiscardUnknown()

func (*WithdrawSuccessMsg) XXX_Marshal 

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

func (*WithdrawSuccessMsg) XXX_Merge 

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

func (*WithdrawSuccessMsg) XXX_Size 

func (m *WithdrawSuccessMsg) XXX_Size() int

func (*WithdrawSuccessMsg) XXX_Unmarshal 

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

type WithdrawWithinBatchRequest 

type WithdrawWithinBatchRequest struct {
	PoolId uint64
}

type WithdrawWithinRequest 

type WithdrawWithinRequest struct {
	PoolId   uint64
	PoolCoin sdk.Coin
}

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.