types

package
v0.21.0-rc.4 Latest Latest
Warning

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

 Go to latest Published: Jun 21, 2023 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// MinPoolAssets minimum number of assets a pool may have
	MinPoolAssets = 2
	// MaxPoolAssets maximum number of assets a pool may have
	MaxPoolAssets = 2

	// DisplayPoolShareExponent the exponent of a pool display share compared to a pool base share (one pool display share = 10^18 pool base shares)
	DisplayPoolShareExponent = 18

	// GuaranteedWeightPrecision Scaling factor for every weight. The pool weight is:
	// weight_in_MsgCreateBalancerPool * GuaranteedWeightPrecision
	//
	// This is done so that smooth weight changes have enough precision to actually be smooth.
	GuaranteedWeightPrecision int64 = 1 << 30
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "spot"

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

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

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_dex"
)
View Source 
const TypeMsgCreatePool = "create_pool"
View Source 
const TypeMsgExitPool = "exit_pool"
View Source 
const TypeMsgJoinPool = "join_pool"
View Source 
const TypeMsgSwapAssets = "swap_assets"

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	// OneDisplayPoolShare represents one display pool share
	OneDisplayPoolShare = sdkmath.NewIntWithDecimal(1, DisplayPoolShareExponent)

	// InitPoolSharesSupply is the amount of new shares to initialize a pool with.
	InitPoolSharesSupply = OneDisplayPoolShare.MulRaw(100)

	// MaxUserSpecifiedWeight Pool creators can specify a weight in [1, MaxUserSpecifiedWeight)
	// for every token in the balancer pool.
	//
	// The weight used in the balancer equation is then creator-specified-weight * GuaranteedWeightPrecision.
	// This is done so that LBP's / smooth weight changes can actually happen smoothly,
	// without complex precision loss / edge effects.
	MaxUserSpecifiedWeight = sdkmath.NewIntFromUint64(1 << 20)
)
View Source 
var (
	ErrTooFewPoolAssets           = sdkerrors.Register(ModuleName, 1, "pool should have at least 2 assets, as they must be swapping between at least two assets")
	ErrTooManyPoolAssets          = sdkerrors.Register(ModuleName, 2, "pool has too many assets (currently capped at 2 assets per pool)")
	ErrInvalidSwapFee             = sdkerrors.Register(ModuleName, 3, "invalid pool swap fee, must be between [0, 1]")
	ErrInvalidExitFee             = sdkerrors.Register(ModuleName, 4, "invalid pool exit fee, must be between [0, 1]")
	ErrInvalidTokenWeight         = sdkerrors.Register(ModuleName, 5, "token weight must be greater than zero")
	ErrTokenNotAllowed            = sdkerrors.Register(ModuleName, 8, "token not allowed")
	ErrInvalidPoolType            = sdkerrors.Register(ModuleName, 15, "pool_type needs to be either `balancer` or `stableswap`")
	ErrAmplificationMissing       = sdkerrors.Register(ModuleName, 16, "amplification parameter is missing")
	ErrAmplificationTooLow        = sdkerrors.Register(ModuleName, 17, "amplification parameter a needs to be greater than 1")
	ErrInitialDeposit             = sdkerrors.Register(ModuleName, 19, "initial deposit requires all coins deposited")
	ErrPoolWithSameAssetsExists   = sdkerrors.Register(ModuleName, 20, "a pool with the same denoms already exists")
	ErrBorkedPool                 = sdkerrors.Register(ModuleName, 21, "the pool is borked")
	ErrInvariantLowerAfterJoining = sdkerrors.Register(ModuleName, 22, "the invariant was unexpectedly lower after joining")

	// create-pool tx cli errors
	ErrMissingPoolFileFlag   = sdkerrors.Register(ModuleName, 6, "must pass in a pool json using the --pool-file flag")
	ErrInvalidCreatePoolArgs = sdkerrors.Register(ModuleName, 7, "deposit tokens and token weights should have same length and denom order")
	ErrAmplificationIntable  = sdkerrors.Register(ModuleName, 23,
		"amplification string failed to parse as int256")

	// Invalid MsgSwapAsset
	ErrInvalidPoolId        = sdkerrors.Register(ModuleName, 9, "invalid pool id")
	ErrInvalidTokenIn       = sdkerrors.Register(ModuleName, 10, "invalid tokens in")
	ErrInvalidTokenOutDenom = sdkerrors.Register(ModuleName, 11, "invalid token out denom")

	// Errors when swapping assets
	ErrPoolNotFound       = sdkerrors.Register(ModuleName, 12, "pool not found")
	ErrTokenDenomNotFound = sdkerrors.Register(ModuleName, 13, "token denom not found in pool")
	ErrSameTokenDenom     = sdkerrors.Register(ModuleName, 14, "cannot use same token denom to swap in and out")

	ErrNotImplemented = sdkerrors.Register(ModuleName, 18, "not implemented")
)

x/spot module sentinel errors

View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// KeyNextGlobalPoolNumber defines key to store the next Pool ID to be used
	KeyNextGlobalPoolNumber = []byte{0x01}
	// KeyPrefixPools defines prefix to store pools
	KeyPrefixPools = []byte{0x02}
	// KeyTotalLiquidity defines key to store total liquidity
	KeyTotalLiquidity = []byte{0x03}
	// KeyPrefixPoolIds defines prefix to store pool ids by denoms in the pool
	KeyPrefixPoolIds = []byte{0x04}
)
View Source 
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPool        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPool          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPool = 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 PoolType_name = map[int32]string{
	0: "BALANCER",
	1: "STABLESWAP",
}
View Source 
var PoolType_value = map[string]int32{
	"BALANCER":   0,
	"STABLESWAP": 1,
}

Functions

func GetDenomLiquidityPrefix 

func GetDenomLiquidityPrefix(denom string) []byte

func GetDenomPrefixPoolIds 

func GetDenomPrefixPoolIds(denoms ...string) []byte

func GetKeyPrefixPools 

func GetKeyPrefixPools(poolId uint64) []byte

func GetPoolShareBaseDenom 

func GetPoolShareBaseDenom(poolId uint64) (poolDenom string)

Returns the *base* denomination of a pool share token for a given poolId.

args: 

poolId: the pool id number

ret: 

poolDenom: the pool denomination name of the poolId

func GetPoolShareDisplayDenom 

func GetPoolShareDisplayDenom(poolId uint64) (poolDenom string)

Returns the *display* denomination of a pool share token for a given poolId. Display denom means the denomination showed to the user, which could be many exponents greater than the base denom. e.g. 1 atom is the display denom, but 10^6 uatom is the base denom.

In Nibiru, a display denom is 10^18 base denoms.

args: 

poolId: the pool id number

ret: 

poolDenom: the pool denomination name of the poolId

func KeyPrefix 

func KeyPrefix(p string) []byte

func MustSdkIntToUint256 

func MustSdkIntToUint256(num sdkmath.Int) *uint256.Int

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgHandler 

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

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

func RegisterMsgHandlerClient 

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

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

func RegisterMsgHandlerFromEndpoint 

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

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

func RegisterMsgHandlerServer 

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

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AccountKeeper 

type AccountKeeper interface {
	IterateAccounts(ctx sdk.Context, process func(authtypes.AccountI) (stop bool))
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	NewAccount(sdk.Context, authtypes.AccountI) authtypes.AccountI
	SetAccount(ctx sdk.Context, acc authtypes.AccountI)
	GetModuleAddress(name string) sdk.AccAddress
	GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI

	SetModuleAccount(sdk.Context, authtypes.ModuleAccountI)
}

AccountKeeper defines the expected account keeper used for simulations (noalias)

type BankKeeper 

type BankKeeper interface {

	// Methods imported from bank should be defined here
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	SendCoinsFromModuleToModule(ctx sdk.Context, senderPool, recipientPool string, amt sdk.Coins) error
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error

	SendCoins(ctx sdk.Context, fromAddr sdk.AccAddress, toAddr sdk.AccAddress, amt sdk.Coins) error

	MintCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
	BurnCoins(ctx sdk.Context, name string, amt sdk.Coins) error

	SetDenomMetaData(ctx sdk.Context, denomMetaData banktypes.Metadata)

	// Only needed for simulation interface matching
	// TODO: Look into golang syntax to make this "Everything in stakingtypes.bankkeeper + extra funcs"
	// I think it has to do with listing another interface as the first line here?
	GetAllBalances(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	// SetBalances(ctx sdk.Context, addr sdk.AccAddress, balances sdk.Coins) error
	LockedCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
	GetSupply(ctx sdk.Context, denom string) sdk.Coin
	UndelegateCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	DelegateCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	IterateAllBalances(ctx sdk.Context, callback func(addr sdk.AccAddress, coin sdk.Coin) (stop bool))
}

BankKeeper defines the expected interface needed to retrieve account balances.

type DistrKeeper 

type DistrKeeper interface {
	FundCommunityPool(ctx sdk.Context, amount sdk.Coins, sender sdk.AccAddress) error
}

DistrKeeper defines the contract needed to be fulfilled for distribution keeper.

type EventAssetsSwapped 

type EventAssetsSwapped struct {
	// the address of the user who swapped tokens
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// the amount of tokens that the user deposited
	TokenIn types.Coin `protobuf:"bytes,2,opt,name=token_in,json=tokenIn,proto3" json:"token_in"`
	// the amount of tokens that the user received
	TokenOut types.Coin `protobuf:"bytes,3,opt,name=token_out,json=tokenOut,proto3" json:"token_out"`
	// the amount of fees collected by the pool
	Fee types.Coin `protobuf:"bytes,4,opt,name=fee,proto3" json:"fee"`
	// the final state of the pool
	FinalPool Pool `protobuf:"bytes,5,opt,name=final_pool,json=finalPool,proto3" json:"final_pool"`
}

func (*EventAssetsSwapped) Descriptor 

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

func (*EventAssetsSwapped) GetAddress 

func (m *EventAssetsSwapped) GetAddress() string

func (*EventAssetsSwapped) GetFee added in v0.21.0 

func (m *EventAssetsSwapped) GetFee() types.Coin

func (*EventAssetsSwapped) GetFinalPool added in v0.21.0 

func (m *EventAssetsSwapped) GetFinalPool() Pool

func (*EventAssetsSwapped) GetTokenIn 

func (m *EventAssetsSwapped) GetTokenIn() types.Coin

func (*EventAssetsSwapped) GetTokenOut 

func (m *EventAssetsSwapped) GetTokenOut() types.Coin

func (*EventAssetsSwapped) Marshal 

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

func (*EventAssetsSwapped) MarshalTo 

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

func (*EventAssetsSwapped) MarshalToSizedBuffer 

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

func (*EventAssetsSwapped) ProtoMessage 

func (*EventAssetsSwapped) ProtoMessage()

func (*EventAssetsSwapped) Reset 

func (m *EventAssetsSwapped) Reset()

func (*EventAssetsSwapped) Size 

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

func (*EventAssetsSwapped) String 

func (m *EventAssetsSwapped) String() string

func (*EventAssetsSwapped) Unmarshal 

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

func (*EventAssetsSwapped) XXX_DiscardUnknown 

func (m *EventAssetsSwapped) XXX_DiscardUnknown()

func (*EventAssetsSwapped) XXX_Marshal 

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

func (*EventAssetsSwapped) XXX_Merge 

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

func (*EventAssetsSwapped) XXX_Size 

func (m *EventAssetsSwapped) XXX_Size() int

func (*EventAssetsSwapped) XXX_Unmarshal 

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

type EventPoolCreated 

type EventPoolCreated struct {
	// the address of the user who created the pool
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	// the create pool fee
	Fees []types.Coin `protobuf:"bytes,2,rep,name=fees,proto3" json:"fees"`
	// the final state of the pool
	FinalPool Pool `protobuf:"bytes,4,opt,name=final_pool,json=finalPool,proto3" json:"final_pool"`
	// the amount of pool shares that the user received
	FinalUserPoolShares types.Coin `protobuf:"bytes,5,opt,name=final_user_pool_shares,json=finalUserPoolShares,proto3" json:"final_user_pool_shares"`
}

func (*EventPoolCreated) Descriptor 

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

func (*EventPoolCreated) GetCreator 

func (m *EventPoolCreated) GetCreator() string

func (*EventPoolCreated) GetFees added in v0.21.0 

func (m *EventPoolCreated) GetFees() []types.Coin

func (*EventPoolCreated) GetFinalPool added in v0.21.0 

func (m *EventPoolCreated) GetFinalPool() Pool

func (*EventPoolCreated) GetFinalUserPoolShares added in v0.21.0 

func (m *EventPoolCreated) GetFinalUserPoolShares() types.Coin

func (*EventPoolCreated) Marshal 

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

func (*EventPoolCreated) MarshalTo 

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

func (*EventPoolCreated) MarshalToSizedBuffer 

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

func (*EventPoolCreated) ProtoMessage 

func (*EventPoolCreated) ProtoMessage()

func (*EventPoolCreated) Reset 

func (m *EventPoolCreated) Reset()

func (*EventPoolCreated) Size 

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

func (*EventPoolCreated) String 

func (m *EventPoolCreated) String() string

func (*EventPoolCreated) Unmarshal 

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

func (*EventPoolCreated) XXX_DiscardUnknown 

func (m *EventPoolCreated) XXX_DiscardUnknown()

func (*EventPoolCreated) XXX_Marshal 

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

func (*EventPoolCreated) XXX_Merge 

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

func (*EventPoolCreated) XXX_Size 

func (m *EventPoolCreated) XXX_Size() int

func (*EventPoolCreated) XXX_Unmarshal 

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

type EventPoolExited 

type EventPoolExited struct {
	// the address of the user who exited the pool
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// the amount of pool shares that the user exited with
	PoolSharesIn types.Coin `protobuf:"bytes,2,opt,name=pool_shares_in,json=poolSharesIn,proto3" json:"pool_shares_in"`
	// the amount of tokens returned to the user
	TokensOut []types.Coin `protobuf:"bytes,3,rep,name=tokens_out,json=tokensOut,proto3" json:"tokens_out"`
	// the amount of fees collected by the pool
	Fees []types.Coin `protobuf:"bytes,4,rep,name=fees,proto3" json:"fees"`
	// the final state of the pool
	FinalPool Pool `protobuf:"bytes,5,opt,name=final_pool,json=finalPool,proto3" json:"final_pool"`
	// the final amount of user pool shares
	FinalUserPoolShares types.Coin `protobuf:"bytes,6,opt,name=final_user_pool_shares,json=finalUserPoolShares,proto3" json:"final_user_pool_shares"`
}

func (*EventPoolExited) Descriptor 

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

func (*EventPoolExited) GetAddress 

func (m *EventPoolExited) GetAddress() string

func (*EventPoolExited) GetFees added in v0.21.0 

func (m *EventPoolExited) GetFees() []types.Coin

func (*EventPoolExited) GetFinalPool added in v0.21.0 

func (m *EventPoolExited) GetFinalPool() Pool

func (*EventPoolExited) GetFinalUserPoolShares added in v0.21.0 

func (m *EventPoolExited) GetFinalUserPoolShares() types.Coin

func (*EventPoolExited) GetPoolSharesIn 

func (m *EventPoolExited) GetPoolSharesIn() types.Coin

func (*EventPoolExited) GetTokensOut 

func (m *EventPoolExited) GetTokensOut() []types.Coin

func (*EventPoolExited) Marshal 

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

func (*EventPoolExited) MarshalTo 

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

func (*EventPoolExited) MarshalToSizedBuffer 

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

func (*EventPoolExited) ProtoMessage 

func (*EventPoolExited) ProtoMessage()

func (*EventPoolExited) Reset 

func (m *EventPoolExited) Reset()

func (*EventPoolExited) Size 

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

func (*EventPoolExited) String 

func (m *EventPoolExited) String() string

func (*EventPoolExited) Unmarshal 

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

func (*EventPoolExited) XXX_DiscardUnknown 

func (m *EventPoolExited) XXX_DiscardUnknown()

func (*EventPoolExited) XXX_Marshal 

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

func (*EventPoolExited) XXX_Merge 

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

func (*EventPoolExited) XXX_Size 

func (m *EventPoolExited) XXX_Size() int

func (*EventPoolExited) XXX_Unmarshal 

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

type EventPoolJoined 

type EventPoolJoined struct {
	// the address of the user who joined the pool
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// the amount of tokens that the user deposited
	TokensIn []types.Coin `protobuf:"bytes,2,rep,name=tokens_in,json=tokensIn,proto3" json:"tokens_in"`
	// the amount of pool shares that the user received
	PoolSharesOut types.Coin `protobuf:"bytes,3,opt,name=pool_shares_out,json=poolSharesOut,proto3" json:"pool_shares_out"`
	// the amount of tokens remaining for the user
	RemCoins []types.Coin `protobuf:"bytes,4,rep,name=rem_coins,json=remCoins,proto3" json:"rem_coins"`
	// the final state of the pool
	FinalPool Pool `protobuf:"bytes,5,opt,name=final_pool,json=finalPool,proto3" json:"final_pool"`
	// the final amount of user pool shares
	FinalUserPoolShares types.Coin `protobuf:"bytes,6,opt,name=final_user_pool_shares,json=finalUserPoolShares,proto3" json:"final_user_pool_shares"`
}

func (*EventPoolJoined) Descriptor 

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

func (*EventPoolJoined) GetAddress 

func (m *EventPoolJoined) GetAddress() string

func (*EventPoolJoined) GetFinalPool added in v0.21.0 

func (m *EventPoolJoined) GetFinalPool() Pool

func (*EventPoolJoined) GetFinalUserPoolShares added in v0.21.0 

func (m *EventPoolJoined) GetFinalUserPoolShares() types.Coin

func (*EventPoolJoined) GetPoolSharesOut 

func (m *EventPoolJoined) GetPoolSharesOut() types.Coin

func (*EventPoolJoined) GetRemCoins 

func (m *EventPoolJoined) GetRemCoins() []types.Coin

func (*EventPoolJoined) GetTokensIn 

func (m *EventPoolJoined) GetTokensIn() []types.Coin

func (*EventPoolJoined) Marshal 

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

func (*EventPoolJoined) MarshalTo 

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

func (*EventPoolJoined) MarshalToSizedBuffer 

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

func (*EventPoolJoined) ProtoMessage 

func (*EventPoolJoined) ProtoMessage()

func (*EventPoolJoined) Reset 

func (m *EventPoolJoined) Reset()

func (*EventPoolJoined) Size 

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

func (*EventPoolJoined) String 

func (m *EventPoolJoined) String() string

func (*EventPoolJoined) Unmarshal 

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

func (*EventPoolJoined) XXX_DiscardUnknown 

func (m *EventPoolJoined) XXX_DiscardUnknown()

func (*EventPoolJoined) XXX_Marshal 

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

func (*EventPoolJoined) XXX_Merge 

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

func (*EventPoolJoined) XXX_Size 

func (m *EventPoolJoined) XXX_Size() int

func (*EventPoolJoined) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// params defines all the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	// pools defines all the pools of the module.
	Pools []Pool `protobuf:"bytes,2,rep,name=pools,proto3" json:"pools"`
}

GenesisState defines the spot module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default Capability genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetPools added in v0.21.0 

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

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// Used to create a pool.
	CreatePool(ctx context.Context, in *MsgCreatePool, opts ...grpc.CallOption) (*MsgCreatePoolResponse, error)
	// Join a pool as a liquidity provider.
	JoinPool(ctx context.Context, in *MsgJoinPool, opts ...grpc.CallOption) (*MsgJoinPoolResponse, error)
	// Exit a pool position by returning LP shares
	ExitPool(ctx context.Context, in *MsgExitPool, opts ...grpc.CallOption) (*MsgExitPoolResponse, error)
	// Swap assets in a pool
	SwapAssets(ctx context.Context, in *MsgSwapAssets, opts ...grpc.CallOption) (*MsgSwapAssetsResponse, 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 {
	Creator    string      `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	PoolParams *PoolParams `protobuf:"bytes,2,opt,name=pool_params,json=poolParams,proto3" json:"pool_params,omitempty" yaml:"pool_params"`
	PoolAssets []PoolAsset `protobuf:"bytes,3,rep,name=pool_assets,json=poolAssets,proto3" json:"pool_assets"`
}

func NewMsgCreatePool 

func NewMsgCreatePool(creator string, poolAssets []PoolAsset, poolParams *PoolParams) *MsgCreatePool

func (*MsgCreatePool) Descriptor 

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

func (*MsgCreatePool) GetCreator 

func (m *MsgCreatePool) GetCreator() string

func (*MsgCreatePool) GetPoolAssets 

func (m *MsgCreatePool) GetPoolAssets() []PoolAsset

func (*MsgCreatePool) GetPoolParams 

func (m *MsgCreatePool) GetPoolParams() *PoolParams

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 {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

func (*MsgCreatePoolResponse) Descriptor 

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

func (*MsgCreatePoolResponse) GetPoolId 

func (m *MsgCreatePoolResponse) GetPoolId() uint64

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 MsgExitPool 

type MsgExitPool struct {
	Sender     string     `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId     uint64     `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	PoolShares types.Coin `protobuf:"bytes,3,opt,name=pool_shares,json=poolShares,proto3" json:"pool_shares" yaml:"pool_shares"`
}

func NewMsgExitPool 

func NewMsgExitPool(sender string, poolId uint64, poolShares sdk.Coin) *MsgExitPool

func (*MsgExitPool) Descriptor 

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

func (*MsgExitPool) GetPoolId 

func (m *MsgExitPool) GetPoolId() uint64

func (*MsgExitPool) GetPoolShares 

func (m *MsgExitPool) GetPoolShares() types.Coin

func (*MsgExitPool) GetSender 

func (m *MsgExitPool) GetSender() string

func (*MsgExitPool) GetSignBytes 

func (msg *MsgExitPool) GetSignBytes() []byte

func (*MsgExitPool) GetSigners 

func (msg *MsgExitPool) GetSigners() []sdk.AccAddress

func (*MsgExitPool) Marshal 

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

func (*MsgExitPool) MarshalTo 

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

func (*MsgExitPool) MarshalToSizedBuffer 

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

func (*MsgExitPool) ProtoMessage 

func (*MsgExitPool) ProtoMessage()

func (*MsgExitPool) Reset 

func (m *MsgExitPool) Reset()

func (*MsgExitPool) Route 

func (msg *MsgExitPool) Route() string

func (*MsgExitPool) Size 

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

func (*MsgExitPool) String 

func (m *MsgExitPool) String() string

func (*MsgExitPool) Type 

func (msg *MsgExitPool) Type() string

func (*MsgExitPool) Unmarshal 

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

func (*MsgExitPool) ValidateBasic 

func (msg *MsgExitPool) ValidateBasic() error

func (*MsgExitPool) XXX_DiscardUnknown 

func (m *MsgExitPool) XXX_DiscardUnknown()

func (*MsgExitPool) XXX_Marshal 

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

func (*MsgExitPool) XXX_Merge 

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

func (*MsgExitPool) XXX_Size 

func (m *MsgExitPool) XXX_Size() int

func (*MsgExitPool) XXX_Unmarshal 

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

type MsgExitPoolResponse 

type MsgExitPoolResponse struct {
	TokensOut []types.Coin `protobuf:"bytes,3,rep,name=tokens_out,json=tokensOut,proto3" json:"tokens_out" yaml:"tokens_out"`
}

func (*MsgExitPoolResponse) Descriptor 

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

func (*MsgExitPoolResponse) GetTokensOut 

func (m *MsgExitPoolResponse) GetTokensOut() []types.Coin

func (*MsgExitPoolResponse) Marshal 

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

func (*MsgExitPoolResponse) MarshalTo 

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

func (*MsgExitPoolResponse) MarshalToSizedBuffer 

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

func (*MsgExitPoolResponse) ProtoMessage 

func (*MsgExitPoolResponse) ProtoMessage()

func (*MsgExitPoolResponse) Reset 

func (m *MsgExitPoolResponse) Reset()

func (*MsgExitPoolResponse) Size 

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

func (*MsgExitPoolResponse) String 

func (m *MsgExitPoolResponse) String() string

func (*MsgExitPoolResponse) Unmarshal 

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

func (*MsgExitPoolResponse) XXX_DiscardUnknown 

func (m *MsgExitPoolResponse) XXX_DiscardUnknown()

func (*MsgExitPoolResponse) XXX_Marshal 

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

func (*MsgExitPoolResponse) XXX_Merge 

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

func (*MsgExitPoolResponse) XXX_Size 

func (m *MsgExitPoolResponse) XXX_Size() int

func (*MsgExitPoolResponse) XXX_Unmarshal 

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

type MsgJoinPool 

type MsgJoinPool struct {
	Sender      string       `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId      uint64       `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	TokensIn    []types.Coin `protobuf:"bytes,3,rep,name=tokens_in,json=tokensIn,proto3" json:"tokens_in" yaml:"tokens_in"`
	UseAllCoins bool         `protobuf:"varint,4,opt,name=use_all_coins,json=useAllCoins,proto3" json:"use_all_coins,omitempty" yaml:"use_all_coins"`
}

Message to join a pool (identified by poolId) with a set of tokens to deposit.

func NewMsgJoinPool 

func NewMsgJoinPool(sender string, poolId uint64, tokensIn sdk.Coins, useAllCoins bool) *MsgJoinPool

func (*MsgJoinPool) Descriptor 

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

func (*MsgJoinPool) GetPoolId 

func (m *MsgJoinPool) GetPoolId() uint64

func (*MsgJoinPool) GetSender 

func (m *MsgJoinPool) GetSender() string

func (*MsgJoinPool) GetSignBytes 

func (msg *MsgJoinPool) GetSignBytes() []byte

func (*MsgJoinPool) GetSigners 

func (msg *MsgJoinPool) GetSigners() []sdk.AccAddress

func (*MsgJoinPool) GetTokensIn 

func (m *MsgJoinPool) GetTokensIn() []types.Coin

func (*MsgJoinPool) GetUseAllCoins 

func (m *MsgJoinPool) GetUseAllCoins() bool

func (*MsgJoinPool) Marshal 

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

func (*MsgJoinPool) MarshalTo 

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

func (*MsgJoinPool) MarshalToSizedBuffer 

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

func (*MsgJoinPool) ProtoMessage 

func (*MsgJoinPool) ProtoMessage()

func (*MsgJoinPool) Reset 

func (m *MsgJoinPool) Reset()

func (*MsgJoinPool) Route 

func (msg *MsgJoinPool) Route() string

func (*MsgJoinPool) Size 

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

func (*MsgJoinPool) String 

func (m *MsgJoinPool) String() string

func (*MsgJoinPool) Type 

func (msg *MsgJoinPool) Type() string

func (*MsgJoinPool) Unmarshal 

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

func (*MsgJoinPool) ValidateBasic 

func (msg *MsgJoinPool) ValidateBasic() error

func (*MsgJoinPool) XXX_DiscardUnknown 

func (m *MsgJoinPool) XXX_DiscardUnknown()

func (*MsgJoinPool) XXX_Marshal 

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

func (*MsgJoinPool) XXX_Merge 

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

func (*MsgJoinPool) XXX_Size 

func (m *MsgJoinPool) XXX_Size() int

func (*MsgJoinPool) XXX_Unmarshal 

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

type MsgJoinPoolResponse 

type MsgJoinPoolResponse struct {
	// the final state of the pool after a join
	Pool *Pool `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"`
	// sum of LP tokens minted from the join
	NumPoolSharesOut types.Coin `` /* 130-byte string literal not displayed */
	// remaining tokens from attempting to join the pool
	RemainingCoins []types.Coin `protobuf:"bytes,3,rep,name=remaining_coins,json=remainingCoins,proto3" json:"remaining_coins" yaml:"tokens_in"`
}

Response when a user joins a pool.

func (*MsgJoinPoolResponse) Descriptor 

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

func (*MsgJoinPoolResponse) GetNumPoolSharesOut 

func (m *MsgJoinPoolResponse) GetNumPoolSharesOut() types.Coin

func (*MsgJoinPoolResponse) GetPool 

func (m *MsgJoinPoolResponse) GetPool() *Pool

func (*MsgJoinPoolResponse) GetRemainingCoins 

func (m *MsgJoinPoolResponse) GetRemainingCoins() []types.Coin

func (*MsgJoinPoolResponse) Marshal 

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

func (*MsgJoinPoolResponse) MarshalTo 

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

func (*MsgJoinPoolResponse) MarshalToSizedBuffer 

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

func (*MsgJoinPoolResponse) ProtoMessage 

func (*MsgJoinPoolResponse) ProtoMessage()

func (*MsgJoinPoolResponse) Reset 

func (m *MsgJoinPoolResponse) Reset()

func (*MsgJoinPoolResponse) Size 

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

func (*MsgJoinPoolResponse) String 

func (m *MsgJoinPoolResponse) String() string

func (*MsgJoinPoolResponse) Unmarshal 

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

func (*MsgJoinPoolResponse) XXX_DiscardUnknown 

func (m *MsgJoinPoolResponse) XXX_DiscardUnknown()

func (*MsgJoinPoolResponse) XXX_Marshal 

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

func (*MsgJoinPoolResponse) XXX_Merge 

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

func (*MsgJoinPoolResponse) XXX_Size 

func (m *MsgJoinPoolResponse) XXX_Size() int

func (*MsgJoinPoolResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// Used to create a pool.
	CreatePool(context.Context, *MsgCreatePool) (*MsgCreatePoolResponse, error)
	// Join a pool as a liquidity provider.
	JoinPool(context.Context, *MsgJoinPool) (*MsgJoinPoolResponse, error)
	// Exit a pool position by returning LP shares
	ExitPool(context.Context, *MsgExitPool) (*MsgExitPoolResponse, error)
	// Swap assets in a pool
	SwapAssets(context.Context, *MsgSwapAssets) (*MsgSwapAssetsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSwapAssets 

type MsgSwapAssets struct {
	Sender        string     `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId        uint64     `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty" yaml:"pool_id"`
	TokenIn       types.Coin `protobuf:"bytes,3,opt,name=token_in,json=tokenIn,proto3" json:"token_in" yaml:"token_in"`
	TokenOutDenom string     `protobuf:"bytes,4,opt,name=token_out_denom,json=tokenOutDenom,proto3" json:"token_out_denom,omitempty" yaml:"token_out_denom"`
}

func NewMsgSwapAssets 

func NewMsgSwapAssets(sender string, poolId uint64, tokenIn sdk.Coin, tokenOutDenom string) *MsgSwapAssets

func (*MsgSwapAssets) Descriptor 

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

func (*MsgSwapAssets) GetPoolId 

func (m *MsgSwapAssets) GetPoolId() uint64

func (*MsgSwapAssets) GetSender 

func (m *MsgSwapAssets) GetSender() string

func (*MsgSwapAssets) GetSignBytes 

func (msg *MsgSwapAssets) GetSignBytes() []byte

func (*MsgSwapAssets) GetSigners 

func (msg *MsgSwapAssets) GetSigners() []sdk.AccAddress

func (*MsgSwapAssets) GetTokenIn 

func (m *MsgSwapAssets) GetTokenIn() types.Coin

func (*MsgSwapAssets) GetTokenOutDenom 

func (m *MsgSwapAssets) GetTokenOutDenom() string

func (*MsgSwapAssets) Marshal 

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

func (*MsgSwapAssets) MarshalTo 

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

func (*MsgSwapAssets) MarshalToSizedBuffer 

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

func (*MsgSwapAssets) ProtoMessage 

func (*MsgSwapAssets) ProtoMessage()

func (*MsgSwapAssets) Reset 

func (m *MsgSwapAssets) Reset()

func (*MsgSwapAssets) Route 

func (msg *MsgSwapAssets) Route() string

func (*MsgSwapAssets) Size 

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

func (*MsgSwapAssets) String 

func (m *MsgSwapAssets) String() string

func (*MsgSwapAssets) Type 

func (msg *MsgSwapAssets) Type() string

func (*MsgSwapAssets) Unmarshal 

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

func (*MsgSwapAssets) ValidateBasic 

func (msg *MsgSwapAssets) ValidateBasic() error

func (*MsgSwapAssets) XXX_DiscardUnknown 

func (m *MsgSwapAssets) XXX_DiscardUnknown()

func (*MsgSwapAssets) XXX_Marshal 

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

func (*MsgSwapAssets) XXX_Merge 

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

func (*MsgSwapAssets) XXX_Size 

func (m *MsgSwapAssets) XXX_Size() int

func (*MsgSwapAssets) XXX_Unmarshal 

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

type MsgSwapAssetsResponse 

type MsgSwapAssetsResponse struct {
	TokenOut types.Coin `protobuf:"bytes,3,opt,name=token_out,json=tokenOut,proto3" json:"token_out" yaml:"token_out"`
}

func (*MsgSwapAssetsResponse) Descriptor 

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

func (*MsgSwapAssetsResponse) GetTokenOut 

func (m *MsgSwapAssetsResponse) GetTokenOut() types.Coin

func (*MsgSwapAssetsResponse) Marshal 

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

func (*MsgSwapAssetsResponse) MarshalTo 

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

func (*MsgSwapAssetsResponse) MarshalToSizedBuffer 

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

func (*MsgSwapAssetsResponse) ProtoMessage 

func (*MsgSwapAssetsResponse) ProtoMessage()

func (*MsgSwapAssetsResponse) Reset 

func (m *MsgSwapAssetsResponse) Reset()

func (*MsgSwapAssetsResponse) Size 

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

func (*MsgSwapAssetsResponse) String 

func (m *MsgSwapAssetsResponse) String() string

func (*MsgSwapAssetsResponse) Unmarshal 

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

func (*MsgSwapAssetsResponse) XXX_DiscardUnknown 

func (m *MsgSwapAssetsResponse) XXX_DiscardUnknown()

func (*MsgSwapAssetsResponse) XXX_Marshal 

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

func (*MsgSwapAssetsResponse) XXX_Merge 

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

func (*MsgSwapAssetsResponse) XXX_Size 

func (m *MsgSwapAssetsResponse) XXX_Size() int

func (*MsgSwapAssetsResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// The start pool number, i.e. the first pool number that isn't taken yet.
	StartingPoolNumber uint64 `protobuf:"varint,1,opt,name=starting_pool_number,json=startingPoolNumber,proto3" json:"starting_pool_number,omitempty"`
	// The cost of creating a pool, taken from the pool creator's account.
	PoolCreationFee github_com_cosmos_cosmos_sdk_types.Coins `` /* 177-byte string literal not displayed */
	// The assets that can be used to create liquidity pools
	WhitelistedAsset []string `protobuf:"bytes,3,rep,name=whitelisted_asset,json=whitelistedAsset,proto3" json:"whitelisted_asset,omitempty"`
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(startingPoolNumber uint64, poolCreationFee sdk.Coins, whitelistedAssets []string) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetPoolCreationFee 

func (m *Params) GetPoolCreationFee() github_com_cosmos_cosmos_sdk_types.Coins

func (*Params) GetStartingPoolNumber 

func (m *Params) GetStartingPoolNumber() uint64

func (*Params) GetWhitelistedAsset 

func (m *Params) GetWhitelistedAsset() []string

func (Params) GetWhitelistedAssetsAsMap 

func (p Params) GetWhitelistedAssetsAsMap() map[string]bool

GetWhitelistedAssetsAsMap returns the whitelisted assets as map, util for checking if a value is on the whitelist.

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs get the params.ParamSet

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (Params) String 

func (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type Pool 

type Pool struct {
	// The pool id.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The pool account address.
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	// Fees and other pool-specific parameters.
	PoolParams PoolParams `protobuf:"bytes,3,opt,name=pool_params,json=poolParams,proto3" json:"pool_params" yaml:"pool_params"`
	// These are assumed to be sorted by denomiation.
	// They contain the pool asset and the information about the weight
	PoolAssets []PoolAsset `protobuf:"bytes,4,rep,name=pool_assets,json=poolAssets,proto3" json:"pool_assets" yaml:"pool_assets"`
	// sum of all non-normalized pool weights
	TotalWeight github_com_cosmos_cosmos_sdk_types.Int `` /* 154-byte string literal not displayed */
	// sum of all LP tokens sent out
	TotalShares types.Coin `protobuf:"bytes,6,opt,name=total_shares,json=totalShares,proto3" json:"total_shares" yaml:"total_shares"`
}

func NewPool 

func NewPool(
	poolId uint64,
	poolAccountAddr sdk.Address,
	poolParams PoolParams,
	poolAssets []PoolAsset,
) (pool Pool, err error)

Creates a new pool and sets the initial assets.

args: 

poolId: the pool numeric id
poolAccountAddr: the pool's account address for holding funds
poolParams: pool configuration options
poolAssets: the initial pool assets and weights

ret: 

pool: a new pool
err: error if any

func (*Pool) AddAllTokensToPool 

func (pool *Pool) AddAllTokensToPool(tokensIn sdk.Coins) (
	numShares sdkmath.Int, remCoins sdk.Coins, err error,
)

AddAllTokensToPool Adds tokens to a pool optimizing the amount of shares (swap + join) and updates the pool balances (i.e. liquidity). We maximally join with both tokens first, and then perform a single asset join with the remaining assets.

This function is only necessary for balancer pool. Stableswap pool already takes all the deposit from the user.

args:

  • tokensIn: the tokens to add to the pool

ret:

  • numShares: the number of LP shares given to the user for the deposit
  • remCoins: the number of coins remaining after the deposit
  • err: error if any

func (*Pool) AddTokensToPool 

func (pool *Pool) AddTokensToPool(tokensIn sdk.Coins) (
	numShares sdkmath.Int, remCoins sdk.Coins, err error,
)

AddTokensToPool Adds tokens to a pool and updates the pool balances (i.e. liquidity).

args:

  • tokensIn: the tokens to add to the pool

ret:

  • numShares: the number of LP shares given to the user for the deposit
  • remCoins: the number of coins remaining after the deposit
  • err: error if any

func (*Pool) ApplySwap 

func (pool *Pool) ApplySwap(tokenIn sdk.Coin, tokenOut sdk.Coin) (err error)

Applies a swap to the pool by adding tokenIn and removing tokenOut from pool asset balances.

args:

  • tokenIn: the amount of token to deposit
  • tokenOut: the amount of token to withdraw

ret:

  • err: error if any

func (Pool) AreTokensInDenomInPoolAssets added in v0.21.0 

func (pool Pool) AreTokensInDenomInPoolAssets(tokensIn sdk.Coins) bool

Ensure the denoms of the tokens in are assets of the pool

args:

  • tokensIn: the tokens to check

ret:

  • ok: true if all the denom from tokens in tokens in are in the pool

func (Pool) CalcInAmtGivenOut 

func (pool Pool) CalcInAmtGivenOut(tokenOut sdk.Coin, tokenInDenom string) (
	tokenIn sdk.Coin, err error,
)

Calculates the amount of tokenIn required to obtain tokenOut coins from a swap, accounting for additional fees. Only supports single asset swaps. This function is the inverse of CalcOutAmtGivenIn.

args:

  • tokenOut: the amount of tokens to swap
  • tokenInDenom: the target token denom

ret:

  • tokenIn: the tokens received from the swap
  • err: error if any

func (Pool) CalcInAmtGivenOutBalancer 

func (pool Pool) CalcInAmtGivenOutBalancer(tokenOut sdk.Coin, tokenInDenom string) (
	tokenIn sdk.Coin, err error,
)

Calculates the amount of tokenIn required to obtain tokenOut coins from a swap, accounting for additional fees. Only supports single asset swaps. This function is the inverse of CalcOutAmtGivenIn.

args:

  • tokenOut: the amount of tokens to swap
  • tokenInDenom: the target token denom

ret:

  • tokenIn: the tokens received from the swap
  • err: error if any

func (Pool) CalcInAmtGivenOutStableswap 

func (pool Pool) CalcInAmtGivenOutStableswap(tokenOut sdk.Coin, tokenInDenom string) (
	tokenIn sdk.Coin, err error,
)

Calculates the amount of tokenIn required to obtain tokenOut coins from a swap, accounting for additional fees. This is not implemented yet in curve and in Nibiru.

func (Pool) CalcOutAmtGivenIn 

func (pool Pool) CalcOutAmtGivenIn(tokenIn sdk.Coin, tokenOutDenom string, noFee bool) (
	tokenOut sdk.Coin, fee sdk.Coin, err error,
)

CalcOutAmtGivenIn Calculates the amount of tokenOut given tokenIn, deducting the swap fee. Solved using the SolveConstantProductInvariant AMM curve. Only supports single asset swaps.

args:

  • tokenIn: the amount of tokens to swap
  • tokenOutDenom: the target token denom
  • noFee: whether we want to bypass swap fee (for single asset join)

ret:

  • tokenOut: the tokens received from the swap
  • fee: the fee deducted from the swap
  • err: error if any

func (Pool) CalcSpotPrice 

func (pool Pool) CalcSpotPrice(tokenIn, tokenOut string) (sdk.Dec, error)

CalcSpotPrice calculates the spot price based on weight. spotPrice = (BalanceIn / WeightIn) / (BalanceOut / WeightOut)

func (*Pool) Descriptor 

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

func (Pool) Exchange 

func (pool Pool) Exchange(tokenIn sdk.Coin, tokenOutDenom string) (dy sdkmath.Int, err error)

Calculate the amount of token out

func (*Pool) ExitPool 

func (pool *Pool) ExitPool(exitingShares sdkmath.Int) (
	exitedCoins sdk.Coins, fees sdk.Coins, err error,
)

ExitPool Given the amount of pool shares to exit, calculates the amount of coins to exit from the pool and modifies the pool. Accounts for an exit fee, if any, on the pool.

args:

  • exitingShares: the number of pool shares to exit from the pool

func (Pool) GetAddress 

func (pool Pool) GetAddress() (addr sdk.AccAddress)

GetAddress Fetch the pool's address as an sdk.Address.

func (Pool) GetD 

func (pool Pool) GetD(poolAssets []PoolAsset) (*uint256.Int, error)

For a stableswap pool, compute the D invariant value in non-overflowing integer operations iteratively A * sum(x_i) * n**n + D = A * D * n**n + D**(n+1) / (n**n * prod(x_i)) Converging solution: D[j+1] = (A * n**n * sum(x_i) - D[j]**(n+1) / (n**n prod(x_i))) / (A * n**n - 1)

func (*Pool) Marshal 

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

func (*Pool) MarshalTo 

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

func (*Pool) MarshalToSizedBuffer 

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

func (Pool) MinSharesInForTokensOut added in v0.21.0 

func (pool Pool) MinSharesInForTokensOut() (minShares sdkmath.Int)

Compute the minimum number of shares a user need to provide to get at least one u-token

func (Pool) PoolBalances 

func (pool Pool) PoolBalances() sdk.Coins

Maps poolAssets to its underlying coins.

ret:

  • coins: all the coins in the pool assets

args:

  • poolAssets: the slice of pool assets

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) Size 

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

func (Pool) SolveStableswapInvariant 

func (pool Pool) SolveStableswapInvariant(tokenIn sdk.Coin, tokenOutDenom string) (yAmount sdkmath.Int, err error)

Calculate y if one makes x = tokenIn Done by solving quadratic equation iteratively. x_1**2 + x1 * (sum' - (A*n**n - 1) * D / (A * n**n)) = D ** (n+1)/(n ** (2 * n) * prod' * A) x_1**2 + b*x_1 = c x_1 = (x_1**2 + c) / (2*x_1 + b - D)

func (*Pool) String 

func (m *Pool) String() string

func (*Pool) SubtractPoolAssetBalance 

func (pool *Pool) SubtractPoolAssetBalance(assetDenom string, subAmt sdkmath.Int) (err error)

Subtracts an amount of coins from a pool's assets. Throws an error if the final amount is less than zero.

func (Pool) TokensOutFromPoolSharesIn 

func (pool Pool) TokensOutFromPoolSharesIn(numSharesIn sdkmath.Int) (
	tokensOut sdk.Coins, fees sdk.Coins, err error,
)

TokensOutFromPoolSharesIn Calculates the number of tokens to remove from liquidity given LP shares returned to the pool.

Note that this function is pure/read-only. It only calculates the theoretical amoount and doesn't modify the actual state.

args:

  • numSharesIn: number of LP shares to return to the pool

ret:

  • tokensOut: the tokens withdrawn from the pool
  • fees: the fees collected
  • err: error if any

func (*Pool) Unmarshal 

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

func (*Pool) XXX_DiscardUnknown 

func (m *Pool) XXX_DiscardUnknown()

func (*Pool) XXX_Marshal 

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

func (*Pool) XXX_Merge 

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

func (*Pool) XXX_Size 

func (m *Pool) XXX_Size() int

func (*Pool) XXX_Unmarshal 

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

type PoolAsset 

type PoolAsset struct {
	// Coins we are talking about,
	// the denomination must be unique amongst all PoolAssets for this pool.
	Token types.Coin `protobuf:"bytes,1,opt,name=token,proto3" json:"token" yaml:"token"`
	// Weight that is not normalized. This weight must be less than 2^50
	Weight github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,2,opt,name=weight,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"weight" yaml:"weight"`
}

Which assets the pool contains.

func (*PoolAsset) Descriptor 

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

func (*PoolAsset) GetToken 

func (m *PoolAsset) GetToken() types.Coin

func (*PoolAsset) Marshal 

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

func (*PoolAsset) MarshalTo 

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

func (*PoolAsset) MarshalToSizedBuffer 

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

func (*PoolAsset) ProtoMessage 

func (*PoolAsset) ProtoMessage()

func (*PoolAsset) Reset 

func (m *PoolAsset) Reset()

func (*PoolAsset) Size 

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

func (*PoolAsset) String 

func (m *PoolAsset) String() string

func (*PoolAsset) Unmarshal 

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

func (PoolAsset) Validate 

func (poolAsset PoolAsset) Validate() error

Validates a PoolAsset amount and weights.

func (*PoolAsset) XXX_DiscardUnknown 

func (m *PoolAsset) XXX_DiscardUnknown()

func (*PoolAsset) XXX_Marshal 

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

func (*PoolAsset) XXX_Merge 

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

func (*PoolAsset) XXX_Size 

func (m *PoolAsset) XXX_Size() int

func (*PoolAsset) XXX_Unmarshal 

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

type PoolParams 

type PoolParams struct {
	SwapFee github_com_cosmos_cosmos_sdk_types.Dec `` /* 138-byte string literal not displayed */
	ExitFee github_com_cosmos_cosmos_sdk_types.Dec `` /* 138-byte string literal not displayed */
	// Amplification Parameter (A): Larger value of A make the curve better
	// resemble a straight line in the center (when pool is near balance).  Highly
	// volatile assets should use a lower value, while assets that are closer
	// together may be best with a higher value. This is only used if the
	// pool_type is set to 1 (stableswap)
	A        github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,3,opt,name=A,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Int" json:"A" yaml:"amplification"`
	PoolType PoolType                               `` /* 132-byte string literal not displayed */
}

Configuration parameters for the pool.

func (*PoolParams) Descriptor 

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

func (*PoolParams) GetPoolType 

func (m *PoolParams) GetPoolType() PoolType

func (*PoolParams) Marshal 

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

func (*PoolParams) MarshalTo 

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

func (*PoolParams) MarshalToSizedBuffer 

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

func (*PoolParams) ProtoMessage 

func (*PoolParams) ProtoMessage()

func (*PoolParams) Reset 

func (m *PoolParams) Reset()

func (*PoolParams) Size 

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

func (*PoolParams) String 

func (m *PoolParams) String() string

func (*PoolParams) Unmarshal 

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

func (*PoolParams) XXX_DiscardUnknown 

func (m *PoolParams) XXX_DiscardUnknown()

func (*PoolParams) XXX_Marshal 

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

func (*PoolParams) XXX_Merge 

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

func (*PoolParams) XXX_Size 

func (m *PoolParams) XXX_Size() int

func (*PoolParams) XXX_Unmarshal 

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

type PoolType 

type PoolType int32

- `balancer`: Balancer are pools defined by the equation xy=k, extended by the weighs introduced by Balancer. - `stableswap`: Stableswap pools are defined by a combination of constant-product and constant-sum pool 

const (
	PoolType_BALANCER   PoolType = 0
	PoolType_STABLESWAP PoolType = 1
)

func (PoolType) EnumDescriptor 

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

func (PoolType) String 

func (x PoolType) String() string

type QueryClient 

type QueryClient interface {
	// Parameters of the spot module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Next available pool id number.
	PoolNumber(ctx context.Context, in *QueryPoolNumberRequest, opts ...grpc.CallOption) (*QueryPoolNumberResponse, error)
	// Fetch a pool by id.
	Pool(ctx context.Context, in *QueryPoolRequest, opts ...grpc.CallOption) (*QueryPoolResponse, error)
	// Returns all pools.
	Pools(ctx context.Context, in *QueryPoolsRequest, opts ...grpc.CallOption) (*QueryPoolsResponse, error)
	// Parameters of a single pool.
	PoolParams(ctx context.Context, in *QueryPoolParamsRequest, opts ...grpc.CallOption) (*QueryPoolParamsResponse, error)
	// Number of pools.
	NumPools(ctx context.Context, in *QueryNumPoolsRequest, opts ...grpc.CallOption) (*QueryNumPoolsResponse, error)
	// Total liquidity across all pools.
	TotalLiquidity(ctx context.Context, in *QueryTotalLiquidityRequest, opts ...grpc.CallOption) (*QueryTotalLiquidityResponse, error)
	// Total liquidity in a single pool.
	TotalPoolLiquidity(ctx context.Context, in *QueryTotalPoolLiquidityRequest, opts ...grpc.CallOption) (*QueryTotalPoolLiquidityResponse, error)
	// Total shares in a single pool.
	TotalShares(ctx context.Context, in *QueryTotalSharesRequest, opts ...grpc.CallOption) (*QueryTotalSharesResponse, error)
	// Instantaneous price of an asset in a pool.
	SpotPrice(ctx context.Context, in *QuerySpotPriceRequest, opts ...grpc.CallOption) (*QuerySpotPriceResponse, error)
	// Estimates the amount of assets returned given an exact amount of tokens to
	// swap.
	EstimateSwapExactAmountIn(ctx context.Context, in *QuerySwapExactAmountInRequest, opts ...grpc.CallOption) (*QuerySwapExactAmountInResponse, error)
	// Estimates the amount of tokens required to return the exact amount of
	// assets requested.
	EstimateSwapExactAmountOut(ctx context.Context, in *QuerySwapExactAmountOutRequest, opts ...grpc.CallOption) (*QuerySwapExactAmountOutResponse, error)
	// Estimates the amount of pool shares returned given an amount of tokens to
	// join.
	EstimateJoinExactAmountIn(ctx context.Context, in *QueryJoinExactAmountInRequest, opts ...grpc.CallOption) (*QueryJoinExactAmountInResponse, error)
	// Estimates the amount of tokens required to obtain an exact amount of pool
	// shares.
	EstimateJoinExactAmountOut(ctx context.Context, in *QueryJoinExactAmountOutRequest, opts ...grpc.CallOption) (*QueryJoinExactAmountOutResponse, error)
	// Estimates the amount of tokens returned to the user given an exact amount
	// of pool shares.
	EstimateExitExactAmountIn(ctx context.Context, in *QueryExitExactAmountInRequest, opts ...grpc.CallOption) (*QueryExitExactAmountInResponse, error)
	// Estimates the amount of pool shares required to extract an exact amount of
	// tokens from the pool.
	EstimateExitExactAmountOut(ctx context.Context, in *QueryExitExactAmountOutRequest, opts ...grpc.CallOption) (*QueryExitExactAmountOutResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryExitExactAmountInRequest 

type QueryExitExactAmountInRequest struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// amount of pool shares to return to pool
	PoolSharesIn github_com_cosmos_cosmos_sdk_types.Int `` /* 161-byte string literal not displayed */
}

func (*QueryExitExactAmountInRequest) Descriptor 

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

func (*QueryExitExactAmountInRequest) GetPoolId 

func (m *QueryExitExactAmountInRequest) GetPoolId() uint64

func (*QueryExitExactAmountInRequest) Marshal 

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

func (*QueryExitExactAmountInRequest) MarshalTo 

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

func (*QueryExitExactAmountInRequest) MarshalToSizedBuffer 

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

func (*QueryExitExactAmountInRequest) ProtoMessage 

func (*QueryExitExactAmountInRequest) ProtoMessage()

func (*QueryExitExactAmountInRequest) Reset 

func (m *QueryExitExactAmountInRequest) Reset()

func (*QueryExitExactAmountInRequest) Size 

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

func (*QueryExitExactAmountInRequest) String 

func (m *QueryExitExactAmountInRequest) String() string

func (*QueryExitExactAmountInRequest) Unmarshal 

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

func (*QueryExitExactAmountInRequest) XXX_DiscardUnknown 

func (m *QueryExitExactAmountInRequest) XXX_DiscardUnknown()

func (*QueryExitExactAmountInRequest) XXX_Marshal 

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

func (*QueryExitExactAmountInRequest) XXX_Merge 

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

func (*QueryExitExactAmountInRequest) XXX_Size 

func (m *QueryExitExactAmountInRequest) XXX_Size() int

func (*QueryExitExactAmountInRequest) XXX_Unmarshal 

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

type QueryExitExactAmountInResponse 

type QueryExitExactAmountInResponse struct {
	// coins obtained after exiting
	TokensOut github_com_cosmos_cosmos_sdk_types.Coins `` /* 150-byte string literal not displayed */
	Fees      github_com_cosmos_cosmos_sdk_types.Coins `protobuf:"bytes,2,rep,name=fees,proto3,castrepeated=github.com/cosmos/cosmos-sdk/types.Coins" json:"fees" yaml:"fees"`
}

func (*QueryExitExactAmountInResponse) Descriptor 

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

func (*QueryExitExactAmountInResponse) GetFees added in v0.21.0 

func (m *QueryExitExactAmountInResponse) GetFees() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryExitExactAmountInResponse) GetTokensOut 

func (m *QueryExitExactAmountInResponse) GetTokensOut() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryExitExactAmountInResponse) Marshal 

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

func (*QueryExitExactAmountInResponse) MarshalTo 

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

func (*QueryExitExactAmountInResponse) MarshalToSizedBuffer 

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

func (*QueryExitExactAmountInResponse) ProtoMessage 

func (*QueryExitExactAmountInResponse) ProtoMessage()

func (*QueryExitExactAmountInResponse) Reset 

func (m *QueryExitExactAmountInResponse) Reset()

func (*QueryExitExactAmountInResponse) Size 

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

func (*QueryExitExactAmountInResponse) String 

func (m *QueryExitExactAmountInResponse) String() string

func (*QueryExitExactAmountInResponse) Unmarshal 

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

func (*QueryExitExactAmountInResponse) XXX_DiscardUnknown 

func (m *QueryExitExactAmountInResponse) XXX_DiscardUnknown()

func (*QueryExitExactAmountInResponse) XXX_Marshal 

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

func (*QueryExitExactAmountInResponse) XXX_Merge 

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

func (*QueryExitExactAmountInResponse) XXX_Size 

func (m *QueryExitExactAmountInResponse) XXX_Size() int

func (*QueryExitExactAmountInResponse) XXX_Unmarshal 

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

type QueryExitExactAmountOutRequest 

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

func (*QueryExitExactAmountOutRequest) Descriptor 

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

func (*QueryExitExactAmountOutRequest) GetPoolId 

func (m *QueryExitExactAmountOutRequest) GetPoolId() uint64

func (*QueryExitExactAmountOutRequest) Marshal 

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

func (*QueryExitExactAmountOutRequest) MarshalTo 

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

func (*QueryExitExactAmountOutRequest) MarshalToSizedBuffer 

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

func (*QueryExitExactAmountOutRequest) ProtoMessage 

func (*QueryExitExactAmountOutRequest) ProtoMessage()

func (*QueryExitExactAmountOutRequest) Reset 

func (m *QueryExitExactAmountOutRequest) Reset()

func (*QueryExitExactAmountOutRequest) Size 

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

func (*QueryExitExactAmountOutRequest) String 

func (m *QueryExitExactAmountOutRequest) String() string

func (*QueryExitExactAmountOutRequest) Unmarshal 

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

func (*QueryExitExactAmountOutRequest) XXX_DiscardUnknown 

func (m *QueryExitExactAmountOutRequest) XXX_DiscardUnknown()

func (*QueryExitExactAmountOutRequest) XXX_Marshal 

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

func (*QueryExitExactAmountOutRequest) XXX_Merge 

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

func (*QueryExitExactAmountOutRequest) XXX_Size 

func (m *QueryExitExactAmountOutRequest) XXX_Size() int

func (*QueryExitExactAmountOutRequest) XXX_Unmarshal 

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

type QueryExitExactAmountOutResponse 

type QueryExitExactAmountOutResponse struct {
}

func (*QueryExitExactAmountOutResponse) Descriptor 

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

func (*QueryExitExactAmountOutResponse) Marshal 

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

func (*QueryExitExactAmountOutResponse) MarshalTo 

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

func (*QueryExitExactAmountOutResponse) MarshalToSizedBuffer 

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

func (*QueryExitExactAmountOutResponse) ProtoMessage 

func (*QueryExitExactAmountOutResponse) ProtoMessage()

func (*QueryExitExactAmountOutResponse) Reset 

func (m *QueryExitExactAmountOutResponse) Reset()

func (*QueryExitExactAmountOutResponse) Size 

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

func (*QueryExitExactAmountOutResponse) String 

func (m *QueryExitExactAmountOutResponse) String() string

func (*QueryExitExactAmountOutResponse) Unmarshal 

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

func (*QueryExitExactAmountOutResponse) XXX_DiscardUnknown 

func (m *QueryExitExactAmountOutResponse) XXX_DiscardUnknown()

func (*QueryExitExactAmountOutResponse) XXX_Marshal 

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

func (*QueryExitExactAmountOutResponse) XXX_Merge 

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

func (*QueryExitExactAmountOutResponse) XXX_Size 

func (m *QueryExitExactAmountOutResponse) XXX_Size() int

func (*QueryExitExactAmountOutResponse) XXX_Unmarshal 

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

type QueryJoinExactAmountInRequest 

type QueryJoinExactAmountInRequest struct {
	PoolId   uint64                                   `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	TokensIn github_com_cosmos_cosmos_sdk_types.Coins `` /* 146-byte string literal not displayed */
}

func (*QueryJoinExactAmountInRequest) Descriptor 

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

func (*QueryJoinExactAmountInRequest) GetPoolId 

func (m *QueryJoinExactAmountInRequest) GetPoolId() uint64

func (*QueryJoinExactAmountInRequest) GetTokensIn 

func (m *QueryJoinExactAmountInRequest) GetTokensIn() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryJoinExactAmountInRequest) Marshal 

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

func (*QueryJoinExactAmountInRequest) MarshalTo 

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

func (*QueryJoinExactAmountInRequest) MarshalToSizedBuffer 

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

func (*QueryJoinExactAmountInRequest) ProtoMessage 

func (*QueryJoinExactAmountInRequest) ProtoMessage()

func (*QueryJoinExactAmountInRequest) Reset 

func (m *QueryJoinExactAmountInRequest) Reset()

func (*QueryJoinExactAmountInRequest) Size 

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

func (*QueryJoinExactAmountInRequest) String 

func (m *QueryJoinExactAmountInRequest) String() string

func (*QueryJoinExactAmountInRequest) Unmarshal 

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

func (*QueryJoinExactAmountInRequest) XXX_DiscardUnknown 

func (m *QueryJoinExactAmountInRequest) XXX_DiscardUnknown()

func (*QueryJoinExactAmountInRequest) XXX_Marshal 

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

func (*QueryJoinExactAmountInRequest) XXX_Merge 

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

func (*QueryJoinExactAmountInRequest) XXX_Size 

func (m *QueryJoinExactAmountInRequest) XXX_Size() int

func (*QueryJoinExactAmountInRequest) XXX_Unmarshal 

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

type QueryJoinExactAmountInResponse 

type QueryJoinExactAmountInResponse struct {
	// amount of pool shares returned to user after join
	PoolSharesOut github_com_cosmos_cosmos_sdk_types.Int `` /* 165-byte string literal not displayed */
	// coins remaining after pool join
	RemCoins github_com_cosmos_cosmos_sdk_types.Coins `` /* 146-byte string literal not displayed */
}

func (*QueryJoinExactAmountInResponse) Descriptor 

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

func (*QueryJoinExactAmountInResponse) GetRemCoins 

func (m *QueryJoinExactAmountInResponse) GetRemCoins() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryJoinExactAmountInResponse) Marshal 

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

func (*QueryJoinExactAmountInResponse) MarshalTo 

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

func (*QueryJoinExactAmountInResponse) MarshalToSizedBuffer 

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

func (*QueryJoinExactAmountInResponse) ProtoMessage 

func (*QueryJoinExactAmountInResponse) ProtoMessage()

func (*QueryJoinExactAmountInResponse) Reset 

func (m *QueryJoinExactAmountInResponse) Reset()

func (*QueryJoinExactAmountInResponse) Size 

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

func (*QueryJoinExactAmountInResponse) String 

func (m *QueryJoinExactAmountInResponse) String() string

func (*QueryJoinExactAmountInResponse) Unmarshal 

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

func (*QueryJoinExactAmountInResponse) XXX_DiscardUnknown 

func (m *QueryJoinExactAmountInResponse) XXX_DiscardUnknown()

func (*QueryJoinExactAmountInResponse) XXX_Marshal 

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

func (*QueryJoinExactAmountInResponse) XXX_Merge 

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

func (*QueryJoinExactAmountInResponse) XXX_Size 

func (m *QueryJoinExactAmountInResponse) XXX_Size() int

func (*QueryJoinExactAmountInResponse) XXX_Unmarshal 

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

type QueryJoinExactAmountOutRequest 

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

func (*QueryJoinExactAmountOutRequest) Descriptor 

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

func (*QueryJoinExactAmountOutRequest) GetPoolId 

func (m *QueryJoinExactAmountOutRequest) GetPoolId() uint64

func (*QueryJoinExactAmountOutRequest) Marshal 

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

func (*QueryJoinExactAmountOutRequest) MarshalTo 

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

func (*QueryJoinExactAmountOutRequest) MarshalToSizedBuffer 

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

func (*QueryJoinExactAmountOutRequest) ProtoMessage 

func (*QueryJoinExactAmountOutRequest) ProtoMessage()

func (*QueryJoinExactAmountOutRequest) Reset 

func (m *QueryJoinExactAmountOutRequest) Reset()

func (*QueryJoinExactAmountOutRequest) Size 

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

func (*QueryJoinExactAmountOutRequest) String 

func (m *QueryJoinExactAmountOutRequest) String() string

func (*QueryJoinExactAmountOutRequest) Unmarshal 

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

func (*QueryJoinExactAmountOutRequest) XXX_DiscardUnknown 

func (m *QueryJoinExactAmountOutRequest) XXX_DiscardUnknown()

func (*QueryJoinExactAmountOutRequest) XXX_Marshal 

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

func (*QueryJoinExactAmountOutRequest) XXX_Merge 

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

func (*QueryJoinExactAmountOutRequest) XXX_Size 

func (m *QueryJoinExactAmountOutRequest) XXX_Size() int

func (*QueryJoinExactAmountOutRequest) XXX_Unmarshal 

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

type QueryJoinExactAmountOutResponse 

type QueryJoinExactAmountOutResponse struct {
}

func (*QueryJoinExactAmountOutResponse) Descriptor 

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

func (*QueryJoinExactAmountOutResponse) Marshal 

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

func (*QueryJoinExactAmountOutResponse) MarshalTo 

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

func (*QueryJoinExactAmountOutResponse) MarshalToSizedBuffer 

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

func (*QueryJoinExactAmountOutResponse) ProtoMessage 

func (*QueryJoinExactAmountOutResponse) ProtoMessage()

func (*QueryJoinExactAmountOutResponse) Reset 

func (m *QueryJoinExactAmountOutResponse) Reset()

func (*QueryJoinExactAmountOutResponse) Size 

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

func (*QueryJoinExactAmountOutResponse) String 

func (m *QueryJoinExactAmountOutResponse) String() string

func (*QueryJoinExactAmountOutResponse) Unmarshal 

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

func (*QueryJoinExactAmountOutResponse) XXX_DiscardUnknown 

func (m *QueryJoinExactAmountOutResponse) XXX_DiscardUnknown()

func (*QueryJoinExactAmountOutResponse) XXX_Marshal 

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

func (*QueryJoinExactAmountOutResponse) XXX_Merge 

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

func (*QueryJoinExactAmountOutResponse) XXX_Size 

func (m *QueryJoinExactAmountOutResponse) XXX_Size() int

func (*QueryJoinExactAmountOutResponse) XXX_Unmarshal 

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

type QueryNumPoolsRequest 

type QueryNumPoolsRequest struct {
}

func (*QueryNumPoolsRequest) Descriptor 

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

func (*QueryNumPoolsRequest) Marshal 

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

func (*QueryNumPoolsRequest) MarshalTo 

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

func (*QueryNumPoolsRequest) MarshalToSizedBuffer 

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

func (*QueryNumPoolsRequest) ProtoMessage 

func (*QueryNumPoolsRequest) ProtoMessage()

func (*QueryNumPoolsRequest) Reset 

func (m *QueryNumPoolsRequest) Reset()

func (*QueryNumPoolsRequest) Size 

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

func (*QueryNumPoolsRequest) String 

func (m *QueryNumPoolsRequest) String() string

func (*QueryNumPoolsRequest) Unmarshal 

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

func (*QueryNumPoolsRequest) XXX_DiscardUnknown 

func (m *QueryNumPoolsRequest) XXX_DiscardUnknown()

func (*QueryNumPoolsRequest) XXX_Marshal 

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

func (*QueryNumPoolsRequest) XXX_Merge 

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

func (*QueryNumPoolsRequest) XXX_Size 

func (m *QueryNumPoolsRequest) XXX_Size() int

func (*QueryNumPoolsRequest) XXX_Unmarshal 

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

type QueryNumPoolsResponse 

type QueryNumPoolsResponse struct {
	NumPools uint64 `protobuf:"varint,1,opt,name=num_pools,json=numPools,proto3" json:"num_pools,omitempty"`
}

func (*QueryNumPoolsResponse) Descriptor 

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

func (*QueryNumPoolsResponse) GetNumPools 

func (m *QueryNumPoolsResponse) GetNumPools() uint64

func (*QueryNumPoolsResponse) Marshal 

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

func (*QueryNumPoolsResponse) MarshalTo 

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

func (*QueryNumPoolsResponse) MarshalToSizedBuffer 

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

func (*QueryNumPoolsResponse) ProtoMessage 

func (*QueryNumPoolsResponse) ProtoMessage()

func (*QueryNumPoolsResponse) Reset 

func (m *QueryNumPoolsResponse) Reset()

func (*QueryNumPoolsResponse) Size 

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

func (*QueryNumPoolsResponse) String 

func (m *QueryNumPoolsResponse) String() string

func (*QueryNumPoolsResponse) Unmarshal 

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

func (*QueryNumPoolsResponse) XXX_DiscardUnknown 

func (m *QueryNumPoolsResponse) XXX_DiscardUnknown()

func (*QueryNumPoolsResponse) XXX_Marshal 

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

func (*QueryNumPoolsResponse) XXX_Merge 

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

func (*QueryNumPoolsResponse) XXX_Size 

func (m *QueryNumPoolsResponse) XXX_Size() int

func (*QueryNumPoolsResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryPoolNumberRequest 

type QueryPoolNumberRequest struct {
}

func (*QueryPoolNumberRequest) Descriptor 

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

func (*QueryPoolNumberRequest) Marshal 

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

func (*QueryPoolNumberRequest) MarshalTo 

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

func (*QueryPoolNumberRequest) MarshalToSizedBuffer 

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

func (*QueryPoolNumberRequest) ProtoMessage 

func (*QueryPoolNumberRequest) ProtoMessage()

func (*QueryPoolNumberRequest) Reset 

func (m *QueryPoolNumberRequest) Reset()

func (*QueryPoolNumberRequest) Size 

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

func (*QueryPoolNumberRequest) String 

func (m *QueryPoolNumberRequest) String() string

func (*QueryPoolNumberRequest) Unmarshal 

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

func (*QueryPoolNumberRequest) XXX_DiscardUnknown 

func (m *QueryPoolNumberRequest) XXX_DiscardUnknown()

func (*QueryPoolNumberRequest) XXX_Marshal 

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

func (*QueryPoolNumberRequest) XXX_Merge 

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

func (*QueryPoolNumberRequest) XXX_Size 

func (m *QueryPoolNumberRequest) XXX_Size() int

func (*QueryPoolNumberRequest) XXX_Unmarshal 

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

type QueryPoolNumberResponse 

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

func (*QueryPoolNumberResponse) Descriptor 

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

func (*QueryPoolNumberResponse) GetPoolId 

func (m *QueryPoolNumberResponse) GetPoolId() uint64

func (*QueryPoolNumberResponse) Marshal 

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

func (*QueryPoolNumberResponse) MarshalTo 

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

func (*QueryPoolNumberResponse) MarshalToSizedBuffer 

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

func (*QueryPoolNumberResponse) ProtoMessage 

func (*QueryPoolNumberResponse) ProtoMessage()

func (*QueryPoolNumberResponse) Reset 

func (m *QueryPoolNumberResponse) Reset()

func (*QueryPoolNumberResponse) Size 

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

func (*QueryPoolNumberResponse) String 

func (m *QueryPoolNumberResponse) String() string

func (*QueryPoolNumberResponse) Unmarshal 

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

func (*QueryPoolNumberResponse) XXX_DiscardUnknown 

func (m *QueryPoolNumberResponse) XXX_DiscardUnknown()

func (*QueryPoolNumberResponse) XXX_Marshal 

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

func (*QueryPoolNumberResponse) XXX_Merge 

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

func (*QueryPoolNumberResponse) XXX_Size 

func (m *QueryPoolNumberResponse) XXX_Size() int

func (*QueryPoolNumberResponse) XXX_Unmarshal 

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

type QueryPoolParamsRequest 

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

func (*QueryPoolParamsRequest) Descriptor 

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

func (*QueryPoolParamsRequest) GetPoolId 

func (m *QueryPoolParamsRequest) GetPoolId() uint64

func (*QueryPoolParamsRequest) Marshal 

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

func (*QueryPoolParamsRequest) MarshalTo 

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

func (*QueryPoolParamsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolParamsRequest) ProtoMessage 

func (*QueryPoolParamsRequest) ProtoMessage()

func (*QueryPoolParamsRequest) Reset 

func (m *QueryPoolParamsRequest) Reset()

func (*QueryPoolParamsRequest) Size 

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

func (*QueryPoolParamsRequest) String 

func (m *QueryPoolParamsRequest) String() string

func (*QueryPoolParamsRequest) Unmarshal 

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

func (*QueryPoolParamsRequest) XXX_DiscardUnknown 

func (m *QueryPoolParamsRequest) XXX_DiscardUnknown()

func (*QueryPoolParamsRequest) XXX_Marshal 

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

func (*QueryPoolParamsRequest) XXX_Merge 

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

func (*QueryPoolParamsRequest) XXX_Size 

func (m *QueryPoolParamsRequest) XXX_Size() int

func (*QueryPoolParamsRequest) XXX_Unmarshal 

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

type QueryPoolParamsResponse 

type QueryPoolParamsResponse struct {
	PoolParams *PoolParams `protobuf:"bytes,1,opt,name=pool_params,json=poolParams,proto3" json:"pool_params,omitempty"`
}

func (*QueryPoolParamsResponse) Descriptor 

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

func (*QueryPoolParamsResponse) GetPoolParams 

func (m *QueryPoolParamsResponse) GetPoolParams() *PoolParams

func (*QueryPoolParamsResponse) Marshal 

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

func (*QueryPoolParamsResponse) MarshalTo 

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

func (*QueryPoolParamsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolParamsResponse) ProtoMessage 

func (*QueryPoolParamsResponse) ProtoMessage()

func (*QueryPoolParamsResponse) Reset 

func (m *QueryPoolParamsResponse) Reset()

func (*QueryPoolParamsResponse) Size 

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

func (*QueryPoolParamsResponse) String 

func (m *QueryPoolParamsResponse) String() string

func (*QueryPoolParamsResponse) Unmarshal 

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

func (*QueryPoolParamsResponse) XXX_DiscardUnknown 

func (m *QueryPoolParamsResponse) XXX_DiscardUnknown()

func (*QueryPoolParamsResponse) XXX_Marshal 

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

func (*QueryPoolParamsResponse) XXX_Merge 

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

func (*QueryPoolParamsResponse) XXX_Size 

func (m *QueryPoolParamsResponse) XXX_Size() int

func (*QueryPoolParamsResponse) XXX_Unmarshal 

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

type QueryPoolRequest 

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

func (*QueryPoolRequest) Descriptor 

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

func (*QueryPoolRequest) GetPoolId 

func (m *QueryPoolRequest) GetPoolId() uint64

func (*QueryPoolRequest) Marshal 

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

func (*QueryPoolRequest) MarshalTo 

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

func (*QueryPoolRequest) MarshalToSizedBuffer 

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

func (*QueryPoolRequest) ProtoMessage 

func (*QueryPoolRequest) ProtoMessage()

func (*QueryPoolRequest) Reset 

func (m *QueryPoolRequest) Reset()

func (*QueryPoolRequest) Size 

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

func (*QueryPoolRequest) String 

func (m *QueryPoolRequest) String() string

func (*QueryPoolRequest) Unmarshal 

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

func (*QueryPoolRequest) XXX_DiscardUnknown 

func (m *QueryPoolRequest) XXX_DiscardUnknown()

func (*QueryPoolRequest) XXX_Marshal 

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

func (*QueryPoolRequest) XXX_Merge 

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

func (*QueryPoolRequest) XXX_Size 

func (m *QueryPoolRequest) XXX_Size() int

func (*QueryPoolRequest) XXX_Unmarshal 

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

type QueryPoolResponse 

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

func (*QueryPoolResponse) Descriptor 

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

func (*QueryPoolResponse) GetPool 

func (m *QueryPoolResponse) GetPool() *Pool

func (*QueryPoolResponse) Marshal 

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

func (*QueryPoolResponse) MarshalTo 

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

func (*QueryPoolResponse) MarshalToSizedBuffer 

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

func (*QueryPoolResponse) ProtoMessage 

func (*QueryPoolResponse) ProtoMessage()

func (*QueryPoolResponse) Reset 

func (m *QueryPoolResponse) Reset()

func (*QueryPoolResponse) Size 

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

func (*QueryPoolResponse) String 

func (m *QueryPoolResponse) String() string

func (*QueryPoolResponse) Unmarshal 

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

func (*QueryPoolResponse) XXX_DiscardUnknown 

func (m *QueryPoolResponse) XXX_DiscardUnknown()

func (*QueryPoolResponse) XXX_Marshal 

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

func (*QueryPoolResponse) XXX_Merge 

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

func (*QueryPoolResponse) XXX_Size 

func (m *QueryPoolResponse) XXX_Size() int

func (*QueryPoolResponse) XXX_Unmarshal 

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

type QueryPoolsRequest 

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

func (*QueryPoolsRequest) Descriptor 

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

func (*QueryPoolsRequest) GetPagination 

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

func (*QueryPoolsRequest) Marshal 

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

func (*QueryPoolsRequest) MarshalTo 

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

func (*QueryPoolsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolsRequest) ProtoMessage 

func (*QueryPoolsRequest) ProtoMessage()

func (*QueryPoolsRequest) Reset 

func (m *QueryPoolsRequest) Reset()

func (*QueryPoolsRequest) Size 

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

func (*QueryPoolsRequest) String 

func (m *QueryPoolsRequest) String() string

func (*QueryPoolsRequest) Unmarshal 

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

func (*QueryPoolsRequest) XXX_DiscardUnknown 

func (m *QueryPoolsRequest) XXX_DiscardUnknown()

func (*QueryPoolsRequest) XXX_Marshal 

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

func (*QueryPoolsRequest) XXX_Merge 

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

func (*QueryPoolsRequest) XXX_Size 

func (m *QueryPoolsRequest) XXX_Size() int

func (*QueryPoolsRequest) XXX_Unmarshal 

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

type QueryPoolsResponse 

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

func (*QueryPoolsResponse) Descriptor 

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

func (*QueryPoolsResponse) GetPagination 

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

func (*QueryPoolsResponse) GetPools 

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

func (*QueryPoolsResponse) Marshal 

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

func (*QueryPoolsResponse) MarshalTo 

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

func (*QueryPoolsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolsResponse) ProtoMessage 

func (*QueryPoolsResponse) ProtoMessage()

func (*QueryPoolsResponse) Reset 

func (m *QueryPoolsResponse) Reset()

func (*QueryPoolsResponse) Size 

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

func (*QueryPoolsResponse) String 

func (m *QueryPoolsResponse) String() string

func (*QueryPoolsResponse) Unmarshal 

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

func (*QueryPoolsResponse) XXX_DiscardUnknown 

func (m *QueryPoolsResponse) XXX_DiscardUnknown()

func (*QueryPoolsResponse) XXX_Marshal 

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

func (*QueryPoolsResponse) XXX_Merge 

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

func (*QueryPoolsResponse) XXX_Size 

func (m *QueryPoolsResponse) XXX_Size() int

func (*QueryPoolsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Parameters of the spot module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Next available pool id number.
	PoolNumber(context.Context, *QueryPoolNumberRequest) (*QueryPoolNumberResponse, error)
	// Fetch a pool by id.
	Pool(context.Context, *QueryPoolRequest) (*QueryPoolResponse, error)
	// Returns all pools.
	Pools(context.Context, *QueryPoolsRequest) (*QueryPoolsResponse, error)
	// Parameters of a single pool.
	PoolParams(context.Context, *QueryPoolParamsRequest) (*QueryPoolParamsResponse, error)
	// Number of pools.
	NumPools(context.Context, *QueryNumPoolsRequest) (*QueryNumPoolsResponse, error)
	// Total liquidity across all pools.
	TotalLiquidity(context.Context, *QueryTotalLiquidityRequest) (*QueryTotalLiquidityResponse, error)
	// Total liquidity in a single pool.
	TotalPoolLiquidity(context.Context, *QueryTotalPoolLiquidityRequest) (*QueryTotalPoolLiquidityResponse, error)
	// Total shares in a single pool.
	TotalShares(context.Context, *QueryTotalSharesRequest) (*QueryTotalSharesResponse, error)
	// Instantaneous price of an asset in a pool.
	SpotPrice(context.Context, *QuerySpotPriceRequest) (*QuerySpotPriceResponse, error)
	// Estimates the amount of assets returned given an exact amount of tokens to
	// swap.
	EstimateSwapExactAmountIn(context.Context, *QuerySwapExactAmountInRequest) (*QuerySwapExactAmountInResponse, error)
	// Estimates the amount of tokens required to return the exact amount of
	// assets requested.
	EstimateSwapExactAmountOut(context.Context, *QuerySwapExactAmountOutRequest) (*QuerySwapExactAmountOutResponse, error)
	// Estimates the amount of pool shares returned given an amount of tokens to
	// join.
	EstimateJoinExactAmountIn(context.Context, *QueryJoinExactAmountInRequest) (*QueryJoinExactAmountInResponse, error)
	// Estimates the amount of tokens required to obtain an exact amount of pool
	// shares.
	EstimateJoinExactAmountOut(context.Context, *QueryJoinExactAmountOutRequest) (*QueryJoinExactAmountOutResponse, error)
	// Estimates the amount of tokens returned to the user given an exact amount
	// of pool shares.
	EstimateExitExactAmountIn(context.Context, *QueryExitExactAmountInRequest) (*QueryExitExactAmountInResponse, error)
	// Estimates the amount of pool shares required to extract an exact amount of
	// tokens from the pool.
	EstimateExitExactAmountOut(context.Context, *QueryExitExactAmountOutRequest) (*QueryExitExactAmountOutResponse, error)
}

QueryServer is the server API for Query service.

type QuerySpotPriceRequest 

type QuerySpotPriceRequest struct {
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// the denomination of the token you are giving into the pool
	TokenInDenom string `protobuf:"bytes,2,opt,name=token_in_denom,json=tokenInDenom,proto3" json:"token_in_denom,omitempty"`
	// the denomination of the token you are taking out of the pool
	TokenOutDenom string `protobuf:"bytes,3,opt,name=token_out_denom,json=tokenOutDenom,proto3" json:"token_out_denom,omitempty"`
}

Returns the amount of tokenInDenom to produce 1 tokenOutDenom For example, if the price of NIBI = 9.123 NUSD, then setting tokenInDenom=NUSD and tokenOutDenom=NIBI would give "9.123".

func (*QuerySpotPriceRequest) Descriptor 

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

func (*QuerySpotPriceRequest) GetPoolId 

func (m *QuerySpotPriceRequest) GetPoolId() uint64

func (*QuerySpotPriceRequest) GetTokenInDenom 

func (m *QuerySpotPriceRequest) GetTokenInDenom() string

func (*QuerySpotPriceRequest) GetTokenOutDenom 

func (m *QuerySpotPriceRequest) GetTokenOutDenom() string

func (*QuerySpotPriceRequest) Marshal 

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

func (*QuerySpotPriceRequest) MarshalTo 

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

func (*QuerySpotPriceRequest) MarshalToSizedBuffer 

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

func (*QuerySpotPriceRequest) ProtoMessage 

func (*QuerySpotPriceRequest) ProtoMessage()

func (*QuerySpotPriceRequest) Reset 

func (m *QuerySpotPriceRequest) Reset()

func (*QuerySpotPriceRequest) Size 

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

func (*QuerySpotPriceRequest) String 

func (m *QuerySpotPriceRequest) String() string

func (*QuerySpotPriceRequest) Unmarshal 

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

func (*QuerySpotPriceRequest) XXX_DiscardUnknown 

func (m *QuerySpotPriceRequest) XXX_DiscardUnknown()

func (*QuerySpotPriceRequest) XXX_Marshal 

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

func (*QuerySpotPriceRequest) XXX_Merge 

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

func (*QuerySpotPriceRequest) XXX_Size 

func (m *QuerySpotPriceRequest) XXX_Size() int

func (*QuerySpotPriceRequest) XXX_Unmarshal 

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

type QuerySpotPriceResponse 

type QuerySpotPriceResponse struct {
	SpotPrice string `protobuf:"bytes,1,opt,name=spot_price,json=spotPrice,proto3" json:"spot_price,omitempty"`
}

func (*QuerySpotPriceResponse) Descriptor 

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

func (*QuerySpotPriceResponse) GetSpotPrice 

func (m *QuerySpotPriceResponse) GetSpotPrice() string

func (*QuerySpotPriceResponse) Marshal 

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

func (*QuerySpotPriceResponse) MarshalTo 

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

func (*QuerySpotPriceResponse) MarshalToSizedBuffer 

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

func (*QuerySpotPriceResponse) ProtoMessage 

func (*QuerySpotPriceResponse) ProtoMessage()

func (*QuerySpotPriceResponse) Reset 

func (m *QuerySpotPriceResponse) Reset()

func (*QuerySpotPriceResponse) Size 

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

func (*QuerySpotPriceResponse) String 

func (m *QuerySpotPriceResponse) String() string

func (*QuerySpotPriceResponse) Unmarshal 

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

func (*QuerySpotPriceResponse) XXX_DiscardUnknown 

func (m *QuerySpotPriceResponse) XXX_DiscardUnknown()

func (*QuerySpotPriceResponse) XXX_Marshal 

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

func (*QuerySpotPriceResponse) XXX_Merge 

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

func (*QuerySpotPriceResponse) XXX_Size 

func (m *QuerySpotPriceResponse) XXX_Size() int

func (*QuerySpotPriceResponse) XXX_Unmarshal 

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

type QuerySwapExactAmountInRequest 

type QuerySwapExactAmountInRequest struct {
	PoolId        uint64     `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	TokenIn       types.Coin `protobuf:"bytes,2,opt,name=token_in,json=tokenIn,proto3" json:"token_in" yaml:"token_in"`
	TokenOutDenom string     `protobuf:"bytes,3,opt,name=token_out_denom,json=tokenOutDenom,proto3" json:"token_out_denom,omitempty"`
}

Given an exact amount of tokens in and a target tokenOutDenom, calculates the expected amount of tokens out received from a swap.

func (*QuerySwapExactAmountInRequest) Descriptor 

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

func (*QuerySwapExactAmountInRequest) GetPoolId 

func (m *QuerySwapExactAmountInRequest) GetPoolId() uint64

func (*QuerySwapExactAmountInRequest) GetTokenIn 

func (m *QuerySwapExactAmountInRequest) GetTokenIn() types.Coin

func (*QuerySwapExactAmountInRequest) GetTokenOutDenom 

func (m *QuerySwapExactAmountInRequest) GetTokenOutDenom() string

func (*QuerySwapExactAmountInRequest) Marshal 

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

func (*QuerySwapExactAmountInRequest) MarshalTo 

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

func (*QuerySwapExactAmountInRequest) MarshalToSizedBuffer 

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

func (*QuerySwapExactAmountInRequest) ProtoMessage 

func (*QuerySwapExactAmountInRequest) ProtoMessage()

func (*QuerySwapExactAmountInRequest) Reset 

func (m *QuerySwapExactAmountInRequest) Reset()

func (*QuerySwapExactAmountInRequest) Size 

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

func (*QuerySwapExactAmountInRequest) String 

func (m *QuerySwapExactAmountInRequest) String() string

func (*QuerySwapExactAmountInRequest) Unmarshal 

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

func (*QuerySwapExactAmountInRequest) XXX_DiscardUnknown 

func (m *QuerySwapExactAmountInRequest) XXX_DiscardUnknown()

func (*QuerySwapExactAmountInRequest) XXX_Marshal 

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

func (*QuerySwapExactAmountInRequest) XXX_Merge 

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

func (*QuerySwapExactAmountInRequest) XXX_Size 

func (m *QuerySwapExactAmountInRequest) XXX_Size() int

func (*QuerySwapExactAmountInRequest) XXX_Unmarshal 

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

type QuerySwapExactAmountInResponse 

type QuerySwapExactAmountInResponse struct {
	TokenOut types.Coin `protobuf:"bytes,2,opt,name=token_out,json=tokenOut,proto3" json:"token_out" yaml:"token_out"`
	Fee      types.Coin `protobuf:"bytes,3,opt,name=fee,proto3" json:"fee" yaml:"fee"`
}

func (*QuerySwapExactAmountInResponse) Descriptor 

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

func (*QuerySwapExactAmountInResponse) GetFee added in v0.21.0 

func (m *QuerySwapExactAmountInResponse) GetFee() types.Coin

func (*QuerySwapExactAmountInResponse) GetTokenOut 

func (m *QuerySwapExactAmountInResponse) GetTokenOut() types.Coin

func (*QuerySwapExactAmountInResponse) Marshal 

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

func (*QuerySwapExactAmountInResponse) MarshalTo 

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

func (*QuerySwapExactAmountInResponse) MarshalToSizedBuffer 

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

func (*QuerySwapExactAmountInResponse) ProtoMessage 

func (*QuerySwapExactAmountInResponse) ProtoMessage()

func (*QuerySwapExactAmountInResponse) Reset 

func (m *QuerySwapExactAmountInResponse) Reset()

func (*QuerySwapExactAmountInResponse) Size 

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

func (*QuerySwapExactAmountInResponse) String 

func (m *QuerySwapExactAmountInResponse) String() string

func (*QuerySwapExactAmountInResponse) Unmarshal 

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

func (*QuerySwapExactAmountInResponse) XXX_DiscardUnknown 

func (m *QuerySwapExactAmountInResponse) XXX_DiscardUnknown()

func (*QuerySwapExactAmountInResponse) XXX_Marshal 

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

func (*QuerySwapExactAmountInResponse) XXX_Merge 

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

func (*QuerySwapExactAmountInResponse) XXX_Size 

func (m *QuerySwapExactAmountInResponse) XXX_Size() int

func (*QuerySwapExactAmountInResponse) XXX_Unmarshal 

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

type QuerySwapExactAmountOutRequest 

type QuerySwapExactAmountOutRequest struct {
	PoolId       uint64     `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	TokenOut     types.Coin `protobuf:"bytes,2,opt,name=token_out,json=tokenOut,proto3" json:"token_out" yaml:"token_out"`
	TokenInDenom string     `protobuf:"bytes,3,opt,name=token_in_denom,json=tokenInDenom,proto3" json:"token_in_denom,omitempty"`
}

Given an exact amount of tokens out and a target tokenInDenom, calculates the expected amount of tokens in required to do the swap.

func (*QuerySwapExactAmountOutRequest) Descriptor 

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

func (*QuerySwapExactAmountOutRequest) GetPoolId 

func (m *QuerySwapExactAmountOutRequest) GetPoolId() uint64

func (*QuerySwapExactAmountOutRequest) GetTokenInDenom 

func (m *QuerySwapExactAmountOutRequest) GetTokenInDenom() string

func (*QuerySwapExactAmountOutRequest) GetTokenOut 

func (m *QuerySwapExactAmountOutRequest) GetTokenOut() types.Coin

func (*QuerySwapExactAmountOutRequest) Marshal 

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

func (*QuerySwapExactAmountOutRequest) MarshalTo 

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

func (*QuerySwapExactAmountOutRequest) MarshalToSizedBuffer 

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

func (*QuerySwapExactAmountOutRequest) ProtoMessage 

func (*QuerySwapExactAmountOutRequest) ProtoMessage()

func (*QuerySwapExactAmountOutRequest) Reset 

func (m *QuerySwapExactAmountOutRequest) Reset()

func (*QuerySwapExactAmountOutRequest) Size 

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

func (*QuerySwapExactAmountOutRequest) String 

func (m *QuerySwapExactAmountOutRequest) String() string

func (*QuerySwapExactAmountOutRequest) Unmarshal 

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

func (*QuerySwapExactAmountOutRequest) XXX_DiscardUnknown 

func (m *QuerySwapExactAmountOutRequest) XXX_DiscardUnknown()

func (*QuerySwapExactAmountOutRequest) XXX_Marshal 

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

func (*QuerySwapExactAmountOutRequest) XXX_Merge 

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

func (*QuerySwapExactAmountOutRequest) XXX_Size 

func (m *QuerySwapExactAmountOutRequest) XXX_Size() int

func (*QuerySwapExactAmountOutRequest) XXX_Unmarshal 

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

type QuerySwapExactAmountOutResponse 

type QuerySwapExactAmountOutResponse struct {
	TokenIn types.Coin `protobuf:"bytes,2,opt,name=token_in,json=tokenIn,proto3" json:"token_in" yaml:"token_in"`
}

func (*QuerySwapExactAmountOutResponse) Descriptor 

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

func (*QuerySwapExactAmountOutResponse) GetTokenIn 

func (m *QuerySwapExactAmountOutResponse) GetTokenIn() types.Coin

func (*QuerySwapExactAmountOutResponse) Marshal 

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

func (*QuerySwapExactAmountOutResponse) MarshalTo 

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

func (*QuerySwapExactAmountOutResponse) MarshalToSizedBuffer 

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

func (*QuerySwapExactAmountOutResponse) ProtoMessage 

func (*QuerySwapExactAmountOutResponse) ProtoMessage()

func (*QuerySwapExactAmountOutResponse) Reset 

func (m *QuerySwapExactAmountOutResponse) Reset()

func (*QuerySwapExactAmountOutResponse) Size 

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

func (*QuerySwapExactAmountOutResponse) String 

func (m *QuerySwapExactAmountOutResponse) String() string

func (*QuerySwapExactAmountOutResponse) Unmarshal 

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

func (*QuerySwapExactAmountOutResponse) XXX_DiscardUnknown 

func (m *QuerySwapExactAmountOutResponse) XXX_DiscardUnknown()

func (*QuerySwapExactAmountOutResponse) XXX_Marshal 

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

func (*QuerySwapExactAmountOutResponse) XXX_Merge 

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

func (*QuerySwapExactAmountOutResponse) XXX_Size 

func (m *QuerySwapExactAmountOutResponse) XXX_Size() int

func (*QuerySwapExactAmountOutResponse) XXX_Unmarshal 

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

type QueryTotalLiquidityRequest 

type QueryTotalLiquidityRequest struct {
}

-------------------------------------------- Query total liquidity the protocol

func (*QueryTotalLiquidityRequest) Descriptor 

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

func (*QueryTotalLiquidityRequest) Marshal 

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

func (*QueryTotalLiquidityRequest) MarshalTo 

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

func (*QueryTotalLiquidityRequest) MarshalToSizedBuffer 

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

func (*QueryTotalLiquidityRequest) ProtoMessage 

func (*QueryTotalLiquidityRequest) ProtoMessage()

func (*QueryTotalLiquidityRequest) Reset 

func (m *QueryTotalLiquidityRequest) Reset()

func (*QueryTotalLiquidityRequest) Size 

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

func (*QueryTotalLiquidityRequest) String 

func (m *QueryTotalLiquidityRequest) String() string

func (*QueryTotalLiquidityRequest) Unmarshal 

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

func (*QueryTotalLiquidityRequest) XXX_DiscardUnknown 

func (m *QueryTotalLiquidityRequest) XXX_DiscardUnknown()

func (*QueryTotalLiquidityRequest) XXX_Marshal 

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

func (*QueryTotalLiquidityRequest) XXX_Merge 

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

func (*QueryTotalLiquidityRequest) XXX_Size 

func (m *QueryTotalLiquidityRequest) XXX_Size() int

func (*QueryTotalLiquidityRequest) XXX_Unmarshal 

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

type QueryTotalLiquidityResponse 

type QueryTotalLiquidityResponse struct {
	Liquidity github_com_cosmos_cosmos_sdk_types.Coins `` /* 132-byte string literal not displayed */
}

func (*QueryTotalLiquidityResponse) Descriptor 

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

func (*QueryTotalLiquidityResponse) GetLiquidity 

func (m *QueryTotalLiquidityResponse) GetLiquidity() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryTotalLiquidityResponse) Marshal 

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

func (*QueryTotalLiquidityResponse) MarshalTo 

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

func (*QueryTotalLiquidityResponse) MarshalToSizedBuffer 

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

func (*QueryTotalLiquidityResponse) ProtoMessage 

func (*QueryTotalLiquidityResponse) ProtoMessage()

func (*QueryTotalLiquidityResponse) Reset 

func (m *QueryTotalLiquidityResponse) Reset()

func (*QueryTotalLiquidityResponse) Size 

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

func (*QueryTotalLiquidityResponse) String 

func (m *QueryTotalLiquidityResponse) String() string

func (*QueryTotalLiquidityResponse) Unmarshal 

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

func (*QueryTotalLiquidityResponse) XXX_DiscardUnknown 

func (m *QueryTotalLiquidityResponse) XXX_DiscardUnknown()

func (*QueryTotalLiquidityResponse) XXX_Marshal 

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

func (*QueryTotalLiquidityResponse) XXX_Merge 

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

func (*QueryTotalLiquidityResponse) XXX_Size 

func (m *QueryTotalLiquidityResponse) XXX_Size() int

func (*QueryTotalLiquidityResponse) XXX_Unmarshal 

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

type QueryTotalPoolLiquidityRequest 

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

-------------------------------------------- Query total liquidity for a pool

func (*QueryTotalPoolLiquidityRequest) Descriptor 

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

func (*QueryTotalPoolLiquidityRequest) GetPoolId 

func (m *QueryTotalPoolLiquidityRequest) GetPoolId() uint64

func (*QueryTotalPoolLiquidityRequest) Marshal 

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

func (*QueryTotalPoolLiquidityRequest) MarshalTo 

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

func (*QueryTotalPoolLiquidityRequest) MarshalToSizedBuffer 

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

func (*QueryTotalPoolLiquidityRequest) ProtoMessage 

func (*QueryTotalPoolLiquidityRequest) ProtoMessage()

func (*QueryTotalPoolLiquidityRequest) Reset 

func (m *QueryTotalPoolLiquidityRequest) Reset()

func (*QueryTotalPoolLiquidityRequest) Size 

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

func (*QueryTotalPoolLiquidityRequest) String 

func (m *QueryTotalPoolLiquidityRequest) String() string

func (*QueryTotalPoolLiquidityRequest) Unmarshal 

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

func (*QueryTotalPoolLiquidityRequest) XXX_DiscardUnknown 

func (m *QueryTotalPoolLiquidityRequest) XXX_DiscardUnknown()

func (*QueryTotalPoolLiquidityRequest) XXX_Marshal 

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

func (*QueryTotalPoolLiquidityRequest) XXX_Merge 

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

func (*QueryTotalPoolLiquidityRequest) XXX_Size 

func (m *QueryTotalPoolLiquidityRequest) XXX_Size() int

func (*QueryTotalPoolLiquidityRequest) XXX_Unmarshal 

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

type QueryTotalPoolLiquidityResponse 

type QueryTotalPoolLiquidityResponse struct {
	Liquidity github_com_cosmos_cosmos_sdk_types.Coins `` /* 132-byte string literal not displayed */
}

func (*QueryTotalPoolLiquidityResponse) Descriptor 

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

func (*QueryTotalPoolLiquidityResponse) GetLiquidity 

func (m *QueryTotalPoolLiquidityResponse) GetLiquidity() github_com_cosmos_cosmos_sdk_types.Coins

func (*QueryTotalPoolLiquidityResponse) Marshal 

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

func (*QueryTotalPoolLiquidityResponse) MarshalTo 

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

func (*QueryTotalPoolLiquidityResponse) MarshalToSizedBuffer 

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

func (*QueryTotalPoolLiquidityResponse) ProtoMessage 

func (*QueryTotalPoolLiquidityResponse) ProtoMessage()

func (*QueryTotalPoolLiquidityResponse) Reset 

func (m *QueryTotalPoolLiquidityResponse) Reset()

func (*QueryTotalPoolLiquidityResponse) Size 

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

func (*QueryTotalPoolLiquidityResponse) String 

func (m *QueryTotalPoolLiquidityResponse) String() string

func (*QueryTotalPoolLiquidityResponse) Unmarshal 

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

func (*QueryTotalPoolLiquidityResponse) XXX_DiscardUnknown 

func (m *QueryTotalPoolLiquidityResponse) XXX_DiscardUnknown()

func (*QueryTotalPoolLiquidityResponse) XXX_Marshal 

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

func (*QueryTotalPoolLiquidityResponse) XXX_Merge 

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

func (*QueryTotalPoolLiquidityResponse) XXX_Size 

func (m *QueryTotalPoolLiquidityResponse) XXX_Size() int

func (*QueryTotalPoolLiquidityResponse) XXX_Unmarshal 

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

type QueryTotalSharesRequest 

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

func (*QueryTotalSharesRequest) Descriptor 

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

func (*QueryTotalSharesRequest) GetPoolId 

func (m *QueryTotalSharesRequest) GetPoolId() uint64

func (*QueryTotalSharesRequest) Marshal 

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

func (*QueryTotalSharesRequest) MarshalTo 

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

func (*QueryTotalSharesRequest) MarshalToSizedBuffer 

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

func (*QueryTotalSharesRequest) ProtoMessage 

func (*QueryTotalSharesRequest) ProtoMessage()

func (*QueryTotalSharesRequest) Reset 

func (m *QueryTotalSharesRequest) Reset()

func (*QueryTotalSharesRequest) Size 

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

func (*QueryTotalSharesRequest) String 

func (m *QueryTotalSharesRequest) String() string

func (*QueryTotalSharesRequest) Unmarshal 

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

func (*QueryTotalSharesRequest) XXX_DiscardUnknown 

func (m *QueryTotalSharesRequest) XXX_DiscardUnknown()

func (*QueryTotalSharesRequest) XXX_Marshal 

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

func (*QueryTotalSharesRequest) XXX_Merge 

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

func (*QueryTotalSharesRequest) XXX_Size 

func (m *QueryTotalSharesRequest) XXX_Size() int

func (*QueryTotalSharesRequest) XXX_Unmarshal 

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

type QueryTotalSharesResponse 

type QueryTotalSharesResponse struct {
	// sum of all LP tokens sent out
	TotalShares types.Coin `protobuf:"bytes,1,opt,name=total_shares,json=totalShares,proto3" json:"total_shares" yaml:"total_shares"`
}

func (*QueryTotalSharesResponse) Descriptor 

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

func (*QueryTotalSharesResponse) GetTotalShares 

func (m *QueryTotalSharesResponse) GetTotalShares() types.Coin

func (*QueryTotalSharesResponse) Marshal 

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

func (*QueryTotalSharesResponse) MarshalTo 

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

func (*QueryTotalSharesResponse) MarshalToSizedBuffer 

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

func (*QueryTotalSharesResponse) ProtoMessage 

func (*QueryTotalSharesResponse) ProtoMessage()

func (*QueryTotalSharesResponse) Reset 

func (m *QueryTotalSharesResponse) Reset()

func (*QueryTotalSharesResponse) Size 

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

func (*QueryTotalSharesResponse) String 

func (m *QueryTotalSharesResponse) String() string

func (*QueryTotalSharesResponse) Unmarshal 

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

func (*QueryTotalSharesResponse) XXX_DiscardUnknown 

func (m *QueryTotalSharesResponse) XXX_DiscardUnknown()

func (*QueryTotalSharesResponse) XXX_Marshal 

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

func (*QueryTotalSharesResponse) XXX_Merge 

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

func (*QueryTotalSharesResponse) XXX_Size 

func (m *QueryTotalSharesResponse) XXX_Size() int

func (*QueryTotalSharesResponse) XXX_Unmarshal 

func (m *QueryTotalSharesResponse) 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) ExitPool 

func (*UnimplementedMsgServer) ExitPool(ctx context.Context, req *MsgExitPool) (*MsgExitPoolResponse, error)

func (*UnimplementedMsgServer) JoinPool 

func (*UnimplementedMsgServer) JoinPool(ctx context.Context, req *MsgJoinPool) (*MsgJoinPoolResponse, error)

func (*UnimplementedMsgServer) SwapAssets 

func (*UnimplementedMsgServer) SwapAssets(ctx context.Context, req *MsgSwapAssets) (*MsgSwapAssetsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) EstimateExitExactAmountIn 

func (*UnimplementedQueryServer) EstimateExitExactAmountIn(ctx context.Context, req *QueryExitExactAmountInRequest) (*QueryExitExactAmountInResponse, error)

func (*UnimplementedQueryServer) EstimateExitExactAmountOut 

func (*UnimplementedQueryServer) EstimateExitExactAmountOut(ctx context.Context, req *QueryExitExactAmountOutRequest) (*QueryExitExactAmountOutResponse, error)

func (*UnimplementedQueryServer) EstimateJoinExactAmountIn 

func (*UnimplementedQueryServer) EstimateJoinExactAmountIn(ctx context.Context, req *QueryJoinExactAmountInRequest) (*QueryJoinExactAmountInResponse, error)

func (*UnimplementedQueryServer) EstimateJoinExactAmountOut 

func (*UnimplementedQueryServer) EstimateJoinExactAmountOut(ctx context.Context, req *QueryJoinExactAmountOutRequest) (*QueryJoinExactAmountOutResponse, error)

func (*UnimplementedQueryServer) EstimateSwapExactAmountIn 

func (*UnimplementedQueryServer) EstimateSwapExactAmountIn(ctx context.Context, req *QuerySwapExactAmountInRequest) (*QuerySwapExactAmountInResponse, error)

func (*UnimplementedQueryServer) EstimateSwapExactAmountOut 

func (*UnimplementedQueryServer) EstimateSwapExactAmountOut(ctx context.Context, req *QuerySwapExactAmountOutRequest) (*QuerySwapExactAmountOutResponse, error)

func (*UnimplementedQueryServer) NumPools 

func (*UnimplementedQueryServer) NumPools(ctx context.Context, req *QueryNumPoolsRequest) (*QueryNumPoolsResponse, error)

func (*UnimplementedQueryServer) Params 

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

func (*UnimplementedQueryServer) Pool 

func (*UnimplementedQueryServer) Pool(ctx context.Context, req *QueryPoolRequest) (*QueryPoolResponse, error)

func (*UnimplementedQueryServer) PoolNumber 

func (*UnimplementedQueryServer) PoolNumber(ctx context.Context, req *QueryPoolNumberRequest) (*QueryPoolNumberResponse, error)

func (*UnimplementedQueryServer) PoolParams 

func (*UnimplementedQueryServer) PoolParams(ctx context.Context, req *QueryPoolParamsRequest) (*QueryPoolParamsResponse, error)

func (*UnimplementedQueryServer) Pools 

func (*UnimplementedQueryServer) Pools(ctx context.Context, req *QueryPoolsRequest) (*QueryPoolsResponse, error)

func (*UnimplementedQueryServer) SpotPrice 

func (*UnimplementedQueryServer) SpotPrice(ctx context.Context, req *QuerySpotPriceRequest) (*QuerySpotPriceResponse, error)

func (*UnimplementedQueryServer) TotalLiquidity 

func (*UnimplementedQueryServer) TotalLiquidity(ctx context.Context, req *QueryTotalLiquidityRequest) (*QueryTotalLiquidityResponse, error)

func (*UnimplementedQueryServer) TotalPoolLiquidity 

func (*UnimplementedQueryServer) TotalPoolLiquidity(ctx context.Context, req *QueryTotalPoolLiquidityRequest) (*QueryTotalPoolLiquidityResponse, error)

func (*UnimplementedQueryServer) TotalShares 

func (*UnimplementedQueryServer) TotalShares(ctx context.Context, req *QueryTotalSharesRequest) (*QueryTotalSharesResponse, 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.