Documentation ¶
Index ¶
- func NewMsgServerImpl(keeper Keeper) types.MsgServer
- func NewQuerier(keeper Keeper, legacyQuerierCdc *codec.LegacyAmino) sdk.Querier
- func NewQueryServerImpl(k Keeper) types.QueryServer
- type Keeper
- func (k Keeper) ClaimAtomicSwap(ctx sdk.Context, from sdk.AccAddress, swapID []byte, randomNumber []byte) error
- func (k Keeper) CreateAtomicSwap(ctx sdk.Context, randomNumberHash []byte, timestamp int64, heightSpan uint64, ...) error
- func (k Keeper) CreateNewAssetSupply(ctx sdk.Context, denom string) types.AssetSupply
- func (k Keeper) DecrementCurrentAssetSupply(ctx sdk.Context, coin sdk.Coin) error
- func (k Keeper) DecrementIncomingAssetSupply(ctx sdk.Context, coin sdk.Coin) error
- func (k Keeper) DecrementOutgoingAssetSupply(ctx sdk.Context, coin sdk.Coin) error
- func (k Keeper) DeleteClosedAtomicSwapsFromLongtermStorage(ctx sdk.Context)
- func (k Keeper) GetAllAssetSupplies(ctx sdk.Context) (supplies types.AssetSupplies)
- func (k Keeper) GetAllAtomicSwaps(ctx sdk.Context) (atomicSwaps types.AtomicSwaps)
- func (k Keeper) GetAsset(ctx sdk.Context, denom string) (types.AssetParam, error)
- func (k Keeper) GetAssetByCoinID(ctx sdk.Context, coinID int64) (types.AssetParam, bool)
- func (k Keeper) GetAssetSupply(ctx sdk.Context, denom string) (types.AssetSupply, bool)
- func (k Keeper) GetAssets(ctx sdk.Context) (types.AssetParams, bool)
- func (k Keeper) GetAtomicSwap(ctx sdk.Context, swapID []byte) (types.AtomicSwap, bool)
- func (k Keeper) GetAuthorizedAddresses(ctx sdk.Context) []sdk.AccAddress
- func (k Keeper) GetDeputyAddress(ctx sdk.Context, denom string) (sdk.AccAddress, error)
- func (k Keeper) GetFixedFee(ctx sdk.Context, denom string) (sdkmath.Int, error)
- func (k Keeper) GetMaxBlockLock(ctx sdk.Context, denom string) (uint64, error)
- func (k Keeper) GetMaxSwapAmount(ctx sdk.Context, denom string) (sdkmath.Int, error)
- func (k Keeper) GetMinBlockLock(ctx sdk.Context, denom string) (uint64, error)
- func (k Keeper) GetMinSwapAmount(ctx sdk.Context, denom string) (sdkmath.Int, error)
- func (k Keeper) GetParams(ctx sdk.Context) (params types.Params)
- func (k Keeper) GetPreviousBlockTime(ctx sdk.Context) (blockTime time.Time, found bool)
- func (k Keeper) GetSupplyLimit(ctx sdk.Context, denom string) (types.SupplyLimit, error)
- func (k Keeper) IncrementCurrentAssetSupply(ctx sdk.Context, coin sdk.Coin) error
- func (k Keeper) IncrementIncomingAssetSupply(ctx sdk.Context, coin sdk.Coin) error
- func (k Keeper) IncrementOutgoingAssetSupply(ctx sdk.Context, coin sdk.Coin) error
- func (k Keeper) InsertIntoByBlockIndex(ctx sdk.Context, atomicSwap types.AtomicSwap)
- func (k Keeper) InsertIntoLongtermStorage(ctx sdk.Context, atomicSwap types.AtomicSwap)
- func (k Keeper) IterateAssetSupplies(ctx sdk.Context, cb func(supply types.AssetSupply) (stop bool))
- func (k Keeper) IterateAtomicSwaps(ctx sdk.Context, cb func(atomicSwap types.AtomicSwap) (stop bool))
- func (k Keeper) IterateAtomicSwapsByBlock(ctx sdk.Context, inclusiveCutoffTime uint64, ...)
- func (k Keeper) IterateAtomicSwapsLongtermStorage(ctx sdk.Context, inclusiveCutoffTime uint64, ...)
- func (k Keeper) Logger(ctx sdk.Context) log.Logger
- func (k Keeper) RefundAtomicSwap(ctx sdk.Context, from sdk.AccAddress, swapID []byte) error
- func (k Keeper) RemoveAtomicSwap(ctx sdk.Context, swapID []byte)
- func (k Keeper) RemoveFromByBlockIndex(ctx sdk.Context, atomicSwap types.AtomicSwap)
- func (k Keeper) RemoveFromLongtermStorage(ctx sdk.Context, atomicSwap types.AtomicSwap)
- func (k Keeper) SetAsset(ctx sdk.Context, asset types.AssetParam)
- func (k Keeper) SetAssetSupply(ctx sdk.Context, supply types.AssetSupply, denom string)
- func (k Keeper) SetAtomicSwap(ctx sdk.Context, atomicSwap types.AtomicSwap)
- func (k Keeper) SetParams(ctx sdk.Context, params types.Params)
- func (k Keeper) SetPreviousBlockTime(ctx sdk.Context, blockTime time.Time)
- func (k Keeper) UpdateExpiredAtomicSwaps(ctx sdk.Context)
- func (k Keeper) UpdateTimeBasedSupplyLimits(ctx sdk.Context)
- func (k Keeper) ValidateLiveAsset(ctx sdk.Context, coin sdk.Coin) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMsgServerImpl ¶ added in v0.16.0
NewMsgServerImpl returns an implementation of the bep3 MsgServer interface for the provided Keeper.
func NewQuerier ¶
func NewQuerier(keeper Keeper, legacyQuerierCdc *codec.LegacyAmino) sdk.Querier
NewQuerier is the module level router for state queries
func NewQueryServerImpl ¶ added in v0.16.0
func NewQueryServerImpl(k Keeper) types.QueryServer
NewQueryServerImpl creates a new server for handling gRPC queries.
Types ¶
type Keeper ¶
Keeper of the bep3 store
func NewKeeper ¶
func NewKeeper(cdc codec.Codec, key storetypes.StoreKey, sk types.BankKeeper, ak types.AccountKeeper, paramstore paramtypes.Subspace, maccs map[string]bool, ) Keeper
NewKeeper creates a bep3 keeper
func (Keeper) ClaimAtomicSwap ¶
func (k Keeper) ClaimAtomicSwap(ctx sdk.Context, from sdk.AccAddress, swapID []byte, randomNumber []byte) error
ClaimAtomicSwap validates a claim attempt, and if successful, sends the escrowed amount and closes the AtomicSwap.
func (Keeper) CreateAtomicSwap ¶
func (k Keeper) CreateAtomicSwap(ctx sdk.Context, randomNumberHash []byte, timestamp int64, heightSpan uint64, sender, recipient sdk.AccAddress, senderOtherChain, recipientOtherChain string, amount sdk.Coins, crossChain bool, ) error
CreateAtomicSwap creates a new atomic swap.
func (Keeper) CreateNewAssetSupply ¶ added in v0.11.0
CreateNewAssetSupply creates a new AssetSupply in the store for the input denom
func (Keeper) DecrementCurrentAssetSupply ¶
DecrementCurrentAssetSupply decrement an asset's supply by the coin
func (Keeper) DecrementIncomingAssetSupply ¶
DecrementIncomingAssetSupply decrements an asset's incoming supply
func (Keeper) DecrementOutgoingAssetSupply ¶
DecrementOutgoingAssetSupply decrements an asset's outgoing supply
func (Keeper) DeleteClosedAtomicSwapsFromLongtermStorage ¶
DeleteClosedAtomicSwapsFromLongtermStorage removes swaps one week after completion.
func (Keeper) GetAllAssetSupplies ¶
func (k Keeper) GetAllAssetSupplies(ctx sdk.Context) (supplies types.AssetSupplies)
GetAllAssetSupplies returns all asset supplies from the store
func (Keeper) GetAllAtomicSwaps ¶
func (k Keeper) GetAllAtomicSwaps(ctx sdk.Context) (atomicSwaps types.AtomicSwaps)
GetAllAtomicSwaps returns all AtomicSwaps from the store
func (Keeper) GetAsset ¶ added in v0.11.0
GetAsset returns the asset param associated with the input denom
func (Keeper) GetAssetByCoinID ¶
GetAssetByCoinID returns an asset by its denom
func (Keeper) GetAssetSupply ¶
GetAssetSupply gets an asset's current supply from the store.
func (Keeper) GetAtomicSwap ¶
GetAtomicSwap gets an AtomicSwap from the store.
func (Keeper) GetAuthorizedAddresses ¶ added in v0.12.1
func (k Keeper) GetAuthorizedAddresses(ctx sdk.Context) []sdk.AccAddress
GetAuthorizedAddresses returns a list of addresses that have special authorization within this module, eg all the deputies.
func (Keeper) GetDeputyAddress ¶ added in v0.11.0
GetDeputyAddress returns the deputy address for the input denom
func (Keeper) GetFixedFee ¶ added in v0.11.0
GetFixedFee returns the fixed fee for incoming swaps
func (Keeper) GetMaxBlockLock ¶
GetMaxBlockLock returns the maximum block lock
func (Keeper) GetMaxSwapAmount ¶ added in v0.11.0
GetMaxSwapAmount returns the maximum swap amount
func (Keeper) GetMinBlockLock ¶
GetMinBlockLock returns the minimum block lock
func (Keeper) GetMinSwapAmount ¶ added in v0.11.0
GetMinSwapAmount returns the minimum swap amount
func (Keeper) GetPreviousBlockTime ¶ added in v0.11.0
GetPreviousBlockTime get the blocktime for the previous block
func (Keeper) GetSupplyLimit ¶ added in v0.11.0
GetSupplyLimit returns the supply limit for the input denom
func (Keeper) IncrementCurrentAssetSupply ¶
IncrementCurrentAssetSupply increments an asset's supply by the coin
func (Keeper) IncrementIncomingAssetSupply ¶
IncrementIncomingAssetSupply increments an asset's incoming supply
func (Keeper) IncrementOutgoingAssetSupply ¶
IncrementOutgoingAssetSupply increments an asset's outgoing supply
func (Keeper) InsertIntoByBlockIndex ¶
func (k Keeper) InsertIntoByBlockIndex(ctx sdk.Context, atomicSwap types.AtomicSwap)
InsertIntoByBlockIndex adds a swap ID and expiration time into the byBlock index.
func (Keeper) InsertIntoLongtermStorage ¶
func (k Keeper) InsertIntoLongtermStorage(ctx sdk.Context, atomicSwap types.AtomicSwap)
InsertIntoLongtermStorage adds a swap ID and deletion time into the longterm storage index. Completed swaps are stored for 1 week.
func (Keeper) IterateAssetSupplies ¶
func (k Keeper) IterateAssetSupplies(ctx sdk.Context, cb func(supply types.AssetSupply) (stop bool))
IterateAssetSupplies provides an iterator over all stored AssetSupplies.
func (Keeper) IterateAtomicSwaps ¶
func (k Keeper) IterateAtomicSwaps(ctx sdk.Context, cb func(atomicSwap types.AtomicSwap) (stop bool))
IterateAtomicSwaps provides an iterator over all stored AtomicSwaps. For each AtomicSwap, cb will be called. If cb returns true, the iterator will close and stop.
func (Keeper) IterateAtomicSwapsByBlock ¶
func (k Keeper) IterateAtomicSwapsByBlock(ctx sdk.Context, inclusiveCutoffTime uint64, cb func(swapID []byte) (stop bool))
IterateAtomicSwapsByBlock provides an iterator over AtomicSwaps ordered by AtomicSwap expiration block For each AtomicSwap cb will be called. If cb returns true the iterator will close and stop.
func (Keeper) IterateAtomicSwapsLongtermStorage ¶
func (k Keeper) IterateAtomicSwapsLongtermStorage(ctx sdk.Context, inclusiveCutoffTime uint64, cb func(swapID []byte) (stop bool), )
IterateAtomicSwapsLongtermStorage provides an iterator over AtomicSwaps ordered by deletion height. For each AtomicSwap cb will be called. If cb returns true the iterator will close and stop.
func (Keeper) RefundAtomicSwap ¶
RefundAtomicSwap refunds an AtomicSwap, sending assets to the original sender and closing the AtomicSwap.
func (Keeper) RemoveAtomicSwap ¶
RemoveAtomicSwap removes an AtomicSwap from the AtomicSwapKeyPrefix.
func (Keeper) RemoveFromByBlockIndex ¶
func (k Keeper) RemoveFromByBlockIndex(ctx sdk.Context, atomicSwap types.AtomicSwap)
RemoveFromByBlockIndex removes an AtomicSwap from the byBlock index.
func (Keeper) RemoveFromLongtermStorage ¶
func (k Keeper) RemoveFromLongtermStorage(ctx sdk.Context, atomicSwap types.AtomicSwap)
RemoveFromLongtermStorage removes a swap from the into the longterm storage index
func (Keeper) SetAsset ¶ added in v0.11.0
func (k Keeper) SetAsset(ctx sdk.Context, asset types.AssetParam)
SetAsset sets an asset in the params
func (Keeper) SetAssetSupply ¶
SetAssetSupply updates an asset's supply
func (Keeper) SetAtomicSwap ¶
func (k Keeper) SetAtomicSwap(ctx sdk.Context, atomicSwap types.AtomicSwap)
SetAtomicSwap puts the AtomicSwap into the store, and updates any indexes.
func (Keeper) SetPreviousBlockTime ¶ added in v0.11.0
SetPreviousBlockTime set the time of the previous block
func (Keeper) UpdateExpiredAtomicSwaps ¶
UpdateExpiredAtomicSwaps finds all AtomicSwaps that are past (or at) their ending times and expires them.
func (Keeper) UpdateTimeBasedSupplyLimits ¶ added in v0.11.0
UpdateTimeBasedSupplyLimits updates the time based supply for each asset, resetting it if the current time window has elapsed.