keeper

package
v0.2.5 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FilteredPaginateAccountBalances 

func FilteredPaginateAccountBalances(
	ctx sdk.Context,
	bankKeeper types.BankKeeper,
	address sdk.AccAddress,
	pageRequest *query.PageRequest,
	onResult func(coin sdk.Coin, accumulate bool) bool,
) (*query.PageResponse, error)

func GetInOutTokens 

func GetInOutTokens(tokenIn, tokenA, tokenB string) (_, tokenOut string)

func GetPoolMetadataIDBytes 

func GetPoolMetadataIDBytes(id uint64) []byte

GetPoolMetadataIDBytes returns the byte representation of the ID

func NewLimitOrderExpiration 

func NewLimitOrderExpiration(tranche *types.LimitOrderTranche) *types.LimitOrderExpiration

func NewLimitOrderTranche 

func NewLimitOrderTranche(
	limitOrderTrancheKey *types.LimitOrderTrancheKey,
	goodTil *time.Time,
) (*types.LimitOrderTranche, error)

func NewTrancheKey 

func NewTrancheKey(ctx sdk.Context) string

#nosec

func NormalizeAllTickIndexes 

func NormalizeAllTickIndexes(takerDenom, token0 string, tickIndexes []int64) []int64

func SortAmounts 

func SortAmounts(tokenA, token0 string, amountsA, amountsB []sdk.Int) ([]sdk.Int, []sdk.Int)

Types

type Keeper 

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

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey,
	memKey storetypes.StoreKey,
	ps paramtypes.Subspace,

	bankKeeper types.BankKeeper,
) *Keeper

func (Keeper) BurnShares 

func (k Keeper) BurnShares(
	ctx sdk.Context,
	addr sdk.AccAddress,
	amount sdk.Int,
	sharesID string,
) error

func (Keeper) CancelLimitOrder 

func (k Keeper) CancelLimitOrder(
	goCtx context.Context,
	msg *types.MsgCancelLimitOrder,
) (*types.MsgCancelLimitOrderResponse, error)

func (Keeper) CancelLimitOrderCore 

func (k Keeper) CancelLimitOrderCore(
	goCtx context.Context,
	trancheKey string,
	callerAddr sdk.AccAddress,
) error

Handles MsgCancelLimitOrder, removing a specified number of shares from a limit order and returning the respective amount in terms of the reserve to the user.

func (Keeper) DepositCore 

func (k Keeper) DepositCore(
	goCtx context.Context,
	pairID *types.PairID,
	callerAddr sdk.AccAddress,
	receiverAddr sdk.AccAddress,
	amounts0 []sdk.Int,
	amounts1 []sdk.Int,
	tickIndices []int64,
	fees []uint64,
	options []*types.DepositOptions,
) (amounts0Deposit, amounts1Deposit []sdk.Int, sharesIssued sdk.Coins, err error)

Handles core logic for MsgDexDeposit, checking and initializing data structures (tick, pair), calculating shares based on amount deposited, and sending funds to moduleAddress.

func (Keeper) DexDeposit 

func (k Keeper) DexDeposit(
	goCtx context.Context,
	msg *types.MsgDexDeposit,
) (*types.MsgDexDepositResponse, error)

func (Keeper) DexWithdrawal 

func (k Keeper) DexWithdrawal(
	goCtx context.Context,
	msg *types.MsgDexWithdrawal,
) (*types.MsgDexWithdrawalResponse, error)

func (Keeper) EstimateMultiHopSwap 

func (k Keeper) EstimateMultiHopSwap(
	goCtx context.Context,
	req *types.QueryEstimateMultiHopSwapRequest,
) (*types.QueryEstimateMultiHopSwapResponse, error)

TODO: This doesn't run ValidateBasic() checks.

func (Keeper) EstimatePlaceLimitOrder 

func (k Keeper) EstimatePlaceLimitOrder(
	goCtx context.Context,
	req *types.QueryEstimatePlaceLimitOrderRequest,
) (*types.QueryEstimatePlaceLimitOrderResponse, error)

TODO: This doesn't run ValidateBasic() checks.

func (Keeper) FindLimitOrderTranche 

func (k Keeper) FindLimitOrderTranche(
	ctx sdk.Context,
	limitOrderTrancheKey *types.LimitOrderTrancheKey,
) (val *types.LimitOrderTranche, fromFilled, found bool)

func (Keeper) GetAllDepositsForAddress 

func (k Keeper) GetAllDepositsForAddress(ctx sdk.Context, addr sdk.AccAddress) []*types.DepositRecord

func (Keeper) GetAllInactiveLimitOrderTranche 

func (k Keeper) GetAllInactiveLimitOrderTranche(ctx sdk.Context) (list []*types.LimitOrderTranche)

GetAllInactiveLimitOrderTranche returns all inactiveLimitOrderTranche

func (Keeper) GetAllLimitOrderExpiration 

func (k Keeper) GetAllLimitOrderExpiration(ctx sdk.Context) (list []*types.LimitOrderExpiration)

GetAllLimitOrderExpiration returns all goodTilRecord

func (Keeper) GetAllLimitOrderTrancheAtIndex 

func (k Keeper) GetAllLimitOrderTrancheAtIndex(
	sdkCtx sdk.Context,
	tradePairID *types.TradePairID,
	tickIndexTakerToMaker int64,
) (trancheList []types.LimitOrderTranche)

func (Keeper) GetAllLimitOrderTrancheUser 

func (k Keeper) GetAllLimitOrderTrancheUser(ctx sdk.Context) (list []*types.LimitOrderTrancheUser)

GetAllLimitOrderTrancheUser returns all LimitOrderTrancheUser

func (Keeper) GetAllLimitOrderTrancheUserForAddress 

func (k Keeper) GetAllLimitOrderTrancheUserForAddress(
	ctx sdk.Context,
	address sdk.AccAddress,
) (list []*types.LimitOrderTrancheUser)

func (Keeper) GetAllPoolMetadata 

func (k Keeper) GetAllPoolMetadata(ctx sdk.Context) (list []types.PoolMetadata)

GetAllPoolMetadata returns all poolMetadata

func (Keeper) GetAllTickLiquidity 

func (k Keeper) GetAllTickLiquidity(ctx sdk.Context) (list []*types.TickLiquidity)

GetAllTickLiquidity returns all tickLiquidity

func (Keeper) GetCurrLiq 

func (k Keeper) GetCurrLiq(ctx sdk.Context, tradePairID *types.TradePairID) *types.TickLiquidity

func (Keeper) GetCurrPrice 

func (k Keeper) GetCurrPrice(ctx sdk.Context, tradePairID *types.TradePairID) (math_utils.PrecDec, bool)

func (Keeper) GetCurrTickIndexTakerToMaker 

func (k Keeper) GetCurrTickIndexTakerToMaker(
	ctx sdk.Context,
	tradePairID *types.TradePairID,
) (int64, bool)

Returns a takerToMaker tick index

func (Keeper) GetCurrTickIndexTakerToMakerNormalized 

func (k Keeper) GetCurrTickIndexTakerToMakerNormalized(
	ctx sdk.Context,
	tradePairID *types.TradePairID,
) (int64, bool)

Returns a takerToMaker tick index

func (Keeper) GetFillTranche 

func (k Keeper) GetFillTranche(
	sdkCtx sdk.Context,
	tradePairID *types.TradePairID,
	tickIndexTakerToMaker int64,
) (*types.LimitOrderTranche, bool)

func (Keeper) GetInactiveLimitOrderTranche 

func (k Keeper) GetInactiveLimitOrderTranche(
	ctx sdk.Context,
	limitOrderTrancheKey *types.LimitOrderTrancheKey,
) (val *types.LimitOrderTranche, found bool)

GetInactiveLimitOrderTranche returns a inactiveLimitOrderTranche from its index

func (Keeper) GetLimitOrderExpiration 

func (k Keeper) GetLimitOrderExpiration(
	ctx sdk.Context,
	goodTilDate time.Time,
	trancheRef []byte,
) (val *types.LimitOrderExpiration, found bool)

GetLimitOrderExpiration returns a goodTilRecord from its index

func (Keeper) GetLimitOrderTranche 

func (k Keeper) GetLimitOrderTranche(
	ctx sdk.Context,
	limitOrderTrancheKey *types.LimitOrderTrancheKey,
) (tranche *types.LimitOrderTranche)

func (Keeper) GetLimitOrderTrancheByKey 

func (k Keeper) GetLimitOrderTrancheByKey(
	ctx sdk.Context,
	key []byte,
) (tranche *types.LimitOrderTranche, found bool)

func (Keeper) GetLimitOrderTrancheUser 

func (k Keeper) GetLimitOrderTrancheUser(
	ctx sdk.Context,
	address string,
	trancheKey string,
) (val *types.LimitOrderTrancheUser, found bool)

GetLimitOrderTrancheUser returns a LimitOrderTrancheUser from its index

func (Keeper) GetNextPoolID 

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

GetNextPoolId get ID for the next pool to be created

func (Keeper) GetOrInitLimitOrderTrancheUser 

func (k Keeper) GetOrInitLimitOrderTrancheUser(
	ctx sdk.Context,
	tradePairID *types.TradePairID,
	tickIndex int64,
	trancheKey string,
	orderType types.LimitOrderType,
	receiver string,
) *types.LimitOrderTrancheUser

func (Keeper) GetOrInitPlaceTranche 

func (k Keeper) GetOrInitPlaceTranche(ctx sdk.Context,
	tradePairID *types.TradePairID,
	tickIndexTakerToMaker int64,
	goodTil *time.Time,
	orderType types.LimitOrderType,
) (placeTranche *types.LimitOrderTranche, err error)

func (Keeper) GetOrInitPool 

func (k Keeper) GetOrInitPool(
	ctx sdk.Context,
	pairID *types.PairID,
	centerTickIndexNormalized int64,
	fee uint64,
) (*types.Pool, error)

func (Keeper) GetParams 

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

GetParams get all parameters as types.Params

func (Keeper) GetPlaceTranche 

func (k Keeper) GetPlaceTranche(
	sdkCtx sdk.Context,
	tradePairID *types.TradePairID,
	tickIndexTakerToMaker int64,
) *types.LimitOrderTranche

func (Keeper) GetPool 

func (k Keeper) GetPool(
	ctx sdk.Context,
	pairID *types.PairID,
	centerTickIndexNormalized int64,
	fee uint64,
) (*types.Pool, bool)

func (Keeper) GetPoolByID 

func (k Keeper) GetPoolByID(ctx sdk.Context, poolID uint64) (pool *types.Pool, found bool)

func (Keeper) GetPoolCount 

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

GetPoolCount get the total number of pools

func (Keeper) GetPoolIDByParams 

func (k Keeper) GetPoolIDByParams(
	ctx sdk.Context,
	pairID *types.PairID,
	centerTickIndexNormalized int64,
	fee uint64,
) (id uint64, found bool)

func (Keeper) GetPoolMetadata 

func (k Keeper) GetPoolMetadata(ctx sdk.Context, id uint64) (val types.PoolMetadata, found bool)

GetPoolMetadata returns a poolMetadata from its id

func (Keeper) GetPoolMetadataByDenom 

func (k Keeper) GetPoolMetadataByDenom(
	ctx sdk.Context,
	denom string,
) (pm types.PoolMetadata, err error)

func (Keeper) GetPoolReserves 

func (k Keeper) GetPoolReserves(
	ctx sdk.Context,
	poolReservesID *types.PoolReservesKey,
) (pool *types.PoolReserves, found bool)

func (Keeper) GetValidFees 

func (k Keeper) GetValidFees(ctx sdk.Context) []uint64

func (Keeper) HopsToRouteData 

func (k Keeper) HopsToRouteData(
	ctx sdk.Context,
	hops []string,
	exitLimitPrice math_utils.PrecDec,
) ([]MultihopStep, error)

func (Keeper) InactiveLimitOrderTranche 

func (k Keeper) InactiveLimitOrderTranche(
	c context.Context,
	req *types.QueryGetInactiveLimitOrderTrancheRequest,
) (*types.QueryGetInactiveLimitOrderTrancheResponse, error)

func (Keeper) InactiveLimitOrderTrancheAll 

func (k Keeper) InactiveLimitOrderTrancheAll(
	c context.Context,
	req *types.QueryAllInactiveLimitOrderTrancheRequest,
) (*types.QueryAllInactiveLimitOrderTrancheResponse, error)

func (Keeper) InitPool 

func (k Keeper) InitPool(
	ctx sdk.Context,
	pairID *types.PairID,
	centerTickIndexNormalized int64,
	fee uint64,
) (pool *types.Pool, err error)

func (Keeper) LimitOrderTranche 

func (k Keeper) LimitOrderTranche(
	c context.Context,
	req *types.QueryGetLimitOrderTrancheRequest,
) (*types.QueryGetLimitOrderTrancheResponse, error)

Returns a specific limit order tranche either from the tickLiquidity index or from the FillLimitOrderTranche index

func (Keeper) LimitOrderTrancheAll 

func (k Keeper) LimitOrderTrancheAll(
	c context.Context,
	req *types.QueryAllLimitOrderTrancheRequest,
) (*types.QueryAllLimitOrderTrancheResponse, error)

Returns all ACTIVE limit order tranches for a given pairID/tokenIn combination Does NOT return inactiveLimitOrderTranches

func (Keeper) LimitOrderTrancheUser 

func (k Keeper) LimitOrderTrancheUser(c context.Context,
	req *types.QueryGetLimitOrderTrancheUserRequest,
) (*types.QueryGetLimitOrderTrancheUserResponse, error)

func (Keeper) LimitOrderTrancheUserAll 

func (k Keeper) LimitOrderTrancheUserAll(
	c context.Context,
	req *types.QueryAllLimitOrderTrancheUserRequest,
) (*types.QueryAllLimitOrderTrancheUserResponse, error)

func (Keeper) LimitOrderTrancheUserAllByAddress 

func (k Keeper) LimitOrderTrancheUserAllByAddress(
	goCtx context.Context,
	req *types.QueryAllUserLimitOrdersRequest,
) (*types.QueryAllUserLimitOrdersResponse, error)

func (Keeper) Logger 

func (k Keeper) Logger(ctx sdk.Context) log.Logger

func (Keeper) MintShares 

func (k Keeper) MintShares(ctx sdk.Context, addr sdk.AccAddress, shareCoin sdk.Coin) error

func (Keeper) MultiHopSwap 

func (k Keeper) MultiHopSwap(
	goCtx context.Context,
	msg *types.MsgMultiHopSwap,
) (*types.MsgMultiHopSwapResponse, error)

func (Keeper) MultiHopSwapCore 

func (k Keeper) MultiHopSwapCore(
	goCtx context.Context,
	amountIn sdk.Int,
	routes []*types.MultiHopRoute,
	exitLimitPrice math_utils.PrecDec,
	pickBestRoute bool,
	callerAddr sdk.AccAddress,
	receiverAddr sdk.AccAddress,
) (coinOut sdk.Coin, err error)

func (Keeper) MultihopStep 

func (k Keeper) MultihopStep(
	bctx *types.BranchableCache,
	step MultihopStep,
	inCoin sdk.Coin,
	exitLimitPrice math_utils.PrecDec,
	currentPrice math_utils.PrecDec,
	remainingSteps []MultihopStep,
	stepCache map[multihopCacheKey]StepResult,
) (sdk.Coin, *types.BranchableCache, error)

func (Keeper) NewLiquidityIterator 

func (k Keeper) NewLiquidityIterator(
	ctx sdk.Context,
	tradePairID *types.TradePairID,
) *LiquidityIterator

func (Keeper) NewTickIterator 

func (k Keeper) NewTickIterator(
	ctx sdk.Context,
	tradePairID *types.TradePairID,
) TickIterator

func (Keeper) Params 

func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Keeper) PlaceLimitOrder 

func (k Keeper) PlaceLimitOrder(
	goCtx context.Context,
	msg *types.MsgPlaceLimitOrder,
) (*types.MsgPlaceLimitOrderResponse, error)

func (Keeper) PlaceLimitOrderCore 

func (k Keeper) PlaceLimitOrderCore(
	goCtx context.Context,
	tokenIn string,
	tokenOut string,
	amountIn sdk.Int,
	tickIndexInToOut int64,
	orderType types.LimitOrderType,
	goodTil *time.Time,
	maxAmountOut *sdk.Int,
	callerAddr sdk.AccAddress,
	receiverAddr sdk.AccAddress,
) (trancheKey string, totalInCoin sdk.Coin, swapInCoin sdk.Coin, swapOutCoin sdk.Coin, err error)

Handles MsgPlaceLimitOrder, initializing (tick, pair) data structures if needed, calculating and storing information for a new limit order at a specific tick.

func (Keeper) Pool 

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

func (Keeper) PoolByID 

func (k Keeper) PoolByID(
	goCtx context.Context,
	req *types.QueryPoolByIDRequest,
) (*types.QueryPoolResponse, error)

func (Keeper) PoolMetadata 

func (k Keeper) PoolMetadata(goCtx context.Context, req *types.QueryGetPoolMetadataRequest) (*types.QueryGetPoolMetadataResponse, error)

func (Keeper) PoolMetadataAll 

func (k Keeper) PoolMetadataAll(goCtx context.Context, req *types.QueryAllPoolMetadataRequest) (*types.QueryAllPoolMetadataResponse, error)

func (Keeper) PoolReserves 

func (k Keeper) PoolReserves(
	goCtx context.Context,
	req *types.QueryGetPoolReservesRequest,
) (*types.QueryGetPoolReservesResponse, error)

func (Keeper) PoolReservesAll 

func (k Keeper) PoolReservesAll(
	goCtx context.Context,
	req *types.QueryAllPoolReservesRequest,
) (*types.QueryAllPoolReservesResponse, error)

func (Keeper) PurgeExpiredLimitOrders 

func (k Keeper) PurgeExpiredLimitOrders(ctx sdk.Context, curTime time.Time)

func (Keeper) RemoveInactiveLimitOrderTranche 

func (k Keeper) RemoveInactiveLimitOrderTranche(
	ctx sdk.Context,
	limitOrderTrancheKey *types.LimitOrderTrancheKey,
)

RemoveInactiveLimitOrderTranche removes a inactiveLimitOrderTranche from the store

func (Keeper) RemoveLimitOrderExpiration 

func (k Keeper) RemoveLimitOrderExpiration(
	ctx sdk.Context,
	goodTilDate time.Time,
	trancheRef []byte,
)

RemoveLimitOrderExpiration removes a goodTilRecord from the store

func (Keeper) RemoveLimitOrderExpirationByKey 

func (k Keeper) RemoveLimitOrderExpirationByKey(ctx sdk.Context, key []byte)

func (Keeper) RemoveLimitOrderTranche 

func (k Keeper) RemoveLimitOrderTranche(ctx sdk.Context, trancheKey *types.LimitOrderTrancheKey)

func (Keeper) RemoveLimitOrderTrancheUser 

func (k Keeper) RemoveLimitOrderTrancheUser(ctx sdk.Context, trancheUser *types.LimitOrderTrancheUser)

func (Keeper) RemoveLimitOrderTrancheUserByKey 

func (k Keeper) RemoveLimitOrderTrancheUserByKey(
	ctx sdk.Context,
	trancheKey string,
	address string,
)

RemoveLimitOrderTrancheUserByKey removes a LimitOrderTrancheUser from the store

func (Keeper) RemovePoolMetadata 

func (k Keeper) RemovePoolMetadata(ctx sdk.Context, id uint64)

RemovePoolMetadata removes a poolMetadata from the store

func (Keeper) RemovePoolReserves 

func (k Keeper) RemovePoolReserves(ctx sdk.Context, poolReservesID *types.PoolReservesKey)

RemoveTickLiquidity removes a tickLiquidity from the store

func (Keeper) RunMultihopRoute 

func (k Keeper) RunMultihopRoute(
	ctx sdk.Context,
	route types.MultiHopRoute,
	initialInCoin sdk.Coin,
	exitLimitPrice math_utils.PrecDec,
	stepCache map[multihopCacheKey]StepResult,
) (sdk.Coin, func(), error)

func (Keeper) SaveInactiveTranche 

func (k Keeper) SaveInactiveTranche(sdkCtx sdk.Context, tranche *types.LimitOrderTranche)

func (Keeper) SaveLiquidity 

func (k Keeper) SaveLiquidity(sdkCtx sdk.Context, liquidityI types.Liquidity)

func (Keeper) SaveTranche 

func (k Keeper) SaveTranche(ctx sdk.Context, tranche *types.LimitOrderTranche)

func (Keeper) SaveTrancheUser 

func (k Keeper) SaveTrancheUser(ctx sdk.Context, trancheUser *types.LimitOrderTrancheUser)

func (Keeper) SetInactiveLimitOrderTranche 

func (k Keeper) SetInactiveLimitOrderTranche(ctx sdk.Context, limitOrderTranche *types.LimitOrderTranche)

SetInactiveLimitOrderTranche set a specific inactiveLimitOrderTranche in the store from its index

func (Keeper) SetLimitOrderExpiration 

func (k Keeper) SetLimitOrderExpiration(
	ctx sdk.Context,
	goodTilRecord *types.LimitOrderExpiration,
)

SetLimitOrderExpiration set a specific goodTilRecord in the store from its index

func (Keeper) SetLimitOrderTranche 

func (k Keeper) SetLimitOrderTranche(ctx sdk.Context, tranche *types.LimitOrderTranche)

func (Keeper) SetLimitOrderTrancheUser 

func (k Keeper) SetLimitOrderTrancheUser(ctx sdk.Context, limitOrderTrancheUser *types.LimitOrderTrancheUser)

SetLimitOrderTrancheUser set a specific LimitOrderTrancheUser in the store from its index

func (Keeper) SetParams 

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

SetParams set the params

func (Keeper) SetPool 

func (k Keeper) SetPool(ctx sdk.Context, pool *types.Pool)

func (Keeper) SetPoolCount 

func (k Keeper) SetPoolCount(ctx sdk.Context, count uint64)

SetPoolCount set the total number of pools

func (Keeper) SetPoolMetadata 

func (k Keeper) SetPoolMetadata(ctx sdk.Context, poolMetadata types.PoolMetadata)

SetPoolMetadata set a specific poolMetadata in the store

func (Keeper) SetPoolReserves 

func (k Keeper) SetPoolReserves(ctx sdk.Context, poolReserves *types.PoolReserves)

func (Keeper) Swap 

func (k Keeper) Swap(
	ctx sdk.Context,
	tradePairID *types.TradePairID,
	maxAmountTakerDenom sdk.Int,
	maxAmountMakerDenom *sdk.Int,
	limitPrice *math_utils.PrecDec,
) (totalTakerCoin, totalMakerCoin sdk.Coin, orderFilled bool, err error)

func (Keeper) SwapExactAmountIn 

func (k Keeper) SwapExactAmountIn(ctx sdk.Context,
	tradePairID *types.TradePairID,
	amountIn sdk.Int,
) (totalOut sdk.Coin, err error)

func (Keeper) SwapWithCache 

func (k Keeper) SwapWithCache(
	ctx sdk.Context,
	tradePairID *types.TradePairID,
	maxAmountIn sdk.Int,
	maxAmountOut *sdk.Int,
	limitPrice *math_utils.PrecDec,
) (totalIn, totalOut sdk.Coin, orderFilled bool, err error)

func (Keeper) TickLiquidityAll 

func (k Keeper) TickLiquidityAll(
	c context.Context,
	req *types.QueryAllTickLiquidityRequest,
) (*types.QueryAllTickLiquidityResponse, error)

func (Keeper) UserDepositsAll 

func (k Keeper) UserDepositsAll(
	goCtx context.Context,
	req *types.QueryAllUserDepositsRequest,
) (*types.QueryAllUserDepositsResponse, error)

func (Keeper) ValidateFee 

func (k Keeper) ValidateFee(ctx sdk.Context, fee uint64) error

func (Keeper) WithdrawCore 

func (k Keeper) WithdrawCore(
	goCtx context.Context,
	pairID *types.PairID,
	callerAddr sdk.AccAddress,
	receiverAddr sdk.AccAddress,
	sharesToRemoveList []sdk.Int,
	tickIndicesNormalized []int64,
	fees []uint64,
) error

Handles core logic for MsgDexWithdrawal; calculating and withdrawing reserve0,reserve1 from a specified tick given a specfied number of shares to remove. Calculates the amount of reserve0, reserve1 to withdraw based on the percentage of the desired number of shares to remove compared to the total number of shares at the given tick.

func (Keeper) WithdrawFilledLimitOrder 

func (k Keeper) WithdrawFilledLimitOrder(
	goCtx context.Context,
	msg *types.MsgWithdrawFilledLimitOrder,
) (*types.MsgWithdrawFilledLimitOrderResponse, error)

func (Keeper) WithdrawFilledLimitOrderCore 

func (k Keeper) WithdrawFilledLimitOrderCore(
	goCtx context.Context,
	trancheKey string,
	callerAddr sdk.AccAddress,
) error

Handles MsgWithdrawFilledLimitOrder, calculates and sends filled liqudity from module to user for a limit order based on amount wished to receive.

type LiquidityIterator 

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

func (*LiquidityIterator) Close 

func (s *LiquidityIterator) Close()

func (*LiquidityIterator) Next 

func (s *LiquidityIterator) Next() types.Liquidity

func (*LiquidityIterator) WrapTickLiquidity 

func (s *LiquidityIterator) WrapTickLiquidity(tick types.TickLiquidity) types.Liquidity

type MultihopStep 

type MultihopStep struct {
	RemainingBestPrice math_utils.PrecDec
	// contains filtered or unexported fields
}

type StepResult 

type StepResult struct {
	Ctx     *types.BranchableCache
	CoinOut sdk.Coin
	Err     error
}

type TickIterator 

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

func (TickIterator) Close 

func (ti TickIterator) Close() error

func (TickIterator) Next 

func (ti TickIterator) Next()

func (TickIterator) Valid 

func (ti TickIterator) Valid() bool

func (TickIterator) Value 

func (ti TickIterator) Value() (tick types.TickLiquidity)

Source Files

View all Source files

Directories

Path Synopsis
internal
testutils

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.