Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

types

package

Go to main page

Versions in this module

v0

v0.17.0

Jul 19, 2023

v0.16.1-fury.x

Jul 17, 2023

v0.16.0-fury.x

Jul 18, 2023

v0.4.2-20230907204745-m1.fury

Aug 24, 2023

v0.4.1

Jul 21, 2023

v0.4.0

Jul 16, 2023

v0.4.0-fury.1

Jul 19, 2023

v0.3.7

Jul 11, 2023

v0.3.6

Jul 11, 2023

v0.3.5

Jul 10, 2023

v0.3.4

Jul 7, 2023

v0.3.3

Jul 7, 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)