types

package
v0.0.0-...-7868e01 Latest Latest
Warning

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

 Go to latest Published: May 17, 2021 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	MinPoolAssets = 2
	MaxPoolAssets = 8

	OneShareExponent = 18
)
View Source 
const (
	TypeEvtPoolJoined   = "pool_joined"
	TypeEvtPoolExited   = "pool_exited"
	TypeEvtPoolCreated  = "pool_created"
	TypeEvtTokenSwapped = "token_swapped"

	AttributeValueCategory = ModuleName
	AttributeKeyPoolId     = "pool_id"
	AttributeKeySwapFee    = "swap_fee"
)
View Source 
const (
	ModuleName = "gamm"

	StoreKey = ModuleName

	RouterKey = ModuleName

	QuerierRoute = ModuleName
)
View Source 
const (
	TypeMsgCreatePool              = "create_pool"
	TypeMsgSwapExactAmountIn       = "swap_exact_amount_in"
	TypeMsgSwapExactAmountOut      = "swap_exact_amount_out"
	TypeMsgJoinPool                = "join_pool"
	TypeMsgExitPool                = "exit_pool"
	TypeMsgJoinSwapExternAmountIn  = "join_swap_extern_amount_in"
	TypeMsgJoinSwapShareAmountOut  = "join_swap_share_amount_out"
	TypeMsgExitSwapExternAmountOut = "exit_swap_extern_amount_out"
	TypeMsgExitSwapShareAmountIn   = "exit_swap_share_amount_in"
)

constants

Variables

View Source 
var (
	// OneShare represents the amount of subshares in a single pool share
	OneShare = sdk.NewIntWithDecimal(1, OneShareExponent)

	// InitPoolSharesSupply is the amount of new shares to initialize a pool with
	InitPoolSharesSupply = OneShare.MulRaw(100)
)
View Source 
var (
	ErrPoolNotFound      = sdkerrors.Register(ModuleName, 1, "pool not found")
	ErrPoolAlreadyExist  = sdkerrors.Register(ModuleName, 2, "pool already exist")
	ErrPoolLocked        = sdkerrors.Register(ModuleName, 3, "pool is locked")
	ErrTooFewPoolAssets  = sdkerrors.Register(ModuleName, 4, "pool should have at least 2 assets, as they must be swapping between at least two assets")
	ErrTooManyPoolAssets = sdkerrors.Register(ModuleName, 5, "pool has too many assets (currently capped at 8 assets per pool)")
	ErrLimitMaxAmount    = sdkerrors.Register(ModuleName, 6, "calculated amount is larger than max amount")
	ErrLimitMinAmount    = sdkerrors.Register(ModuleName, 7, "calculated amount is lesser than min amount")
	ErrInvalidMathApprox = sdkerrors.Register(ModuleName, 8, "invalid calculated result")

	ErrEmptyRoutes              = sdkerrors.Register(ModuleName, 21, "routes not defined")
	ErrEmptyPoolAssets          = sdkerrors.Register(ModuleName, 22, "PoolAssets not defined")
	ErrNegativeSwapFee          = sdkerrors.Register(ModuleName, 23, "swap fee is negative")
	ErrNegativeExitFee          = sdkerrors.Register(ModuleName, 24, "exit fee is negative")
	ErrTooMuchSwapFee           = sdkerrors.Register(ModuleName, 25, "swap fee should be lesser than 1 (100%)")
	ErrTooMuchExitFee           = sdkerrors.Register(ModuleName, 26, "exit fee should be lesser than 1 (100%)")
	ErrNotPositiveWeight        = sdkerrors.Register(ModuleName, 27, "token weight should be greater than 0")
	ErrWeightTooLarge           = sdkerrors.Register(ModuleName, 28, "user specified token weight should be less than 2^20")
	ErrNotPositiveCriteria      = sdkerrors.Register(ModuleName, 29, "min out amount or max in amount should be positive")
	ErrNotPositiveRequireAmount = sdkerrors.Register(ModuleName, 30, "required amount should be positive")

	ErrPoolParamsInvalidDenom     = sdkerrors.Register(ModuleName, 50, "pool params' LBP params has an invalid denomination")
	ErrPoolParamsInvalidNumDenoms = sdkerrors.Register(ModuleName, 51, "pool params' LBP doesn't have same number of params as underlying pool")
)

x/gamm module sentinel errors

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}
)
View Source 
var (
	MaxUserSpecifiedWeight    sdk.Int = sdk.NewIntFromUint64(1 << 20)
	GuaranteedWeightPrecision int64   = 1 << 30
)
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 (

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

Functions

func GetKeyPrefixPools 

func GetKeyPrefixPools(poolId uint64) []byte

func GetPoolShareDenom 

func GetPoolShareDenom(poolId uint64) string

func NewPoolAddress 

func NewPoolAddress(poolId uint64) sdk.AccAddress

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

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

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func SortPoolAssetsByDenom 

func SortPoolAssetsByDenom(assets []PoolAsset)

SortPoolAssetsByDenom sorts pool assets in place, by weight

func ValidateFutureGovernor 

func ValidateFutureGovernor(governor string) error

func ValidateUserSpecifiedPoolAssets 

func ValidateUserSpecifiedPoolAssets(assets []PoolAsset) error

func ValidateUserSpecifiedWeight 

func ValidateUserSpecifiedWeight(weight sdk.Int) error

Types

type AccountKeeper 

type AccountKeeper interface {
	NewAccount(sdk.Context, authtypes.AccountI) authtypes.AccountI
	NewAccountWithAddress(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI

	GetAccount(ctx sdk.Context, addr sdk.AccAddress) authtypes.AccountI
	GetAllAccounts(ctx sdk.Context) []authtypes.AccountI
	SetAccount(ctx sdk.Context, acc authtypes.AccountI)

	IterateAccounts(ctx sdk.Context, process func(authtypes.AccountI) bool)

	ValidatePermissions(macc authtypes.ModuleAccountI) error

	GetModuleAddress(moduleName string) sdk.AccAddress
	GetModuleAddressAndPermissions(moduleName string) (addr sdk.AccAddress, permissions []string)
	GetModuleAccountAndPermissions(ctx sdk.Context, moduleName string) (authtypes.ModuleAccountI, []string)
	GetModuleAccount(ctx sdk.Context, moduleName string) authtypes.ModuleAccountI
	SetModuleAccount(ctx sdk.Context, macc authtypes.ModuleAccountI)

	UnmarshalAccount(bz []byte) (authtypes.AccountI, error)
}

AccountKeeper defines the account contract that must be fulfilled when creating a x/gamm keeper.

type BankKeeper 

type BankKeeper interface {
	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)
}

BankKeeper defines the banking contract that must be fulfilled when creating a x/gamm keeper.

type GammHooks 

type GammHooks interface {
	// AfterPoolCreated is called after CreatePool
	AfterPoolCreated(ctx sdk.Context, sender sdk.AccAddress, poolId uint64)
	// AfterJoinPool is called after JoinPool, JoinSwapExternAmountIn, and JoinSwapShareAmountOut
	AfterJoinPool(ctx sdk.Context, sender sdk.AccAddress, poolId uint64, enterCoins sdk.Coins, shareOutAmount sdk.Int)
	// AfterExitPool is called after ExitPool, ExitSwapShareAmountIn, and ExitSwapExternAmountOut
	AfterExitPool(ctx sdk.Context, sender sdk.AccAddress, poolId uint64, shareInAmount sdk.Int, exitCoins sdk.Coins)
	// AfterSwap is called after SwapExactAmountIn and SwapExactAmountOut
	AfterSwap(ctx sdk.Context, sender sdk.AccAddress, poolId uint64, input sdk.Coins, output sdk.Coins)
}

type MsgClient 

type MsgClient interface {
	CreatePool(ctx context.Context, in *MsgCreatePool, opts ...grpc.CallOption) (*MsgCreatePoolResponse, error)
	JoinPool(ctx context.Context, in *MsgJoinPool, opts ...grpc.CallOption) (*MsgJoinPoolResponse, error)
	ExitPool(ctx context.Context, in *MsgExitPool, opts ...grpc.CallOption) (*MsgExitPoolResponse, error)
	SwapExactAmountIn(ctx context.Context, in *MsgSwapExactAmountIn, opts ...grpc.CallOption) (*MsgSwapExactAmountInResponse, error)
	SwapExactAmountOut(ctx context.Context, in *MsgSwapExactAmountOut, opts ...grpc.CallOption) (*MsgSwapExactAmountOutResponse, error)
	JoinSwapExternAmountIn(ctx context.Context, in *MsgJoinSwapExternAmountIn, opts ...grpc.CallOption) (*MsgJoinSwapExternAmountInResponse, error)
	JoinSwapShareAmountOut(ctx context.Context, in *MsgJoinSwapShareAmountOut, opts ...grpc.CallOption) (*MsgJoinSwapShareAmountOutResponse, error)
	ExitSwapExternAmountOut(ctx context.Context, in *MsgExitSwapExternAmountOut, opts ...grpc.CallOption) (*MsgExitSwapExternAmountOutResponse, error)
	ExitSwapShareAmountIn(ctx context.Context, in *MsgExitSwapShareAmountIn, opts ...grpc.CallOption) (*MsgExitSwapShareAmountInResponse, 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 {
	Sender             string      `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolParams         PoolParams  `protobuf:"bytes,2,opt,name=poolParams,proto3" json:"poolParams" yaml:"pool_params"`
	PoolAssets         []PoolAsset `protobuf:"bytes,3,rep,name=poolAssets,proto3" json:"poolAssets"`
	FuturePoolGovernor string      `` /* 145-byte string literal not displayed */
}

===================== MsgCreatePool

func (*MsgCreatePool) Descriptor 

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

func (*MsgCreatePool) GetFuturePoolGovernor 

func (m *MsgCreatePool) GetFuturePoolGovernor() string

func (*MsgCreatePool) GetPoolAssets 

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

func (*MsgCreatePool) GetPoolParams 

func (m *MsgCreatePool) GetPoolParams() PoolParams

func (*MsgCreatePool) GetSender 

func (m *MsgCreatePool) GetSender() string

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

func (*MsgCreatePoolResponse) Descriptor 

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

func (*MsgCreatePoolResponse) Marshal 

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

func (*MsgCreatePoolResponse) MarshalTo 

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

func (*MsgCreatePoolResponse) MarshalToSizedBuffer 

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

func (*MsgCreatePoolResponse) ProtoMessage 

func (*MsgCreatePoolResponse) ProtoMessage()

func (*MsgCreatePoolResponse) Reset 

func (m *MsgCreatePoolResponse) Reset()

func (*MsgCreatePoolResponse) Size 

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

func (*MsgCreatePoolResponse) String 

func (m *MsgCreatePoolResponse) String() string

func (*MsgCreatePoolResponse) Unmarshal 

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

func (*MsgCreatePoolResponse) XXX_DiscardUnknown 

func (m *MsgCreatePoolResponse) XXX_DiscardUnknown()

func (*MsgCreatePoolResponse) XXX_Marshal 

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

func (*MsgCreatePoolResponse) XXX_Merge 

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

func (*MsgCreatePoolResponse) XXX_Size 

func (m *MsgCreatePoolResponse) XXX_Size() int

func (*MsgCreatePoolResponse) XXX_Unmarshal 

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

type 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=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	ShareInAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 142-byte string literal not displayed */
	TokenOutMins  []types.Coin                           `protobuf:"bytes,4,rep,name=tokenOutMins,proto3" json:"tokenOutMins" yaml:"token_out_min_amounts"`
}

===================== MsgExitPool

func (*MsgExitPool) Descriptor 

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

func (*MsgExitPool) GetPoolId 

func (m *MsgExitPool) GetPoolId() uint64

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

func (m *MsgExitPool) GetTokenOutMins() []types.Coin

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

func (*MsgExitPoolResponse) Descriptor 

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

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 MsgExitSwapExternAmountOut 

type MsgExitSwapExternAmountOut struct {
	Sender           string                                 `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId           uint64                                 `protobuf:"varint,2,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	TokenOut         types.Coin                             `protobuf:"bytes,3,opt,name=tokenOut,proto3" json:"tokenOut" yaml:"token_out"`
	ShareInMaxAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 152-byte string literal not displayed */
}

===================== MsgExitSwapExternAmountOut

func (*MsgExitSwapExternAmountOut) Descriptor 

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

func (*MsgExitSwapExternAmountOut) GetPoolId 

func (m *MsgExitSwapExternAmountOut) GetPoolId() uint64

func (*MsgExitSwapExternAmountOut) GetSender 

func (m *MsgExitSwapExternAmountOut) GetSender() string

func (MsgExitSwapExternAmountOut) GetSignBytes 

func (msg MsgExitSwapExternAmountOut) GetSignBytes() []byte

func (MsgExitSwapExternAmountOut) GetSigners 

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

func (*MsgExitSwapExternAmountOut) GetTokenOut 

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

func (*MsgExitSwapExternAmountOut) Marshal 

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

func (*MsgExitSwapExternAmountOut) MarshalTo 

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

func (*MsgExitSwapExternAmountOut) MarshalToSizedBuffer 

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

func (*MsgExitSwapExternAmountOut) ProtoMessage 

func (*MsgExitSwapExternAmountOut) ProtoMessage()

func (*MsgExitSwapExternAmountOut) Reset 

func (m *MsgExitSwapExternAmountOut) Reset()

func (MsgExitSwapExternAmountOut) Route 

func (msg MsgExitSwapExternAmountOut) Route() string

func (*MsgExitSwapExternAmountOut) Size 

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

func (*MsgExitSwapExternAmountOut) String 

func (m *MsgExitSwapExternAmountOut) String() string

func (MsgExitSwapExternAmountOut) Type 

func (msg MsgExitSwapExternAmountOut) Type() string

func (*MsgExitSwapExternAmountOut) Unmarshal 

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

func (MsgExitSwapExternAmountOut) ValidateBasic 

func (msg MsgExitSwapExternAmountOut) ValidateBasic() error

func (*MsgExitSwapExternAmountOut) XXX_DiscardUnknown 

func (m *MsgExitSwapExternAmountOut) XXX_DiscardUnknown()

func (*MsgExitSwapExternAmountOut) XXX_Marshal 

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

func (*MsgExitSwapExternAmountOut) XXX_Merge 

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

func (*MsgExitSwapExternAmountOut) XXX_Size 

func (m *MsgExitSwapExternAmountOut) XXX_Size() int

func (*MsgExitSwapExternAmountOut) XXX_Unmarshal 

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

type MsgExitSwapExternAmountOutResponse 

type MsgExitSwapExternAmountOutResponse struct {
}

func (*MsgExitSwapExternAmountOutResponse) Descriptor 

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

func (*MsgExitSwapExternAmountOutResponse) Marshal 

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

func (*MsgExitSwapExternAmountOutResponse) MarshalTo 

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

func (*MsgExitSwapExternAmountOutResponse) MarshalToSizedBuffer 

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

func (*MsgExitSwapExternAmountOutResponse) ProtoMessage 

func (*MsgExitSwapExternAmountOutResponse) ProtoMessage()

func (*MsgExitSwapExternAmountOutResponse) Reset 

func (m *MsgExitSwapExternAmountOutResponse) Reset()

func (*MsgExitSwapExternAmountOutResponse) Size 

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

func (*MsgExitSwapExternAmountOutResponse) String 

func (m *MsgExitSwapExternAmountOutResponse) String() string

func (*MsgExitSwapExternAmountOutResponse) Unmarshal 

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

func (*MsgExitSwapExternAmountOutResponse) XXX_DiscardUnknown 

func (m *MsgExitSwapExternAmountOutResponse) XXX_DiscardUnknown()

func (*MsgExitSwapExternAmountOutResponse) XXX_Marshal 

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

func (*MsgExitSwapExternAmountOutResponse) XXX_Merge 

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

func (*MsgExitSwapExternAmountOutResponse) XXX_Size 

func (m *MsgExitSwapExternAmountOutResponse) XXX_Size() int

func (*MsgExitSwapExternAmountOutResponse) XXX_Unmarshal 

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

type MsgExitSwapShareAmountIn 

type MsgExitSwapShareAmountIn struct {
	Sender            string                                 `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId            uint64                                 `protobuf:"varint,2,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	TokenOutDenom     string                                 `protobuf:"bytes,3,opt,name=tokenOutDenom,proto3" json:"tokenOutDenom,omitempty" yaml:"token_out_denom"`
	ShareInAmount     github_com_cosmos_cosmos_sdk_types.Int `` /* 142-byte string literal not displayed */
	TokenOutMinAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 155-byte string literal not displayed */
}

===================== MsgExitSwapShareAmountIn

func (*MsgExitSwapShareAmountIn) Descriptor 

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

func (*MsgExitSwapShareAmountIn) GetPoolId 

func (m *MsgExitSwapShareAmountIn) GetPoolId() uint64

func (*MsgExitSwapShareAmountIn) GetSender 

func (m *MsgExitSwapShareAmountIn) GetSender() string

func (MsgExitSwapShareAmountIn) GetSignBytes 

func (msg MsgExitSwapShareAmountIn) GetSignBytes() []byte

func (MsgExitSwapShareAmountIn) GetSigners 

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

func (*MsgExitSwapShareAmountIn) GetTokenOutDenom 

func (m *MsgExitSwapShareAmountIn) GetTokenOutDenom() string

func (*MsgExitSwapShareAmountIn) Marshal 

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

func (*MsgExitSwapShareAmountIn) MarshalTo 

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

func (*MsgExitSwapShareAmountIn) MarshalToSizedBuffer 

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

func (*MsgExitSwapShareAmountIn) ProtoMessage 

func (*MsgExitSwapShareAmountIn) ProtoMessage()

func (*MsgExitSwapShareAmountIn) Reset 

func (m *MsgExitSwapShareAmountIn) Reset()

func (MsgExitSwapShareAmountIn) Route 

func (msg MsgExitSwapShareAmountIn) Route() string

func (*MsgExitSwapShareAmountIn) Size 

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

func (*MsgExitSwapShareAmountIn) String 

func (m *MsgExitSwapShareAmountIn) String() string

func (MsgExitSwapShareAmountIn) Type 

func (msg MsgExitSwapShareAmountIn) Type() string

func (*MsgExitSwapShareAmountIn) Unmarshal 

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

func (MsgExitSwapShareAmountIn) ValidateBasic 

func (msg MsgExitSwapShareAmountIn) ValidateBasic() error

func (*MsgExitSwapShareAmountIn) XXX_DiscardUnknown 

func (m *MsgExitSwapShareAmountIn) XXX_DiscardUnknown()

func (*MsgExitSwapShareAmountIn) XXX_Marshal 

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

func (*MsgExitSwapShareAmountIn) XXX_Merge 

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

func (*MsgExitSwapShareAmountIn) XXX_Size 

func (m *MsgExitSwapShareAmountIn) XXX_Size() int

func (*MsgExitSwapShareAmountIn) XXX_Unmarshal 

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

type MsgExitSwapShareAmountInResponse 

type MsgExitSwapShareAmountInResponse struct {
}

func (*MsgExitSwapShareAmountInResponse) Descriptor 

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

func (*MsgExitSwapShareAmountInResponse) Marshal 

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

func (*MsgExitSwapShareAmountInResponse) MarshalTo 

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

func (*MsgExitSwapShareAmountInResponse) MarshalToSizedBuffer 

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

func (*MsgExitSwapShareAmountInResponse) ProtoMessage 

func (*MsgExitSwapShareAmountInResponse) ProtoMessage()

func (*MsgExitSwapShareAmountInResponse) Reset 

func (m *MsgExitSwapShareAmountInResponse) Reset()

func (*MsgExitSwapShareAmountInResponse) Size 

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

func (*MsgExitSwapShareAmountInResponse) String 

func (m *MsgExitSwapShareAmountInResponse) String() string

func (*MsgExitSwapShareAmountInResponse) Unmarshal 

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

func (*MsgExitSwapShareAmountInResponse) XXX_DiscardUnknown 

func (m *MsgExitSwapShareAmountInResponse) XXX_DiscardUnknown()

func (*MsgExitSwapShareAmountInResponse) XXX_Marshal 

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

func (*MsgExitSwapShareAmountInResponse) XXX_Merge 

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

func (*MsgExitSwapShareAmountInResponse) XXX_Size 

func (m *MsgExitSwapShareAmountInResponse) XXX_Size() int

func (*MsgExitSwapShareAmountInResponse) XXX_Unmarshal 

func (m *MsgExitSwapShareAmountInResponse) 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=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	ShareOutAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 144-byte string literal not displayed */
	TokenInMaxs    []types.Coin                           `protobuf:"bytes,4,rep,name=tokenInMaxs,proto3" json:"tokenInMaxs" yaml:"token_in_max_amounts"`
}

===================== 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) GetTokenInMaxs 

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

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

func (*MsgJoinPoolResponse) Descriptor 

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

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 MsgJoinSwapExternAmountIn 

type MsgJoinSwapExternAmountIn struct {
	Sender            string                                 `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId            uint64                                 `protobuf:"varint,2,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	TokenIn           types.Coin                             `protobuf:"bytes,3,opt,name=tokenIn,proto3" json:"tokenIn" yaml:"token_in"`
	ShareOutMinAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 155-byte string literal not displayed */
}

===================== MsgJoinSwapExternAmountIn

func (*MsgJoinSwapExternAmountIn) Descriptor 

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

func (*MsgJoinSwapExternAmountIn) GetPoolId 

func (m *MsgJoinSwapExternAmountIn) GetPoolId() uint64

func (*MsgJoinSwapExternAmountIn) GetSender 

func (m *MsgJoinSwapExternAmountIn) GetSender() string

func (MsgJoinSwapExternAmountIn) GetSignBytes 

func (msg MsgJoinSwapExternAmountIn) GetSignBytes() []byte

func (MsgJoinSwapExternAmountIn) GetSigners 

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

func (*MsgJoinSwapExternAmountIn) GetTokenIn 

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

func (*MsgJoinSwapExternAmountIn) Marshal 

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

func (*MsgJoinSwapExternAmountIn) MarshalTo 

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

func (*MsgJoinSwapExternAmountIn) MarshalToSizedBuffer 

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

func (*MsgJoinSwapExternAmountIn) ProtoMessage 

func (*MsgJoinSwapExternAmountIn) ProtoMessage()

func (*MsgJoinSwapExternAmountIn) Reset 

func (m *MsgJoinSwapExternAmountIn) Reset()

func (MsgJoinSwapExternAmountIn) Route 

func (msg MsgJoinSwapExternAmountIn) Route() string

func (*MsgJoinSwapExternAmountIn) Size 

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

func (*MsgJoinSwapExternAmountIn) String 

func (m *MsgJoinSwapExternAmountIn) String() string

func (MsgJoinSwapExternAmountIn) Type 

func (msg MsgJoinSwapExternAmountIn) Type() string

func (*MsgJoinSwapExternAmountIn) Unmarshal 

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

func (MsgJoinSwapExternAmountIn) ValidateBasic 

func (msg MsgJoinSwapExternAmountIn) ValidateBasic() error

func (*MsgJoinSwapExternAmountIn) XXX_DiscardUnknown 

func (m *MsgJoinSwapExternAmountIn) XXX_DiscardUnknown()

func (*MsgJoinSwapExternAmountIn) XXX_Marshal 

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

func (*MsgJoinSwapExternAmountIn) XXX_Merge 

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

func (*MsgJoinSwapExternAmountIn) XXX_Size 

func (m *MsgJoinSwapExternAmountIn) XXX_Size() int

func (*MsgJoinSwapExternAmountIn) XXX_Unmarshal 

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

type MsgJoinSwapExternAmountInResponse 

type MsgJoinSwapExternAmountInResponse struct {
}

func (*MsgJoinSwapExternAmountInResponse) Descriptor 

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

func (*MsgJoinSwapExternAmountInResponse) Marshal 

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

func (*MsgJoinSwapExternAmountInResponse) MarshalTo 

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

func (*MsgJoinSwapExternAmountInResponse) MarshalToSizedBuffer 

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

func (*MsgJoinSwapExternAmountInResponse) ProtoMessage 

func (*MsgJoinSwapExternAmountInResponse) ProtoMessage()

func (*MsgJoinSwapExternAmountInResponse) Reset 

func (m *MsgJoinSwapExternAmountInResponse) Reset()

func (*MsgJoinSwapExternAmountInResponse) Size 

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

func (*MsgJoinSwapExternAmountInResponse) String 

func (m *MsgJoinSwapExternAmountInResponse) String() string

func (*MsgJoinSwapExternAmountInResponse) Unmarshal 

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

func (*MsgJoinSwapExternAmountInResponse) XXX_DiscardUnknown 

func (m *MsgJoinSwapExternAmountInResponse) XXX_DiscardUnknown()

func (*MsgJoinSwapExternAmountInResponse) XXX_Marshal 

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

func (*MsgJoinSwapExternAmountInResponse) XXX_Merge 

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

func (*MsgJoinSwapExternAmountInResponse) XXX_Size 

func (m *MsgJoinSwapExternAmountInResponse) XXX_Size() int

func (*MsgJoinSwapExternAmountInResponse) XXX_Unmarshal 

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

type MsgJoinSwapShareAmountOut 

type MsgJoinSwapShareAmountOut struct {
	Sender           string                                 `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId           uint64                                 `protobuf:"varint,2,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	TokenInDenom     string                                 `protobuf:"bytes,3,opt,name=tokenInDenom,proto3" json:"tokenInDenom,omitempty" yaml:"token_in_denom"`
	ShareOutAmount   github_com_cosmos_cosmos_sdk_types.Int `` /* 145-byte string literal not displayed */
	TokenInMaxAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 152-byte string literal not displayed */
}

===================== MsgJoinSwapShareAmountOut

func (*MsgJoinSwapShareAmountOut) Descriptor 

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

func (*MsgJoinSwapShareAmountOut) GetPoolId 

func (m *MsgJoinSwapShareAmountOut) GetPoolId() uint64

func (*MsgJoinSwapShareAmountOut) GetSender 

func (m *MsgJoinSwapShareAmountOut) GetSender() string

func (MsgJoinSwapShareAmountOut) GetSignBytes 

func (msg MsgJoinSwapShareAmountOut) GetSignBytes() []byte

func (MsgJoinSwapShareAmountOut) GetSigners 

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

func (*MsgJoinSwapShareAmountOut) GetTokenInDenom 

func (m *MsgJoinSwapShareAmountOut) GetTokenInDenom() string

func (*MsgJoinSwapShareAmountOut) Marshal 

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

func (*MsgJoinSwapShareAmountOut) MarshalTo 

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

func (*MsgJoinSwapShareAmountOut) MarshalToSizedBuffer 

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

func (*MsgJoinSwapShareAmountOut) ProtoMessage 

func (*MsgJoinSwapShareAmountOut) ProtoMessage()

func (*MsgJoinSwapShareAmountOut) Reset 

func (m *MsgJoinSwapShareAmountOut) Reset()

func (MsgJoinSwapShareAmountOut) Route 

func (msg MsgJoinSwapShareAmountOut) Route() string

func (*MsgJoinSwapShareAmountOut) Size 

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

func (*MsgJoinSwapShareAmountOut) String 

func (m *MsgJoinSwapShareAmountOut) String() string

func (MsgJoinSwapShareAmountOut) Type 

func (msg MsgJoinSwapShareAmountOut) Type() string

func (*MsgJoinSwapShareAmountOut) Unmarshal 

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

func (MsgJoinSwapShareAmountOut) ValidateBasic 

func (msg MsgJoinSwapShareAmountOut) ValidateBasic() error

func (*MsgJoinSwapShareAmountOut) XXX_DiscardUnknown 

func (m *MsgJoinSwapShareAmountOut) XXX_DiscardUnknown()

func (*MsgJoinSwapShareAmountOut) XXX_Marshal 

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

func (*MsgJoinSwapShareAmountOut) XXX_Merge 

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

func (*MsgJoinSwapShareAmountOut) XXX_Size 

func (m *MsgJoinSwapShareAmountOut) XXX_Size() int

func (*MsgJoinSwapShareAmountOut) XXX_Unmarshal 

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

type MsgJoinSwapShareAmountOutResponse 

type MsgJoinSwapShareAmountOutResponse struct {
}

func (*MsgJoinSwapShareAmountOutResponse) Descriptor 

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

func (*MsgJoinSwapShareAmountOutResponse) Marshal 

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

func (*MsgJoinSwapShareAmountOutResponse) MarshalTo 

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

func (*MsgJoinSwapShareAmountOutResponse) MarshalToSizedBuffer 

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

func (*MsgJoinSwapShareAmountOutResponse) ProtoMessage 

func (*MsgJoinSwapShareAmountOutResponse) ProtoMessage()

func (*MsgJoinSwapShareAmountOutResponse) Reset 

func (m *MsgJoinSwapShareAmountOutResponse) Reset()

func (*MsgJoinSwapShareAmountOutResponse) Size 

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

func (*MsgJoinSwapShareAmountOutResponse) String 

func (m *MsgJoinSwapShareAmountOutResponse) String() string

func (*MsgJoinSwapShareAmountOutResponse) Unmarshal 

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

func (*MsgJoinSwapShareAmountOutResponse) XXX_DiscardUnknown 

func (m *MsgJoinSwapShareAmountOutResponse) XXX_DiscardUnknown()

func (*MsgJoinSwapShareAmountOutResponse) XXX_Marshal 

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

func (*MsgJoinSwapShareAmountOutResponse) XXX_Merge 

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

func (*MsgJoinSwapShareAmountOutResponse) XXX_Size 

func (m *MsgJoinSwapShareAmountOutResponse) XXX_Size() int

func (*MsgJoinSwapShareAmountOutResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	CreatePool(context.Context, *MsgCreatePool) (*MsgCreatePoolResponse, error)
	JoinPool(context.Context, *MsgJoinPool) (*MsgJoinPoolResponse, error)
	ExitPool(context.Context, *MsgExitPool) (*MsgExitPoolResponse, error)
	SwapExactAmountIn(context.Context, *MsgSwapExactAmountIn) (*MsgSwapExactAmountInResponse, error)
	SwapExactAmountOut(context.Context, *MsgSwapExactAmountOut) (*MsgSwapExactAmountOutResponse, error)
	JoinSwapExternAmountIn(context.Context, *MsgJoinSwapExternAmountIn) (*MsgJoinSwapExternAmountInResponse, error)
	JoinSwapShareAmountOut(context.Context, *MsgJoinSwapShareAmountOut) (*MsgJoinSwapShareAmountOutResponse, error)
	ExitSwapExternAmountOut(context.Context, *MsgExitSwapExternAmountOut) (*MsgExitSwapExternAmountOutResponse, error)
	ExitSwapShareAmountIn(context.Context, *MsgExitSwapShareAmountIn) (*MsgExitSwapShareAmountInResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSwapExactAmountIn 

type MsgSwapExactAmountIn struct {
	Sender            string                                 `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	Routes            []SwapAmountInRoute                    `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes"`
	TokenIn           types.Coin                             `protobuf:"bytes,3,opt,name=tokenIn,proto3" json:"tokenIn" yaml:"token_in"`
	TokenOutMinAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 155-byte string literal not displayed */
}

func (*MsgSwapExactAmountIn) Descriptor 

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

func (*MsgSwapExactAmountIn) GetRoutes 

func (m *MsgSwapExactAmountIn) GetRoutes() []SwapAmountInRoute

func (*MsgSwapExactAmountIn) GetSender 

func (m *MsgSwapExactAmountIn) GetSender() string

func (MsgSwapExactAmountIn) GetSignBytes 

func (msg MsgSwapExactAmountIn) GetSignBytes() []byte

func (MsgSwapExactAmountIn) GetSigners 

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

func (*MsgSwapExactAmountIn) GetTokenIn 

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

func (*MsgSwapExactAmountIn) Marshal 

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

func (*MsgSwapExactAmountIn) MarshalTo 

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

func (*MsgSwapExactAmountIn) MarshalToSizedBuffer 

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

func (*MsgSwapExactAmountIn) ProtoMessage 

func (*MsgSwapExactAmountIn) ProtoMessage()

func (*MsgSwapExactAmountIn) Reset 

func (m *MsgSwapExactAmountIn) Reset()

func (MsgSwapExactAmountIn) Route 

func (msg MsgSwapExactAmountIn) Route() string

func (*MsgSwapExactAmountIn) Size 

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

func (*MsgSwapExactAmountIn) String 

func (m *MsgSwapExactAmountIn) String() string

func (MsgSwapExactAmountIn) Type 

func (msg MsgSwapExactAmountIn) Type() string

func (*MsgSwapExactAmountIn) Unmarshal 

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

func (MsgSwapExactAmountIn) ValidateBasic 

func (msg MsgSwapExactAmountIn) ValidateBasic() error

func (*MsgSwapExactAmountIn) XXX_DiscardUnknown 

func (m *MsgSwapExactAmountIn) XXX_DiscardUnknown()

func (*MsgSwapExactAmountIn) XXX_Marshal 

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

func (*MsgSwapExactAmountIn) XXX_Merge 

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

func (*MsgSwapExactAmountIn) XXX_Size 

func (m *MsgSwapExactAmountIn) XXX_Size() int

func (*MsgSwapExactAmountIn) XXX_Unmarshal 

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

type MsgSwapExactAmountInResponse 

type MsgSwapExactAmountInResponse struct {
}

func (*MsgSwapExactAmountInResponse) Descriptor 

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

func (*MsgSwapExactAmountInResponse) Marshal 

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

func (*MsgSwapExactAmountInResponse) MarshalTo 

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

func (*MsgSwapExactAmountInResponse) MarshalToSizedBuffer 

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

func (*MsgSwapExactAmountInResponse) ProtoMessage 

func (*MsgSwapExactAmountInResponse) ProtoMessage()

func (*MsgSwapExactAmountInResponse) Reset 

func (m *MsgSwapExactAmountInResponse) Reset()

func (*MsgSwapExactAmountInResponse) Size 

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

func (*MsgSwapExactAmountInResponse) String 

func (m *MsgSwapExactAmountInResponse) String() string

func (*MsgSwapExactAmountInResponse) Unmarshal 

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

func (*MsgSwapExactAmountInResponse) XXX_DiscardUnknown 

func (m *MsgSwapExactAmountInResponse) XXX_DiscardUnknown()

func (*MsgSwapExactAmountInResponse) XXX_Marshal 

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

func (*MsgSwapExactAmountInResponse) XXX_Merge 

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

func (*MsgSwapExactAmountInResponse) XXX_Size 

func (m *MsgSwapExactAmountInResponse) XXX_Size() int

func (*MsgSwapExactAmountInResponse) XXX_Unmarshal 

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

type MsgSwapExactAmountOut 

type MsgSwapExactAmountOut struct {
	Sender           string                                 `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	Routes           []SwapAmountOutRoute                   `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes"`
	TokenInMaxAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 152-byte string literal not displayed */
	TokenOut         types.Coin                             `protobuf:"bytes,4,opt,name=tokenOut,proto3" json:"tokenOut" yaml:"token_out"`
}

func (*MsgSwapExactAmountOut) Descriptor 

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

func (*MsgSwapExactAmountOut) GetRoutes 

func (m *MsgSwapExactAmountOut) GetRoutes() []SwapAmountOutRoute

func (*MsgSwapExactAmountOut) GetSender 

func (m *MsgSwapExactAmountOut) GetSender() string

func (MsgSwapExactAmountOut) GetSignBytes 

func (msg MsgSwapExactAmountOut) GetSignBytes() []byte

func (MsgSwapExactAmountOut) GetSigners 

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

func (*MsgSwapExactAmountOut) GetTokenOut 

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

func (*MsgSwapExactAmountOut) Marshal 

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

func (*MsgSwapExactAmountOut) MarshalTo 

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

func (*MsgSwapExactAmountOut) MarshalToSizedBuffer 

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

func (*MsgSwapExactAmountOut) ProtoMessage 

func (*MsgSwapExactAmountOut) ProtoMessage()

func (*MsgSwapExactAmountOut) Reset 

func (m *MsgSwapExactAmountOut) Reset()

func (MsgSwapExactAmountOut) Route 

func (msg MsgSwapExactAmountOut) Route() string

func (*MsgSwapExactAmountOut) Size 

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

func (*MsgSwapExactAmountOut) String 

func (m *MsgSwapExactAmountOut) String() string

func (MsgSwapExactAmountOut) Type 

func (msg MsgSwapExactAmountOut) Type() string

func (*MsgSwapExactAmountOut) Unmarshal 

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

func (MsgSwapExactAmountOut) ValidateBasic 

func (msg MsgSwapExactAmountOut) ValidateBasic() error

func (*MsgSwapExactAmountOut) XXX_DiscardUnknown 

func (m *MsgSwapExactAmountOut) XXX_DiscardUnknown()

func (*MsgSwapExactAmountOut) XXX_Marshal 

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

func (*MsgSwapExactAmountOut) XXX_Merge 

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

func (*MsgSwapExactAmountOut) XXX_Size 

func (m *MsgSwapExactAmountOut) XXX_Size() int

func (*MsgSwapExactAmountOut) XXX_Unmarshal 

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

type MsgSwapExactAmountOutResponse 

type MsgSwapExactAmountOutResponse struct {
}

func (*MsgSwapExactAmountOutResponse) Descriptor 

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

func (*MsgSwapExactAmountOutResponse) Marshal 

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

func (*MsgSwapExactAmountOutResponse) MarshalTo 

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

func (*MsgSwapExactAmountOutResponse) MarshalToSizedBuffer 

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

func (*MsgSwapExactAmountOutResponse) ProtoMessage 

func (*MsgSwapExactAmountOutResponse) ProtoMessage()

func (*MsgSwapExactAmountOutResponse) Reset 

func (m *MsgSwapExactAmountOutResponse) Reset()

func (*MsgSwapExactAmountOutResponse) Size 

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

func (*MsgSwapExactAmountOutResponse) String 

func (m *MsgSwapExactAmountOutResponse) String() string

func (*MsgSwapExactAmountOutResponse) Unmarshal 

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

func (*MsgSwapExactAmountOutResponse) XXX_DiscardUnknown 

func (m *MsgSwapExactAmountOutResponse) XXX_DiscardUnknown()

func (*MsgSwapExactAmountOutResponse) XXX_Marshal 

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

func (*MsgSwapExactAmountOutResponse) XXX_Merge 

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

func (*MsgSwapExactAmountOutResponse) XXX_Size 

func (m *MsgSwapExactAmountOutResponse) XXX_Size() int

func (*MsgSwapExactAmountOutResponse) XXX_Unmarshal 

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

type MultiGammHooks 

type MultiGammHooks []GammHooks

combine multiple gamm hooks, all hook functions are run in array sequence

func NewMultiGammHooks 

func NewMultiGammHooks(hooks ...GammHooks) MultiGammHooks

func (MultiGammHooks) AfterExitPool 

func (h MultiGammHooks) AfterExitPool(ctx sdk.Context, sender sdk.AccAddress, poolId uint64, shareInAmount sdk.Int, exitCoins sdk.Coins)

func (MultiGammHooks) AfterJoinPool 

func (h MultiGammHooks) AfterJoinPool(ctx sdk.Context, sender sdk.AccAddress, poolId uint64, enterCoins sdk.Coins, shareOutAmount sdk.Int)

func (MultiGammHooks) AfterPoolCreated 

func (h MultiGammHooks) AfterPoolCreated(ctx sdk.Context, sender sdk.AccAddress, poolId uint64)

func (MultiGammHooks) AfterSwap 

func (h MultiGammHooks) AfterSwap(ctx sdk.Context, sender sdk.AccAddress, poolId uint64, input sdk.Coins, output sdk.Coins)

type Pool 

type Pool struct {
	Address    string     `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty" yaml:"address"`
	Id         uint64     `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	PoolParams PoolParams `protobuf:"bytes,3,opt,name=poolParams,proto3" json:"poolParams" yaml:"pool_params"`
	// This string specifies who will govern the pool in the future.
	// Valid forms of this are:
	// {token name},{duration}
	// {duration}
	// where {token name} if specified is the token which determines the governor,
	// and if not specified is the LP token for this pool.
	// duration is a time specified as 0w,1w,2w, etc. which specifies how long the
	// token would need to be locked up to count in governance. 0w means no
	// lockup.
	// TODO: Further improve these docs
	FuturePoolGovernor string `` /* 145-byte string literal not displayed */
	// sum of all LP tokens sent out
	TotalShare types.Coin `protobuf:"bytes,5,opt,name=totalShare,proto3" json:"totalShare" yaml:"total_share"`
	// These are assumed to be sorted by denomiation.
	// They contain the pool asset and the information about the weight
	PoolAssets []PoolAsset `protobuf:"bytes,6,rep,name=poolAssets,proto3" json:"poolAssets" yaml:"pool_assets"`
	// sum of all non-normalized pool weights
	TotalWeight github_com_cosmos_cosmos_sdk_types.Int `` /* 135-byte string literal not displayed */
}

func (*Pool) AddTotalShare 

func (pa *Pool) AddTotalShare(amt sdk.Int)

func (*Pool) Descriptor 

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

func (Pool) GetAddress 

func (pa Pool) GetAddress() sdk.AccAddress

GetAddress returns the address of a pool. If the pool address is not bech32 valid, it returns an empty address.

func (Pool) GetAllPoolAssets 

func (pa Pool) GetAllPoolAssets() []PoolAsset

func (Pool) GetId 

func (pa Pool) GetId() uint64

func (Pool) GetPoolAsset 

func (pa Pool) GetPoolAsset(denom string) (PoolAsset, error)

GetPoolAssets returns the denom's PoolAsset, If the PoolAsset doesn't exist, will return error. As above, it will search the denom's PoolAsset by using binary search. So, it is important to make sure that the PoolAssets are sorted.

func (Pool) GetPoolAssets 

func (pa Pool) GetPoolAssets(denoms ...string) ([]PoolAsset, error)

func (Pool) GetPoolParams 

func (pa Pool) GetPoolParams() PoolParams

func (Pool) GetTokenBalance 

func (pa Pool) GetTokenBalance(denom string) (sdk.Int, error)

func (Pool) GetTokenWeight 

func (pa Pool) GetTokenWeight(denom string) (sdk.Int, error)

func (Pool) GetTotalShare 

func (pa Pool) GetTotalShare() sdk.Coin

func (Pool) GetTotalWeight 

func (pa Pool) GetTotalWeight() sdk.Int

func (*Pool) Marshal 

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

func (Pool) MarshalJSON 

func (pa Pool) MarshalJSON() ([]byte, error)

MarshalJSON returns the JSON representation of a Pool.

func (*Pool) MarshalTo 

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

func (*Pool) MarshalToSizedBuffer 

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

func (Pool) MarshalYAML 

func (pa Pool) MarshalYAML() (interface{}, error)

MarshalYAML returns the YAML representation of a Pool.

func (Pool) NumAssets 

func (pa Pool) NumAssets() int

func (*Pool) PokeTokenWeights 

func (pa *Pool) PokeTokenWeights(blockTime time.Time)

PokeTokenWeights checks to see if the pool's token weights need to be updated, and if so, does so.

func (*Pool) ProtoMessage 

func (*Pool) ProtoMessage()

func (*Pool) Reset 

func (m *Pool) Reset()

func (*Pool) Size 

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

func (Pool) String 

func (pa Pool) String() string

func (*Pool) SubTotalShare 

func (pa *Pool) SubTotalShare(amt sdk.Int)

func (*Pool) Unmarshal 

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

func (*Pool) UnmarshalJSON 

func (pa *Pool) UnmarshalJSON(bz []byte) error

UnmarshalJSON unmarshals raw JSON bytes into a Pool.

func (*Pool) UpdatePoolAssetBalance 

func (pa *Pool) UpdatePoolAssetBalance(coin sdk.Coin) error

func (*Pool) UpdatePoolAssetBalances 

func (pa *Pool) UpdatePoolAssetBalances(coins sdk.Coins) 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"`
}

func SortPoolAssetsOutOfPlaceByDenom 

func SortPoolAssetsOutOfPlaceByDenom(assets []PoolAsset) []PoolAsset

SortPoolAssetsOutOfPlaceByDenom sorts pool assets in place, by weight Doesn't deep copy the underlying weights, but it does place the assets into a new slice.

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

func (pa PoolAsset) MarshalYAML() (interface{}, error)

MarshalYAML returns the YAML representation of a PoolAsset. This is assumed to not be called on a stand-alone instance, so it removes the first marshalled line.

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

func (asset PoolAsset) ValidateWeight() error

Validates a pool asset, to check if it has a valid weight.

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 PoolI 

type PoolI interface {
	proto.Message

	GetAddress() sdk.AccAddress
	String() string

	GetId() uint64
	GetPoolParams() PoolParams
	GetTotalWeight() sdk.Int
	GetTotalShare() sdk.Coin
	AddTotalShare(amt sdk.Int)
	SubTotalShare(amt sdk.Int)
	GetPoolAsset(denom string) (PoolAsset, error)
	// UpdatePoolAssetBalance updates the balances for
	// the token with denomination coin.denom
	UpdatePoolAssetBalance(coin sdk.Coin) error
	// UpdatePoolAssetBalances calls UpdatePoolAssetBalance
	// on each constituent coin.
	UpdatePoolAssetBalances(coins sdk.Coins) error
	GetPoolAssets(denoms ...string) ([]PoolAsset, error)
	GetAllPoolAssets() []PoolAsset
	PokeTokenWeights(blockTime time.Time)
	GetTokenWeight(denom string) (sdk.Int, error)
	GetTokenBalance(denom string) (sdk.Int, error)
	NumAssets() int
}

PoolI defines an interface for pools that hold tokens.

func NewPool 

func NewPool(poolId uint64, poolParams PoolParams, assets []PoolAsset, futureGovernor string, blockTime time.Time) (PoolI, error)

NewPool returns a weighted CPMM pool with the provided parameters, and initial assets. Invariants that are assumed to be satisfied and not checked: TODO: Why don't we check these in here? * 2 <= len(assets) <= 8 * FutureGovernor is valid * poolID doesn't already exist

type PoolParams 

type PoolParams struct {
	SwapFee github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,1,opt,name=swapFee,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"swapFee" yaml:"swap_fee"`
	ExitFee github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,2,opt,name=exitFee,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"exitFee" yaml:"exit_fee"`
	//
	SmoothWeightChangeParams *SmoothWeightChangeParams `` /* 136-byte string literal not displayed */
}

PoolParams defined the parameters that will be managed by the pool governance in the future. This params are not managed by the chain governanace. Instead they will be managed by the token holders of the pool. The pool's token holders are specified in future_pool_governor.

func (*PoolParams) Descriptor 

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

func (*PoolParams) GetSmoothWeightChangeParams 

func (m *PoolParams) GetSmoothWeightChangeParams() *SmoothWeightChangeParams

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

func (params PoolParams) Validate(poolWeights []PoolAsset) 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 QueryClient 

type QueryClient interface {
	Pool(ctx context.Context, in *QueryPoolRequest, opts ...grpc.CallOption) (*QueryPoolResponse, error)
	Pools(ctx context.Context, in *QueryPoolsRequest, opts ...grpc.CallOption) (*QueryPoolsResponse, error)
	TotalPools(ctx context.Context, in *QueryTotalPoolsRequest, opts ...grpc.CallOption) (*QueryTotalPoolsResponse, error)
	PoolParams(ctx context.Context, in *QueryPoolParamsRequest, opts ...grpc.CallOption) (*QueryPoolParamsResponse, error)
	TotalShare(ctx context.Context, in *QueryTotalShareRequest, opts ...grpc.CallOption) (*QueryTotalShareResponse, error)
	PoolAssets(ctx context.Context, in *QueryPoolAssetsRequest, opts ...grpc.CallOption) (*QueryPoolAssetsResponse, error)
	SpotPrice(ctx context.Context, in *QuerySpotPriceRequest, opts ...grpc.CallOption) (*QuerySpotPriceResponse, error)
	// Estimate the swap.
	EstimateSwapExactAmountIn(ctx context.Context, in *QuerySwapExactAmountInRequest, opts ...grpc.CallOption) (*QuerySwapExactAmountInResponse, error)
	EstimateSwapExactAmountOut(ctx context.Context, in *QuerySwapExactAmountOutRequest, opts ...grpc.CallOption) (*QuerySwapExactAmountOutResponse, 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 QueryPoolAssetsRequest 

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

=============================== PoolAssets

func (*QueryPoolAssetsRequest) Descriptor 

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

func (*QueryPoolAssetsRequest) GetPoolId 

func (m *QueryPoolAssetsRequest) GetPoolId() uint64

func (*QueryPoolAssetsRequest) Marshal 

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

func (*QueryPoolAssetsRequest) MarshalTo 

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

func (*QueryPoolAssetsRequest) MarshalToSizedBuffer 

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

func (*QueryPoolAssetsRequest) ProtoMessage 

func (*QueryPoolAssetsRequest) ProtoMessage()

func (*QueryPoolAssetsRequest) Reset 

func (m *QueryPoolAssetsRequest) Reset()

func (*QueryPoolAssetsRequest) Size 

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

func (*QueryPoolAssetsRequest) String 

func (m *QueryPoolAssetsRequest) String() string

func (*QueryPoolAssetsRequest) Unmarshal 

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

func (*QueryPoolAssetsRequest) XXX_DiscardUnknown 

func (m *QueryPoolAssetsRequest) XXX_DiscardUnknown()

func (*QueryPoolAssetsRequest) XXX_Marshal 

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

func (*QueryPoolAssetsRequest) XXX_Merge 

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

func (*QueryPoolAssetsRequest) XXX_Size 

func (m *QueryPoolAssetsRequest) XXX_Size() int

func (*QueryPoolAssetsRequest) XXX_Unmarshal 

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

type QueryPoolAssetsResponse 

type QueryPoolAssetsResponse struct {
	PoolAssets []PoolAsset `protobuf:"bytes,1,rep,name=poolAssets,proto3" json:"poolAssets"`
}

func (*QueryPoolAssetsResponse) Descriptor 

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

func (*QueryPoolAssetsResponse) GetPoolAssets 

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

func (*QueryPoolAssetsResponse) Marshal 

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

func (*QueryPoolAssetsResponse) MarshalTo 

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

func (*QueryPoolAssetsResponse) MarshalToSizedBuffer 

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

func (*QueryPoolAssetsResponse) ProtoMessage 

func (*QueryPoolAssetsResponse) ProtoMessage()

func (*QueryPoolAssetsResponse) Reset 

func (m *QueryPoolAssetsResponse) Reset()

func (*QueryPoolAssetsResponse) Size 

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

func (*QueryPoolAssetsResponse) String 

func (m *QueryPoolAssetsResponse) String() string

func (*QueryPoolAssetsResponse) Unmarshal 

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

func (*QueryPoolAssetsResponse) XXX_DiscardUnknown 

func (m *QueryPoolAssetsResponse) XXX_DiscardUnknown()

func (*QueryPoolAssetsResponse) XXX_Marshal 

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

func (*QueryPoolAssetsResponse) XXX_Merge 

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

func (*QueryPoolAssetsResponse) XXX_Size 

func (m *QueryPoolAssetsResponse) XXX_Size() int

func (*QueryPoolAssetsResponse) XXX_Unmarshal 

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

type QueryPoolParamsRequest 

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

=============================== PoolParams

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

func (*QueryPoolParamsResponse) Descriptor 

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

func (*QueryPoolParamsResponse) GetParams 

func (m *QueryPoolParamsResponse) GetParams() 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=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
}

=============================== Pool

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 *types.Any `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() *types.Any

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,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

=============================== Pools

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 []*types.Any `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() []*types.Any

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 {
	Pool(context.Context, *QueryPoolRequest) (*QueryPoolResponse, error)
	Pools(context.Context, *QueryPoolsRequest) (*QueryPoolsResponse, error)
	TotalPools(context.Context, *QueryTotalPoolsRequest) (*QueryTotalPoolsResponse, error)
	PoolParams(context.Context, *QueryPoolParamsRequest) (*QueryPoolParamsResponse, error)
	TotalShare(context.Context, *QueryTotalShareRequest) (*QueryTotalShareResponse, error)
	PoolAssets(context.Context, *QueryPoolAssetsRequest) (*QueryPoolAssetsResponse, error)
	SpotPrice(context.Context, *QuerySpotPriceRequest) (*QuerySpotPriceResponse, error)
	// Estimate the swap.
	EstimateSwapExactAmountIn(context.Context, *QuerySwapExactAmountInRequest) (*QuerySwapExactAmountInResponse, error)
	EstimateSwapExactAmountOut(context.Context, *QuerySwapExactAmountOutRequest) (*QuerySwapExactAmountOutResponse, error)
}

QueryServer is the server API for Query service.

type QuerySpotPriceRequest 

type QuerySpotPriceRequest struct {
	PoolId        uint64 `protobuf:"varint,1,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	TokenInDenom  string `protobuf:"bytes,2,opt,name=tokenInDenom,proto3" json:"tokenInDenom,omitempty" yaml:"token_in_denom"`
	TokenOutDenom string `protobuf:"bytes,3,opt,name=tokenOutDenom,proto3" json:"tokenOutDenom,omitempty" yaml:"token_out_denom"`
	WithSwapFee   bool   `protobuf:"varint,4,opt,name=withSwapFee,proto3" json:"withSwapFee,omitempty" yaml:"with_swap_fee"`
}

=============================== SpotPrice

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

func (m *QuerySpotPriceRequest) GetWithSwapFee() bool

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 {
	// String of the Dec. Ex) 10.203uatom
	SpotPrice string `protobuf:"bytes,1,opt,name=spotPrice,proto3" json:"spotPrice,omitempty" yaml:"spot_price"`
}

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 {
	Sender  string              `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId  uint64              `protobuf:"varint,2,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	TokenIn string              `protobuf:"bytes,3,opt,name=tokenIn,proto3" json:"tokenIn,omitempty" yaml:"token_in"`
	Routes  []SwapAmountInRoute `protobuf:"bytes,4,rep,name=routes,proto3" json:"routes" yaml:"routes"`
}

=============================== EstimateSwapExactAmountIn

func (*QuerySwapExactAmountInRequest) Descriptor 

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

func (*QuerySwapExactAmountInRequest) GetPoolId 

func (m *QuerySwapExactAmountInRequest) GetPoolId() uint64

func (*QuerySwapExactAmountInRequest) GetRoutes 

func (m *QuerySwapExactAmountInRequest) GetRoutes() []SwapAmountInRoute

func (*QuerySwapExactAmountInRequest) GetSender 

func (m *QuerySwapExactAmountInRequest) GetSender() string

func (*QuerySwapExactAmountInRequest) GetTokenIn 

func (m *QuerySwapExactAmountInRequest) GetTokenIn() 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 {
	TokenOutAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 145-byte string literal not displayed */
}

func (*QuerySwapExactAmountInResponse) Descriptor 

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

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 {
	Sender   string               `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty" yaml:"sender"`
	PoolId   uint64               `protobuf:"varint,2,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	Routes   []SwapAmountOutRoute `protobuf:"bytes,3,rep,name=routes,proto3" json:"routes" yaml:"routes"`
	TokenOut string               `protobuf:"bytes,4,opt,name=tokenOut,proto3" json:"tokenOut,omitempty" yaml:"token_out"`
}

=============================== EstimateSwapExactAmountOut

func (*QuerySwapExactAmountOutRequest) Descriptor 

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

func (*QuerySwapExactAmountOutRequest) GetPoolId 

func (m *QuerySwapExactAmountOutRequest) GetPoolId() uint64

func (*QuerySwapExactAmountOutRequest) GetRoutes 

func (m *QuerySwapExactAmountOutRequest) GetRoutes() []SwapAmountOutRoute

func (*QuerySwapExactAmountOutRequest) GetSender 

func (m *QuerySwapExactAmountOutRequest) GetSender() string

func (*QuerySwapExactAmountOutRequest) GetTokenOut 

func (m *QuerySwapExactAmountOutRequest) GetTokenOut() string

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 {
	TokenInAmount github_com_cosmos_cosmos_sdk_types.Int `` /* 142-byte string literal not displayed */
}

func (*QuerySwapExactAmountOutResponse) Descriptor 

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

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 QueryTotalPoolsRequest 

type QueryTotalPoolsRequest struct {
}

=============================== TotalPools

func (*QueryTotalPoolsRequest) Descriptor 

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

func (*QueryTotalPoolsRequest) Marshal 

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

func (*QueryTotalPoolsRequest) MarshalTo 

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

func (*QueryTotalPoolsRequest) MarshalToSizedBuffer 

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

func (*QueryTotalPoolsRequest) ProtoMessage 

func (*QueryTotalPoolsRequest) ProtoMessage()

func (*QueryTotalPoolsRequest) Reset 

func (m *QueryTotalPoolsRequest) Reset()

func (*QueryTotalPoolsRequest) Size 

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

func (*QueryTotalPoolsRequest) String 

func (m *QueryTotalPoolsRequest) String() string

func (*QueryTotalPoolsRequest) Unmarshal 

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

func (*QueryTotalPoolsRequest) XXX_DiscardUnknown 

func (m *QueryTotalPoolsRequest) XXX_DiscardUnknown()

func (*QueryTotalPoolsRequest) XXX_Marshal 

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

func (*QueryTotalPoolsRequest) XXX_Merge 

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

func (*QueryTotalPoolsRequest) XXX_Size 

func (m *QueryTotalPoolsRequest) XXX_Size() int

func (*QueryTotalPoolsRequest) XXX_Unmarshal 

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

type QueryTotalPoolsResponse 

type QueryTotalPoolsResponse struct {
	TotalPools uint64 `protobuf:"varint,1,opt,name=totalPools,proto3" json:"totalPools,omitempty" yaml:"total_pools"`
}

func (*QueryTotalPoolsResponse) Descriptor 

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

func (*QueryTotalPoolsResponse) GetTotalPools 

func (m *QueryTotalPoolsResponse) GetTotalPools() uint64

func (*QueryTotalPoolsResponse) Marshal 

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

func (*QueryTotalPoolsResponse) MarshalTo 

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

func (*QueryTotalPoolsResponse) MarshalToSizedBuffer 

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

func (*QueryTotalPoolsResponse) ProtoMessage 

func (*QueryTotalPoolsResponse) ProtoMessage()

func (*QueryTotalPoolsResponse) Reset 

func (m *QueryTotalPoolsResponse) Reset()

func (*QueryTotalPoolsResponse) Size 

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

func (*QueryTotalPoolsResponse) String 

func (m *QueryTotalPoolsResponse) String() string

func (*QueryTotalPoolsResponse) Unmarshal 

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

func (*QueryTotalPoolsResponse) XXX_DiscardUnknown 

func (m *QueryTotalPoolsResponse) XXX_DiscardUnknown()

func (*QueryTotalPoolsResponse) XXX_Marshal 

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

func (*QueryTotalPoolsResponse) XXX_Merge 

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

func (*QueryTotalPoolsResponse) XXX_Size 

func (m *QueryTotalPoolsResponse) XXX_Size() int

func (*QueryTotalPoolsResponse) XXX_Unmarshal 

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

type QueryTotalShareRequest 

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

=============================== TotalShare

func (*QueryTotalShareRequest) Descriptor 

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

func (*QueryTotalShareRequest) GetPoolId 

func (m *QueryTotalShareRequest) GetPoolId() uint64

func (*QueryTotalShareRequest) Marshal 

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

func (*QueryTotalShareRequest) MarshalTo 

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

func (*QueryTotalShareRequest) MarshalToSizedBuffer 

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

func (*QueryTotalShareRequest) ProtoMessage 

func (*QueryTotalShareRequest) ProtoMessage()

func (*QueryTotalShareRequest) Reset 

func (m *QueryTotalShareRequest) Reset()

func (*QueryTotalShareRequest) Size 

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

func (*QueryTotalShareRequest) String 

func (m *QueryTotalShareRequest) String() string

func (*QueryTotalShareRequest) Unmarshal 

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

func (*QueryTotalShareRequest) XXX_DiscardUnknown 

func (m *QueryTotalShareRequest) XXX_DiscardUnknown()

func (*QueryTotalShareRequest) XXX_Marshal 

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

func (*QueryTotalShareRequest) XXX_Merge 

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

func (*QueryTotalShareRequest) XXX_Size 

func (m *QueryTotalShareRequest) XXX_Size() int

func (*QueryTotalShareRequest) XXX_Unmarshal 

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

type QueryTotalShareResponse 

type QueryTotalShareResponse struct {
	TotalShare types1.Coin `protobuf:"bytes,1,opt,name=totalShare,proto3" json:"totalShare" yaml:"total_share"`
}

func (*QueryTotalShareResponse) Descriptor 

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

func (*QueryTotalShareResponse) GetTotalShare 

func (m *QueryTotalShareResponse) GetTotalShare() types1.Coin

func (*QueryTotalShareResponse) Marshal 

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

func (*QueryTotalShareResponse) MarshalTo 

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

func (*QueryTotalShareResponse) MarshalToSizedBuffer 

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

func (*QueryTotalShareResponse) ProtoMessage 

func (*QueryTotalShareResponse) ProtoMessage()

func (*QueryTotalShareResponse) Reset 

func (m *QueryTotalShareResponse) Reset()

func (*QueryTotalShareResponse) Size 

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

func (*QueryTotalShareResponse) String 

func (m *QueryTotalShareResponse) String() string

func (*QueryTotalShareResponse) Unmarshal 

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

func (*QueryTotalShareResponse) XXX_DiscardUnknown 

func (m *QueryTotalShareResponse) XXX_DiscardUnknown()

func (*QueryTotalShareResponse) XXX_Marshal 

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

func (*QueryTotalShareResponse) XXX_Merge 

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

func (*QueryTotalShareResponse) XXX_Size 

func (m *QueryTotalShareResponse) XXX_Size() int

func (*QueryTotalShareResponse) XXX_Unmarshal 

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

type SmoothWeightChangeParams 

type SmoothWeightChangeParams struct {
	// The start time for beginning the weight change.
	// If a parameter change / pool instantiation leaves this blank,
	// it should be generated by the state_machine as the current time.
	StartTime time.Time `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time" yaml:"start_time"`
	// Duration for the weights to change over
	Duration time.Duration `protobuf:"bytes,2,opt,name=duration,proto3,stdduration" json:"duration,omitempty" yaml:"duration"`
	// The initial pool weights. These are copied from the pool's settings
	// at the time of weight change instantiation.
	// The amount PoolAsset.token.amount field is ignored if present,
	// future type refactorings should just have a type with the denom & weight
	// here.
	InitialPoolWeights []PoolAsset `protobuf:"bytes,3,rep,name=initialPoolWeights,proto3" json:"initialPoolWeights" yaml:"initial_pool_weights"`
	// The target pool weights. The pool weights will change linearly with respect
	// to time between start_time, and start_time + duration. The amount
	// PoolAsset.token.amount field is ignored if present, future type
	// refactorings should just have a type with the denom & weight here.
	TargetPoolWeights []PoolAsset `protobuf:"bytes,4,rep,name=targetPoolWeights,proto3" json:"targetPoolWeights" yaml:"target_pool_weights"`
}

Parameters for changing the weights in a balancer pool smoothly from a start weight and end weight over a period of time. Currently, the only smooth change supported is linear changing between the two weights, but more types may be added in the future. When these parameters are set, the weight w(t) for pool time `t` is the following: 

t <= start_time: w(t) = initial_pool_weights
start_time < t <= start_time + duration:
  w(t) = initial_pool_weights + (t - start_time) *
    (target_pool_weights - initial_pool_weights) / (duration)
t > start_time + duration: w(t) = target_pool_weights

func (*SmoothWeightChangeParams) Descriptor 

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

func (*SmoothWeightChangeParams) GetDuration 

func (m *SmoothWeightChangeParams) GetDuration() time.Duration

func (*SmoothWeightChangeParams) GetInitialPoolWeights 

func (m *SmoothWeightChangeParams) GetInitialPoolWeights() []PoolAsset

func (*SmoothWeightChangeParams) GetStartTime 

func (m *SmoothWeightChangeParams) GetStartTime() time.Time

func (*SmoothWeightChangeParams) GetTargetPoolWeights 

func (m *SmoothWeightChangeParams) GetTargetPoolWeights() []PoolAsset

func (*SmoothWeightChangeParams) Marshal 

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

func (*SmoothWeightChangeParams) MarshalTo 

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

func (*SmoothWeightChangeParams) MarshalToSizedBuffer 

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

func (*SmoothWeightChangeParams) ProtoMessage 

func (*SmoothWeightChangeParams) ProtoMessage()

func (*SmoothWeightChangeParams) Reset 

func (m *SmoothWeightChangeParams) Reset()

func (*SmoothWeightChangeParams) Size 

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

func (*SmoothWeightChangeParams) String 

func (m *SmoothWeightChangeParams) String() string

func (*SmoothWeightChangeParams) Unmarshal 

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

func (*SmoothWeightChangeParams) XXX_DiscardUnknown 

func (m *SmoothWeightChangeParams) XXX_DiscardUnknown()

func (*SmoothWeightChangeParams) XXX_Marshal 

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

func (*SmoothWeightChangeParams) XXX_Merge 

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

func (*SmoothWeightChangeParams) XXX_Size 

func (m *SmoothWeightChangeParams) XXX_Size() int

func (*SmoothWeightChangeParams) XXX_Unmarshal 

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

type SwapAmountInRoute 

type SwapAmountInRoute struct {
	PoolId        uint64 `protobuf:"varint,1,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	TokenOutDenom string `protobuf:"bytes,2,opt,name=tokenOutDenom,proto3" json:"tokenOutDenom,omitempty" yaml:"token_out_denom"`
}

===================== MsgSwapExactAmountIn

func (*SwapAmountInRoute) Descriptor 

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

func (*SwapAmountInRoute) GetPoolId 

func (m *SwapAmountInRoute) GetPoolId() uint64

func (*SwapAmountInRoute) GetTokenOutDenom 

func (m *SwapAmountInRoute) GetTokenOutDenom() string

func (*SwapAmountInRoute) Marshal 

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

func (*SwapAmountInRoute) MarshalTo 

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

func (*SwapAmountInRoute) MarshalToSizedBuffer 

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

func (*SwapAmountInRoute) ProtoMessage 

func (*SwapAmountInRoute) ProtoMessage()

func (*SwapAmountInRoute) Reset 

func (m *SwapAmountInRoute) Reset()

func (*SwapAmountInRoute) Size 

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

func (*SwapAmountInRoute) String 

func (m *SwapAmountInRoute) String() string

func (*SwapAmountInRoute) Unmarshal 

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

func (*SwapAmountInRoute) XXX_DiscardUnknown 

func (m *SwapAmountInRoute) XXX_DiscardUnknown()

func (*SwapAmountInRoute) XXX_Marshal 

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

func (*SwapAmountInRoute) XXX_Merge 

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

func (*SwapAmountInRoute) XXX_Size 

func (m *SwapAmountInRoute) XXX_Size() int

func (*SwapAmountInRoute) XXX_Unmarshal 

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

type SwapAmountInRoutes 

type SwapAmountInRoutes []SwapAmountInRoute

func (SwapAmountInRoutes) Validate 

func (routes SwapAmountInRoutes) Validate() error

type SwapAmountOutRoute 

type SwapAmountOutRoute struct {
	PoolId       uint64 `protobuf:"varint,1,opt,name=poolId,proto3" json:"poolId,omitempty" yaml:"pool_id"`
	TokenInDenom string `protobuf:"bytes,2,opt,name=tokenInDenom,proto3" json:"tokenInDenom,omitempty" yaml:"token_out_denom"`
}

===================== MsgSwapExactAmountOut

func (*SwapAmountOutRoute) Descriptor 

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

func (*SwapAmountOutRoute) GetPoolId 

func (m *SwapAmountOutRoute) GetPoolId() uint64

func (*SwapAmountOutRoute) GetTokenInDenom 

func (m *SwapAmountOutRoute) GetTokenInDenom() string

func (*SwapAmountOutRoute) Marshal 

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

func (*SwapAmountOutRoute) MarshalTo 

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

func (*SwapAmountOutRoute) MarshalToSizedBuffer 

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

func (*SwapAmountOutRoute) ProtoMessage 

func (*SwapAmountOutRoute) ProtoMessage()

func (*SwapAmountOutRoute) Reset 

func (m *SwapAmountOutRoute) Reset()

func (*SwapAmountOutRoute) Size 

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

func (*SwapAmountOutRoute) String 

func (m *SwapAmountOutRoute) String() string

func (*SwapAmountOutRoute) Unmarshal 

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

func (*SwapAmountOutRoute) XXX_DiscardUnknown 

func (m *SwapAmountOutRoute) XXX_DiscardUnknown()

func (*SwapAmountOutRoute) XXX_Marshal 

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

func (*SwapAmountOutRoute) XXX_Merge 

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

func (*SwapAmountOutRoute) XXX_Size 

func (m *SwapAmountOutRoute) XXX_Size() int

func (*SwapAmountOutRoute) XXX_Unmarshal 

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

type SwapAmountOutRoutes 

type SwapAmountOutRoutes []SwapAmountOutRoute

func (SwapAmountOutRoutes) Validate 

func (routes SwapAmountOutRoutes) Validate() 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) ExitSwapExternAmountOut 

func (*UnimplementedMsgServer) ExitSwapExternAmountOut(ctx context.Context, req *MsgExitSwapExternAmountOut) (*MsgExitSwapExternAmountOutResponse, error)

func (*UnimplementedMsgServer) ExitSwapShareAmountIn 

func (*UnimplementedMsgServer) ExitSwapShareAmountIn(ctx context.Context, req *MsgExitSwapShareAmountIn) (*MsgExitSwapShareAmountInResponse, error)

func (*UnimplementedMsgServer) JoinPool 

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

func (*UnimplementedMsgServer) JoinSwapExternAmountIn 

func (*UnimplementedMsgServer) JoinSwapExternAmountIn(ctx context.Context, req *MsgJoinSwapExternAmountIn) (*MsgJoinSwapExternAmountInResponse, error)

func (*UnimplementedMsgServer) JoinSwapShareAmountOut 

func (*UnimplementedMsgServer) JoinSwapShareAmountOut(ctx context.Context, req *MsgJoinSwapShareAmountOut) (*MsgJoinSwapShareAmountOutResponse, error)

func (*UnimplementedMsgServer) SwapExactAmountIn 

func (*UnimplementedMsgServer) SwapExactAmountIn(ctx context.Context, req *MsgSwapExactAmountIn) (*MsgSwapExactAmountInResponse, error)

func (*UnimplementedMsgServer) SwapExactAmountOut 

func (*UnimplementedMsgServer) SwapExactAmountOut(ctx context.Context, req *MsgSwapExactAmountOut) (*MsgSwapExactAmountOutResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

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

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

func (*UnimplementedQueryServer) PoolAssets 

func (*UnimplementedQueryServer) PoolAssets(ctx context.Context, req *QueryPoolAssetsRequest) (*QueryPoolAssetsResponse, 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) TotalPools 

func (*UnimplementedQueryServer) TotalPools(ctx context.Context, req *QueryTotalPoolsRequest) (*QueryTotalPoolsResponse, error)

func (*UnimplementedQueryServer) TotalShare 

func (*UnimplementedQueryServer) TotalShare(ctx context.Context, req *QueryTotalShareRequest) (*QueryTotalShareResponse, 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.