keeper

package
v7.0.0-alpha-1 Latest Latest
Warning

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

 Go to latest Published: Feb 16, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AllInvariants 

func AllInvariants(keeper Keeper, bk types.BankKeeper) sdk.Invariant

AllInvariants runs all invariants of the gamm module

func NewBalancerMsgServerImpl 

func NewBalancerMsgServerImpl(keeper Keeper) balancer.MsgServer

func NewMsgServerImpl 

func NewMsgServerImpl(keeper Keeper) types.MsgServer

func PoolAccountInvariant 

func PoolAccountInvariant(keeper Keeper, bk types.BankKeeper) sdk.Invariant

PoolAccountInvariant checks that the pool account balance reflects the sum of pool assets

func PoolProductConstantInvariant 

func PoolProductConstantInvariant(keeper Keeper) sdk.Invariant

PoolProductContantInvariant chekcs that the pool constant invariant V where V = product([asset_balance_n^asset_weight_n]) holds. The invariant increases with positive swap fee, and decresed upon liquidity removal.

func PoolTotalWeightInvariant 

func PoolTotalWeightInvariant(keeper Keeper, bk types.BankKeeper) sdk.Invariant

PoolTotalWeightInvariant checks that the pool total weight reflect the sum of pool weights

func RegisterInvariants 

func RegisterInvariants(ir sdk.InvariantRegistry, keeper Keeper, bk types.BankKeeper)

RegisterInvariants registers all governance invariants

Types

type Keeper 

type Keeper struct {
	// contains filtered or unexported fields
}

func NewKeeper 

func NewKeeper(cdc codec.BinaryCodec, storeKey sdk.StoreKey, paramSpace paramtypes.Subspace, accountKeeper types.AccountKeeper, bankKeeper types.BankKeeper, distrKeeper types.DistrKeeper) Keeper

func (Keeper) BurnPoolShareFromAccount 

func (k Keeper) BurnPoolShareFromAccount(ctx sdk.Context, pool types.PoolI, addr sdk.AccAddress, amount sdk.Int) error

BurnPoolShareFromAccount burns `amount` of the given pools shares held by `addr`.

func (Keeper) CalculateSpotPrice 

func (k Keeper) CalculateSpotPrice(ctx sdk.Context, poolId uint64, tokenInDenom, tokenOutDenom string) (sdk.Dec, error)

func (Keeper) CalculateSpotPriceWithSwapFee 

func (k Keeper) CalculateSpotPriceWithSwapFee(ctx sdk.Context, poolId uint64, tokenInDenom, tokenOutDenom string) (sdk.Dec, error)

func (Keeper) CleanupBalancerPool 

func (k Keeper) CleanupBalancerPool(ctx sdk.Context, poolIds []uint64, excludedModules []string) (err error)

CleanupBalancerPool destructs a pool and refund all the assets according to the shares held by the accounts. CleanupBalancerPool should not be called during the chain execution time, as it iterates the entire account balances. TODO: once SDK v0.46.0, use https://github.com/cosmos/cosmos-sdk/pull/9611

All locks on this pool share must be unlocked prior to execution. Use LockupKeeper.ForceUnlock on remaining locks before calling this function.

func (Keeper) CreateBalancerPool 

func (k Keeper) CreateBalancerPool(
	ctx sdk.Context,
	sender sdk.AccAddress,
	BalancerPoolParams balancer.BalancerPoolParams,
	poolAssets []types.PoolAsset,
	futurePoolGovernor string,
) (uint64, error)

func (Keeper) DeleteLegacyTotalLiquidity 

func (k Keeper) DeleteLegacyTotalLiquidity(ctx sdk.Context)

func (Keeper) DeletePool 

func (k Keeper) DeletePool(ctx sdk.Context, poolId uint64) error

func (Keeper) EstimateSwapExactAmountIn 

func (k Keeper) EstimateSwapExactAmountIn(ctx context.Context, req *types.QuerySwapExactAmountInRequest) (*types.QuerySwapExactAmountInResponse, error)

func (Keeper) EstimateSwapExactAmountOut 

func (k Keeper) EstimateSwapExactAmountOut(ctx context.Context, req *types.QuerySwapExactAmountOutRequest) (*types.QuerySwapExactAmountOutResponse, error)

func (Keeper) ExitPool 

func (k Keeper) ExitPool(
	ctx sdk.Context,
	sender sdk.AccAddress,
	poolId uint64,
	shareInAmount sdk.Int,
	tokenOutMins sdk.Coins,
) (err error)

func (Keeper) ExitSwapExternAmountOut 

func (k Keeper) ExitSwapExternAmountOut(
	ctx sdk.Context,
	sender sdk.AccAddress,
	poolId uint64,
	tokenOut sdk.Coin,
	shareInMaxAmount sdk.Int,
) (shareInAmount sdk.Int, err error)

func (Keeper) ExitSwapShareAmountIn 

func (k Keeper) ExitSwapShareAmountIn(
	ctx sdk.Context,
	sender sdk.AccAddress,
	poolId uint64,
	tokenOutDenom string,
	shareInAmount sdk.Int,
	tokenOutMinAmount sdk.Int,
) (tokenOutAmount sdk.Int, err error)

func (Keeper) GetDenomLiquidity 

func (k Keeper) GetDenomLiquidity(ctx sdk.Context, denom string) sdk.Int

func (Keeper) GetLegacyTotalLiquidity 

func (k Keeper) GetLegacyTotalLiquidity(ctx sdk.Context) sdk.Coins

func (Keeper) GetNextPoolNumberAndIncrement 

func (k Keeper) GetNextPoolNumberAndIncrement(ctx sdk.Context) uint64

GetNextPoolNumberAndIncrement returns the next pool number, and increments the corresponding state entry

func (Keeper) GetParams 

func (k Keeper) GetParams(ctx sdk.Context) (params types.Params)

GetParams returns the total set params

func (Keeper) GetPool 

func (k Keeper) GetPool(ctx sdk.Context, poolId uint64) (types.PoolI, error)

func (Keeper) GetPools 

func (k Keeper) GetPools(ctx sdk.Context) (res []types.PoolI, err error)

func (Keeper) GetTotalLiquidity 

func (k Keeper) GetTotalLiquidity(ctx sdk.Context) sdk.Coins

func (Keeper) IterateDenomLiquidity 

func (k Keeper) IterateDenomLiquidity(ctx sdk.Context, cb func(sdk.Coin) bool)

func (Keeper) JoinPool 

func (k Keeper) JoinPool(
	ctx sdk.Context,
	sender sdk.AccAddress,
	poolId uint64,
	shareOutAmount sdk.Int,
	tokenInMaxs sdk.Coins,
) (err error)

func (Keeper) JoinSwapExternAmountIn 

func (k Keeper) JoinSwapExternAmountIn(
	ctx sdk.Context,
	sender sdk.AccAddress,
	poolId uint64,
	tokenIn sdk.Coin,
	shareOutMinAmount sdk.Int,
) (shareOutAmount sdk.Int, err error)

func (Keeper) JoinSwapShareAmountOut 

func (k Keeper) JoinSwapShareAmountOut(
	ctx sdk.Context,
	sender sdk.AccAddress,
	poolId uint64,
	tokenInDenom string,
	shareOutAmount sdk.Int,
	tokenInMaxAmount sdk.Int,
) (tokenInAmount sdk.Int, err error)

func (Keeper) MarshalPool 

func (k Keeper) MarshalPool(pool types.PoolI) ([]byte, error)

func (Keeper) MintPoolShareToAccount 

func (k Keeper) MintPoolShareToAccount(ctx sdk.Context, pool types.PoolI, addr sdk.AccAddress, amount sdk.Int) error

func (Keeper) MultihopSwapExactAmountIn 

func (k Keeper) MultihopSwapExactAmountIn(
	ctx sdk.Context,
	sender sdk.AccAddress,
	routes []types.SwapAmountInRoute,
	tokenIn sdk.Coin,
	tokenOutMinAmount sdk.Int,
) (tokenOutAmount sdk.Int, err error)

MultihopSwapExactAmountIn defines the input denom and input amount for the first pool, the output of the first pool is chained as the input for the next routed pool transaction succeeds when final amount out is greater than tokenOutMinAmount defined

func (Keeper) MultihopSwapExactAmountOut 

func (k Keeper) MultihopSwapExactAmountOut(
	ctx sdk.Context,
	sender sdk.AccAddress,
	routes []types.SwapAmountOutRoute,
	tokenInMaxAmount sdk.Int,
	tokenOut sdk.Coin,
) (tokenInAmount sdk.Int, err error)

MultihopSwapExactAmountOut defines the output denom and output amount for the last pool. Calculation starts by providing the tokenOutAmount of the final pool to calculate the required tokenInAmount the calculated tokenInAmount is used as defined tokenOutAmount of the previous pool, calculating in reverse order of the swap Transaction succeeds if the calculated tokenInAmount of the first pool is less than the defined tokenInMaxAmount defined.

func (Keeper) NumPools 

func (k Keeper) NumPools(
	ctx context.Context,
	req *types.QueryNumPoolsRequest,
) (*types.QueryNumPoolsResponse, error)

func (Keeper) Pool 

func (k Keeper) Pool(
	ctx context.Context,
	req *types.QueryPoolRequest,
) (*types.QueryPoolResponse, error)

func (Keeper) PoolAssets 

func (k Keeper) PoolAssets(ctx context.Context, req *types.QueryPoolAssetsRequest) (*types.QueryPoolAssetsResponse, error)

func (Keeper) PoolParams 

func (k Keeper) PoolParams(ctx context.Context, req *types.QueryPoolParamsRequest) (*types.QueryPoolParamsResponse, error)

func (Keeper) Pools 

func (k Keeper) Pools(
	ctx context.Context,
	req *types.QueryPoolsRequest,
) (*types.QueryPoolsResponse, error)

func (Keeper) RecordTotalLiquidityDecrease 

func (k Keeper) RecordTotalLiquidityDecrease(ctx sdk.Context, coins sdk.Coins)

func (Keeper) RecordTotalLiquidityIncrease 

func (k Keeper) RecordTotalLiquidityIncrease(ctx sdk.Context, coins sdk.Coins)

func (Keeper) SetDenomLiquidity 

func (k Keeper) SetDenomLiquidity(ctx sdk.Context, denom string, amount sdk.Int)

func (*Keeper) SetHooks 

func (k *Keeper) SetHooks(gh types.GammHooks) *Keeper

Set the gamm hooks

func (Keeper) SetLegacyTotalLiquidity 

func (k Keeper) SetLegacyTotalLiquidity(ctx sdk.Context, coins sdk.Coins)

func (Keeper) SetNextPoolNumber 

func (k Keeper) SetNextPoolNumber(ctx sdk.Context, poolNumber uint64)

SetNextPoolNumber sets next pool number

func (Keeper) SetParams 

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams sets the total set of params

func (Keeper) SetPool 

func (k Keeper) SetPool(ctx sdk.Context, pool types.PoolI) error

func (Keeper) SetTotalLiquidity 

func (k Keeper) SetTotalLiquidity(ctx sdk.Context, coins sdk.Coins)

func (Keeper) SpotPrice 

func (k Keeper) SpotPrice(ctx context.Context, req *types.QuerySpotPriceRequest) (*types.QuerySpotPriceResponse, error)

func (Keeper) SwapExactAmountIn 

func (k Keeper) SwapExactAmountIn(
	ctx sdk.Context,
	sender sdk.AccAddress,
	poolId uint64,
	tokenIn sdk.Coin,
	tokenOutDenom string,
	tokenOutMinAmount sdk.Int,
) (tokenOutAmount sdk.Int, spotPriceAfter sdk.Dec, err error)

func (Keeper) SwapExactAmountOut 

func (k Keeper) SwapExactAmountOut(
	ctx sdk.Context,
	sender sdk.AccAddress,
	poolId uint64,
	tokenInDenom string,
	tokenInMaxAmount sdk.Int,
	tokenOut sdk.Coin,
) (tokenInAmount sdk.Int, spotPriceAfter sdk.Dec, err error)

func (Keeper) TotalLiquidity 

func (k Keeper) TotalLiquidity(ctx context.Context, req *types.QueryTotalLiquidityRequest) (*types.QueryTotalLiquidityResponse, error)

func (Keeper) TotalShares 

func (k Keeper) TotalShares(ctx context.Context, req *types.QueryTotalSharesRequest) (*types.QueryTotalSharesResponse, error)

func (Keeper) UnmarshalPool 

func (k Keeper) UnmarshalPool(bz []byte) (types.PoolI, 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.