Versions in this module Expand all Collapse all v0 v0.3.2 Jul 7, 2023 v0.3.1 Jul 6, 2023 v0.2.1 Jul 6, 2023 Changes in this version + const AttributeKeyDepositor + const AttributeKeyExactDirection + const AttributeKeyFeePaid + const AttributeKeyOwner + const AttributeKeyPoolID + const AttributeKeyRequester + const AttributeKeyShares + const AttributeKeySwapInput + const AttributeKeySwapOutput + const AttributeValueCategory + const DefaultParamspace + const EventTypeSwapDeposit + const EventTypeSwapTrade + const EventTypeSwapWithdraw + const ModuleAccountName + const ModuleName + const PoolIDSep + const QuerierRoute + const QueryGetDeposits + const QueryGetParams + const QueryGetPool + const QueryGetPools + const RouterKey + const StoreKey + const TypeMsgDeposit + const TypeMsgWithdraw + const TypeSwapExactForTokens + const TypeSwapForExactTokens + var DefaultAllowedPools = AllowedPools + var DefaultPoolRecords = PoolRecords + var DefaultShareRecords = ShareRecords + var DefaultSwapFee = sdk.ZeroDec() + var DepositorPoolSharesPrefix = []byte + var ErrDeadlineExceeded = errorsmod.Register(ModuleName, 4, "deadline exceeded") + var ErrDepositNotFound = errorsmod.Register(ModuleName, 10, "deposit not found") + var ErrInsufficientLiquidity = errorsmod.Register(ModuleName, 8, "insufficient liquidity") + var ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSwap = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") + var ErrInvalidCoin = errorsmod.Register(ModuleName, 11, "invalid coin") + var ErrInvalidDeadline = errorsmod.Register(ModuleName, 3, "invalid deadline") + var ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSwap = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidPool = errorsmod.Register(ModuleName, 6, "invalid pool") + var ErrInvalidShares = errorsmod.Register(ModuleName, 9, "invalid shares") + var ErrInvalidSlippage = errorsmod.Register(ModuleName, 7, "invalid slippage") + var ErrNotAllowed = errorsmod.Register(ModuleName, 2, "not allowed") + var ErrNotImplemented = errorsmod.Register(ModuleName, 12, "not implemented") + var ErrSlippageExceeded = errorsmod.Register(ModuleName, 5, "slippage exceeded") + var ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupSwap = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") + var KeyAllowedPools = []byte("AllowedPools") + var KeySwapFee = []byte("SwapFee") + var MaxSwapFee = sdk.OneDec() + var ModuleCdc = codec.NewAminoCodec(amino) + var PoolKeyPrefix = []byte + func DepositorPoolSharesKey(depositor sdk.AccAddress, poolID string) []byte + func ParamKeyTable() paramtypes.KeyTable + func PoolID(denomA string, denomB string) string + func PoolIDFromCoins(coins sdk.Coins) string + func PoolKey(poolID string) []byte + func RegisterInterfaces(registry types.InterfaceRegistry) + func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino) + func RegisterMsgServer(s grpc1.Server, srv MsgServer) + func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error + func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error + func RegisterQueryServer(s grpc1.Server, srv QueryServer) + type AccountKeeper interface + GetAccount func(ctx sdk.Context, addr sdk.AccAddress) types.AccountI + GetModuleAccount func(ctx sdk.Context, name string) types.ModuleAccountI + GetModuleAddress func(name string) sdk.AccAddress + SetModuleAccount func(sdk.Context, types.ModuleAccountI) + type AllowedPool struct + TokenA string + TokenB string + func NewAllowedPool(tokenA, tokenB string) AllowedPool + func (*AllowedPool) Descriptor() ([]byte, []int) + func (*AllowedPool) ProtoMessage() + func (m *AllowedPool) GetTokenA() string + func (m *AllowedPool) GetTokenB() string + func (m *AllowedPool) Marshal() (dAtA []byte, err error) + func (m *AllowedPool) MarshalTo(dAtA []byte) (int, error) + func (m *AllowedPool) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AllowedPool) Reset() + func (m *AllowedPool) Size() (n int) + func (m *AllowedPool) Unmarshal(dAtA []byte) error + func (m *AllowedPool) XXX_DiscardUnknown() + func (m *AllowedPool) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AllowedPool) XXX_Merge(src proto.Message) + func (m *AllowedPool) XXX_Size() int + func (m *AllowedPool) XXX_Unmarshal(b []byte) error + func (p AllowedPool) Name() string + func (p AllowedPool) String() string + func (p AllowedPool) Validate() error + type AllowedPools []AllowedPool + func NewAllowedPools(allowedPools ...AllowedPool) AllowedPools + func (p AllowedPools) Validate() error + type BankKeeper interface + GetAllBalances func(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins + SendCoinsFromAccountToModule func(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, ...) error + SendCoinsFromModuleToAccount func(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, ...) error + SendCoinsFromModuleToModule func(ctx sdk.Context, senderModule, recipientModule string, amt sdk.Coins) error + type BasePool struct + func NewBasePool(reservesA, reservesB sdkmath.Int) (*BasePool, error) + func NewBasePoolWithExistingShares(reservesA, reservesB, totalShares sdkmath.Int) (*BasePool, error) + func (p *BasePool) AddLiquidity(desiredA sdkmath.Int, desiredB sdkmath.Int) (sdkmath.Int, sdkmath.Int, sdkmath.Int) + func (p *BasePool) IsEmpty() bool + func (p *BasePool) RemoveLiquidity(shares sdkmath.Int) (sdkmath.Int, sdkmath.Int) + func (p *BasePool) ReservesA() sdkmath.Int + func (p *BasePool) ReservesB() sdkmath.Int + func (p *BasePool) ShareValue(shares sdkmath.Int) (sdkmath.Int, sdkmath.Int) + func (p *BasePool) SwapAForExactB(b sdkmath.Int, fee sdk.Dec) (sdkmath.Int, sdkmath.Int) + func (p *BasePool) SwapBForExactA(a sdkmath.Int, fee sdk.Dec) (sdkmath.Int, sdkmath.Int) + func (p *BasePool) SwapExactAForB(a sdkmath.Int, fee sdk.Dec) (sdkmath.Int, sdkmath.Int) + func (p *BasePool) SwapExactBForA(b sdkmath.Int, fee sdk.Dec) (sdkmath.Int, sdkmath.Int) + func (p *BasePool) TotalShares() sdkmath.Int + type DenominatedPool struct + func NewDenominatedPool(reserves sdk.Coins) (*DenominatedPool, error) + func NewDenominatedPoolWithExistingShares(reserves sdk.Coins, totalShares sdkmath.Int) (*DenominatedPool, error) + func (p *DenominatedPool) AddLiquidity(deposit sdk.Coins) (sdk.Coins, sdkmath.Int) + func (p *DenominatedPool) IsEmpty() bool + func (p *DenominatedPool) RemoveLiquidity(shares sdkmath.Int) sdk.Coins + func (p *DenominatedPool) Reserves() sdk.Coins + func (p *DenominatedPool) ShareValue(shares sdkmath.Int) sdk.Coins + func (p *DenominatedPool) SwapWithExactInput(swapInput sdk.Coin, fee sdk.Dec) (sdk.Coin, sdk.Coin) + func (p *DenominatedPool) SwapWithExactOutput(swapOutput sdk.Coin, fee sdk.Dec) (sdk.Coin, sdk.Coin) + func (p *DenominatedPool) TotalShares() sdkmath.Int + type DepositResponse struct + Depositor string + PoolId string + SharesOwned github_com_cosmos_cosmos_sdk_types.Int + SharesValue github_com_cosmos_cosmos_sdk_types.Coins + func (*DepositResponse) Descriptor() ([]byte, []int) + func (*DepositResponse) ProtoMessage() + func (m *DepositResponse) Marshal() (dAtA []byte, err error) + func (m *DepositResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DepositResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DepositResponse) Reset() + func (m *DepositResponse) Size() (n int) + func (m *DepositResponse) String() string + func (m *DepositResponse) Unmarshal(dAtA []byte) error + func (m *DepositResponse) XXX_DiscardUnknown() + func (m *DepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DepositResponse) XXX_Merge(src proto.Message) + func (m *DepositResponse) XXX_Size() int + func (m *DepositResponse) XXX_Unmarshal(b []byte) error + type DepositsQueryResult struct + Depositor sdk.AccAddress + PoolID string + SharesOwned sdkmath.Int + SharesValue sdk.Coins + func NewDepositsQueryResult(shareRecord ShareRecord, sharesValue sdk.Coins) DepositsQueryResult + type DepositsQueryResults []DepositsQueryResult + type GenesisState struct + Params Params + PoolRecords PoolRecords + ShareRecords ShareRecords + func DefaultGenesisState() GenesisState + func NewGenesisState(params Params, poolRecords PoolRecords, shareRecords ShareRecords) GenesisState + func (*GenesisState) Descriptor() ([]byte, []int) + func (*GenesisState) ProtoMessage() + func (gs GenesisState) Validate() error + func (m *GenesisState) GetParams() Params + func (m *GenesisState) GetPoolRecords() PoolRecords + func (m *GenesisState) GetShareRecords() ShareRecords + func (m *GenesisState) Marshal() (dAtA []byte, err error) + func (m *GenesisState) MarshalTo(dAtA []byte) (int, error) + func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GenesisState) Reset() + func (m *GenesisState) Size() (n int) + func (m *GenesisState) String() string + func (m *GenesisState) Unmarshal(dAtA []byte) error + func (m *GenesisState) XXX_DiscardUnknown() + func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GenesisState) XXX_Merge(src proto.Message) + func (m *GenesisState) XXX_Size() int + func (m *GenesisState) XXX_Unmarshal(b []byte) error + type MsgClient interface + Deposit func(ctx context.Context, in *MsgDeposit, opts ...grpc.CallOption) (*MsgDepositResponse, error) + SwapExactForTokens func(ctx context.Context, in *MsgSwapExactForTokens, opts ...grpc.CallOption) (*MsgSwapExactForTokensResponse, error) + SwapForExactTokens func(ctx context.Context, in *MsgSwapForExactTokens, opts ...grpc.CallOption) (*MsgSwapForExactTokensResponse, error) + Withdraw func(ctx context.Context, in *MsgWithdraw, opts ...grpc.CallOption) (*MsgWithdrawResponse, error) + func NewMsgClient(cc grpc1.ClientConn) MsgClient + type MsgDeposit struct + Deadline int64 + Depositor string + Slippage github_com_cosmos_cosmos_sdk_types.Dec + TokenA types.Coin + TokenB types.Coin + func NewMsgDeposit(depositor string, tokenA sdk.Coin, tokenB sdk.Coin, slippage sdk.Dec, ...) *MsgDeposit + func (*MsgDeposit) Descriptor() ([]byte, []int) + func (*MsgDeposit) ProtoMessage() + func (m *MsgDeposit) Marshal() (dAtA []byte, err error) + func (m *MsgDeposit) MarshalTo(dAtA []byte) (int, error) + func (m *MsgDeposit) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgDeposit) Reset() + func (m *MsgDeposit) Size() (n int) + func (m *MsgDeposit) String() string + func (m *MsgDeposit) Unmarshal(dAtA []byte) error + func (m *MsgDeposit) XXX_DiscardUnknown() + func (m *MsgDeposit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgDeposit) XXX_Merge(src proto.Message) + func (m *MsgDeposit) XXX_Size() int + func (m *MsgDeposit) XXX_Unmarshal(b []byte) error + func (msg MsgDeposit) DeadlineExceeded(blockTime time.Time) bool + func (msg MsgDeposit) GetDeadline() time.Time + func (msg MsgDeposit) GetSignBytes() []byte + func (msg MsgDeposit) GetSigners() []sdk.AccAddress + func (msg MsgDeposit) Route() string + func (msg MsgDeposit) Type() string + func (msg MsgDeposit) ValidateBasic() error + type MsgDepositResponse struct + func (*MsgDepositResponse) Descriptor() ([]byte, []int) + func (*MsgDepositResponse) ProtoMessage() + func (m *MsgDepositResponse) Marshal() (dAtA []byte, err error) + func (m *MsgDepositResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgDepositResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgDepositResponse) Reset() + func (m *MsgDepositResponse) Size() (n int) + func (m *MsgDepositResponse) String() string + func (m *MsgDepositResponse) Unmarshal(dAtA []byte) error + func (m *MsgDepositResponse) XXX_DiscardUnknown() + func (m *MsgDepositResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgDepositResponse) XXX_Merge(src proto.Message) + func (m *MsgDepositResponse) XXX_Size() int + func (m *MsgDepositResponse) XXX_Unmarshal(b []byte) error + type MsgServer interface + Deposit func(context.Context, *MsgDeposit) (*MsgDepositResponse, error) + SwapExactForTokens func(context.Context, *MsgSwapExactForTokens) (*MsgSwapExactForTokensResponse, error) + SwapForExactTokens func(context.Context, *MsgSwapForExactTokens) (*MsgSwapForExactTokensResponse, error) + Withdraw func(context.Context, *MsgWithdraw) (*MsgWithdrawResponse, error) + type MsgSwapExactForTokens struct + Deadline int64 + ExactTokenA types.Coin + Requester string + Slippage github_com_cosmos_cosmos_sdk_types.Dec + TokenB types.Coin + func NewMsgSwapExactForTokens(requester string, exactTokenA sdk.Coin, tokenB sdk.Coin, slippage sdk.Dec, ...) *MsgSwapExactForTokens + func (*MsgSwapExactForTokens) Descriptor() ([]byte, []int) + func (*MsgSwapExactForTokens) ProtoMessage() + func (m *MsgSwapExactForTokens) Marshal() (dAtA []byte, err error) + func (m *MsgSwapExactForTokens) MarshalTo(dAtA []byte) (int, error) + func (m *MsgSwapExactForTokens) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgSwapExactForTokens) Reset() + func (m *MsgSwapExactForTokens) Size() (n int) + func (m *MsgSwapExactForTokens) String() string + func (m *MsgSwapExactForTokens) Unmarshal(dAtA []byte) error + func (m *MsgSwapExactForTokens) XXX_DiscardUnknown() + func (m *MsgSwapExactForTokens) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgSwapExactForTokens) XXX_Merge(src proto.Message) + func (m *MsgSwapExactForTokens) XXX_Size() int + func (m *MsgSwapExactForTokens) XXX_Unmarshal(b []byte) error + func (msg MsgSwapExactForTokens) DeadlineExceeded(blockTime time.Time) bool + func (msg MsgSwapExactForTokens) GetDeadline() time.Time + func (msg MsgSwapExactForTokens) GetSignBytes() []byte + func (msg MsgSwapExactForTokens) GetSigners() []sdk.AccAddress + func (msg MsgSwapExactForTokens) Route() string + func (msg MsgSwapExactForTokens) Type() string + func (msg MsgSwapExactForTokens) ValidateBasic() error + type MsgSwapExactForTokensResponse struct + func (*MsgSwapExactForTokensResponse) Descriptor() ([]byte, []int) + func (*MsgSwapExactForTokensResponse) ProtoMessage() + func (m *MsgSwapExactForTokensResponse) Marshal() (dAtA []byte, err error) + func (m *MsgSwapExactForTokensResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgSwapExactForTokensResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgSwapExactForTokensResponse) Reset() + func (m *MsgSwapExactForTokensResponse) Size() (n int) + func (m *MsgSwapExactForTokensResponse) String() string + func (m *MsgSwapExactForTokensResponse) Unmarshal(dAtA []byte) error + func (m *MsgSwapExactForTokensResponse) XXX_DiscardUnknown() + func (m *MsgSwapExactForTokensResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgSwapExactForTokensResponse) XXX_Merge(src proto.Message) + func (m *MsgSwapExactForTokensResponse) XXX_Size() int + func (m *MsgSwapExactForTokensResponse) XXX_Unmarshal(b []byte) error + type MsgSwapForExactTokens struct + Deadline int64 + ExactTokenB types.Coin + Requester string + Slippage github_com_cosmos_cosmos_sdk_types.Dec + TokenA types.Coin + func NewMsgSwapForExactTokens(requester string, tokenA sdk.Coin, exactTokenB sdk.Coin, slippage sdk.Dec, ...) *MsgSwapForExactTokens + func (*MsgSwapForExactTokens) Descriptor() ([]byte, []int) + func (*MsgSwapForExactTokens) ProtoMessage() + func (m *MsgSwapForExactTokens) Marshal() (dAtA []byte, err error) + func (m *MsgSwapForExactTokens) MarshalTo(dAtA []byte) (int, error) + func (m *MsgSwapForExactTokens) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgSwapForExactTokens) Reset() + func (m *MsgSwapForExactTokens) Size() (n int) + func (m *MsgSwapForExactTokens) String() string + func (m *MsgSwapForExactTokens) Unmarshal(dAtA []byte) error + func (m *MsgSwapForExactTokens) XXX_DiscardUnknown() + func (m *MsgSwapForExactTokens) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgSwapForExactTokens) XXX_Merge(src proto.Message) + func (m *MsgSwapForExactTokens) XXX_Size() int + func (m *MsgSwapForExactTokens) XXX_Unmarshal(b []byte) error + func (msg MsgSwapForExactTokens) DeadlineExceeded(blockTime time.Time) bool + func (msg MsgSwapForExactTokens) GetDeadline() time.Time + func (msg MsgSwapForExactTokens) GetSignBytes() []byte + func (msg MsgSwapForExactTokens) GetSigners() []sdk.AccAddress + func (msg MsgSwapForExactTokens) Route() string + func (msg MsgSwapForExactTokens) Type() string + func (msg MsgSwapForExactTokens) ValidateBasic() error + type MsgSwapForExactTokensResponse struct + func (*MsgSwapForExactTokensResponse) Descriptor() ([]byte, []int) + func (*MsgSwapForExactTokensResponse) ProtoMessage() + func (m *MsgSwapForExactTokensResponse) Marshal() (dAtA []byte, err error) + func (m *MsgSwapForExactTokensResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgSwapForExactTokensResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgSwapForExactTokensResponse) Reset() + func (m *MsgSwapForExactTokensResponse) Size() (n int) + func (m *MsgSwapForExactTokensResponse) String() string + func (m *MsgSwapForExactTokensResponse) Unmarshal(dAtA []byte) error + func (m *MsgSwapForExactTokensResponse) XXX_DiscardUnknown() + func (m *MsgSwapForExactTokensResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgSwapForExactTokensResponse) XXX_Merge(src proto.Message) + func (m *MsgSwapForExactTokensResponse) XXX_Size() int + func (m *MsgSwapForExactTokensResponse) XXX_Unmarshal(b []byte) error + type MsgWithDeadline interface + DeadlineExceeded func(blockTime time.Time) bool + GetDeadline func() time.Time + type MsgWithdraw struct + Deadline int64 + From string + MinTokenA types.Coin + MinTokenB types.Coin + Shares github_com_cosmos_cosmos_sdk_types.Int + func NewMsgWithdraw(from string, shares sdkmath.Int, minTokenA, minTokenB sdk.Coin, deadline int64) *MsgWithdraw + func (*MsgWithdraw) Descriptor() ([]byte, []int) + func (*MsgWithdraw) ProtoMessage() + func (m *MsgWithdraw) Marshal() (dAtA []byte, err error) + func (m *MsgWithdraw) MarshalTo(dAtA []byte) (int, error) + func (m *MsgWithdraw) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgWithdraw) Reset() + func (m *MsgWithdraw) Size() (n int) + func (m *MsgWithdraw) String() string + func (m *MsgWithdraw) Unmarshal(dAtA []byte) error + func (m *MsgWithdraw) XXX_DiscardUnknown() + func (m *MsgWithdraw) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgWithdraw) XXX_Merge(src proto.Message) + func (m *MsgWithdraw) XXX_Size() int + func (m *MsgWithdraw) XXX_Unmarshal(b []byte) error + func (msg MsgWithdraw) DeadlineExceeded(blockTime time.Time) bool + func (msg MsgWithdraw) GetDeadline() time.Time + func (msg MsgWithdraw) GetSignBytes() []byte + func (msg MsgWithdraw) GetSigners() []sdk.AccAddress + func (msg MsgWithdraw) Route() string + func (msg MsgWithdraw) Type() string + func (msg MsgWithdraw) ValidateBasic() error + type MsgWithdrawResponse struct + func (*MsgWithdrawResponse) Descriptor() ([]byte, []int) + func (*MsgWithdrawResponse) ProtoMessage() + func (m *MsgWithdrawResponse) Marshal() (dAtA []byte, err error) + func (m *MsgWithdrawResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MsgWithdrawResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MsgWithdrawResponse) Reset() + func (m *MsgWithdrawResponse) Size() (n int) + func (m *MsgWithdrawResponse) String() string + func (m *MsgWithdrawResponse) Unmarshal(dAtA []byte) error + func (m *MsgWithdrawResponse) XXX_DiscardUnknown() + func (m *MsgWithdrawResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MsgWithdrawResponse) XXX_Merge(src proto.Message) + func (m *MsgWithdrawResponse) XXX_Size() int + func (m *MsgWithdrawResponse) XXX_Unmarshal(b []byte) error + type Params struct + AllowedPools AllowedPools + SwapFee github_com_cosmos_cosmos_sdk_types.Dec + func DefaultParams() Params + func NewParams(pairs AllowedPools, swapFee sdk.Dec) Params + func (*Params) Descriptor() ([]byte, []int) + func (*Params) ProtoMessage() + func (m *Params) GetAllowedPools() AllowedPools + func (m *Params) Marshal() (dAtA []byte, err error) + func (m *Params) MarshalTo(dAtA []byte) (int, error) + func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Params) Reset() + func (m *Params) Size() (n int) + func (m *Params) Unmarshal(dAtA []byte) error + func (m *Params) XXX_DiscardUnknown() + func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Params) XXX_Merge(src proto.Message) + func (m *Params) XXX_Size() int + func (m *Params) XXX_Unmarshal(b []byte) error + func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs + func (p Params) String() string + func (p Params) Validate() error + type PoolRecord struct + PoolID string + ReservesA types.Coin + ReservesB types.Coin + TotalShares github_com_cosmos_cosmos_sdk_types.Int + func NewPoolRecord(reserves sdk.Coins, totalShares sdkmath.Int) PoolRecord + func NewPoolRecordFromPool(pool *DenominatedPool) PoolRecord + func (*PoolRecord) Descriptor() ([]byte, []int) + func (*PoolRecord) ProtoMessage() + func (m *PoolRecord) GetPoolID() string + func (m *PoolRecord) GetReservesA() types.Coin + func (m *PoolRecord) GetReservesB() types.Coin + func (m *PoolRecord) Marshal() (dAtA []byte, err error) + func (m *PoolRecord) MarshalTo(dAtA []byte) (int, error) + func (m *PoolRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PoolRecord) Reset() + func (m *PoolRecord) Size() (n int) + func (m *PoolRecord) String() string + func (m *PoolRecord) Unmarshal(dAtA []byte) error + func (m *PoolRecord) XXX_DiscardUnknown() + func (m *PoolRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PoolRecord) XXX_Merge(src proto.Message) + func (m *PoolRecord) XXX_Size() int + func (m *PoolRecord) XXX_Unmarshal(b []byte) error + func (p PoolRecord) Reserves() sdk.Coins + func (p PoolRecord) Validate() error + type PoolRecords []PoolRecord + func (prs PoolRecords) Validate() error + type PoolResponse struct + Coins github_com_cosmos_cosmos_sdk_types.Coins + Name string + TotalShares github_com_cosmos_cosmos_sdk_types.Int + func (*PoolResponse) Descriptor() ([]byte, []int) + func (*PoolResponse) ProtoMessage() + func (m *PoolResponse) Marshal() (dAtA []byte, err error) + func (m *PoolResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PoolResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PoolResponse) Reset() + func (m *PoolResponse) Size() (n int) + func (m *PoolResponse) String() string + func (m *PoolResponse) Unmarshal(dAtA []byte) error + func (m *PoolResponse) XXX_DiscardUnknown() + func (m *PoolResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PoolResponse) XXX_Merge(src proto.Message) + func (m *PoolResponse) XXX_Size() int + func (m *PoolResponse) XXX_Unmarshal(b []byte) error + type PoolStatsQueryResult struct + Coins sdk.Coins + Name string + TotalShares sdkmath.Int + func NewPoolStatsQueryResult(name string, coins sdk.Coins, totalShares sdkmath.Int) PoolStatsQueryResult + type PoolStatsQueryResults []PoolStatsQueryResult + type QueryClient interface + Deposits func(ctx context.Context, in *QueryDepositsRequest, opts ...grpc.CallOption) (*QueryDepositsResponse, error) + Params func(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) + Pools func(ctx context.Context, in *QueryPoolsRequest, opts ...grpc.CallOption) (*QueryPoolsResponse, error) + func NewQueryClient(cc grpc1.ClientConn) QueryClient + type QueryDepositsParams struct + Limit int + Owner sdk.AccAddress + Page int + Pool string + func NewQueryDepositsParams(page, limit int, owner sdk.AccAddress, pool string) QueryDepositsParams + type QueryDepositsRequest struct + Owner string + Pagination *query.PageRequest + PoolId string + func (*QueryDepositsRequest) Descriptor() ([]byte, []int) + func (*QueryDepositsRequest) ProtoMessage() + func (m *QueryDepositsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryDepositsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryDepositsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryDepositsRequest) Reset() + func (m *QueryDepositsRequest) Size() (n int) + func (m *QueryDepositsRequest) String() string + func (m *QueryDepositsRequest) Unmarshal(dAtA []byte) error + func (m *QueryDepositsRequest) XXX_DiscardUnknown() + func (m *QueryDepositsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryDepositsRequest) XXX_Merge(src proto.Message) + func (m *QueryDepositsRequest) XXX_Size() int + func (m *QueryDepositsRequest) XXX_Unmarshal(b []byte) error + type QueryDepositsResponse struct + Deposits []DepositResponse + Pagination *query.PageResponse + func (*QueryDepositsResponse) Descriptor() ([]byte, []int) + func (*QueryDepositsResponse) ProtoMessage() + func (m *QueryDepositsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryDepositsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryDepositsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryDepositsResponse) Reset() + func (m *QueryDepositsResponse) Size() (n int) + func (m *QueryDepositsResponse) String() string + func (m *QueryDepositsResponse) Unmarshal(dAtA []byte) error + func (m *QueryDepositsResponse) XXX_DiscardUnknown() + func (m *QueryDepositsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryDepositsResponse) XXX_Merge(src proto.Message) + func (m *QueryDepositsResponse) XXX_Size() int + func (m *QueryDepositsResponse) XXX_Unmarshal(b []byte) error + type QueryParamsRequest struct + func (*QueryParamsRequest) Descriptor() ([]byte, []int) + func (*QueryParamsRequest) ProtoMessage() + func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryParamsRequest) Reset() + func (m *QueryParamsRequest) Size() (n int) + func (m *QueryParamsRequest) String() string + func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error + func (m *QueryParamsRequest) XXX_DiscardUnknown() + func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryParamsRequest) XXX_Merge(src proto.Message) + func (m *QueryParamsRequest) XXX_Size() int + func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error + type QueryParamsResponse struct + Params Params + func (*QueryParamsResponse) Descriptor() ([]byte, []int) + func (*QueryParamsResponse) ProtoMessage() + func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryParamsResponse) Reset() + func (m *QueryParamsResponse) Size() (n int) + func (m *QueryParamsResponse) String() string + func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error + func (m *QueryParamsResponse) XXX_DiscardUnknown() + func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryParamsResponse) XXX_Merge(src proto.Message) + func (m *QueryParamsResponse) XXX_Size() int + func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error + type QueryPoolParams struct + Pool string + func NewQueryPoolParams(pool string) QueryPoolParams + type QueryPoolsRequest struct + Pagination *query.PageRequest + PoolId string + func (*QueryPoolsRequest) Descriptor() ([]byte, []int) + func (*QueryPoolsRequest) ProtoMessage() + func (m *QueryPoolsRequest) GetPagination() *query.PageRequest + func (m *QueryPoolsRequest) GetPoolId() string + func (m *QueryPoolsRequest) Marshal() (dAtA []byte, err error) + func (m *QueryPoolsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryPoolsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryPoolsRequest) Reset() + func (m *QueryPoolsRequest) Size() (n int) + func (m *QueryPoolsRequest) String() string + func (m *QueryPoolsRequest) Unmarshal(dAtA []byte) error + func (m *QueryPoolsRequest) XXX_DiscardUnknown() + func (m *QueryPoolsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryPoolsRequest) XXX_Merge(src proto.Message) + func (m *QueryPoolsRequest) XXX_Size() int + func (m *QueryPoolsRequest) XXX_Unmarshal(b []byte) error + type QueryPoolsResponse struct + Pagination *query.PageResponse + Pools []PoolResponse + func (*QueryPoolsResponse) Descriptor() ([]byte, []int) + func (*QueryPoolsResponse) ProtoMessage() + func (m *QueryPoolsResponse) GetPagination() *query.PageResponse + func (m *QueryPoolsResponse) GetPools() []PoolResponse + func (m *QueryPoolsResponse) Marshal() (dAtA []byte, err error) + func (m *QueryPoolsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryPoolsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryPoolsResponse) Reset() + func (m *QueryPoolsResponse) Size() (n int) + func (m *QueryPoolsResponse) String() string + func (m *QueryPoolsResponse) Unmarshal(dAtA []byte) error + func (m *QueryPoolsResponse) XXX_DiscardUnknown() + func (m *QueryPoolsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryPoolsResponse) XXX_Merge(src proto.Message) + func (m *QueryPoolsResponse) XXX_Size() int + func (m *QueryPoolsResponse) XXX_Unmarshal(b []byte) error + type QueryServer interface + Deposits func(context.Context, *QueryDepositsRequest) (*QueryDepositsResponse, error) + Params func(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) + Pools func(context.Context, *QueryPoolsRequest) (*QueryPoolsResponse, error) + type ShareRecord struct + Depositor github_com_cosmos_cosmos_sdk_types.AccAddress + PoolID string + SharesOwned github_com_cosmos_cosmos_sdk_types.Int + func NewShareRecord(depositor sdk.AccAddress, poolID string, sharesOwned sdkmath.Int) ShareRecord + func (*ShareRecord) Descriptor() ([]byte, []int) + func (*ShareRecord) ProtoMessage() + func (m *ShareRecord) GetDepositor() github_com_cosmos_cosmos_sdk_types.AccAddress + func (m *ShareRecord) GetPoolID() string + func (m *ShareRecord) Marshal() (dAtA []byte, err error) + func (m *ShareRecord) MarshalTo(dAtA []byte) (int, error) + func (m *ShareRecord) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShareRecord) Reset() + func (m *ShareRecord) Size() (n int) + func (m *ShareRecord) String() string + func (m *ShareRecord) Unmarshal(dAtA []byte) error + func (m *ShareRecord) XXX_DiscardUnknown() + func (m *ShareRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShareRecord) XXX_Merge(src proto.Message) + func (m *ShareRecord) XXX_Size() int + func (m *ShareRecord) XXX_Unmarshal(b []byte) error + func (sr ShareRecord) Validate() error + type ShareRecords []ShareRecord + func (srs ShareRecords) Validate() error + type SwapHooks interface + AfterPoolDepositCreated func(ctx sdk.Context, poolID string, depositor sdk.AccAddress, ...) + BeforePoolDepositModified func(ctx sdk.Context, poolID string, depositor sdk.AccAddress, ...) + type UnimplementedMsgServer struct + func (*UnimplementedMsgServer) Deposit(ctx context.Context, req *MsgDeposit) (*MsgDepositResponse, error) + func (*UnimplementedMsgServer) SwapExactForTokens(ctx context.Context, req *MsgSwapExactForTokens) (*MsgSwapExactForTokensResponse, error) + func (*UnimplementedMsgServer) SwapForExactTokens(ctx context.Context, req *MsgSwapForExactTokens) (*MsgSwapForExactTokensResponse, error) + func (*UnimplementedMsgServer) Withdraw(ctx context.Context, req *MsgWithdraw) (*MsgWithdrawResponse, error) + type UnimplementedQueryServer struct + func (*UnimplementedQueryServer) Deposits(ctx context.Context, req *QueryDepositsRequest) (*QueryDepositsResponse, error) + func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error) + func (*UnimplementedQueryServer) Pools(ctx context.Context, req *QueryPoolsRequest) (*QueryPoolsResponse, error)
Go to main page