keeperv1

package
v1.105.1 Latest Latest
Warning

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

 Go to latest Published: Jul 25, 2023 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ModuleName  = types.ModuleName
	ReserveName = types.ReserveName
	AsgardName  = types.AsgardName
	BondName    = types.BondName
	StoreKey    = types.StoreKey
	MayaFund    = types.MayaFund

	// Vaults
	AsgardVault    = types.VaultType_AsgardVault
	YggdrasilVault = types.VaultType_YggdrasilVault
	ActiveVault    = types.VaultStatus_ActiveVault
	InitVault      = types.VaultStatus_InitVault
	RetiringVault  = types.VaultStatus_RetiringVault
	InactiveVault  = types.VaultStatus_InactiveVault

	// Node status
	NodeActive  = types.NodeStatus_Active
	NodeStandby = types.NodeStatus_Standby
	NodeUnknown = types.NodeStatus_Unknown

	// Node type
	NodeTypeUnknown   = types.NodeType_TypeUnknown
	NodeTypeValidator = types.NodeType_TypeValidator
	NodeTypeVault     = types.NodeType_TypeVault

	// Bond type
	AsgardKeygen = types.KeygenType_AsgardKeygen

	// Pool Status
	PoolAvailable = types.PoolStatus_Available
	PoolStaged    = types.PoolStatus_Staged
	PoolSuspended = types.PoolStatus_Suspended
	AllPoolStatus = PoolAvailable & PoolStaged & PoolSuspended
)
View Source 
const DefaultTier = int64(0)
View Source 
const KRAKEN string = "ReleaseTheKraken"

Variables

View Source 
var (
	NewPool                    = types.NewPool
	NewJail                    = types.NewJail
	NewNetwork                 = types.NewNetwork
	NewProtocolOwnedLiquidity  = types.NewProtocolOwnedLiquidity
	NewObservedTx              = types.NewObservedTx
	NewTssVoter                = types.NewTssVoter
	NewBanVoter                = types.NewBanVoter
	NewForgiveSlashVoter       = types.NewForgiveSlashVoter
	NewErrataTxVoter           = types.NewErrataTxVoter
	NewObservedTxVoter         = types.NewObservedTxVoter
	NewKeygen                  = types.NewKeygen
	NewKeygenBlock             = types.NewKeygenBlock
	NewTxOut                   = types.NewTxOut
	HasSuperMajority           = types.HasSuperMajority
	RegisterCodec              = types.RegisterCodec
	NewNodeAccount             = types.NewNodeAccount
	NewBondProviders           = types.NewBondProviders
	NewBondProvider            = types.NewBondProvider
	NewVault                   = types.NewVault
	NewReserveContributor      = types.NewReserveContributor
	NewMAYAName                = types.NewMAYAName
	GetRandomTx                = types.GetRandomTx
	GetRandomValidatorNode     = types.GetRandomValidatorNode
	GetRandomVaultNode         = types.GetRandomVaultNode
	GetRandomBNBAddress        = types.GetRandomBNBAddress
	GetRandomBTCAddress        = types.GetRandomBTCAddress
	GetRandomBCHAddress        = types.GetRandomBCHAddress
	GetRandomBaseAddress       = types.GetRandomBaseAddress
	GetRandomTxHash            = types.GetRandomTxHash
	GetRandomBech32Addr        = types.GetRandomBech32Addr
	GetRandomPubKey            = types.GetRandomPubKey
	GetRandomPubKeySet         = types.GetRandomPubKeySet
	GetCurrentVersion          = types.GetCurrentVersion
	NewObservedNetworkFeeVoter = types.NewObservedNetworkFeeVoter
	NewNetworkFee              = types.NewNetworkFee
	NewTssKeysignFailVoter     = types.NewTssKeysignFailVoter
	SetupConfigForTest         = types.SetupConfigForTest
	NewChainContract           = types.NewChainContract
	GetLiquidityPools          = types.GetLiquidityPools
)

Functions

This section is empty.

Types

type BanVoter 

type BanVoter = types.BanVoter

type BondProvider 

type BondProvider = types.BondProvider

type BondProviders 

type BondProviders = types.BondProviders

type ChainContract 

type ChainContract = types.ChainContract

type ErrataTxVoter 

type ErrataTxVoter = types.ErrataTxVoter

type ForgiveSlashVoter 

type ForgiveSlashVoter = types.ForgiveSlashVoter

type Jail 

type Jail = types.Jail

type KVStore 

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

KVStore Keeper maintains the link to data storage and exposes getter/setter methods for the various parts of the state machine

func NewKVStore 

func NewKVStore(cdc codec.BinaryCodec, coinKeeper bankkeeper.Keeper, accountKeeper authkeeper.AccountKeeper, ibcTransferkeeper ibctransferkeeper.Keeper, storeKey cosmos.StoreKey, version semver.Version) KVStore

NewKVStore creates new instances of the thorchain Keeper

func (KVStore) AddBondFeeToReserve 

func (k KVStore) AddBondFeeToReserve(ctx cosmos.Context, fee cosmos.Uint) error

AddBondFeeToReserve add fee to reserve, the fee is always in RUNE

func (KVStore) AddCoins 

func (k KVStore) AddCoins(ctx cosmos.Context, addr cosmos.AccAddress, coins cosmos.Coins) error

func (KVStore) AddObservingAddresses 

func (k KVStore) AddObservingAddresses(ctx cosmos.Context, inAddresses []cosmos.AccAddress) error

AddObservingAddresses - add a list of addresses that have been helpful in getting enough observations to process an inbound tx.

func (KVStore) AddPoolFeeToReserve 

func (k KVStore) AddPoolFeeToReserve(ctx cosmos.Context, fee cosmos.Uint) error

AddPoolFeeToReserve add fee to reserve, the fee is always in RUNE

func (KVStore) AddToLiquidityFees 

func (k KVStore) AddToLiquidityFees(ctx cosmos.Context, asset common.Asset, fee cosmos.Uint) error

AddToLiquidityFees - measure of fees collected in each block

func (KVStore) AppendTxOut 

func (k KVStore) AppendTxOut(ctx cosmos.Context, height int64, item TxOutItem) error

AppendTxOut - append the given item to txOut

func (KVStore) BurnFromModule 

func (k KVStore) BurnFromModule(ctx cosmos.Context, module string, coin common.Coin) error

func (KVStore) CalcLPLiquidityBond 

func (k KVStore) CalcLPLiquidityBond(ctx cosmos.Context, bondAddr common.Address, nodeAddr cosmos.AccAddress) (cosmos.Uint, error)

func (KVStore) CalcNodeLiquidityBond 

func (k KVStore) CalcNodeLiquidityBond(ctx cosmos.Context, na NodeAccount) (cosmos.Uint, error)

CalcNodeLiquidityBond takes the liquidity provided by every bp of a NodeAccount and calculates its rune side value based on LP Units

func (KVStore) CalcTotalBondableLiquidity added in v1.104.1 

func (k KVStore) CalcTotalBondableLiquidity(ctx cosmos.Context, addr common.Address) (cosmos.Uint, error)

CalcTotalBondableLiquidity returns the total liquidity of the LP in rune that is bonded or can be bonded to nodes.

func (KVStore) Cdc 

func (k KVStore) Cdc() codec.BinaryCodec

Cdc return the amino codec

func (KVStore) ClearObservingAddresses 

func (k KVStore) ClearObservingAddresses(ctx cosmos.Context)

ClearObservingAddresses - clear all observing addresses

func (KVStore) ClearTxOut 

func (k KVStore) ClearTxOut(ctx cosmos.Context, height int64) error

ClearTxOut - remove the txout of the given height from key value store

func (KVStore) DecNodeAccountSlashPoints 

func (k KVStore) DecNodeAccountSlashPoints(ctx cosmos.Context, addr cosmos.AccAddress, pts int64) error

DecNodeAccountSlashPoints - decrements the slash points associated with the given node address and uint

func (KVStore) DeleteForgiveSlashVoter 

func (k KVStore) DeleteForgiveSlashVoter(ctx cosmos.Context, addr cosmos.AccAddress) error

DeleteSlashVoter - deletes a foriveSlash voter object

func (KVStore) DeleteMAYAName 

func (k KVStore) DeleteMAYAName(ctx cosmos.Context, name string) error

DeleteMAYAName remove the given MAYAName from data store

func (KVStore) DeleteMimir 

func (k KVStore) DeleteMimir(ctx cosmos.Context, key string) error

func (KVStore) DeleteVault 

func (k KVStore) DeleteVault(ctx cosmos.Context, pubkey common.PubKey) error

DeleteVault remove the given vault from data store

func (KVStore) DistributeMayaFund 

func (k KVStore) DistributeMayaFund(ctx cosmos.Context, constAccessor constants.ConstantValues)

Distribute the tokens that are in the MayaFund in MinRuneForMayaFundDist multiples, the rest should stay on the MayaFund and should be distributed until it reaches another multiple. Loss of precision in token.Amount is desired and expected.

func (KVStore) DynamicInflation 

func (k KVStore) DynamicInflation(ctx cosmos.Context, constAccessor constants.ConstantValues) error

This function will mint some percentage of the inflation and distribute it to the pools and system income in case a threshold is not reach.

func (KVStore) EnsureAztecAddressUnique 

func (k KVStore) EnsureAztecAddressUnique(ctx cosmos.Context, aztecAddress common.Address) error

EnsureAztecAddressUnique check the given aztec bech32 address set against all the the node account return an error when it is overlap with any existing one

func (KVStore) EnsureNodeKeysUnique 

func (k KVStore) EnsureNodeKeysUnique(ctx cosmos.Context, consensusPubKey string, pubKeys common.PubKeySet) error

EnsureNodeKeysUnique check the given consensus pubkey and pubkey set against all the the node account return an error when it is overlap with any existing account

func (KVStore) GetAccount 

func (k KVStore) GetAccount(ctx cosmos.Context, addr cosmos.AccAddress) cosmos.Account

func (KVStore) GetAsgardVaults 

func (k KVStore) GetAsgardVaults(ctx cosmos.Context) (Vaults, error)

GetAsgardVaults return all asgard vaults

func (KVStore) GetAsgardVaultsByStatus 

func (k KVStore) GetAsgardVaultsByStatus(ctx cosmos.Context, status VaultStatus) (Vaults, error)

GetAsgardVaultsByStatus get all the asgard vault that have the given status

func (KVStore) GetBalance 

func (k KVStore) GetBalance(ctx cosmos.Context, addr cosmos.AccAddress) cosmos.Coins

func (KVStore) GetBalanceOfModule 

func (k KVStore) GetBalanceOfModule(ctx cosmos.Context, moduleName, denom string) cosmos.Uint

func (KVStore) GetBanVoter 

func (k KVStore) GetBanVoter(ctx cosmos.Context, addr cosmos.AccAddress) (BanVoter, error)

GetBanVoter - gets information of ban voter

func (KVStore) GetBanVoterIterator 

func (k KVStore) GetBanVoterIterator(ctx cosmos.Context) cosmos.Iterator

GetBanVoterIterator - get an iterator for ban voter

func (KVStore) GetBondProviders 

func (k KVStore) GetBondProviders(ctx cosmos.Context, addr cosmos.AccAddress) (BondProviders, error)

GetBondProviders - gets bond providers for a node account

func (KVStore) GetCacaoOnPools 

func (k KVStore) GetCacaoOnPools(ctx cosmos.Context, poolStatus types.PoolStatus) (sdk.Uint, error)

func (KVStore) GetChainContract 

func (k KVStore) GetChainContract(ctx cosmos.Context, chain common.Chain) (ChainContract, error)

GetChainContract - gets chain contract

func (KVStore) GetChainContractIterator 

func (k KVStore) GetChainContractIterator(ctx cosmos.Context) cosmos.Iterator

GetChainContractIterator - get an iterator for chain contract

func (KVStore) GetChainContracts 

func (k KVStore) GetChainContracts(ctx cosmos.Context, chains common.Chains) []ChainContract

GetChainContracts return a list of chain contracts , which match the requested chains

func (KVStore) GetConstants 

func (k KVStore) GetConstants() constants.ConstantValues

func (KVStore) GetErrataTxVoter 

func (k KVStore) GetErrataTxVoter(ctx cosmos.Context, txID common.TxID, chain common.Chain) (ErrataTxVoter, error)

GetErrataTxVoter - gets information of errata tx voter

func (KVStore) GetErrataTxVoterIterator 

func (k KVStore) GetErrataTxVoterIterator(ctx cosmos.Context) cosmos.Iterator

GetErrataTxVoterIterator iterate errata tx voter

func (KVStore) GetForgiveSlashVoter 

func (k KVStore) GetForgiveSlashVoter(ctx cosmos.Context, addr cosmos.AccAddress) (ForgiveSlashVoter, error)

GetForgiveSlashVoter - gets information of forgiveSlash voter

func (KVStore) GetForgiveSlashVoterIterator 

func (k KVStore) GetForgiveSlashVoterIterator(ctx cosmos.Context) cosmos.Iterator

GetForgiveSlashVoterIterator - get an iterator for forgiveSlash voter

func (KVStore) GetIBCTransferParams 

func (k KVStore) GetIBCTransferParams(ctx cosmos.Context) ibctransfertypes.Params

func (KVStore) GetKey 

func (k KVStore) GetKey(ctx cosmos.Context, prefix kvTypes.DbPrefix, key string) string

GetKey return a key that can be used to store into key value store

func (KVStore) GetKeygenBlock 

func (k KVStore) GetKeygenBlock(ctx cosmos.Context, height int64) (KeygenBlock, error)

GetKeygenBlock from a given height

func (KVStore) GetKeygenBlockIterator 

func (k KVStore) GetKeygenBlockIterator(ctx cosmos.Context) cosmos.Iterator

GetKeygenBlockIterator return an iterator

func (KVStore) GetLastChainHeight 

func (k KVStore) GetLastChainHeight(ctx cosmos.Context, chain common.Chain) (int64, error)

GetLastChainHeight get last chain height

func (KVStore) GetLastChainHeights 

func (k KVStore) GetLastChainHeights(ctx cosmos.Context) (map[common.Chain]int64, error)

GetLastChainHeights get the iterator for last chain height

func (KVStore) GetLastObserveHeight 

func (k KVStore) GetLastObserveHeight(ctx cosmos.Context, address cosmos.AccAddress) (map[common.Chain]int64, error)

GetLastObserveHeight retrieve last observe height of a given node account from key value store

func (KVStore) GetLastSignedHeight 

func (k KVStore) GetLastSignedHeight(ctx cosmos.Context) (int64, error)

GetLastSignedHeight get last signed height from key value store

func (KVStore) GetLatestTssKeysignMetric 

func (k KVStore) GetLatestTssKeysignMetric(ctx cosmos.Context) (*TssKeysignMetric, error)

GetLatestTssKeysignMetric return the latest tss keysign metric

func (KVStore) GetLeastSecure 

func (k KVStore) GetLeastSecure(ctx cosmos.Context, vaults Vaults, signingTransPeriod int64) Vault

GetLeastSecure with given list of vaults, find the vault that is least secure

func (KVStore) GetLiquidityAuctionTier 

func (k KVStore) GetLiquidityAuctionTier(ctx cosmos.Context, addr common.Address) (int64, error)

GetLiquidityAuctionTier retrieve liquidity auction tier from the data store if liquidity auction tier doesn't exist, return const LATier_Dont_Exist

func (KVStore) GetLiquidityProvider 

func (k KVStore) GetLiquidityProvider(ctx cosmos.Context, asset common.Asset, addr common.Address) (LiquidityProvider, error)

GetLiquidityProvider retrieve liquidity provider from the data store

func (KVStore) GetLiquidityProviderByAssets 

func (k KVStore) GetLiquidityProviderByAssets(ctx cosmos.Context, assets common.Assets, addr common.Address) (LiquidityProviders, error)

GetLiquidityProviderByAssets returns an LP in the provided assets

func (KVStore) GetLiquidityProviderIterator 

func (k KVStore) GetLiquidityProviderIterator(ctx cosmos.Context, asset common.Asset) cosmos.Iterator

GetLiquidityProviderIterator iterate liquidity providers

func (KVStore) GetLowestActiveVersion 

func (k KVStore) GetLowestActiveVersion(ctx cosmos.Context) semver.Version

GetLowestActiveVersion - get version number of lowest active node

func (KVStore) GetMAYAName 

func (k KVStore) GetMAYAName(ctx cosmos.Context, name string) (MAYAName, error)

GetMAYAName get MAYAName with the given pubkey from data store

func (KVStore) GetMAYANameIterator 

func (k KVStore) GetMAYANameIterator(ctx cosmos.Context) cosmos.Iterator

GetMAYANameIterator only iterate MAYANames

func (KVStore) GetMimir 

func (k KVStore) GetMimir(ctx cosmos.Context, key string) (int64, error)

GetMimir get a mimir value from key value store

func (KVStore) GetMimirIterator 

func (k KVStore) GetMimirIterator(ctx cosmos.Context) cosmos.Iterator

GetMimirIterator iterate gas units

func (KVStore) GetMinJoinVersion 

func (k KVStore) GetMinJoinVersion(ctx cosmos.Context) semver.Version

GetMinJoinVersion - get min version to join. Min version is the most popular version

func (KVStore) GetModuleAccAddress 

func (k KVStore) GetModuleAccAddress(module string) cosmos.AccAddress

func (KVStore) GetModuleAddress 

func (k KVStore) GetModuleAddress(module string) (common.Address, error)

func (KVStore) GetMostSecure 

func (k KVStore) GetMostSecure(ctx cosmos.Context, vaults Vaults, signingTransPeriod int64) Vault

GetMostSecure with given list of vaults, find the vault that is most secure

func (KVStore) GetNetwork 

func (k KVStore) GetNetwork(ctx cosmos.Context) (Network, error)

GetNetwork retrieve network data from key value store

func (KVStore) GetNetworkFee 

func (k KVStore) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (NetworkFee, error)

GetNetworkFee get the network fee of the given chain from kv store , if it doesn't exist , it will create an empty one

func (KVStore) GetNetworkFeeIterator 

func (k KVStore) GetNetworkFeeIterator(ctx cosmos.Context) cosmos.Iterator

GetNetworkFeeIterator

func (KVStore) GetNodeAccount 

func (k KVStore) GetNodeAccount(ctx cosmos.Context, addr cosmos.AccAddress) (NodeAccount, error)

GetNodeAccount try to get node account with the given address from db

func (KVStore) GetNodeAccountByPubKey 

func (k KVStore) GetNodeAccountByPubKey(ctx cosmos.Context, pk common.PubKey) (NodeAccount, error)

GetNodeAccountByPubKey try to get node account with the given pubkey from db

func (KVStore) GetNodeAccountIterator 

func (k KVStore) GetNodeAccountIterator(ctx cosmos.Context) cosmos.Iterator

GetNodeAccountIterator iterate node account

func (KVStore) GetNodeAccountJail 

func (k KVStore) GetNodeAccountJail(ctx cosmos.Context, addr cosmos.AccAddress) (Jail, error)

GetNodeAccountJail - gets jail details for a given node address

func (KVStore) GetNodeAccountSlashPoints 

func (k KVStore) GetNodeAccountSlashPoints(ctx cosmos.Context, addr cosmos.AccAddress) (int64, error)

GetNodeAccountSlashPoints - get the slash points associated with the given node address

func (KVStore) GetNodeMimirIterator 

func (k KVStore) GetNodeMimirIterator(ctx cosmos.Context) cosmos.Iterator

GetNodeMimirIterator iterate gas units

func (KVStore) GetNodeMimirs 

func (k KVStore) GetNodeMimirs(ctx cosmos.Context, key string) (NodeMimirs, error)

GetNodeMimirs get node mimirs value from key value store

func (KVStore) GetNodePauseChain 

func (k KVStore) GetNodePauseChain(ctx cosmos.Context, acc cosmos.AccAddress) int64
func (k KVStore) GetObservedLink(ctx cosmos.Context, inhash common.TxID) []common.TxID

func (KVStore) GetObservedNetworkFeeVoter 

func (k KVStore) GetObservedNetworkFeeVoter(ctx cosmos.Context, height int64, chain common.Chain, rate int64) (ObservedNetworkFeeVoter, error)

GetObservedNetworkFeeVoter - gets information of an observed network fee voter

func (KVStore) GetObservedNetworkFeeVoterIterator 

func (k KVStore) GetObservedNetworkFeeVoterIterator(ctx cosmos.Context) cosmos.Iterator

GetObservedNetworkFeeVoterIterator iterate tx in voters

func (KVStore) GetObservedTxInVoter 

func (k KVStore) GetObservedTxInVoter(ctx cosmos.Context, hash common.TxID) (ObservedTxVoter, error)

GetObservedTxInVoter - gets information of an observed inbound tx based on the txid

func (KVStore) GetObservedTxInVoterIterator 

func (k KVStore) GetObservedTxInVoterIterator(ctx cosmos.Context) cosmos.Iterator

GetObservedTxInVoterIterator iterate tx in voters

func (KVStore) GetObservedTxOutVoter 

func (k KVStore) GetObservedTxOutVoter(ctx cosmos.Context, hash common.TxID) (ObservedTxVoter, error)

GetObservedTxOutVoter - gets information of an observed outbound tx based on the txid

func (KVStore) GetObservedTxOutVoterIterator 

func (k KVStore) GetObservedTxOutVoterIterator(ctx cosmos.Context) cosmos.Iterator

GetObservedTxOutVoterIterator iterate tx out voters

func (KVStore) GetObservingAddresses 

func (k KVStore) GetObservingAddresses(ctx cosmos.Context) ([]cosmos.AccAddress, error)

GetObservingAddresses - get list of observed addresses. This is a list of addresses that have recently contributed via observing a tx that got 2/3rds majority

func (KVStore) GetOrderBookIndex 

func (k KVStore) GetOrderBookIndex(ctx cosmos.Context, msg MsgSwap) (common.TxIDs, error)

GetOrderBookIndex - read the given order book index information from key values tore

func (KVStore) GetOrderBookIndexIterator 

func (k KVStore) GetOrderBookIndexIterator(ctx cosmos.Context, order types.OrderType, source, target common.Asset) cosmos.Iterator

GetOrderBookIterator iterate order book items

func (KVStore) GetOrderBookItem 

func (k KVStore) GetOrderBookItem(ctx cosmos.Context, txID common.TxID) (MsgSwap, error)

GetOrderBookItem - read the given order book item information from key values store

func (KVStore) GetOrderBookItemIterator 

func (k KVStore) GetOrderBookItemIterator(ctx cosmos.Context) cosmos.Iterator

GetOrderBookItemIterator iterate order book items

func (KVStore) GetOrderBookProcessor 

func (k KVStore) GetOrderBookProcessor(ctx cosmos.Context) ([]bool, error)

GetOrderBookProcessor - get a list of asset pairs to process

func (KVStore) GetPOL 

func (k KVStore) GetPOL(ctx cosmos.Context) (ProtocolOwnedLiquidity, error)

GetPOL retrieve network data from key value store

func (KVStore) GetPool 

func (k KVStore) GetPool(ctx cosmos.Context, asset common.Asset) (Pool, error)

GetPool get the entire Pool metadata struct based on given asset

func (KVStore) GetPoolIterator 

func (k KVStore) GetPoolIterator(ctx cosmos.Context) cosmos.Iterator

GetPoolIterator iterate pools

func (KVStore) GetPoolLUVI 

func (k KVStore) GetPoolLUVI(ctx cosmos.Context, asset common.Asset) (cosmos.Uint, error)

func (KVStore) GetPoolLiquidityFees 

func (k KVStore) GetPoolLiquidityFees(ctx cosmos.Context, height uint64, asset common.Asset) (cosmos.Uint, error)

GetPoolLiquidityFees - total of fees collected in each block per pool

func (KVStore) GetPoolRagnarokStart 

func (k KVStore) GetPoolRagnarokStart(ctx cosmos.Context, asset common.Asset) (int64, error)

GetPoolRagnarokStart get pool ragnarok start block height

func (KVStore) GetPools 

func (k KVStore) GetPools(ctx cosmos.Context) (Pools, error)

GetPools return all pool in key value store regardless state

func (KVStore) GetRagnarokBlockHeight 

func (k KVStore) GetRagnarokBlockHeight(ctx cosmos.Context) (int64, error)

GetRagnarokBlockHeight get ragnarok block height from key value store

func (KVStore) GetRagnarokNth 

func (k KVStore) GetRagnarokNth(ctx cosmos.Context) (int64, error)

GetRagnarokNth when ragnarok get triggered , THORNode will use a few rounds to refund all assets this method return which round it is in

func (KVStore) GetRagnarokPending 

func (k KVStore) GetRagnarokPending(ctx cosmos.Context) (int64, error)

GetRagnarokPending get ragnarok pending state from key value store

func (KVStore) GetRagnarokWithdrawPosition 

func (k KVStore) GetRagnarokWithdrawPosition(ctx cosmos.Context) (RagnarokWithdrawPosition, error)

GetRagnarokWithdrawPosition get ragnarok withdrawing position

func (KVStore) GetRollingPoolLiquidityFee 

func (k KVStore) GetRollingPoolLiquidityFee(ctx cosmos.Context, asset common.Asset) (uint64, error)

GetRollingPoolLiquidityFee get the given rolling liquidity fee from key value store

func (KVStore) GetRuneBalanceOfModule 

func (k KVStore) GetRuneBalanceOfModule(ctx cosmos.Context, moduleName string) cosmos.Uint

GetRuneBalanceOfModule get the RUNE balance

func (KVStore) GetSolvencyVoter 

func (k KVStore) GetSolvencyVoter(ctx cosmos.Context, txID common.TxID, chain common.Chain) (SolvencyVoter, error)

GetSolvencyVoter - gets information of solvency voter

func (KVStore) GetStoreVersion 

func (k KVStore) GetStoreVersion(ctx cosmos.Context) int64

GetStoreVersion get the current key value store version

func (KVStore) GetSwapQueueItem 

func (k KVStore) GetSwapQueueItem(ctx cosmos.Context, txID common.TxID, i int) (MsgSwap, error)

GetSwapQueueItem - write the given swap queue item information to key values tore

func (KVStore) GetSwapQueueIterator 

func (k KVStore) GetSwapQueueIterator(ctx cosmos.Context) cosmos.Iterator

GetSwapQueueIterator iterate swap queue

func (KVStore) GetTotalLiquidityFees 

func (k KVStore) GetTotalLiquidityFees(ctx cosmos.Context, height uint64) (cosmos.Uint, error)

GetTotalLiquidityFees - total of all fees collected in each block

func (KVStore) GetTotalSupply 

func (k KVStore) GetTotalSupply(ctx cosmos.Context, asset common.Asset) cosmos.Uint

func (KVStore) GetTssKeygenMetric 

func (k KVStore) GetTssKeygenMetric(ctx cosmos.Context, pubkey common.PubKey) (*TssKeygenMetric, error)

GetTssKeygenMetric get tss keygen metric from key value store

func (KVStore) GetTssKeysignFailVoter 

func (k KVStore) GetTssKeysignFailVoter(ctx cosmos.Context, id string) (TssKeysignFailVoter, error)

GetTssKeysignFailVoter - gets information of a tss keysign failure voter object

func (KVStore) GetTssKeysignFailVoterIterator 

func (k KVStore) GetTssKeysignFailVoterIterator(ctx cosmos.Context) cosmos.Iterator

GetTssKeysignFailVoterIterator iterate tx in voters

func (KVStore) GetTssKeysignMetric 

func (k KVStore) GetTssKeysignMetric(ctx cosmos.Context, txID common.TxID) (*TssKeysignMetric, error)

GetTssKeysignMetric get tss keygen metric from key value store

func (KVStore) GetTssVoter 

func (k KVStore) GetTssVoter(ctx cosmos.Context, id string) (TssVoter, error)

GetTssVoter - gets information of a tx hash

func (KVStore) GetTssVoterIterator 

func (k KVStore) GetTssVoterIterator(ctx cosmos.Context) cosmos.Iterator

GetTssVoterIterator iterate tx in voters

func (KVStore) GetTxOut 

func (k KVStore) GetTxOut(ctx cosmos.Context, height int64) (*TxOut, error)

GetTxOut - write the given txout information to key values tore

func (KVStore) GetTxOutIterator 

func (k KVStore) GetTxOutIterator(ctx cosmos.Context) cosmos.Iterator

GetTxOutIterator iterate tx out

func (KVStore) GetTxOutValue 

func (k KVStore) GetTxOutValue(ctx cosmos.Context, height int64) (cosmos.Uint, error)

func (KVStore) GetVault 

func (k KVStore) GetVault(ctx cosmos.Context, pk common.PubKey) (Vault, error)

GetVault get Vault with the given pubkey from data store

func (KVStore) GetVaultIterator 

func (k KVStore) GetVaultIterator(ctx cosmos.Context) cosmos.Iterator

GetVaultIterator only iterate vault pools

func (KVStore) GetVersion 

func (k KVStore) GetVersion() semver.Version

GetVersion return the current version

func (KVStore) GetVersionWithCtx 

func (k KVStore) GetVersionWithCtx(ctx cosmos.Context) (semver.Version, bool)

GetVersionWithCtx returns the version with the given context, and returns true if the version was found in the store

func (KVStore) HasCoins 

func (k KVStore) HasCoins(ctx cosmos.Context, addr cosmos.AccAddress, coins cosmos.Coins) bool

func (KVStore) HasOrderBookIndex 

func (k KVStore) HasOrderBookIndex(ctx cosmos.Context, msg MsgSwap) (bool, error)

HasOrderBookIndex - checks if order book item already exists

func (KVStore) HasOrderBookItem 

func (k KVStore) HasOrderBookItem(ctx cosmos.Context, txID common.TxID) bool

HasOrderBookItem - checks if order book item already exists

func (KVStore) HasSwapQueueItem 

func (k KVStore) HasSwapQueueItem(ctx cosmos.Context, txID common.TxID, i int) bool

HasSwapQueueItem - checks if swap item already exists

func (KVStore) HasValidVaultPools 

func (k KVStore) HasValidVaultPools(ctx cosmos.Context) (bool, error)

HasValidVaultPools check the data store to see whether we have a valid vault

func (KVStore) IncNodeAccountSlashPoints 

func (k KVStore) IncNodeAccountSlashPoints(ctx cosmos.Context, addr cosmos.AccAddress, pts int64) error

IncNodeAccountSlashPoints - increments the slash points associated with the given node address and uint

func (KVStore) ListActiveValidators 

func (k KVStore) ListActiveValidators(ctx cosmos.Context) (NodeAccounts, error)

ListActiveValidators - get a list of active validator node accounts

func (KVStore) ListValidatorsByStatus 

func (k KVStore) ListValidatorsByStatus(ctx cosmos.Context, status NodeStatus) (NodeAccounts, error)

ListValidatorsByStatus - get a list of validator node accounts with the given status

func (KVStore) ListValidatorsWithBond 

func (k KVStore) ListValidatorsWithBond(ctx cosmos.Context) (NodeAccounts, error)

ListValidatorsWithBond - gets a list of all validator node accounts that have bond Note: the order of node account in the result is not defined

func (KVStore) MAYANameExists 

func (k KVStore) MAYANameExists(ctx cosmos.Context, name string) bool

MAYANameExists check whether the given name exists

func (KVStore) MintAndSendToAccount 

func (k KVStore) MintAndSendToAccount(ctx cosmos.Context, to cosmos.AccAddress, coin common.Coin) error

func (KVStore) MintToModule 

func (k KVStore) MintToModule(ctx cosmos.Context, module string, coin common.Coin) error

func (KVStore) PoolExist 

func (k KVStore) PoolExist(ctx cosmos.Context, asset common.Asset) bool

PoolExist check whether the given pool exist in the data store

func (KVStore) RagnarokInProgress 

func (k KVStore) RagnarokInProgress(ctx cosmos.Context) bool

RagnarokInProgress return true only when Ragnarok is happening, when Ragnarok block height is not 0

func (KVStore) ReleaseNodeAccountFromJail 

func (k KVStore) ReleaseNodeAccountFromJail(ctx cosmos.Context, addr cosmos.AccAddress) error

ReleaseNodeAccountFromJail - update the jail details of a node account

func (KVStore) RemoveFromAsgardIndex 

func (k KVStore) RemoveFromAsgardIndex(ctx cosmos.Context, pubkey common.PubKey) error

func (KVStore) RemoveLiquidityProvider 

func (k KVStore) RemoveLiquidityProvider(ctx cosmos.Context, lp LiquidityProvider)

RemoveLiquidityProvider remove the liquidity provider to kv store

func (KVStore) RemoveOrderBookIndex 

func (k KVStore) RemoveOrderBookIndex(ctx cosmos.Context, msg MsgSwap) error

RemoveOrderBookIndex - removes a order book item from the kv store

func (KVStore) RemoveOrderBookItem 

func (k KVStore) RemoveOrderBookItem(ctx cosmos.Context, txID common.TxID) error

RemoveOrderBookItem - removes a order book item from the kv store

func (KVStore) RemovePool 

func (k KVStore) RemovePool(ctx cosmos.Context, asset common.Asset)

func (KVStore) RemoveSwapQueueItem 

func (k KVStore) RemoveSwapQueueItem(ctx cosmos.Context, txID common.TxID, i int)

RemoveSwapQueueItem - removes a swap item from the kv store

func (KVStore) ResetNodeAccountSlashPoints 

func (k KVStore) ResetNodeAccountSlashPoints(ctx cosmos.Context, addr cosmos.AccAddress)

ResetNodeAccountSlashPoints - reset the slash points to zero for associated with the given node address

func (KVStore) ResetRollingPoolLiquidityFee 

func (k KVStore) ResetRollingPoolLiquidityFee(ctx cosmos.Context, asset common.Asset)

ResetRollingPoolLiquidityFee set the given pool's rolling liquidity fee to zero

func (KVStore) SaveNetworkFee 

func (k KVStore) SaveNetworkFee(ctx cosmos.Context, chain common.Chain, networkFee NetworkFee) error

SaveNetworkFee save the network fee to kv store

func (KVStore) SendCoins 

func (k KVStore) SendCoins(ctx cosmos.Context, from, to cosmos.AccAddress, coins cosmos.Coins) error

func (KVStore) SendFromAccountToModule 

func (k KVStore) SendFromAccountToModule(ctx cosmos.Context, from cosmos.AccAddress, to string, coins common.Coins) error

SendFromAccountToModule transfer fund from one account to a module

func (KVStore) SendFromModuleToAccount 

func (k KVStore) SendFromModuleToAccount(ctx cosmos.Context, from string, to cosmos.AccAddress, coins common.Coins) error

SendFromModuleToAccount transfer fund from module to an account

func (KVStore) SendFromModuleToModule 

func (k KVStore) SendFromModuleToModule(ctx cosmos.Context, from, to string, coins common.Coins) error

SendFromModuleToModule transfer asset from one module to another

func (KVStore) SetBanVoter 

func (k KVStore) SetBanVoter(ctx cosmos.Context, ban BanVoter)

SetBanVoter - save a ban voter object

func (KVStore) SetBondProviders 

func (k KVStore) SetBondProviders(ctx cosmos.Context, record BondProviders) error

SetBondProviders - update the bond providers of a node account

func (KVStore) SetChainContract 

func (k KVStore) SetChainContract(ctx cosmos.Context, cc ChainContract)

SetChainContract - save chain contract address

func (KVStore) SetErrataTxVoter 

func (k KVStore) SetErrataTxVoter(ctx cosmos.Context, errata ErrataTxVoter)

SetErrataTxVoter - save a errata voter object

func (KVStore) SetForgiveSlashVoter 

func (k KVStore) SetForgiveSlashVoter(ctx cosmos.Context, forgiveSlash ForgiveSlashVoter)

SetForgiveSlashVoter - save a forgiveSlash voter object

func (KVStore) SetIBCTransferParams 

func (k KVStore) SetIBCTransferParams(ctx cosmos.Context, params ibctransfertypes.Params)

func (KVStore) SetKeygenBlock 

func (k KVStore) SetKeygenBlock(ctx cosmos.Context, keygen KeygenBlock)

SetKeygenBlock save the KeygenBlock to kv store

func (KVStore) SetLastChainHeight 

func (k KVStore) SetLastChainHeight(ctx cosmos.Context, chain common.Chain, height int64) error

SetLastChainHeight save last chain height

func (KVStore) SetLastObserveHeight 

func (k KVStore) SetLastObserveHeight(ctx cosmos.Context, chain common.Chain, address cosmos.AccAddress, height int64) error

SetLastObserveHeight save the last observe height into key value store

func (KVStore) SetLastSignedHeight 

func (k KVStore) SetLastSignedHeight(ctx cosmos.Context, height int64) error

SetLastSignedHeight save last signed height into kv store

func (KVStore) SetLiquidityAuctionTier 

func (k KVStore) SetLiquidityAuctionTier(ctx cosmos.Context, addr common.Address, newTier int64) error

SetLiquidityAuctionTier save the liquidity auction tier to kv store if tier already set, it will only be updated if new tier it's equal or greater

func (KVStore) SetLiquidityProvider 

func (k KVStore) SetLiquidityProvider(ctx cosmos.Context, lp LiquidityProvider)

SetLiquidityProvider save the liquidity provider to kv store

func (KVStore) SetLiquidityProviders 

func (k KVStore) SetLiquidityProviders(ctx cosmos.Context, lps LiquidityProviders)

SetLiquidityProvider save the liquidity provider to kv store

func (KVStore) SetMAYAName 

func (k KVStore) SetMAYAName(ctx cosmos.Context, name MAYAName)

SetMAYAName save the MAYAName object to store

func (KVStore) SetMimir 

func (k KVStore) SetMimir(ctx cosmos.Context, key string, value int64)

SetMimir save a mimir value to key value store

func (KVStore) SetNetwork 

func (k KVStore) SetNetwork(ctx cosmos.Context, data Network) error

SetNetwork save the given network data to key value store, it will overwrite existing vault

func (KVStore) SetNodeAccount 

func (k KVStore) SetNodeAccount(ctx cosmos.Context, na NodeAccount) error

SetNodeAccount save the given node account into data store

func (KVStore) SetNodeAccountJail 

func (k KVStore) SetNodeAccountJail(ctx cosmos.Context, addr cosmos.AccAddress, height int64, reason string) error

SetNodeAccountJail - update the jail details of a node account

func (KVStore) SetNodeAccountSlashPoints 

func (k KVStore) SetNodeAccountSlashPoints(ctx cosmos.Context, addr cosmos.AccAddress, pts int64)

SetNodeAccountSlashPoints - set the slash points associated with the given node address and uint

func (KVStore) SetNodeMimir 

func (k KVStore) SetNodeMimir(ctx cosmos.Context, key string, value int64, acc cosmos.AccAddress) error

SetNodeMimir save a mimir value to key value store for a specific node

func (KVStore) SetNodePauseChain 

func (k KVStore) SetNodePauseChain(ctx cosmos.Context, acc cosmos.AccAddress)
func (k KVStore) SetObservedLink(ctx cosmos.Context, inhash, outhash common.TxID)

func (KVStore) SetObservedNetworkFeeVoter 

func (k KVStore) SetObservedNetworkFeeVoter(ctx cosmos.Context, networkFeeVoter ObservedNetworkFeeVoter)

SetObservedNetworkFeeVoter - save a observed network fee voter object

func (KVStore) SetObservedTxInVoter 

func (k KVStore) SetObservedTxInVoter(ctx cosmos.Context, tx ObservedTxVoter)

SetObservedTxInVoter - save a txin voter object

func (KVStore) SetObservedTxOutVoter 

func (k KVStore) SetObservedTxOutVoter(ctx cosmos.Context, tx ObservedTxVoter)

SetObservedTxOutVoter - save a txout voter object

func (KVStore) SetOrderBookIndex 

func (k KVStore) SetOrderBookIndex(ctx cosmos.Context, msg MsgSwap) error

SetOrderBookIndex - writes a order book index to the kv store

func (KVStore) SetOrderBookItem 

func (k KVStore) SetOrderBookItem(ctx cosmos.Context, msg MsgSwap) error

SetOrderBookItem - writes a order book item to the kv store

func (KVStore) SetOrderBookProcessor 

func (k KVStore) SetOrderBookProcessor(ctx cosmos.Context, record []bool) error

SetOrderBookProcessor - writes a list of pairs to process

func (KVStore) SetPOL 

func (k KVStore) SetPOL(ctx cosmos.Context, data ProtocolOwnedLiquidity) error

SetPOL save the given network data to key value store, it will overwrite existing vault

func (KVStore) SetPool 

func (k KVStore) SetPool(ctx cosmos.Context, pool Pool) error

SetPool save the entire Pool metadata struct to key value store

func (KVStore) SetPoolLUVI 

func (k KVStore) SetPoolLUVI(ctx cosmos.Context, asset common.Asset, luvi cosmos.Uint)

func (KVStore) SetPoolRagnarokStart 

func (k KVStore) SetPoolRagnarokStart(ctx cosmos.Context, asset common.Asset)

SetPoolRagnarokStart set pool ragnarok start block height

func (KVStore) SetRagnarokBlockHeight 

func (k KVStore) SetRagnarokBlockHeight(ctx cosmos.Context, height int64)

SetRagnarokBlockHeight save ragnarok block height to key value store, once it get set , it means ragnarok started

func (KVStore) SetRagnarokNth 

func (k KVStore) SetRagnarokNth(ctx cosmos.Context, nth int64)

SetRagnarokNth save the round number into key value store

func (KVStore) SetRagnarokPending 

func (k KVStore) SetRagnarokPending(ctx cosmos.Context, pending int64)

SetRagnarokPending save ragnarok pending to key value store

func (KVStore) SetRagnarokWithdrawPosition 

func (k KVStore) SetRagnarokWithdrawPosition(ctx cosmos.Context, position RagnarokWithdrawPosition)

SetRagnarokWithdrawPosition set ragnarok withdraw position

func (KVStore) SetSolvencyVoter 

func (k KVStore) SetSolvencyVoter(ctx cosmos.Context, solvencyVoter SolvencyVoter)

SetSolvencyVoter - save a solvency voter object

func (KVStore) SetStoreVersion 

func (k KVStore) SetStoreVersion(ctx cosmos.Context, value int64)

SetStoreVersion save the store version

func (KVStore) SetSwapQueueItem 

func (k KVStore) SetSwapQueueItem(ctx cosmos.Context, msg MsgSwap, i int) error

SetSwapQueueItem - writes a swap item to the kv store

func (KVStore) SetTssKeygenMetric 

func (k KVStore) SetTssKeygenMetric(ctx cosmos.Context, metric *TssKeygenMetric)

SetTssKeygenMetric save TssKeygenMetric to key value store

func (KVStore) SetTssKeysignFailVoter 

func (k KVStore) SetTssKeysignFailVoter(ctx cosmos.Context, tss TssKeysignFailVoter)

SetTssKeysignFailVoter - save a tss keysign fail voter object

func (KVStore) SetTssKeysignMetric 

func (k KVStore) SetTssKeysignMetric(ctx cosmos.Context, metric *TssKeysignMetric)

SetTssKeysignMetric save TssKeygenMetric to key value store

func (KVStore) SetTssVoter 

func (k KVStore) SetTssVoter(ctx cosmos.Context, tss TssVoter)

SetTssVoter - save a tss voter object

func (KVStore) SetTxOut 

func (k KVStore) SetTxOut(ctx cosmos.Context, blockOut *TxOut) error

SetTxOut - write the given txout information to key value store

func (KVStore) SetVault 

func (k KVStore) SetVault(ctx cosmos.Context, vault Vault) error

SetVault save the Vault object to store

func (*KVStore) SetVersion 

func (k *KVStore) SetVersion(ver semver.Version)

func (KVStore) SetVersionWithCtx 

func (k KVStore) SetVersionWithCtx(ctx cosmos.Context, v semver.Version)

GetVersionWithCtxt stores the version

func (KVStore) SortBySecurity 

func (k KVStore) SortBySecurity(ctx cosmos.Context, vaults Vaults, signingTransPeriod int64) Vaults

SortBySecurity sorts a list of vaults in an order by how close the total value of the vault is to the total bond of the members of that vault. Sorts by least secure to most secure.

func (KVStore) TotalActiveValidators 

func (k KVStore) TotalActiveValidators(ctx cosmos.Context) (int, error)

TotalActiveValidators count the number of active node account

func (KVStore) VaultExists 

func (k KVStore) VaultExists(ctx cosmos.Context, pk common.PubKey) bool

VaultExists check whether the given pubkey is associated with a vault

type KeygenBlock 

type KeygenBlock = types.KeygenBlock

type LiquidityAuctionTier 

type LiquidityAuctionTier = types.LiquidityAuctionTier

type LiquidityProvider 

type LiquidityProvider = types.LiquidityProvider

type LiquidityProviders 

type LiquidityProviders = types.LiquidityProviders

type MAYAName 

type MAYAName = types.MAYAName

type MAYANameAlias 

type MAYANameAlias = types.MAYANameAlias

type MsgSwap 

type MsgSwap = types.MsgSwap

type Network 

type Network = types.Network

type NetworkFee 

type NetworkFee = types.NetworkFee

type NodeAccount 

type NodeAccount = types.NodeAccount

type NodeAccounts 

type NodeAccounts = types.NodeAccounts

type NodeMimir 

type NodeMimir = types.NodeMimir

type NodeMimirs 

type NodeMimirs = types.NodeMimirs

type NodeStatus 

type NodeStatus = types.NodeStatus

type NodeType 

type NodeType = types.NodeType

type ObservedNetworkFeeVoter 

type ObservedNetworkFeeVoter = types.ObservedNetworkFeeVoter

type ObservedTxVoter 

type ObservedTxVoter = types.ObservedTxVoter

type ObservedTxs 

type ObservedTxs = types.ObservedTxs

type Pool 

type Pool = types.Pool

type Pools 

type Pools = types.Pools

type ProtoAccAddresses 

type ProtoAccAddresses = types.ProtoAccAddresses

type ProtoBools 

type ProtoBools = types.ProtoBools

type ProtoInt64 

type ProtoInt64 = types.ProtoInt64

type ProtoStrings 

type ProtoStrings = types.ProtoStrings

type ProtoUint 

type ProtoUint = common.ProtoUint

type ProtoUint64 

type ProtoUint64 = types.ProtoUint64

type ProtocolOwnedLiquidity 

type ProtocolOwnedLiquidity = types.ProtocolOwnedLiquidity

type RagnarokWithdrawPosition 

type RagnarokWithdrawPosition = types.RagnarokWithdrawPosition

type ReserveContributors 

type ReserveContributors = types.ReserveContributors

type SolvencyVoter 

type SolvencyVoter = types.SolvencyVoter

type TssKeygenMetric 

type TssKeygenMetric = types.TssKeygenMetric

type TssKeysignFailVoter 

type TssKeysignFailVoter = types.TssKeysignFailVoter

type TssKeysignMetric 

type TssKeysignMetric = types.TssKeysignMetric

type TssVoter 

type TssVoter = types.TssVoter

type TxOut 

type TxOut = types.TxOut

type TxOutItem 

type TxOutItem = types.TxOutItem

type Vault 

type Vault = types.Vault

type VaultStatus 

type VaultStatus = types.VaultStatus

type Vaults 

type Vaults = types.Vaults

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.