liquidity

package
v0.5.0-rc12 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2023 License: MIT Imports: 20 Imported by: 0

Documentation

Overview

nolint

nolint

nolint

Index

Constants

View Source 
const (
	EventTypeSwapTransacted = "swap_transacted"

	AttributeValuePoolID     = "pool_id"
	AttributeValueBatchIndex = "batch_index"
	AttributeValueMsgIndex   = "msg_index"

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

	AttributeValueSuccess       = "success"
	AttributeValueSwapRequester = "swap_requester"
	AttributeValueSwapPrice     = "swap_price"

	AttributeValueTransactedCoinAmount      = "transacted_coin_amount"
	AttributeValueRemainingOfferCoinAmount  = "remaining_offer_coin_amount"
	AttributeValueExchangedOfferCoinAmount  = "exchanged_offer_coin_amount"
	AttributeValueExchangedDemandCoinAmount = "exchanged_demand_coin_amount"
	AttributeValueOrderExpiryHeight         = "order_expiry_height"

	Success = "success"
)

Event types for the liquidity module.

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

	// RouterKey is the message router key for the liquidity module
	RouterKey = ModuleName
)
View Source 
const (
	TypeMsgCreatePool          = "create_pool"
	TypeMsgDepositWithinBatch  = "deposit_within_batch"
	TypeMsgWithdrawWithinBatch = "withdraw_within_batch"
	TypeMsgSwapWithinBatch     = "swap_within_batch"
)

Message types for the liquidity module

View Source 
const (
	// MinReserveCoinNum is the minimum number of reserve coins in each liquidity pool.
	MinReserveCoinNum uint32 = 2

	// MaxReserveCoinNum is the maximum number of reserve coins in each liquidity pool.
	MaxReserveCoinNum uint32 = 2
)

Variables

View Source 
var (
	ErrNumOfReserveCoin         = sdkerrors.Register(ModuleName, 5, "invalid number of reserve coin")
	ErrInvalidPoolCreatorAddr   = sdkerrors.Register(ModuleName, 15, "invalid pool creator address")
	ErrInvalidDepositorAddr     = sdkerrors.Register(ModuleName, 16, "invalid pool depositor address")
	ErrInvalidWithdrawerAddr    = sdkerrors.Register(ModuleName, 17, "invalid pool withdrawer address")
	ErrInvalidSwapRequesterAddr = sdkerrors.Register(ModuleName, 18, "invalid pool swap requester address")
	ErrBadPoolCoinAmount        = sdkerrors.Register(ModuleName, 19, "invalid pool coin amount")
	ErrBadDepositCoinsAmount    = sdkerrors.Register(ModuleName, 20, "invalid deposit coins amount")
	ErrBadOfferCoinAmount       = sdkerrors.Register(ModuleName, 21, "invalid offer coin amount")
	ErrBadOrderPrice            = sdkerrors.Register(ModuleName, 23, "invalid order price")
	ErrLessThanMinOfferAmount   = sdkerrors.Register(ModuleName, 34, "offer amount should be over 100 micro")
	ErrBadPoolTypeID            = sdkerrors.Register(ModuleName, 37, "invalid index of the pool type")
)

liquidity module sentinel errors

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 (
	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 (
	MinOfferCoinAmount = sdk.NewInt(100)
)
View Source 
var (

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

legacy amino codecs

Functions

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

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

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers concrete types on the codec.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryServer added in v0.2.4 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type DepositMsgState added in v0.2.4 

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 added in v0.2.4 

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

func (*DepositMsgState) Marshal added in v0.2.4 

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

func (*DepositMsgState) MarshalTo added in v0.2.4 

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

func (*DepositMsgState) MarshalToSizedBuffer added in v0.2.4 

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

func (*DepositMsgState) ProtoMessage added in v0.2.4 

func (*DepositMsgState) ProtoMessage()

func (*DepositMsgState) Reset added in v0.2.4 

func (m *DepositMsgState) Reset()

func (*DepositMsgState) Size added in v0.2.4 

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

func (*DepositMsgState) String added in v0.2.4 

func (m *DepositMsgState) String() string

func (*DepositMsgState) Unmarshal added in v0.2.4 

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

func (*DepositMsgState) XXX_DiscardUnknown added in v0.2.4 

func (m *DepositMsgState) XXX_DiscardUnknown()

func (*DepositMsgState) XXX_Marshal added in v0.2.4 

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

func (*DepositMsgState) XXX_Merge added in v0.2.4 

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

func (*DepositMsgState) XXX_Size added in v0.2.4 

func (m *DepositMsgState) XXX_Size() int

func (*DepositMsgState) XXX_Unmarshal added in v0.2.4 

func (m *DepositMsgState) 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/gravity-devs/liquidity/blob/develop/x/liquidity/spec/04_messages.md

func (*MsgCreatePool) Descriptor 

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

func (MsgCreatePool) GetPoolCreator 

func (msg MsgCreatePool) GetPoolCreator() sdk.AccAddress

func (MsgCreatePool) GetSignBytes 

func (msg MsgCreatePool) GetSignBytes() []byte

func (MsgCreatePool) GetSigners 

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

func (*MsgCreatePool) Marshal 

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

func (*MsgCreatePool) MarshalTo 

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

func (*MsgCreatePool) MarshalToSizedBuffer 

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

func (*MsgCreatePool) ProtoMessage 

func (*MsgCreatePool) ProtoMessage()

func (*MsgCreatePool) Reset 

func (m *MsgCreatePool) Reset()

func (MsgCreatePool) Route 

func (msg MsgCreatePool) Route() string

func (*MsgCreatePool) Size 

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

func (*MsgCreatePool) String 

func (m *MsgCreatePool) String() string

func (MsgCreatePool) Type 

func (msg MsgCreatePool) Type() string

func (*MsgCreatePool) Unmarshal 

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

func (MsgCreatePool) ValidateBasic 

func (msg MsgCreatePool) ValidateBasic() error

func (*MsgCreatePool) XXX_DiscardUnknown 

func (m *MsgCreatePool) XXX_DiscardUnknown()

func (*MsgCreatePool) XXX_Marshal 

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

func (*MsgCreatePool) XXX_Merge 

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

func (*MsgCreatePool) XXX_Size 

func (m *MsgCreatePool) XXX_Size() int

func (*MsgCreatePool) XXX_Unmarshal 

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

type MsgCreatePoolResponse 

type MsgCreatePoolResponse struct {
}

MsgCreatePoolResponse defines the Msg/CreatePool response type.

func (*MsgCreatePoolResponse) Descriptor 

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

func (*MsgCreatePoolResponse) Marshal 

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

func (*MsgCreatePoolResponse) MarshalTo 

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

func (*MsgCreatePoolResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePoolResponse) ProtoMessage 

func (*MsgCreatePoolResponse) ProtoMessage()

func (*MsgCreatePoolResponse) Reset 

func (m *MsgCreatePoolResponse) Reset()

func (*MsgCreatePoolResponse) Size 

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

func (*MsgCreatePoolResponse) String 

func (m *MsgCreatePoolResponse) String() string

func (*MsgCreatePoolResponse) Unmarshal 

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

func (*MsgCreatePoolResponse) XXX_DiscardUnknown 

func (m *MsgCreatePoolResponse) XXX_DiscardUnknown()

func (*MsgCreatePoolResponse) XXX_Marshal 

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

func (*MsgCreatePoolResponse) XXX_Merge 

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

func (*MsgCreatePoolResponse) XXX_Size 

func (m *MsgCreatePoolResponse) XXX_Size() int

func (*MsgCreatePoolResponse) XXX_Unmarshal 

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

type 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/gravity-devs/liquidity/blob/develop/x/liquidity/spec/04_messages.md

func NewMsgDepositWithinBatch 

func NewMsgDepositWithinBatch(depositor sdk.AccAddress, poolID uint64, depositCoins sdk.Coins) *MsgDepositWithinBatch

NewMsgDepositWithinBatch creates a new MsgDepositWithinBatch.

func (*MsgDepositWithinBatch) Descriptor 

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

func (MsgDepositWithinBatch) GetDepositor 

func (msg MsgDepositWithinBatch) GetDepositor() sdk.AccAddress

func (MsgDepositWithinBatch) GetSignBytes 

func (msg MsgDepositWithinBatch) GetSignBytes() []byte

func (MsgDepositWithinBatch) GetSigners 

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

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

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

func (*MsgDepositWithinBatch) Unmarshal 

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

func (MsgDepositWithinBatch) ValidateBasic 

func (msg MsgDepositWithinBatch) ValidateBasic() error

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/gravity-devs/liquidity/tree/develop/doc https://github.com/gravity-devs/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

func (MsgSwapWithinBatch) GetSigners 

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

func (MsgSwapWithinBatch) GetSwapRequester 

func (msg MsgSwapWithinBatch) GetSwapRequester() sdk.AccAddress

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

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

func (*MsgSwapWithinBatch) Unmarshal 

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

func (MsgSwapWithinBatch) ValidateBasic 

func (msg MsgSwapWithinBatch) ValidateBasic() error

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/gravity-devs/liquidity/blob/develop/x/liquidity/spec/04_messages.md

func NewMsgWithdrawWithinBatch 

func NewMsgWithdrawWithinBatch(withdrawer sdk.AccAddress, poolID uint64, poolCoin sdk.Coin) *MsgWithdrawWithinBatch

NewMsgWithdrawWithinBatch creates a new MsgWithdrawWithinBatch.

func (*MsgWithdrawWithinBatch) Descriptor 

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

func (MsgWithdrawWithinBatch) GetSignBytes 

func (msg MsgWithdrawWithinBatch) GetSignBytes() []byte

func (MsgWithdrawWithinBatch) GetSigners 

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

func (MsgWithdrawWithinBatch) GetWithdrawer 

func (msg MsgWithdrawWithinBatch) GetWithdrawer() sdk.AccAddress

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

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

func (*MsgWithdrawWithinBatch) Unmarshal 

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

func (MsgWithdrawWithinBatch) ValidateBasic 

func (msg MsgWithdrawWithinBatch) ValidateBasic() error

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 added in v0.2.4 

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_cosmos_cosmos_sdk_types.Int `` /* 196-byte string literal not displayed */
	// Initial mint amount of pool coins upon pool creation.
	InitPoolCoinMintAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 207-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_cosmos_cosmos_sdk_types.Int `` /* 196-byte string literal not displayed */
	// Fee paid to create a Liquidity Pool. Set a fee to prevent spamming.
	PoolCreationFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 177-byte string literal not displayed */
	// Swap fee rate for every executed swap.
	SwapFeeRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 157-byte string literal not displayed */
	// Reserve coin withdrawal with less proportion by withdrawFeeRate.
	WithdrawFeeRate github_com_cosmos_cosmos_sdk_types.Dec `` /* 173-byte string literal not displayed */
	// Maximum ratio of reserve coins that can be ordered at a swap order.
	MaxOrderAmountRatio github_com_cosmos_cosmos_sdk_types.Dec `` /* 192-byte string literal not displayed */
	// The smallest unit batch 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 added in v0.2.4 

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

func (*Params) Equal added in v0.2.4 

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

func (*Params) Marshal added in v0.2.4 

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

func (*Params) MarshalTo added in v0.2.4 

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

func (*Params) MarshalToSizedBuffer added in v0.2.4 

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

func (*Params) ProtoMessage added in v0.2.4 

func (*Params) ProtoMessage()

func (*Params) Reset added in v0.2.4 

func (m *Params) Reset()

func (*Params) Size added in v0.2.4 

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

func (Params) String added in v0.2.4 

func (p Params) String() string

String returns a human readable string representation of the parameters.

func (*Params) Unmarshal added in v0.2.4 

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

func (*Params) XXX_DiscardUnknown added in v0.2.4 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal added in v0.2.4 

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

func (*Params) XXX_Merge added in v0.2.4 

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

func (*Params) XXX_Size added in v0.2.4 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal added in v0.2.4 

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

type Pool added in v0.2.4 

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 added in v0.2.4 

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

func (*Pool) Equal added in v0.2.4 

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

func (*Pool) Marshal added in v0.2.4 

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

func (*Pool) MarshalTo added in v0.2.4 

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

func (*Pool) MarshalToSizedBuffer added in v0.2.4 

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

func (*Pool) ProtoMessage added in v0.2.4 

func (*Pool) ProtoMessage()

func (*Pool) Reset added in v0.2.4 

func (m *Pool) Reset()

func (*Pool) Size added in v0.2.4 

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

func (*Pool) String added in v0.2.4 

func (m *Pool) String() string

func (*Pool) Unmarshal added in v0.2.4 

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

func (*Pool) XXX_DiscardUnknown added in v0.2.4 

func (m *Pool) XXX_DiscardUnknown()

func (*Pool) XXX_Marshal added in v0.2.4 

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

func (*Pool) XXX_Merge added in v0.2.4 

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

func (*Pool) XXX_Size added in v0.2.4 

func (m *Pool) XXX_Size() int

func (*Pool) XXX_Unmarshal added in v0.2.4 

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

type PoolBatch added in v0.2.4 

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 added in v0.2.4 

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

func (*PoolBatch) Equal added in v0.2.4 

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

func (*PoolBatch) Marshal added in v0.2.4 

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

func (*PoolBatch) MarshalTo added in v0.2.4 

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

func (*PoolBatch) MarshalToSizedBuffer added in v0.2.4 

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

func (*PoolBatch) ProtoMessage added in v0.2.4 

func (*PoolBatch) ProtoMessage()

func (*PoolBatch) Reset added in v0.2.4 

func (m *PoolBatch) Reset()

func (*PoolBatch) Size added in v0.2.4 

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

func (*PoolBatch) String added in v0.2.4 

func (m *PoolBatch) String() string

func (*PoolBatch) Unmarshal added in v0.2.4 

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

func (*PoolBatch) XXX_DiscardUnknown added in v0.2.4 

func (m *PoolBatch) XXX_DiscardUnknown()

func (*PoolBatch) XXX_Marshal added in v0.2.4 

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

func (*PoolBatch) XXX_Merge added in v0.2.4 

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

func (*PoolBatch) XXX_Size added in v0.2.4 

func (m *PoolBatch) XXX_Size() int

func (*PoolBatch) XXX_Unmarshal added in v0.2.4 

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

type PoolMetadata added in v0.2.4 

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_cosmos_cosmos_sdk_types.Coins `` /* 162-byte string literal not displayed */
}

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

func (*PoolMetadata) Descriptor added in v0.2.4 

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

func (*PoolMetadata) Equal added in v0.2.4 

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

func (*PoolMetadata) Marshal added in v0.2.4 

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

func (*PoolMetadata) MarshalTo added in v0.2.4 

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

func (*PoolMetadata) MarshalToSizedBuffer added in v0.2.4 

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

func (*PoolMetadata) ProtoMessage added in v0.2.4 

func (*PoolMetadata) ProtoMessage()

func (*PoolMetadata) Reset added in v0.2.4 

func (m *PoolMetadata) Reset()

func (*PoolMetadata) Size added in v0.2.4 

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

func (*PoolMetadata) String added in v0.2.4 

func (m *PoolMetadata) String() string

func (*PoolMetadata) Unmarshal added in v0.2.4 

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

func (*PoolMetadata) XXX_DiscardUnknown added in v0.2.4 

func (m *PoolMetadata) XXX_DiscardUnknown()

func (*PoolMetadata) XXX_Marshal added in v0.2.4 

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

func (*PoolMetadata) XXX_Merge added in v0.2.4 

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

func (*PoolMetadata) XXX_Size added in v0.2.4 

func (m *PoolMetadata) XXX_Size() int

func (*PoolMetadata) XXX_Unmarshal added in v0.2.4 

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

type PoolType added in v0.2.4 

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 added in v0.2.4 

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

func (*PoolType) Equal added in v0.2.4 

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

func (*PoolType) Marshal added in v0.2.4 

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

func (*PoolType) MarshalTo added in v0.2.4 

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

func (*PoolType) MarshalToSizedBuffer added in v0.2.4 

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

func (*PoolType) ProtoMessage added in v0.2.4 

func (*PoolType) ProtoMessage()

func (*PoolType) Reset added in v0.2.4 

func (m *PoolType) Reset()

func (*PoolType) Size added in v0.2.4 

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

func (*PoolType) String added in v0.2.4 

func (m *PoolType) String() string

func (*PoolType) Unmarshal added in v0.2.4 

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

func (*PoolType) XXX_DiscardUnknown added in v0.2.4 

func (m *PoolType) XXX_DiscardUnknown()

func (*PoolType) XXX_Marshal added in v0.2.4 

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

func (*PoolType) XXX_Merge added in v0.2.4 

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

func (*PoolType) XXX_Size added in v0.2.4 

func (m *PoolType) XXX_Size() int

func (*PoolType) XXX_Unmarshal added in v0.2.4 

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

type QueryClient added in v0.2.4 

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

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 added in v0.2.4 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryLiquidityPoolBatchRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryLiquidityPoolBatchRequest) GetPoolId added in v0.2.4 

func (m *QueryLiquidityPoolBatchRequest) GetPoolId() uint64

func (*QueryLiquidityPoolBatchRequest) Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolBatchRequest) MarshalTo added in v0.2.4 

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

func (*QueryLiquidityPoolBatchRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryLiquidityPoolBatchRequest) ProtoMessage added in v0.2.4 

func (*QueryLiquidityPoolBatchRequest) ProtoMessage()

func (*QueryLiquidityPoolBatchRequest) Reset added in v0.2.4 

func (m *QueryLiquidityPoolBatchRequest) Reset()

func (*QueryLiquidityPoolBatchRequest) Size added in v0.2.4 

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

func (*QueryLiquidityPoolBatchRequest) String added in v0.2.4 

func (m *QueryLiquidityPoolBatchRequest) String() string

func (*QueryLiquidityPoolBatchRequest) Unmarshal added in v0.2.4 

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

func (*QueryLiquidityPoolBatchRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryLiquidityPoolBatchRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolBatchRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolBatchRequest) XXX_Merge added in v0.2.4 

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

func (*QueryLiquidityPoolBatchRequest) XXX_Size added in v0.2.4 

func (m *QueryLiquidityPoolBatchRequest) XXX_Size() int

func (*QueryLiquidityPoolBatchRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryLiquidityPoolBatchResponse added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryLiquidityPoolBatchResponse) GetBatch added in v0.2.4 

func (m *QueryLiquidityPoolBatchResponse) GetBatch() PoolBatch

func (*QueryLiquidityPoolBatchResponse) Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolBatchResponse) MarshalTo added in v0.2.4 

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

func (*QueryLiquidityPoolBatchResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryLiquidityPoolBatchResponse) ProtoMessage added in v0.2.4 

func (*QueryLiquidityPoolBatchResponse) ProtoMessage()

func (*QueryLiquidityPoolBatchResponse) Reset added in v0.2.4 

func (m *QueryLiquidityPoolBatchResponse) Reset()

func (*QueryLiquidityPoolBatchResponse) Size added in v0.2.4 

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

func (*QueryLiquidityPoolBatchResponse) String added in v0.2.4 

func (m *QueryLiquidityPoolBatchResponse) String() string

func (*QueryLiquidityPoolBatchResponse) Unmarshal added in v0.2.4 

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

func (*QueryLiquidityPoolBatchResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryLiquidityPoolBatchResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolBatchResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolBatchResponse) XXX_Merge added in v0.2.4 

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

func (*QueryLiquidityPoolBatchResponse) XXX_Size added in v0.2.4 

func (m *QueryLiquidityPoolBatchResponse) XXX_Size() int

func (*QueryLiquidityPoolBatchResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryLiquidityPoolByPoolCoinDenomRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) GetPoolCoinDenom added in v0.2.4 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) GetPoolCoinDenom() string

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) MarshalTo added in v0.2.4 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) ProtoMessage added in v0.2.4 

func (*QueryLiquidityPoolByPoolCoinDenomRequest) ProtoMessage()

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Reset added in v0.2.4 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) Reset()

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Size added in v0.2.4 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) String added in v0.2.4 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) String() string

func (*QueryLiquidityPoolByPoolCoinDenomRequest) Unmarshal added in v0.2.4 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Merge added in v0.2.4 

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

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Size added in v0.2.4 

func (m *QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Size() int

func (*QueryLiquidityPoolByPoolCoinDenomRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryLiquidityPoolByReserveAccRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryLiquidityPoolByReserveAccRequest) GetReserveAcc added in v0.2.4 

func (m *QueryLiquidityPoolByReserveAccRequest) GetReserveAcc() string

func (*QueryLiquidityPoolByReserveAccRequest) Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolByReserveAccRequest) MarshalTo added in v0.2.4 

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

func (*QueryLiquidityPoolByReserveAccRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryLiquidityPoolByReserveAccRequest) ProtoMessage added in v0.2.4 

func (*QueryLiquidityPoolByReserveAccRequest) ProtoMessage()

func (*QueryLiquidityPoolByReserveAccRequest) Reset added in v0.2.4 

func (m *QueryLiquidityPoolByReserveAccRequest) Reset()

func (*QueryLiquidityPoolByReserveAccRequest) Size added in v0.2.4 

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

func (*QueryLiquidityPoolByReserveAccRequest) String added in v0.2.4 

func (m *QueryLiquidityPoolByReserveAccRequest) String() string

func (*QueryLiquidityPoolByReserveAccRequest) Unmarshal added in v0.2.4 

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

func (*QueryLiquidityPoolByReserveAccRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryLiquidityPoolByReserveAccRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolByReserveAccRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolByReserveAccRequest) XXX_Merge added in v0.2.4 

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

func (*QueryLiquidityPoolByReserveAccRequest) XXX_Size added in v0.2.4 

func (m *QueryLiquidityPoolByReserveAccRequest) XXX_Size() int

func (*QueryLiquidityPoolByReserveAccRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryLiquidityPoolRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryLiquidityPoolRequest) GetPoolId added in v0.2.4 

func (m *QueryLiquidityPoolRequest) GetPoolId() uint64

func (*QueryLiquidityPoolRequest) Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolRequest) MarshalTo added in v0.2.4 

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

func (*QueryLiquidityPoolRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryLiquidityPoolRequest) ProtoMessage added in v0.2.4 

func (*QueryLiquidityPoolRequest) ProtoMessage()

func (*QueryLiquidityPoolRequest) Reset added in v0.2.4 

func (m *QueryLiquidityPoolRequest) Reset()

func (*QueryLiquidityPoolRequest) Size added in v0.2.4 

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

func (*QueryLiquidityPoolRequest) String added in v0.2.4 

func (m *QueryLiquidityPoolRequest) String() string

func (*QueryLiquidityPoolRequest) Unmarshal added in v0.2.4 

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

func (*QueryLiquidityPoolRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryLiquidityPoolRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolRequest) XXX_Merge added in v0.2.4 

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

func (*QueryLiquidityPoolRequest) XXX_Size added in v0.2.4 

func (m *QueryLiquidityPoolRequest) XXX_Size() int

func (*QueryLiquidityPoolRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryLiquidityPoolResponse added in v0.2.4 

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) Descriptor added in v0.2.4 

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

func (*QueryLiquidityPoolResponse) GetPool added in v0.2.4 

func (m *QueryLiquidityPoolResponse) GetPool() Pool

func (*QueryLiquidityPoolResponse) Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolResponse) MarshalTo added in v0.2.4 

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

func (*QueryLiquidityPoolResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryLiquidityPoolResponse) ProtoMessage added in v0.2.4 

func (*QueryLiquidityPoolResponse) ProtoMessage()

func (*QueryLiquidityPoolResponse) Reset added in v0.2.4 

func (m *QueryLiquidityPoolResponse) Reset()

func (*QueryLiquidityPoolResponse) Size added in v0.2.4 

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

func (*QueryLiquidityPoolResponse) String added in v0.2.4 

func (m *QueryLiquidityPoolResponse) String() string

func (*QueryLiquidityPoolResponse) Unmarshal added in v0.2.4 

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

func (*QueryLiquidityPoolResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryLiquidityPoolResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolResponse) XXX_Merge added in v0.2.4 

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

func (*QueryLiquidityPoolResponse) XXX_Size added in v0.2.4 

func (m *QueryLiquidityPoolResponse) XXX_Size() int

func (*QueryLiquidityPoolResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryLiquidityPoolsRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) GetPagination added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) MarshalTo added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) ProtoMessage added in v0.2.4 

func (*QueryLiquidityPoolsRequest) ProtoMessage()

func (*QueryLiquidityPoolsRequest) Reset added in v0.2.4 

func (m *QueryLiquidityPoolsRequest) Reset()

func (*QueryLiquidityPoolsRequest) Size added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) String added in v0.2.4 

func (m *QueryLiquidityPoolsRequest) String() string

func (*QueryLiquidityPoolsRequest) Unmarshal added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryLiquidityPoolsRequest) XXX_DiscardUnknown()

func (*QueryLiquidityPoolsRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) XXX_Merge added in v0.2.4 

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

func (*QueryLiquidityPoolsRequest) XXX_Size added in v0.2.4 

func (m *QueryLiquidityPoolsRequest) XXX_Size() int

func (*QueryLiquidityPoolsRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryLiquidityPoolsResponse added in v0.2.4 

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) Descriptor added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) GetPagination added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) GetPools added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) MarshalTo added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) ProtoMessage added in v0.2.4 

func (*QueryLiquidityPoolsResponse) ProtoMessage()

func (*QueryLiquidityPoolsResponse) Reset added in v0.2.4 

func (m *QueryLiquidityPoolsResponse) Reset()

func (*QueryLiquidityPoolsResponse) Size added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) String added in v0.2.4 

func (m *QueryLiquidityPoolsResponse) String() string

func (*QueryLiquidityPoolsResponse) Unmarshal added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryLiquidityPoolsResponse) XXX_DiscardUnknown()

func (*QueryLiquidityPoolsResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) XXX_Merge added in v0.2.4 

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

func (*QueryLiquidityPoolsResponse) XXX_Size added in v0.2.4 

func (m *QueryLiquidityPoolsResponse) XXX_Size() int

func (*QueryLiquidityPoolsResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryParamsRequest added in v0.2.4 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the QueryParams RPC method.

func (*QueryParamsRequest) Descriptor added in v0.2.4 

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

func (*QueryParamsRequest) Marshal added in v0.2.4 

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

func (*QueryParamsRequest) MarshalTo added in v0.2.4 

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

func (*QueryParamsRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryParamsRequest) ProtoMessage added in v0.2.4 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset added in v0.2.4 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size added in v0.2.4 

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

func (*QueryParamsRequest) String added in v0.2.4 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal added in v0.2.4 

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

func (*QueryParamsRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryParamsRequest) XXX_Merge added in v0.2.4 

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

func (*QueryParamsRequest) XXX_Size added in v0.2.4 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryParamsResponse added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryParamsResponse) GetParams added in v0.2.4 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal added in v0.2.4 

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

func (*QueryParamsResponse) MarshalTo added in v0.2.4 

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

func (*QueryParamsResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryParamsResponse) ProtoMessage added in v0.2.4 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset added in v0.2.4 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size added in v0.2.4 

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

func (*QueryParamsResponse) String added in v0.2.4 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal added in v0.2.4 

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

func (*QueryParamsResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryParamsResponse) XXX_Merge added in v0.2.4 

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

func (*QueryParamsResponse) XXX_Size added in v0.2.4 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchDepositMsgRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgRequest) GetMsgIndex added in v0.2.4 

func (m *QueryPoolBatchDepositMsgRequest) GetMsgIndex() uint64

func (*QueryPoolBatchDepositMsgRequest) GetPoolId added in v0.2.4 

func (m *QueryPoolBatchDepositMsgRequest) GetPoolId() uint64

func (*QueryPoolBatchDepositMsgRequest) Marshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgRequest) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgRequest) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchDepositMsgRequest) ProtoMessage()

func (*QueryPoolBatchDepositMsgRequest) Reset added in v0.2.4 

func (m *QueryPoolBatchDepositMsgRequest) Reset()

func (*QueryPoolBatchDepositMsgRequest) Size added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgRequest) String added in v0.2.4 

func (m *QueryPoolBatchDepositMsgRequest) String() string

func (*QueryPoolBatchDepositMsgRequest) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchDepositMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchDepositMsgRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgRequest) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgRequest) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchDepositMsgRequest) XXX_Size() int

func (*QueryPoolBatchDepositMsgRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchDepositMsgResponse added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgResponse) GetDeposit added in v0.2.4 

func (m *QueryPoolBatchDepositMsgResponse) GetDeposit() DepositMsgState

func (*QueryPoolBatchDepositMsgResponse) Marshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgResponse) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgResponse) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchDepositMsgResponse) ProtoMessage()

func (*QueryPoolBatchDepositMsgResponse) Reset added in v0.2.4 

func (m *QueryPoolBatchDepositMsgResponse) Reset()

func (*QueryPoolBatchDepositMsgResponse) Size added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgResponse) String added in v0.2.4 

func (m *QueryPoolBatchDepositMsgResponse) String() string

func (*QueryPoolBatchDepositMsgResponse) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchDepositMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchDepositMsgResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgResponse) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgResponse) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchDepositMsgResponse) XXX_Size() int

func (*QueryPoolBatchDepositMsgResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchDepositMsgsRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) GetPagination added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) GetPoolId added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsRequest) GetPoolId() uint64

func (*QueryPoolBatchDepositMsgsRequest) Marshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchDepositMsgsRequest) ProtoMessage()

func (*QueryPoolBatchDepositMsgsRequest) Reset added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsRequest) Reset()

func (*QueryPoolBatchDepositMsgsRequest) Size added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) String added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsRequest) String() string

func (*QueryPoolBatchDepositMsgsRequest) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchDepositMsgsRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsRequest) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsRequest) XXX_Size() int

func (*QueryPoolBatchDepositMsgsRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchDepositMsgsResponse added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) GetDeposits added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) GetPagination added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) Marshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchDepositMsgsResponse) ProtoMessage()

func (*QueryPoolBatchDepositMsgsResponse) Reset added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsResponse) Reset()

func (*QueryPoolBatchDepositMsgsResponse) Size added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) String added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsResponse) String() string

func (*QueryPoolBatchDepositMsgsResponse) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchDepositMsgsResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchDepositMsgsResponse) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchDepositMsgsResponse) XXX_Size() int

func (*QueryPoolBatchDepositMsgsResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchSwapMsgRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgRequest) GetMsgIndex added in v0.2.4 

func (m *QueryPoolBatchSwapMsgRequest) GetMsgIndex() uint64

func (*QueryPoolBatchSwapMsgRequest) GetPoolId added in v0.2.4 

func (m *QueryPoolBatchSwapMsgRequest) GetPoolId() uint64

func (*QueryPoolBatchSwapMsgRequest) Marshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgRequest) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgRequest) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchSwapMsgRequest) ProtoMessage()

func (*QueryPoolBatchSwapMsgRequest) Reset added in v0.2.4 

func (m *QueryPoolBatchSwapMsgRequest) Reset()

func (*QueryPoolBatchSwapMsgRequest) Size added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgRequest) String added in v0.2.4 

func (m *QueryPoolBatchSwapMsgRequest) String() string

func (*QueryPoolBatchSwapMsgRequest) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchSwapMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchSwapMsgRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgRequest) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgRequest) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchSwapMsgRequest) XXX_Size() int

func (*QueryPoolBatchSwapMsgRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchSwapMsgResponse added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgResponse) GetSwap added in v0.2.4 

func (m *QueryPoolBatchSwapMsgResponse) GetSwap() SwapMsgState

func (*QueryPoolBatchSwapMsgResponse) Marshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgResponse) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgResponse) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchSwapMsgResponse) ProtoMessage()

func (*QueryPoolBatchSwapMsgResponse) Reset added in v0.2.4 

func (m *QueryPoolBatchSwapMsgResponse) Reset()

func (*QueryPoolBatchSwapMsgResponse) Size added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgResponse) String added in v0.2.4 

func (m *QueryPoolBatchSwapMsgResponse) String() string

func (*QueryPoolBatchSwapMsgResponse) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchSwapMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchSwapMsgResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgResponse) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgResponse) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchSwapMsgResponse) XXX_Size() int

func (*QueryPoolBatchSwapMsgResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchSwapMsgsRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) GetPagination added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) GetPoolId added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsRequest) GetPoolId() uint64

func (*QueryPoolBatchSwapMsgsRequest) Marshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchSwapMsgsRequest) ProtoMessage()

func (*QueryPoolBatchSwapMsgsRequest) Reset added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsRequest) Reset()

func (*QueryPoolBatchSwapMsgsRequest) Size added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) String added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsRequest) String() string

func (*QueryPoolBatchSwapMsgsRequest) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchSwapMsgsRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsRequest) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsRequest) XXX_Size() int

func (*QueryPoolBatchSwapMsgsRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchSwapMsgsResponse added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) GetPagination added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) GetSwaps added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) Marshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchSwapMsgsResponse) ProtoMessage()

func (*QueryPoolBatchSwapMsgsResponse) Reset added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsResponse) Reset()

func (*QueryPoolBatchSwapMsgsResponse) Size added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) String added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsResponse) String() string

func (*QueryPoolBatchSwapMsgsResponse) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchSwapMsgsResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchSwapMsgsResponse) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchSwapMsgsResponse) XXX_Size() int

func (*QueryPoolBatchSwapMsgsResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchWithdrawMsgRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgRequest) GetMsgIndex added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgRequest) GetMsgIndex() uint64

func (*QueryPoolBatchWithdrawMsgRequest) GetPoolId added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgRequest) GetPoolId() uint64

func (*QueryPoolBatchWithdrawMsgRequest) Marshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgRequest) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgRequest) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchWithdrawMsgRequest) ProtoMessage()

func (*QueryPoolBatchWithdrawMsgRequest) Reset added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgRequest) Reset()

func (*QueryPoolBatchWithdrawMsgRequest) Size added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgRequest) String added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgRequest) String() string

func (*QueryPoolBatchWithdrawMsgRequest) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchWithdrawMsgRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgRequest) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgRequest) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgRequest) XXX_Size() int

func (*QueryPoolBatchWithdrawMsgRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchWithdrawMsgResponse added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgResponse) GetWithdraw added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgResponse) GetWithdraw() WithdrawMsgState

func (*QueryPoolBatchWithdrawMsgResponse) Marshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgResponse) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgResponse) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchWithdrawMsgResponse) ProtoMessage()

func (*QueryPoolBatchWithdrawMsgResponse) Reset added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgResponse) Reset()

func (*QueryPoolBatchWithdrawMsgResponse) Size added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgResponse) String added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgResponse) String() string

func (*QueryPoolBatchWithdrawMsgResponse) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchWithdrawMsgResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgResponse) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgResponse) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgResponse) XXX_Size() int

func (*QueryPoolBatchWithdrawMsgResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchWithdrawMsgsRequest added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) GetPagination added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) GetPoolId added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsRequest) GetPoolId() uint64

func (*QueryPoolBatchWithdrawMsgsRequest) Marshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchWithdrawMsgsRequest) ProtoMessage()

func (*QueryPoolBatchWithdrawMsgsRequest) Reset added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsRequest) Reset()

func (*QueryPoolBatchWithdrawMsgsRequest) Size added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) String added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsRequest) String() string

func (*QueryPoolBatchWithdrawMsgsRequest) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsRequest) XXX_DiscardUnknown()

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsRequest) XXX_Size() int

func (*QueryPoolBatchWithdrawMsgsRequest) XXX_Unmarshal added in v0.2.4 

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

type QueryPoolBatchWithdrawMsgsResponse added in v0.2.4 

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 added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) GetPagination added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) GetWithdraws added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) Marshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) MarshalTo added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) MarshalToSizedBuffer added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) ProtoMessage added in v0.2.4 

func (*QueryPoolBatchWithdrawMsgsResponse) ProtoMessage()

func (*QueryPoolBatchWithdrawMsgsResponse) Reset added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsResponse) Reset()

func (*QueryPoolBatchWithdrawMsgsResponse) Size added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) String added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsResponse) String() string

func (*QueryPoolBatchWithdrawMsgsResponse) Unmarshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_DiscardUnknown added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsResponse) XXX_DiscardUnknown()

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_Marshal added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_Merge added in v0.2.4 

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

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_Size added in v0.2.4 

func (m *QueryPoolBatchWithdrawMsgsResponse) XXX_Size() int

func (*QueryPoolBatchWithdrawMsgsResponse) XXX_Unmarshal added in v0.2.4 

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

type QueryServer added in v0.2.4 

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

QueryServer is the server API for Query service.

type SwapMsgState added in v0.2.4 

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 added in v0.2.4 

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

func (*SwapMsgState) Marshal added in v0.2.4 

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

func (*SwapMsgState) MarshalTo added in v0.2.4 

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

func (*SwapMsgState) MarshalToSizedBuffer added in v0.2.4 

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

func (*SwapMsgState) ProtoMessage added in v0.2.4 

func (*SwapMsgState) ProtoMessage()

func (*SwapMsgState) Reset added in v0.2.4 

func (m *SwapMsgState) Reset()

func (*SwapMsgState) Size added in v0.2.4 

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

func (*SwapMsgState) String added in v0.2.4 

func (m *SwapMsgState) String() string

func (*SwapMsgState) Unmarshal added in v0.2.4 

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

func (*SwapMsgState) XXX_DiscardUnknown added in v0.2.4 

func (m *SwapMsgState) XXX_DiscardUnknown()

func (*SwapMsgState) XXX_Marshal added in v0.2.4 

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

func (*SwapMsgState) XXX_Merge added in v0.2.4 

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

func (*SwapMsgState) XXX_Size added in v0.2.4 

func (m *SwapMsgState) XXX_Size() int

func (*SwapMsgState) XXX_Unmarshal added in v0.2.4 

func (m *SwapMsgState) 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 added in v0.2.4 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) LiquidityPool added in v0.2.4 

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

func (*UnimplementedQueryServer) LiquidityPoolBatch added in v0.2.4 

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

func (*UnimplementedQueryServer) LiquidityPoolByPoolCoinDenom added in v0.2.4 

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

func (*UnimplementedQueryServer) LiquidityPoolByReserveAcc added in v0.2.4 

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

func (*UnimplementedQueryServer) LiquidityPools added in v0.2.4 

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

func (*UnimplementedQueryServer) Params added in v0.2.4 

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

func (*UnimplementedQueryServer) PoolBatchDepositMsg added in v0.2.4 

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

func (*UnimplementedQueryServer) PoolBatchDepositMsgs added in v0.2.4 

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

func (*UnimplementedQueryServer) PoolBatchSwapMsg added in v0.2.4 

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

func (*UnimplementedQueryServer) PoolBatchSwapMsgs added in v0.2.4 

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

func (*UnimplementedQueryServer) PoolBatchWithdrawMsg added in v0.2.4 

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

func (*UnimplementedQueryServer) PoolBatchWithdrawMsgs added in v0.2.4 

func (*UnimplementedQueryServer) PoolBatchWithdrawMsgs(ctx context.Context, req *QueryPoolBatchWithdrawMsgsRequest) (*QueryPoolBatchWithdrawMsgsResponse, error)

type WithdrawMsgState added in v0.2.4 

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 added in v0.2.4 

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

func (*WithdrawMsgState) Marshal added in v0.2.4 

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

func (*WithdrawMsgState) MarshalTo added in v0.2.4 

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

func (*WithdrawMsgState) MarshalToSizedBuffer added in v0.2.4 

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

func (*WithdrawMsgState) ProtoMessage added in v0.2.4 

func (*WithdrawMsgState) ProtoMessage()

func (*WithdrawMsgState) Reset added in v0.2.4 

func (m *WithdrawMsgState) Reset()

func (*WithdrawMsgState) Size added in v0.2.4 

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

func (*WithdrawMsgState) String added in v0.2.4 

func (m *WithdrawMsgState) String() string

func (*WithdrawMsgState) Unmarshal added in v0.2.4 

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

func (*WithdrawMsgState) XXX_DiscardUnknown added in v0.2.4 

func (m *WithdrawMsgState) XXX_DiscardUnknown()

func (*WithdrawMsgState) XXX_Marshal added in v0.2.4 

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

func (*WithdrawMsgState) XXX_Merge added in v0.2.4 

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

func (*WithdrawMsgState) XXX_Size added in v0.2.4 

func (m *WithdrawMsgState) XXX_Size() int

func (*WithdrawMsgState) XXX_Unmarshal added in v0.2.4 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.