thorchain

package
v1.131.1 Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2024 License: MIT Imports: 71 Imported by: 1

Documentation

Index

Constants

View Source
const (
	ModuleName             = types.ModuleName
	ReserveName            = types.ReserveName
	AsgardName             = types.AsgardName
	BondName               = types.BondName
	LendingName            = types.LendingName
	AffiliateCollectorName = types.AffiliateCollectorName
	RouterKey              = types.RouterKey
	StoreKey               = types.StoreKey
	DefaultCodespace       = types.DefaultCodespace

	// pool status
	PoolAvailable = types.PoolStatus_Available
	PoolStaged    = types.PoolStatus_Staged
	PoolSuspended = types.PoolStatus_Suspended

	// Admin config keys
	MaxWithdrawBasisPoints = types.MaxWithdrawBasisPoints

	// Vaults
	AsgardVault   = types.VaultType_AsgardVault
	UnknownVault  = types.VaultType_UnknownVault
	ActiveVault   = types.VaultStatus_ActiveVault
	InactiveVault = types.VaultStatus_InactiveVault
	RetiringVault = types.VaultStatus_RetiringVault
	InitVault     = types.VaultStatus_InitVault

	// Node status
	NodeActive      = types.NodeStatus_Active
	NodeWhiteListed = types.NodeStatus_Whitelisted
	NodeDisabled    = types.NodeStatus_Disabled
	NodeReady       = types.NodeStatus_Ready
	NodeStandby     = types.NodeStatus_Standby
	NodeUnknown     = types.NodeStatus_Unknown

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

	// Bond type
	BondPaid     = types.BondType_bond_paid
	BondReturned = types.BondType_bond_returned
	BondCost     = types.BondType_bond_cost
	BondReward   = types.BondType_bond_reward
	AsgardKeygen = types.KeygenType_AsgardKeygen

	// Bond type
	AddPendingLiquidity      = types.PendingLiquidityType_add
	WithdrawPendingLiquidity = types.PendingLiquidityType_withdraw

	// Order Type
	MarketOrder = types.OrderType_market
	LimitOrder  = types.OrderType_limit

	// Mint/Burn type
	MintSupplyType = types.MintBurnSupplyType_mint
	BurnSupplyType = types.MintBurnSupplyType_burn

	// Memos
	TxSwap          = mem.TxSwap
	TxLimitOrder    = mem.TxLimitOrder
	TxAdd           = mem.TxAdd
	TxBond          = mem.TxBond
	TxMigrate       = mem.TxMigrate
	TxRagnarok      = mem.TxRagnarok
	TxReserve       = mem.TxReserve
	TxOutbound      = mem.TxOutbound
	TxRefund        = mem.TxRefund
	TxUnBond        = mem.TxUnbond
	TxLeave         = mem.TxLeave
	TxWithdraw      = mem.TxWithdraw
	TxTHORName      = mem.TxTHORName
	TxLoanOpen      = mem.TxLoanOpen
	TxLoanRepayment = mem.TxLoanRepayment
)
View Source
const (
	YggdrasilVault    = types.VaultType_YggdrasilVault
	TxYggdrasilFund   = mem.TxYggdrasilFund
	TxYggdrasilReturn = mem.TxYggdrasilReturn
)
View Source
const (
	// CodeBadVersion error code for bad version
	CodeInternalError     uint32 = 99
	CodeTxFail            uint32 = 100
	CodeBadVersion        uint32 = 101
	CodeInvalidMessage    uint32 = 102
	CodeInvalidVault      uint32 = 104
	CodeInvalidMemo       uint32 = 105
	CodeInvalidPoolStatus uint32 = 107

	CodeSwapFail                 uint32 = 108
	CodeSwapFailNotEnoughFee     uint32 = 110
	CodeSwapFailInvalidAmount    uint32 = 113
	CodeSwapFailInvalidBalance   uint32 = 114
	CodeSwapFailNotEnoughBalance uint32 = 115

	CodeAddLiquidityFailValidation   uint32 = 120
	CodeFailGetLiquidityProvider     uint32 = 122
	CodeAddLiquidityMismatchAddr     uint32 = 123
	CodeLiquidityInvalidPoolAsset    uint32 = 124
	CodeAddLiquidityRUNEOverLimit    uint32 = 125
	CodeAddLiquidityRUNEMoreThanBond uint32 = 126

	CodeWithdrawFailValidation uint32 = 130
	CodeFailAddOutboundTx      uint32 = 131
	CodeFailSaveEvent          uint32 = 132
	CodeNoLiquidityUnitLeft    uint32 = 135
	CodeWithdrawWithin24Hours  uint32 = 136
	CodeWithdrawFail           uint32 = 137
	CodeEmptyChain             uint32 = 138
	CodeWithdrawLockup         uint32 = 139
)

THORChain error code start at 99

View Source
const (
	EventTypeActiveVault   = "ActiveVault"
	EventTypeInactiveVault = "InactiveVault"
)

const values used to emit events

View Source
const (
	MimirRecallFund      = `MimirRecallFund`
	MimirUpgradeContract = `MimirUpgradeContract`

	MimirRecallFundTemplate      = `MimirRecallFund%s`
	MimirUpgradeContractTemplate = `MimirUpgradeContract%s`
)
View Source
const BEP2RuneOwnerAddress = "bnb1e4q8whcufp6d72w8nwmpuhxd96r4n0fstegyuy"

BEP2RuneOwnerAddress this is the BEP2 RUNE owner address , during migration all upgraded BEP2 RUNE will be send to this owner address THORChain admin will burn those upgraded RUNE appropriately , It need to send to owner address is because only owner can burn it

View Source
const ILPMinimumBlocks = 17280 // 1 days

Variables

View Source
var (
	NewPool                        = types.NewPool
	NewNetwork                     = types.NewNetwork
	NewProtocolOwnedLiquidity      = types.NewProtocolOwnedLiquidity
	NewObservedTx                  = types.NewObservedTx
	NewTssVoter                    = types.NewTssVoter
	NewBanVoter                    = types.NewBanVoter
	NewErrataTxVoter               = types.NewErrataTxVoter
	NewObservedTxVoter             = types.NewObservedTxVoter
	NewMsgTradeAccountDeposit      = types.NewMsgTradeAccountDeposit
	NewMsgTradeAccountWithdrawal   = types.NewMsgTradeAccountWithdrawal
	NewMsgLoanOpen                 = types.NewMsgLoanOpen
	NewMsgLoanRepayment            = types.NewMsgLoanRepayment
	NewMsgMimir                    = types.NewMsgMimir
	NewMsgNodePauseChain           = types.NewMsgNodePauseChain
	NewMsgDeposit                  = types.NewMsgDeposit
	NewMsgTssPool                  = types.NewMsgTssPool
	NewMsgTssKeysignFail           = types.NewMsgTssKeysignFail
	NewMsgObservedTxIn             = types.NewMsgObservedTxIn
	NewMsgObservedTxOut            = types.NewMsgObservedTxOut
	NewMsgNoOp                     = types.NewMsgNoOp
	NewMsgConsolidate              = types.NewMsgConsolidate
	NewMsgDonate                   = types.NewMsgDonate
	NewMsgAddLiquidity             = types.NewMsgAddLiquidity
	NewMsgWithdrawLiquidity        = types.NewMsgWithdrawLiquidity
	NewMsgSwap                     = types.NewMsgSwap
	NewKeygen                      = types.NewKeygen
	NewKeygenBlock                 = types.NewKeygenBlock
	NewMsgSetNodeKeys              = types.NewMsgSetNodeKeys
	NewMsgManageTHORName           = types.NewMsgManageTHORName
	NewTxOut                       = types.NewTxOut
	NewEventRewards                = types.NewEventRewards
	NewEventPool                   = types.NewEventPool
	NewEventDonate                 = types.NewEventDonate
	NewEventSwap                   = types.NewEventSwap
	NewEventStreamingSwap          = types.NewEventStreamingSwap
	NewEventLimitOrder             = types.NewEventLimitOrder
	NewEventAddLiquidity           = types.NewEventAddLiquidity
	NewEventWithdraw               = types.NewEventWithdraw
	NewEventRefund                 = types.NewEventRefund
	NewEventBond                   = types.NewEventBond
	NewEventGas                    = types.NewEventGas
	NewEventScheduledOutbound      = types.NewEventScheduledOutbound
	NewEventSecurity               = types.NewEventSecurity
	NewEventSlash                  = types.NewEventSlash
	NewEventSlashPoint             = types.NewEventSlashPoint
	NewEventReserve                = types.NewEventReserve
	NewEventErrata                 = types.NewEventErrata
	NewEventFee                    = types.NewEventFee
	NewEventOutbound               = types.NewEventOutbound
	NewEventSetMimir               = types.NewEventSetMimir
	NewEventSetNodeMimir           = types.NewEventSetNodeMimir
	NewEventTssKeygenSuccess       = types.NewEventTssKeygenSuccess
	NewEventTssKeygenFailure       = types.NewEventTssKeygenFailure
	NewEventTssKeygenMetric        = types.NewEventTssKeygenMetric
	NewEventTssKeysignMetric       = types.NewEventTssKeysignMetric
	NewEventPoolBalanceChanged     = types.NewEventPoolBalanceChanged
	NewEventPendingLiquidity       = types.NewEventPendingLiquidity
	NewEventTHORName               = types.NewEventTHORName
	NewEventMintBurn               = types.NewEventMintBurn
	NewEventVersion                = types.NewEventVersion
	NewEventTradeAccountDeposit    = types.NewEventTradeAccountDeposit
	NewEventTradeAccountWithdraw   = types.NewEventTradeAccountWithdraw
	NewEventLoanOpen               = types.NewEventLoanOpen
	NewEventLoanRepayment          = types.NewEventLoanRepayment
	NewPoolMod                     = types.NewPoolMod
	NewMsgRefundTx                 = types.NewMsgRefundTx
	NewMsgOutboundTx               = types.NewMsgOutboundTx
	NewMsgMigrate                  = types.NewMsgMigrate
	NewMsgRagnarok                 = types.NewMsgRagnarok
	ModuleCdc                      = types.ModuleCdc
	RegisterCodec                  = types.RegisterCodec
	RegisterInterfaces             = types.RegisterInterfaces
	NewBondProviders               = types.NewBondProviders
	NewBondProvider                = types.NewBondProvider
	NewNodeAccount                 = types.NewNodeAccount
	NewVault                       = types.NewVault
	NewReserveContributor          = types.NewReserveContributor
	NewMsgReserveContributor       = types.NewMsgReserveContributor
	NewMsgBond                     = types.NewMsgBond
	NewMsgUnBond                   = types.NewMsgUnBond
	NewMsgErrataTx                 = types.NewMsgErrataTx
	NewMsgBan                      = types.NewMsgBan
	NewMsgLeave                    = types.NewMsgLeave
	NewMsgSetVersion               = types.NewMsgSetVersion
	NewMsgSetIPAddress             = types.NewMsgSetIPAddress
	NewMsgNetworkFee               = types.NewMsgNetworkFee
	NewNetworkFee                  = types.NewNetworkFee
	NewTHORName                    = types.NewTHORName
	NewLoan                        = types.NewLoan
	NewStreamingSwap               = types.NewStreamingSwap
	GetPoolStatus                  = types.GetPoolStatus
	GetRandomVault                 = types.GetRandomVault
	GetRandomTx                    = types.GetRandomTx
	GetRandomObservedTx            = types.GetRandomObservedTx
	GetRandomTxOutItem             = types.GetRandomTxOutItem
	GetRandomObservedTxVoter       = types.GetRandomObservedTxVoter
	GetRandomValidatorNode         = types.GetRandomValidatorNode
	GetRandomVaultNode             = types.GetRandomVaultNode
	GetRandomTHORAddress           = types.GetRandomTHORAddress
	GetRandomRUNEAddress           = types.GetRandomRUNEAddress
	GetRandomBNBAddress            = types.GetRandomBNBAddress
	GetRandomTERRAAddress          = types.GetRandomTERRAAddress
	GetRandomGAIAAddress           = types.GetRandomGAIAAddress
	GetRandomBTCAddress            = types.GetRandomBTCAddress
	GetRandomLTCAddress            = types.GetRandomLTCAddress
	GetRandomTxHash                = types.GetRandomTxHash
	GetRandomBech32Addr            = types.GetRandomBech32Addr
	GetRandomBech32ConsensusPubKey = types.GetRandomBech32ConsensusPubKey
	GetRandomPubKey                = types.GetRandomPubKey
	GetRandomPubKeySet             = types.GetRandomPubKeySet
	GetCurrentVersion              = types.GetCurrentVersion
	SetupConfigForTest             = types.SetupConfigForTest
	HasSimpleMajority              = types.HasSimpleMajority
	HasSuperMajority               = types.HasSuperMajority
	HasMinority                    = types.HasMinority
	DefaultGenesis                 = types.DefaultGenesis
	NewSolvencyVoter               = types.NewSolvencyVoter
	NewMsgSolvency                 = types.NewMsgSolvency
	NewSwapperClout                = types.NewSwapperClout

	// Memo
	ParseMemo              = mem.ParseMemo
	ParseMemoWithTHORNames = mem.ParseMemoWithTHORNames
	FetchAddress           = mem.FetchAddress
	NewRefundMemo          = mem.NewRefundMemo
	NewOutboundMemo        = mem.NewOutboundMemo
	NewRagnarokMemo        = mem.NewRagnarokMemo
	NewMigrateMemo         = mem.NewMigrateMemo

	FetchDexAggregator         = aggregators.FetchDexAggregator
	FetchDexAggregatorGasLimit = aggregators.FetchDexAggregatorGasLimit
)
View Source
var (
	NewEventSwitch     = types.NewEventSwitch
	NewEventSwitchV87  = types.NewEventSwitchV87
	NewMsgSwitch       = types.NewMsgSwitch
	NewMsgYggdrasil    = types.NewMsgYggdrasil
	GetRandomYggVault  = types.GetRandomYggVault
	NewYggdrasilReturn = mem.NewYggdrasilReturn
	NewYggdrasilFund   = mem.NewYggdrasilFund
)
View Source
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source
var ADMINS = []string{
	"thor1xghvhe4p50aqh5zq2t2vls938as0dkr2mzgpgh",
	"thor19pkncem64gajdwrd5kasspyj0t75hhkpqjn5qh",
}

ADMINS hard coded admin address

View Source
var ErrNotEnoughToPayFee = errors.New("not enough asset to pay for fees")

ErrNotEnoughToPayFee will happen when the emitted asset is not enough to pay for fee

View Source
var IsValidTHORNameV1 = regexp.MustCompile(`^[a-zA-Z0-9+_-]+$`).MatchString
View Source
var VALIDATORS = []string{}

TODO: remove on hard fork

View Source
var WhitelistedArbs = []string{
	"thor1egxvam70a86jafa8gcg3kqfmfax3s0m2g3m754",
	"bc1qq2z2f4gs4nd7t0a9jjp90y9l9zzjtegu4nczha",
	"qz7262r7uufxk89ematxrf6yquk7zfwrjqm97vskzw",
	"0x04c5998ded94f89263370444ce64a99b7dbc9f46",
	"bnb1pa6hpjs7qv0vkd5ks5tqa2xtt2gk5n08yw7v7f",
	"ltc1qaa064vvv4d6stgywnf777j6dl8rd3tt93fp6jx",
}

Functions

func BanAnteHandler added in v1.106.0

func BanAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgBan) error

BanAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func DepositAnteHandler added in v1.106.0

func DepositAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgDeposit) error

DepositAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func DollarInRune added in v0.66.0

func DollarInRune(ctx cosmos.Context, mgr Manager) cosmos.Uint

gets the amount of USD that is equal to 1 RUNE (in other words, 1 RUNE's price in USD)

func DollarInRuneV1 added in v1.102.0

func DollarInRuneV1(ctx cosmos.Context, mgr Manager) cosmos.Uint

func DollarInRuneV102 added in v1.102.0

func DollarInRuneV102(ctx cosmos.Context, mgr Manager) cosmos.Uint

func ErrInternal

func ErrInternal(err error, msg string) error

ErrInternal return an error of errInternal with additional message

func ErrataTxAnteHandler added in v1.106.0

func ErrataTxAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgErrataTx) error

ErrataTxAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func GetKeeper added in v0.54.1

func GetKeeper(version semver.Version, cdc codec.BinaryCodec, coinKeeper bankkeeper.Keeper, accountKeeper authkeeper.AccountKeeper, storeKey cosmos.StoreKey) (keeper.Keeper, error)

GetKeeper return Keeper

func IPAddressAnteHandler added in v1.106.0

func IPAddressAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgSetIPAddress) error

IPAddressAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func InitGenesis

func InitGenesis(ctx cosmos.Context, keeper keeper.Keeper, data GenesisState) []abci.ValidatorUpdate

func IsModuleAccAddress added in v1.121.0

func IsModuleAccAddress(keeper keeper.Keeper, accAddr cosmos.AccAddress) bool

func IsModuleAccAddressV121 added in v1.121.0

func IsModuleAccAddressV121(keeper keeper.Keeper, accAddr cosmos.AccAddress) bool

func MimirAnteHandler added in v1.106.0

func MimirAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgMimir) error

MimirAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func MsgSendHandleV1 added in v1.107.0

func MsgSendHandleV1(ctx cosmos.Context, mgr Manager, msg *MsgSend) (*cosmos.Result, error)

func MsgSendHandleV108 added in v1.108.0

func MsgSendHandleV108(ctx cosmos.Context, mgr Manager, msg *MsgSend) (*cosmos.Result, error)

func MsgSendHandleV112 added in v1.112.0

func MsgSendHandleV112(ctx cosmos.Context, mgr Manager, msg *MsgSend) (*cosmos.Result, error)

func MsgSendHandleV115 added in v1.115.0

func MsgSendHandleV115(ctx cosmos.Context, mgr Manager, msg *MsgSend) (*cosmos.Result, error)

func MsgSendHandleV116 added in v1.116.0

func MsgSendHandleV116(ctx cosmos.Context, mgr Manager, msg *MsgSend) (*cosmos.Result, error)

func MsgSendLogger added in v1.107.0

func MsgSendLogger(ctx cosmos.Context, msg *MsgSend)

func MsgSendValidateV1 added in v1.107.0

func MsgSendValidateV1(ctx cosmos.Context, mgr Manager, msg *MsgSend) error

func MsgSendValidateV121 added in v1.121.0

func MsgSendValidateV121(ctx cosmos.Context, mgr Manager, msg *MsgSend) error

func MsgSendValidateV130 added in v1.130.0

func MsgSendValidateV130(ctx cosmos.Context, mgr Manager, msg *MsgSend) error

func MsgSendValidateV87 added in v1.107.0

func MsgSendValidateV87(ctx cosmos.Context, mgr Manager, msg *MsgSend) error

func MsgTssPoolHandleV117 added in v1.117.0

func MsgTssPoolHandleV117(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) (*cosmos.Result, error)

func MsgTssPoolHandleV120 added in v1.120.0

func MsgTssPoolHandleV120(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) (*cosmos.Result, error)

func MsgTssPoolHandleV123 added in v1.123.0

func MsgTssPoolHandleV123(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) (*cosmos.Result, error)

func MsgTssPoolHandleV124 added in v1.124.0

func MsgTssPoolHandleV124(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) (*cosmos.Result, error)

func MsgTssPoolHandleV73 added in v1.107.0

func MsgTssPoolHandleV73(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) (*cosmos.Result, error)

func MsgTssPoolHandleV92 added in v1.107.0

func MsgTssPoolHandleV92(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) (*cosmos.Result, error)

func MsgTssPoolHandleV93 added in v1.107.0

func MsgTssPoolHandleV93(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) (*cosmos.Result, error)

func MsgTssPoolLogger added in v1.107.0

func MsgTssPoolLogger(ctx cosmos.Context, msg *MsgTssPool)

func MsgTssPoolValidateV114 added in v1.114.0

func MsgTssPoolValidateV114(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) error

func MsgTssPoolValidateV121 added in v1.121.0

func MsgTssPoolValidateV121(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) error

func MsgTssPoolValidateV124 added in v1.124.0

func MsgTssPoolValidateV124(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) error

func MsgTssPoolValidateV71 added in v1.107.0

func MsgTssPoolValidateV71(ctx cosmos.Context, mgr Manager, msg *MsgTssPool) error

func NetworkFeeAnteHandler added in v1.106.0

func NetworkFeeAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgNetworkFee) error

NetworkFeeAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func NewExternalHandler

func NewExternalHandler(mgr Manager) cosmos.Handler

NewExternalHandler returns a handler for "thorchain" type messages.

func NewInternalHandler

func NewInternalHandler(mgr Manager) cosmos.Handler

NewInternalHandler returns a handler for "thorchain" internal type messages.

func NewQuerier

func NewQuerier(mgr *Mgrs, kbs cosmos.KeybaseStore) cosmos.Querier

NewQuerier is the module level router for state queries

func NodePauseChainAnteHandler added in v1.106.0

func NodePauseChainAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgNodePauseChain) error

NodePauseChainAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func ObservedTxInAnteHandler added in v1.106.0

func ObservedTxInAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgObservedTxIn) error

ObservedTxInAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func ObservedTxOutAnteHandler added in v1.106.0

func ObservedTxOutAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgObservedTxOut) error

ObservedTxOutAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func SendAnteHandler added in v1.106.0

func SendAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgSend) error

SendAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func SetNodeKeysAnteHandler added in v1.106.0

func SetNodeKeysAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgSetNodeKeys) error

SetNodeKeysAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func SolvencyAnteHandler added in v1.106.0

func SolvencyAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgSolvency) error

SolvencyAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func TssAnteHandler added in v1.106.0

func TssAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgTssPool) error

TssAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func TssKeysignFailAnteHandler added in v1.106.0

func TssKeysignFailAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgTssKeysignFail) error

TssKeysignAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

func ValidateGenesis

func ValidateGenesis(data GenesisState) error

ValidateGenesis validate genesis is valid or not

func VersionAnteHandler added in v1.106.0

func VersionAnteHandler(ctx cosmos.Context, v semver.Version, k keeper.Keeper, msg MsgSetVersion) error

VersionAnteHandler called by the ante handler to gate mempool entry and also during deliver. Store changes will persist if this function succeeds, regardless of the success of the transaction.

Types

type AddLiquidityHandler added in v0.41.0

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

AddLiquidityHandler is to handle add liquidity

func NewAddLiquidityHandler added in v0.41.0

func NewAddLiquidityHandler(mgr Manager) AddLiquidityHandler

NewAddLiquidityHandler create a new instance of AddLiquidityHandler

func (AddLiquidityHandler) Run added in v0.41.0

Run execute the handler

type AddLiquidityMemo added in v0.41.0

type AddLiquidityMemo = mem.AddLiquidityMemo

type AffiliateFeeCollector added in v1.116.0

type AffiliateFeeCollector = types.AffiliateFeeCollector

type AnteDecorator added in v1.106.0

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

func NewAnteDecorator added in v1.106.0

func NewAnteDecorator(keeper keeper.Keeper) AnteDecorator

func (AnteDecorator) AnteHandle added in v1.106.0

func (ad AnteDecorator) AnteHandle(ctx sdk.Context, tx sdk.Tx, simulate bool, next sdk.AnteHandler) (newCtx sdk.Context, err error)

type AppModule

type AppModule struct {
	AppModuleBasic
	// contains filtered or unexported fields
}

AppModule implements an application module for the thorchain module.

func NewAppModule

func NewAppModule(k keeper.Keeper, cdc codec.Codec, coinKeeper bankkeeper.Keeper, accountKeeper authkeeper.AccountKeeper, storeKey cosmos.StoreKey, telemetryEnabled bool) AppModule

NewAppModule creates a new AppModule Object

func (AppModule) BeginBlock

func (am AppModule) BeginBlock(ctx sdk.Context, req abci.RequestBeginBlock)

BeginBlock called when a block get proposed

func (AppModule) ConsensusVersion added in v1.82.0

func (AppModule) ConsensusVersion() uint64

func (AppModule) EndBlock

func (am AppModule) EndBlock(ctx sdk.Context, req abci.RequestEndBlock) []abci.ValidatorUpdate

EndBlock called when a block get committed

func (AppModule) ExportGenesis

func (am AppModule) ExportGenesis(ctx sdk.Context, cdc codec.JSONCodec) json.RawMessage

ExportGenesis export genesis

func (AppModule) InitGenesis

func (am AppModule) InitGenesis(ctx sdk.Context, cdc codec.JSONCodec, data json.RawMessage) []abci.ValidatorUpdate

InitGenesis initialise genesis

func (AppModule) LegacyQuerierHandler added in v0.41.0

func (am AppModule) LegacyQuerierHandler(legacyQuerierCdc *codec.LegacyAmino) sdk.Querier

LegacyQuerierHandler returns the capability module's Querier.

func (AppModule) Name

func (AppModule) Name() string

func (AppModule) NewHandler

func (am AppModule) NewHandler() sdk.Handler

func (AppModule) NewQuerierHandler

func (am AppModule) NewQuerierHandler() sdk.Querier

func (AppModule) QuerierRoute

func (am AppModule) QuerierRoute() string

func (AppModule) RegisterInvariants

func (am AppModule) RegisterInvariants(ir sdk.InvariantRegistry)

func (AppModule) RegisterServices added in v0.41.0

func (am AppModule) RegisterServices(cfg module.Configurator)

RegisterServices registers module services.

func (AppModule) Route

func (am AppModule) Route() cosmos.Route

type AppModuleBasic

type AppModuleBasic struct{}

AppModuleBasic app module Basics object

func (AppModuleBasic) DefaultGenesis

func (AppModuleBasic) DefaultGenesis(cdc codec.JSONCodec) json.RawMessage

DefaultGenesis returns default genesis state as raw bytes for the module.

func (AppModuleBasic) GetQueryCmd

func (AppModuleBasic) GetQueryCmd() *cobra.Command

GetQueryCmd get the root query command of this module

func (AppModuleBasic) GetTxCmd

func (AppModuleBasic) GetTxCmd() *cobra.Command

GetTxCmd get the root tx command of this module

func (AppModuleBasic) Name

func (AppModuleBasic) Name() string

Name return the module's name

func (AppModuleBasic) RegisterGRPCGatewayRoutes added in v0.41.0

func (AppModuleBasic) RegisterGRPCGatewayRoutes(clientCtx client.Context, mux *runtime.ServeMux)

RegisterGRPCGatewayRoutes registers the gRPC Gateway routes for the mint module. thornode current doesn't have grpc endpoint yet

func (AppModuleBasic) RegisterInterfaces added in v0.41.0

func (a AppModuleBasic) RegisterInterfaces(reg cdctypes.InterfaceRegistry)

RegisterInterfaces registers the module's interface types

func (AppModuleBasic) RegisterLegacyAminoCodec added in v0.41.0

func (AppModuleBasic) RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the module's types for the given codec.

func (AppModuleBasic) RegisterRESTRoutes

func (AppModuleBasic) RegisterRESTRoutes(ctx client.Context, rtr *mux.Router)

RegisterRESTRoutes register rest routes

func (AppModuleBasic) ValidateGenesis

func (AppModuleBasic) ValidateGenesis(cdc codec.JSONCodec, config client.TxEncodingConfig, bz json.RawMessage) error

ValidateGenesis check of the Genesis

type BanHandler

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

BanHandler is to handle Ban message

func NewBanHandler

func NewBanHandler(mgr Manager) BanHandler

NewBanHandler create new instance of BanHandler

func (BanHandler) Run

func (h BanHandler) Run(ctx cosmos.Context, m cosmos.Msg) (*cosmos.Result, error)

Run is the main entry point to execute Ban logic

type BanVoter

type BanVoter = types.BanVoter

type BaseHandler added in v1.107.0

type BaseHandler[M cosmos.Msg] struct {
	TypedHandler[M]
	// contains filtered or unexported fields
}

func NewSendHandler

func NewSendHandler(mgr Manager) BaseHandler[*MsgSend]

NewSendHandler create a new instance of SendHandler

func NewTssHandler

func NewTssHandler(mgr Manager) BaseHandler[*MsgTssPool]

NewTssHandler create a new handler to process MsgTssPool

func (BaseHandler[M]) Run added in v1.107.0

func (h BaseHandler[M]) Run(ctx cosmos.Context, m cosmos.Msg) (*cosmos.Result, error)

type Blame added in v0.41.0

type Blame = types.Blame

type BondHandler

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

BondHandler a handler to process bond

func NewBondHandler

func NewBondHandler(mgr Manager) BondHandler

NewBondHandler create new BondHandler

func (BondHandler) Run

func (h BondHandler) Run(ctx cosmos.Context, m cosmos.Msg) (*cosmos.Result, error)

Run execute the handler

type BondMemo

type BondMemo = mem.BondMemo

type BondProvider added in v0.81.0

type BondProvider = types.BondProvider

type BondProviders added in v0.81.0

type BondProviders = types.BondProviders

type ChainContract added in v0.41.0

type ChainContract = types.ChainContract

type CommonOutboundTxHandler

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

CommonOutboundTxHandler is the place where those common logic can be shared between multiple different kind of outbound tx handler at the moment, handler_refund, and handler_outbound_tx are largely the same , only some small difference

func NewCommonOutboundTxHandler

func NewCommonOutboundTxHandler(mgr Manager) CommonOutboundTxHandler

NewCommonOutboundTxHandler create a new instance of the CommonOutboundTxHandler

type ConsolidateHandler added in v0.54.0

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

ConsolidateHandler handles transactions the network sends to itself, to consolidate UTXOs

func NewConsolidateHandler added in v0.54.0

func NewConsolidateHandler(mgr Manager) ConsolidateHandler

NewConsolidateHandler create a new instance of the ConsolidateHandler

func (ConsolidateHandler) Run added in v0.54.0

type ConsolidateMemo added in v0.54.0

type ConsolidateMemo = mem.ConsolidateMemo

type DepositHandler added in v0.41.0

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

DepositHandler is to process native messages on THORChain

func NewDepositHandler added in v0.41.0

func NewDepositHandler(mgr Manager) DepositHandler

NewDepositHandler create a new instance of DepositHandler

func (DepositHandler) Run added in v0.41.0

Run is the main entry of DepositHandler

type DonateHandler added in v0.41.0

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

DonateHandler is to handle donate message

func NewDonateHandler added in v0.41.0

func NewDonateHandler(mgr Manager) DonateHandler

NewDonateHandler create a new instance of DonateHandler

func (DonateHandler) Run added in v0.41.0

Run is the main entry point to execute donate logic

type DonateMemo added in v0.41.0

type DonateMemo = mem.DonateMemo

type DroppedSwapOutTx added in v1.102.0

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

type EmitEventItem

type EmitEventItem interface {
	Events() (cosmos.Events, error)
}

EmitEventItem define the method all event need to implement

type ErrataTxHandler

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

ErrataTxHandler is to handle ErrataTx message

func NewErrataTxHandler

func NewErrataTxHandler(mgr Manager) ErrataTxHandler

NewErrataTxHandler create new instance of ErrataTxHandler

func (ErrataTxHandler) Run

Run is the main entry point to execute ErrataTx logic

type ErrataTxVoter

type ErrataTxVoter = types.ErrataTxVoter

type EventAddLiquidity added in v0.41.0

type EventAddLiquidity = types.EventAddLiquidity

type EventBond

type EventBond = types.EventBond

type EventDonate added in v0.41.0

type EventDonate = types.EventDonate

type EventErrata

type EventErrata = types.EventErrata

type EventFee

type EventFee = types.EventFee

type EventGas

type EventGas = types.EventGas

type EventLoanOpen added in v1.107.0

type EventLoanOpen = types.EventLoanOpen

type EventLoanRepayment added in v1.107.0

type EventLoanRepayment = types.EventLoanRepayment

type EventManager

type EventManager interface {
	EmitEvent(ctx cosmos.Context, evt EmitEventItem) error
	EmitGasEvent(ctx cosmos.Context, gasEvent *EventGas) error
	EmitSwapEvent(ctx cosmos.Context, swap *EventSwap) error
	EmitFeeEvent(ctx cosmos.Context, feeEvent *EventFee) error
}

EventManager define methods need to be support to manage events

func GetEventManager

func GetEventManager(version semver.Version) (EventManager, error)

GetEventManager will return an implementation of EventManager

type EventMgrVCUR added in v1.116.0

type EventMgrVCUR struct{}

EventMgrVCUR implement EventManager interface

func (*EventMgrVCUR) EmitEvent added in v1.116.0

func (m *EventMgrVCUR) EmitEvent(ctx cosmos.Context, evt EmitEventItem) error

EmitEvent to block

func (*EventMgrVCUR) EmitFeeEvent added in v1.116.0

func (m *EventMgrVCUR) EmitFeeEvent(ctx cosmos.Context, feeEvent *EventFee) error

EmitFeeEvent emit a fee event through event manager

func (*EventMgrVCUR) EmitGasEvent added in v1.116.0

func (m *EventMgrVCUR) EmitGasEvent(ctx cosmos.Context, gasEvent *EventGas) error

EmitGasEvent emit gas events

func (*EventMgrVCUR) EmitSwapEvent added in v1.116.0

func (m *EventMgrVCUR) EmitSwapEvent(ctx cosmos.Context, swap *EventSwap) error

EmitSwapEvent emit swap event to block

type EventOutbound

type EventOutbound = types.EventOutbound

type EventPool

type EventPool = types.EventPool

type EventRefund

type EventRefund = types.EventRefund

type EventReserve

type EventReserve = types.EventReserve

type EventRewards

type EventRewards = types.EventRewards

type EventSlash

type EventSlash = types.EventSlash

type EventSwap

type EventSwap = types.EventSwap

type EventWithdraw added in v0.41.0

type EventWithdraw = types.EventWithdraw

type GasManager

type GasManager interface {
	BeginBlock(mgr Manager) // TODO: Remove Manager argument on hard fork.
	EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)
	AddGasAsset(outAsset common.Asset, gas common.Gas, increaseTxCount bool)
	ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)
	GetGas() common.Gas
	GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint
	GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)
	GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint
	GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)
	CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint
}

GasManager define all the methods required to manage gas

func GetGasManager

func GetGasManager(version semver.Version, keeper keeper.Keeper) (GasManager, error)

GetGasManager return GasManager

type GasMgrV102 added in v1.102.0

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

GasMgrV102 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV102) AddGasAsset added in v1.102.0

func (gm *GasMgrV102) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV102) BeginBlock added in v1.102.0

func (gm *GasMgrV102) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV102) CalcOutboundFeeMultiplier added in v1.108.0

func (gm *GasMgrV102) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

func (*GasMgrV102) EndBlock added in v1.102.0

func (gm *GasMgrV102) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV102) GetFee added in v1.102.0

func (gm *GasMgrV102) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in RUNE

func (*GasMgrV102) GetGas added in v1.102.0

func (gm *GasMgrV102) GetGas() common.Gas

GetGas return gas

func (*GasMgrV102) GetGasRate added in v1.102.0

func (gm *GasMgrV102) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV102) GetMaxGas added in v1.102.0

func (gm *GasMgrV102) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV102) GetNetworkFee added in v1.102.0

func (gm *GasMgrV102) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV102) ProcessGas added in v1.102.0

func (gm *GasMgrV102) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrV108 added in v1.108.0

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

GasMgrV108 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV108) AddGasAsset added in v1.108.0

func (gm *GasMgrV108) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV108) BeginBlock added in v1.108.0

func (gm *GasMgrV108) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV108) CalcOutboundFeeMultiplier added in v1.108.0

func (gm *GasMgrV108) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

CalcOutboundFeeMultiplier returns the current outbound fee multiplier based on current and target outbound fee surplus

func (*GasMgrV108) EndBlock added in v1.108.0

func (gm *GasMgrV108) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV108) GetFee added in v1.108.0

func (gm *GasMgrV108) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in RUNE

func (*GasMgrV108) GetGas added in v1.108.0

func (gm *GasMgrV108) GetGas() common.Gas

GetGas return gas

func (*GasMgrV108) GetGasRate added in v1.108.0

func (gm *GasMgrV108) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV108) GetMaxGas added in v1.108.0

func (gm *GasMgrV108) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV108) GetNetworkFee added in v1.108.0

func (gm *GasMgrV108) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV108) ProcessGas added in v1.108.0

func (gm *GasMgrV108) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrV109 added in v1.109.0

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

GasMgrV109 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV109) AddGasAsset added in v1.109.0

func (gm *GasMgrV109) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV109) BeginBlock added in v1.109.0

func (gm *GasMgrV109) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV109) CalcOutboundFeeMultiplier added in v1.109.0

func (gm *GasMgrV109) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

CalcOutboundFeeMultiplier returns the current outbound fee multiplier based on current and target outbound fee surplus

func (*GasMgrV109) EndBlock added in v1.109.0

func (gm *GasMgrV109) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV109) GetFee added in v1.109.0

func (gm *GasMgrV109) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in asset

func (*GasMgrV109) GetGas added in v1.109.0

func (gm *GasMgrV109) GetGas() common.Gas

GetGas return gas

func (*GasMgrV109) GetGasRate added in v1.109.0

func (gm *GasMgrV109) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV109) GetMaxGas added in v1.109.0

func (gm *GasMgrV109) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV109) GetNetworkFee added in v1.109.0

func (gm *GasMgrV109) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV109) ProcessGas added in v1.109.0

func (gm *GasMgrV109) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrV112 added in v1.112.0

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

GasMgrV112 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV112) AddGasAsset added in v1.112.0

func (gm *GasMgrV112) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV112) BeginBlock added in v1.112.0

func (gm *GasMgrV112) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV112) CalcOutboundFeeMultiplier added in v1.112.0

func (gm *GasMgrV112) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

CalcOutboundFeeMultiplier returns the current outbound fee multiplier based on current and target outbound fee surplus

func (*GasMgrV112) EndBlock added in v1.112.0

func (gm *GasMgrV112) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV112) GetFee added in v1.112.0

func (gm *GasMgrV112) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in asset

func (*GasMgrV112) GetGas added in v1.112.0

func (gm *GasMgrV112) GetGas() common.Gas

GetGas return gas

func (*GasMgrV112) GetGasRate added in v1.112.0

func (gm *GasMgrV112) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV112) GetMaxGas added in v1.112.0

func (gm *GasMgrV112) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV112) GetNetworkFee added in v1.112.0

func (gm *GasMgrV112) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV112) ProcessGas added in v1.112.0

func (gm *GasMgrV112) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrV113 added in v1.113.0

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

GasMgrV113 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV113) AddGasAsset added in v1.113.0

func (gm *GasMgrV113) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV113) BeginBlock added in v1.113.0

func (gm *GasMgrV113) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV113) CalcOutboundFeeMultiplier added in v1.113.0

func (gm *GasMgrV113) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

CalcOutboundFeeMultiplier returns the current outbound fee multiplier based on current and target outbound fee surplus

func (*GasMgrV113) EndBlock added in v1.113.0

func (gm *GasMgrV113) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV113) GetFee added in v1.113.0

func (gm *GasMgrV113) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in asset

func (*GasMgrV113) GetGas added in v1.113.0

func (gm *GasMgrV113) GetGas() common.Gas

GetGas return gas

func (*GasMgrV113) GetGasRate added in v1.113.0

func (gm *GasMgrV113) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV113) GetMaxGas added in v1.113.0

func (gm *GasMgrV113) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV113) GetNetworkFee added in v1.113.0

func (gm *GasMgrV113) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV113) ProcessGas added in v1.113.0

func (gm *GasMgrV113) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrV81 added in v0.81.0

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

GasMgrV81 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV81) AddGasAsset added in v0.81.0

func (gm *GasMgrV81) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV81) BeginBlock added in v0.81.0

func (gm *GasMgrV81) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV81) CalcOutboundFeeMultiplier added in v1.108.0

func (gm *GasMgrV81) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

func (*GasMgrV81) EndBlock added in v0.81.0

func (gm *GasMgrV81) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV81) GetFee added in v0.81.0

func (gm *GasMgrV81) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in RUNE

func (*GasMgrV81) GetGas added in v0.81.0

func (gm *GasMgrV81) GetGas() common.Gas

GetGas return gas

func (*GasMgrV81) GetGasRate added in v0.81.0

func (gm *GasMgrV81) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV81) GetMaxGas added in v0.81.0

func (gm *GasMgrV81) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV81) GetNetworkFee added in v1.97.0

func (gm *GasMgrV81) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV81) ProcessGas added in v0.81.0

func (gm *GasMgrV81) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrV89 added in v1.89.0

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

GasMgrV89 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV89) AddGasAsset added in v1.89.0

func (gm *GasMgrV89) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV89) BeginBlock added in v1.89.0

func (gm *GasMgrV89) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV89) CalcOutboundFeeMultiplier added in v1.108.0

func (gm *GasMgrV89) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

func (*GasMgrV89) EndBlock added in v1.89.0

func (gm *GasMgrV89) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV89) GetFee added in v1.89.0

func (gm *GasMgrV89) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in RUNE

func (*GasMgrV89) GetGas added in v1.89.0

func (gm *GasMgrV89) GetGas() common.Gas

GetGas return gas

func (*GasMgrV89) GetGasRate added in v1.89.0

func (gm *GasMgrV89) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV89) GetMaxGas added in v1.89.0

func (gm *GasMgrV89) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV89) GetNetworkFee added in v1.97.0

func (gm *GasMgrV89) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV89) ProcessGas added in v1.89.0

func (gm *GasMgrV89) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrV94 added in v1.95.0

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

GasMgrV94 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV94) AddGasAsset added in v1.95.0

func (gm *GasMgrV94) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV94) BeginBlock added in v1.95.0

func (gm *GasMgrV94) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV94) CalcOutboundFeeMultiplier added in v1.108.0

func (gm *GasMgrV94) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

func (*GasMgrV94) EndBlock added in v1.95.0

func (gm *GasMgrV94) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV94) GetFee added in v1.95.0

func (gm *GasMgrV94) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in RUNE

func (*GasMgrV94) GetGas added in v1.95.0

func (gm *GasMgrV94) GetGas() common.Gas

GetGas return gas

func (*GasMgrV94) GetGasRate added in v1.95.0

func (gm *GasMgrV94) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV94) GetMaxGas added in v1.95.0

func (gm *GasMgrV94) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV94) GetNetworkFee added in v1.97.0

func (gm *GasMgrV94) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV94) ProcessGas added in v1.95.0

func (gm *GasMgrV94) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrV99 added in v1.99.0

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

GasMgrV99 implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrV99) AddGasAsset added in v1.99.0

func (gm *GasMgrV99) AddGasAsset(_ common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset to the EventGas

func (*GasMgrV99) BeginBlock added in v1.99.0

func (gm *GasMgrV99) BeginBlock(mgr Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrV99) CalcOutboundFeeMultiplier added in v1.108.0

func (gm *GasMgrV99) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

func (*GasMgrV99) EndBlock added in v1.99.0

func (gm *GasMgrV99) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrV99) GetFee added in v1.99.0

func (gm *GasMgrV99) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in RUNE

func (*GasMgrV99) GetGas added in v1.99.0

func (gm *GasMgrV99) GetGas() common.Gas

GetGas return gas

func (*GasMgrV99) GetGasRate added in v1.99.0

func (gm *GasMgrV99) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrV99) GetMaxGas added in v1.99.0

func (gm *GasMgrV99) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrV99) GetNetworkFee added in v1.99.0

func (gm *GasMgrV99) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrV99) ProcessGas added in v1.99.0

func (gm *GasMgrV99) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the pool with RUNE for the gas they have spent

type GasMgrVCUR added in v1.116.0

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

GasMgrVCUR implement GasManager interface which will store the gas related events happened in thorchain to memory emit GasEvent per block if there are any

func (*GasMgrVCUR) AddGasAsset added in v1.116.0

func (gm *GasMgrVCUR) AddGasAsset(outAsset common.Asset, gas common.Gas, increaseTxCount bool)

AddGasAsset for EndBlock's ProcessGas; add the outbound-Asset-associated Gas to the gas manager's outAssetGas, and optionally increment the gas manager's gasCount.

func (*GasMgrVCUR) BeginBlock added in v1.116.0

func (gm *GasMgrVCUR) BeginBlock(_ Manager)

BeginBlock need to be called when a new block get created , update the internal EventGas to new one

func (*GasMgrVCUR) CalcOutboundFeeMultiplier added in v1.116.0

func (gm *GasMgrVCUR) CalcOutboundFeeMultiplier(ctx cosmos.Context, targetSurplusRune, gasSpentRune, gasWithheldRune, maxMultiplier, minMultiplier cosmos.Uint) cosmos.Uint

CalcOutboundFeeMultiplier returns the current outbound fee multiplier based on current and target outbound fee surplus

func (*GasMgrVCUR) EndBlock added in v1.116.0

func (gm *GasMgrVCUR) EndBlock(ctx cosmos.Context, keeper keeper.Keeper, eventManager EventManager)

EndBlock emit the events

func (*GasMgrVCUR) GetFee added in v1.116.0

func (gm *GasMgrVCUR) GetFee(ctx cosmos.Context, chain common.Chain, asset common.Asset) cosmos.Uint

GetFee retrieve the network fee information from kv store, and calculate the dynamic fee customer should pay the return value is the amount of fee in asset

func (*GasMgrVCUR) GetGas added in v1.116.0

func (gm *GasMgrVCUR) GetGas() common.Gas

GetGas return gas

func (*GasMgrVCUR) GetGasRate added in v1.116.0

func (gm *GasMgrVCUR) GetGasRate(ctx cosmos.Context, chain common.Chain) cosmos.Uint

GetGasRate return the gas rate

func (*GasMgrVCUR) GetMaxGas added in v1.116.0

func (gm *GasMgrVCUR) GetMaxGas(ctx cosmos.Context, chain common.Chain) (common.Coin, error)

GetMaxGas will calculate the maximum gas fee a tx can use

func (*GasMgrVCUR) GetNetworkFee added in v1.116.0

func (gm *GasMgrVCUR) GetNetworkFee(ctx cosmos.Context, chain common.Chain) (types.NetworkFee, error)

func (*GasMgrVCUR) ProcessGas added in v1.116.0

func (gm *GasMgrVCUR) ProcessGas(ctx cosmos.Context, keeper keeper.Keeper)

ProcessGas to subsidise the gas asset pools with RUNE for the gas they have spent

type GasPool

type GasPool = types.GasPool

type GenesisState

type GenesisState struct {
	Pools                   []types.Pool                                                        `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools"`
	LiquidityProviders      gitlab_com_thorchain_thornode_x_thorchain_types.LiquidityProviders  `` /* 185-byte string literal not displayed */
	ObservedTxInVoters      gitlab_com_thorchain_thornode_x_thorchain_types.ObservedTxVoters    `` /* 187-byte string literal not displayed */
	ObservedTxOutVoters     gitlab_com_thorchain_thornode_x_thorchain_types.ObservedTxVoters    `` /* 190-byte string literal not displayed */
	TxOuts                  []types.TxOut                                                       `protobuf:"bytes,5,rep,name=tx_outs,json=txOuts,proto3" json:"tx_outs"`
	NodeAccounts            gitlab_com_thorchain_thornode_x_thorchain_types.NodeAccounts        `` /* 161-byte string literal not displayed */
	Vaults                  gitlab_com_thorchain_thornode_x_thorchain_types.Vaults              `protobuf:"bytes,7,rep,name=vaults,proto3,castrepeated=gitlab.com/thorchain/thornode/x/thorchain/types.Vaults" json:"vaults"`
	Reserve                 uint64                                                              `protobuf:"varint,8,opt,name=reserve,proto3" json:"reserve,omitempty"`
	LastSignedHeight        int64                                                               `protobuf:"varint,10,opt,name=last_signed_height,json=lastSignedHeight,proto3" json:"last_signed_height,omitempty"`
	LastChainHeights        []LastChainHeight                                                   `protobuf:"bytes,11,rep,name=last_chain_heights,json=lastChainHeights,proto3" json:"last_chain_heights"`
	ReserveContributors     gitlab_com_thorchain_thornode_x_thorchain_types.ReserveContributors `` /* 190-byte string literal not displayed */
	Network                 types.Network                                                       `protobuf:"bytes,13,opt,name=network,proto3" json:"network"`
	OrderbookItems          []types.MsgSwap                                                     `protobuf:"bytes,19,rep,name=orderbook_items,json=orderbookItems,proto3" json:"orderbook_items"`
	NetworkFees             []types.NetworkFee                                                  `protobuf:"bytes,20,rep,name=network_fees,json=networkFees,proto3" json:"network_fees"`
	ChainContracts          []types.ChainContract                                               `protobuf:"bytes,22,rep,name=chain_contracts,json=chainContracts,proto3" json:"chain_contracts"`
	THORNames               []types.THORName                                                    `protobuf:"bytes,23,rep,name=THORNames,proto3" json:"THORNames"`
	Mimirs                  []Mimir                                                             `protobuf:"bytes,24,rep,name=mimirs,proto3" json:"mimirs"`
	StoreVersion            int64                                                               `protobuf:"varint,25,opt,name=store_version,json=storeVersion,proto3" json:"store_version,omitempty"`
	BondProviders           []types.BondProviders                                               `protobuf:"bytes,26,rep,name=bond_providers,json=bondProviders,proto3" json:"bond_providers"`
	POL                     types.ProtocolOwnedLiquidity                                        `protobuf:"bytes,27,opt,name=POL,proto3" json:"POL"`
	Loans                   []types.Loan                                                        `protobuf:"bytes,28,rep,name=loans,proto3" json:"loans"`
	StreamingSwaps          []types.StreamingSwap                                               `protobuf:"bytes,29,rep,name=streaming_swaps,json=streamingSwaps,proto3" json:"streaming_swaps"`
	SwapQueueItems          []types.MsgSwap                                                     `protobuf:"bytes,30,rep,name=swap_queue_items,json=swapQueueItems,proto3" json:"swap_queue_items"`
	SwapperClout            []types.SwapperClout                                                `protobuf:"bytes,31,rep,name=swapper_clout,json=swapperClout,proto3" json:"swapper_clout"`
	TradeAccounts           []types.TradeAccount                                                `protobuf:"bytes,32,rep,name=trade_accounts,json=tradeAccounts,proto3" json:"trade_accounts"`
	TradeUnits              []types.TradeUnit                                                   `protobuf:"bytes,33,rep,name=trade_units,json=tradeUnits,proto3" json:"trade_units"`
	OutboundFeeWithheldRune gitlab_com_thorchain_thornode_common.Coins                          `` /* 181-byte string literal not displayed */
	OutboundFeeSpentRune    gitlab_com_thorchain_thornode_common.Coins                          `` /* 172-byte string literal not displayed */
}

func DefaultGenesisState

func DefaultGenesisState() GenesisState

DefaultGenesisState the default values THORNode put in the Genesis

func ExportGenesis

func ExportGenesis(ctx cosmos.Context, k keeper.Keeper) GenesisState

ExportGenesis export the data in Genesis

func NewGenesisState

func NewGenesisState() GenesisState

NewGenesisState create a new instance of GenesisState

func (*GenesisState) Descriptor added in v0.41.0

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) GetBondProviders added in v0.81.0

func (m *GenesisState) GetBondProviders() []types.BondProviders

func (*GenesisState) GetChainContracts added in v0.41.0

func (m *GenesisState) GetChainContracts() []types.ChainContract

func (*GenesisState) GetLastChainHeights added in v0.41.0

func (m *GenesisState) GetLastChainHeights() []LastChainHeight

func (*GenesisState) GetLastSignedHeight added in v0.41.0

func (m *GenesisState) GetLastSignedHeight() int64

func (*GenesisState) GetLiquidityProviders added in v0.41.0

func (*GenesisState) GetLoans added in v1.121.0

func (m *GenesisState) GetLoans() []types.Loan

func (*GenesisState) GetMimirs added in v0.75.0

func (m *GenesisState) GetMimirs() []Mimir

func (*GenesisState) GetNetwork added in v0.41.0

func (m *GenesisState) GetNetwork() types.Network

func (*GenesisState) GetNetworkFees added in v0.41.0

func (m *GenesisState) GetNetworkFees() []types.NetworkFee

func (*GenesisState) GetNodeAccounts added in v0.41.0

func (*GenesisState) GetObservedTxInVoters added in v0.41.0

func (*GenesisState) GetObservedTxOutVoters added in v0.41.0

func (*GenesisState) GetOrderbookItems added in v1.121.0

func (m *GenesisState) GetOrderbookItems() []types.MsgSwap

func (*GenesisState) GetOutboundFeeSpentRune added in v1.131.0

func (m *GenesisState) GetOutboundFeeSpentRune() gitlab_com_thorchain_thornode_common.Coins

func (*GenesisState) GetOutboundFeeWithheldRune added in v1.131.0

func (m *GenesisState) GetOutboundFeeWithheldRune() gitlab_com_thorchain_thornode_common.Coins

func (*GenesisState) GetPOL added in v1.121.0

func (*GenesisState) GetPools added in v0.41.0

func (m *GenesisState) GetPools() []types.Pool

func (*GenesisState) GetReserve added in v0.41.0

func (m *GenesisState) GetReserve() uint64

func (*GenesisState) GetReserveContributors added in v0.41.0

func (*GenesisState) GetStoreVersion added in v0.75.0

func (m *GenesisState) GetStoreVersion() int64

func (*GenesisState) GetStreamingSwaps added in v1.121.0

func (m *GenesisState) GetStreamingSwaps() []types.StreamingSwap

func (*GenesisState) GetSwapQueueItems added in v1.121.0

func (m *GenesisState) GetSwapQueueItems() []types.MsgSwap

func (*GenesisState) GetSwapperClout added in v1.125.0

func (m *GenesisState) GetSwapperClout() []types.SwapperClout

func (*GenesisState) GetTHORNames added in v0.58.0

func (m *GenesisState) GetTHORNames() []types.THORName

func (*GenesisState) GetTradeAccounts added in v1.128.0

func (m *GenesisState) GetTradeAccounts() []types.TradeAccount

func (*GenesisState) GetTradeUnits added in v1.128.0

func (m *GenesisState) GetTradeUnits() []types.TradeUnit

func (*GenesisState) GetTxOuts added in v0.41.0

func (m *GenesisState) GetTxOuts() []types.TxOut

func (*GenesisState) GetVaults added in v0.41.0

func (*GenesisState) Marshal added in v0.41.0

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo added in v0.41.0

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer added in v0.41.0

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage added in v0.41.0

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset added in v0.41.0

func (m *GenesisState) Reset()

func (*GenesisState) Size added in v0.41.0

func (m *GenesisState) Size() (n int)

func (*GenesisState) String added in v0.41.0

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal added in v0.41.0

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (*GenesisState) XXX_DiscardUnknown added in v0.41.0

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal added in v0.41.0

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge added in v0.41.0

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size added in v0.41.0

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal added in v0.41.0

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type IPAddressHandler

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

IPAddressHandler is to handle ip address message

func NewIPAddressHandler

func NewIPAddressHandler(mgr Manager) IPAddressHandler

NewIPAddressHandler create new instance of IPAddressHandler

func (IPAddressHandler) Run

Run it the main entry point to execute ip address logic

type InfiniteGasDecorator added in v1.115.0

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

InfiniteGasDecorator uses an infinite gas meter to prevent out-of-gas panics and allow non-versioned changes to be made without breaking consensus, as long as the resulting state is consistent.

func NewInfiniteGasDecorator added in v1.115.0

func NewInfiniteGasDecorator(keeper keeper.Keeper) InfiniteGasDecorator

func (InfiniteGasDecorator) AnteHandle added in v1.115.0

func (d InfiniteGasDecorator) AnteHandle(ctx sdk.Context, tx sdk.Tx, simulate bool, next sdk.AnteHandler) (newCtx sdk.Context, err error)

type Jail

type Jail = types.Jail

type Keygen

type Keygen = types.Keygen

type KeygenBlock

type KeygenBlock = types.KeygenBlock

type LadderDispatch added in v1.107.0

type LadderDispatch[F interface{}] struct {
	// contains filtered or unexported fields
}

func NewHandlers added in v1.107.0

func NewHandlers[M cosmos.Msg]() LadderDispatch[func(cosmos.Context, Manager, M) (*cosmos.Result, error)]

func NewValidators added in v1.107.0

func NewValidators[M cosmos.Msg]() LadderDispatch[func(cosmos.Context, Manager, M) error]

Sadly Go's type system is still primitive and does not allow for generics in type aliases, so the following cleaner convenience type does not work:

type Validators[M MsgType] = LadderDispatch[func(cosmos.Context, Manager, M) error]

See https://github.com/golang/go/issues/46477 for ongoing discussion.

Instead we use these thin convenience functions to do the same type wrapping:

func (LadderDispatch[F]) Get added in v1.107.0

func (l LadderDispatch[F]) Get(targetVersion semver.Version) F

Return the most recent handler that supports the target version.

func (LadderDispatch[F]) Register added in v1.107.0

func (l LadderDispatch[F]) Register(version string, handler F) LadderDispatch[F]

Register a handler for a specific version. Enforces descending order of registered versions.

type LastChainHeight added in v0.75.0

type LastChainHeight struct {
	Chain  string `protobuf:"bytes,1,opt,name=chain,proto3" json:"chain,omitempty"`
	Height int64  `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
}

func (*LastChainHeight) Descriptor added in v0.75.0

func (*LastChainHeight) Descriptor() ([]byte, []int)

func (*LastChainHeight) GetChain added in v0.75.0

func (m *LastChainHeight) GetChain() string

func (*LastChainHeight) GetHeight added in v0.75.0

func (m *LastChainHeight) GetHeight() int64

func (*LastChainHeight) Marshal added in v0.75.0

func (m *LastChainHeight) Marshal() (dAtA []byte, err error)

func (*LastChainHeight) MarshalTo added in v0.75.0

func (m *LastChainHeight) MarshalTo(dAtA []byte) (int, error)

func (*LastChainHeight) MarshalToSizedBuffer added in v0.75.0

func (m *LastChainHeight) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LastChainHeight) ProtoMessage added in v0.75.0

func (*LastChainHeight) ProtoMessage()

func (*LastChainHeight) Reset added in v0.75.0

func (m *LastChainHeight) Reset()

func (*LastChainHeight) Size added in v0.75.0

func (m *LastChainHeight) Size() (n int)

func (*LastChainHeight) String added in v0.75.0

func (m *LastChainHeight) String() string

func (*LastChainHeight) Unmarshal added in v0.75.0

func (m *LastChainHeight) Unmarshal(dAtA []byte) error

func (*LastChainHeight) XXX_DiscardUnknown added in v0.75.0

func (m *LastChainHeight) XXX_DiscardUnknown()

func (*LastChainHeight) XXX_Marshal added in v0.75.0

func (m *LastChainHeight) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LastChainHeight) XXX_Merge added in v0.75.0

func (m *LastChainHeight) XXX_Merge(src proto.Message)

func (*LastChainHeight) XXX_Size added in v0.75.0

func (m *LastChainHeight) XXX_Size() int

func (*LastChainHeight) XXX_Unmarshal added in v0.75.0

func (m *LastChainHeight) XXX_Unmarshal(b []byte) error

type LeaveHandler

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

LeaveHandler a handler to process leave request if an operator of THORChain node would like to leave and get their bond back , they have to send a Leave request through Binance Chain

func NewLeaveHandler

func NewLeaveHandler(mgr Manager) LeaveHandler

NewLeaveHandler create a new LeaveHandler

func (LeaveHandler) Run

func (h LeaveHandler) Run(ctx cosmos.Context, m cosmos.Msg) (*cosmos.Result, error)

Run execute the handler

type LeaveMemo

type LeaveMemo = mem.LeaveMemo

type LiquidityProvider added in v0.41.0

type LiquidityProvider = types.LiquidityProvider

type LiquidityProviders added in v0.41.0

type LiquidityProviders = types.LiquidityProviders

type Loan added in v1.107.0

type Loan = types.Loan

type LoanOpenHandler added in v1.107.0

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

LoanOpenHandler a handler to process bond

func NewLoanOpenHandler added in v1.107.0

func NewLoanOpenHandler(mgr Manager) LoanOpenHandler

NewLoanOpenHandler create new LoanOpenHandler

func (LoanOpenHandler) GetLoanCollateralRemainingForPool added in v1.126.0

func (h LoanOpenHandler) GetLoanCollateralRemainingForPool(ctx cosmos.Context, pool Pool) (cosmos.Uint, error)

func (LoanOpenHandler) Run added in v1.107.0

Run execute the handler

type LoanOpenMemo added in v1.107.0

type LoanOpenMemo = mem.LoanOpenMemo

type LoanRepaymentHandler added in v1.107.0

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

LoanRepaymentHandler a handler to process bond

func NewLoanRepaymentHandler added in v1.107.0

func NewLoanRepaymentHandler(mgr Manager) LoanRepaymentHandler

NewLoanRepaymentHandler create new LoanRepaymentHandler

func (LoanRepaymentHandler) Run added in v1.107.0

Run execute the handler

type LoanRepaymentMemo added in v1.107.0

type LoanRepaymentMemo = mem.LoanRepaymentMemo

type Loans added in v1.107.0

type Loans = types.Loans

type ManageTHORNameHandler added in v0.58.0

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

ManageTHORNameHandler a handler to process MsgNetworkFee messages

func NewManageTHORNameHandler added in v0.58.0

func NewManageTHORNameHandler(mgr Manager) ManageTHORNameHandler

NewManageTHORNameHandler create a new instance of network fee handler

func (ManageTHORNameHandler) Run added in v0.58.0

Run is the main entry point for network fee logic

type ManageTHORNameMemo added in v0.58.0

type ManageTHORNameMemo = mem.ManageTHORNameMemo

type Manager

type Manager interface {
	GetConstants() constants.ConstantValues
	GetVersion() semver.Version
	Keeper() keeper.Keeper
	GasMgr() GasManager
	EventMgr() EventManager
	TxOutStore() TxOutStore
	NetworkMgr() NetworkManager
	ValidatorMgr() ValidatorManager
	ObMgr() ObserverManager
	PoolMgr() PoolManager
	SwapQ() SwapQueue
	OrderBookMgr() OrderBook
	Slasher() Slasher
	YggManager() YggManager // TODO remove on hard fork
	TradeAccountManager() TradeAccountManager
}

Manager is an interface to define all the required methods

type Mgrs

type Mgrs struct {
	K keeper.Keeper
	// contains filtered or unexported fields
}

Mgrs is an implementation of Manager interface

func NewManagers

func NewManagers(keeper keeper.Keeper, cdc codec.Codec, coinKeeper bankkeeper.Keeper, accountKeeper authkeeper.AccountKeeper, storeKey cosmos.StoreKey) *Mgrs

NewManagers create a new Manager

func (*Mgrs) BeginBlock

func (mgr *Mgrs) BeginBlock(ctx cosmos.Context) error

BeginBlock detect whether there are new version available, if it is available then create a new version of Mgr

func (*Mgrs) EventMgr

func (mgr *Mgrs) EventMgr() EventManager

EventMgr return EventMgr

func (*Mgrs) GasMgr

func (mgr *Mgrs) GasMgr() GasManager

GasMgr return GasManager

func (*Mgrs) GetConstants added in v0.56.0

func (mgr *Mgrs) GetConstants() constants.ConstantValues

func (*Mgrs) GetVersion added in v0.55.0

func (mgr *Mgrs) GetVersion() semver.Version

func (*Mgrs) Keeper

func (mgr *Mgrs) Keeper() keeper.Keeper

Keeper return Keeper

func (*Mgrs) NetworkMgr added in v1.88.0

func (mgr *Mgrs) NetworkMgr() NetworkManager

VaultMgr return a valid NetworkManager

func (*Mgrs) ObMgr

func (mgr *Mgrs) ObMgr() ObserverManager

ObMgr return an implementation of ObserverManager

func (*Mgrs) OrderBookMgr added in v1.96.1

func (mgr *Mgrs) OrderBookMgr() OrderBook

OrderBookMgr

func (*Mgrs) PoolMgr added in v1.96.1

func (mgr *Mgrs) PoolMgr() PoolManager

PoolMgr return a valid PoolManager

func (*Mgrs) Slasher

func (mgr *Mgrs) Slasher() Slasher

Slasher return an implementation of Slasher

func (*Mgrs) SwapQ

func (mgr *Mgrs) SwapQ() SwapQueue

SwapQ return an implementation of SwapQueue

func (*Mgrs) TradeAccountManager added in v1.128.0

func (mgr *Mgrs) TradeAccountManager() TradeAccountManager

func (*Mgrs) TxOutStore

func (mgr *Mgrs) TxOutStore() TxOutStore

TxOutStore return an TxOutStore

func (*Mgrs) ValidatorMgr

func (mgr *Mgrs) ValidatorMgr() ValidatorManager

ValidatorMgr return an implementation of ValidatorManager

func (*Mgrs) YggManager

func (mgr *Mgrs) YggManager() YggManager

YggManager return an implementation of YggManager TODO remove on hard fork

type MigrateHandler

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

MigrateHandler is a handler to process MsgMigrate

func NewMigrateHandler

func NewMigrateHandler(mgr Manager) MigrateHandler

NewMigrateHandler create a new instance of MigrateHandler

func (MigrateHandler) Run

Run is the main entry point of Migrate handler

type MigrateMemo

type MigrateMemo = mem.MigrateMemo

type Mimir added in v0.75.0

type Mimir struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value int64  `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Mimir) Descriptor added in v0.75.0

func (*Mimir) Descriptor() ([]byte, []int)

func (*Mimir) GetKey added in v0.75.0

func (m *Mimir) GetKey() string

func (*Mimir) GetValue added in v0.75.0

func (m *Mimir) GetValue() int64

func (*Mimir) Marshal added in v0.75.0

func (m *Mimir) Marshal() (dAtA []byte, err error)

func (*Mimir) MarshalTo added in v0.75.0

func (m *Mimir) MarshalTo(dAtA []byte) (int, error)

func (*Mimir) MarshalToSizedBuffer added in v0.75.0

func (m *Mimir) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Mimir) ProtoMessage added in v0.75.0

func (*Mimir) ProtoMessage()

func (*Mimir) Reset added in v0.75.0

func (m *Mimir) Reset()

func (*Mimir) Size added in v0.75.0

func (m *Mimir) Size() (n int)

func (*Mimir) String added in v0.75.0

func (m *Mimir) String() string

func (*Mimir) Unmarshal added in v0.75.0

func (m *Mimir) Unmarshal(dAtA []byte) error

func (*Mimir) XXX_DiscardUnknown added in v0.75.0

func (m *Mimir) XXX_DiscardUnknown()

func (*Mimir) XXX_Marshal added in v0.75.0

func (m *Mimir) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Mimir) XXX_Merge added in v0.75.0

func (m *Mimir) XXX_Merge(src proto.Message)

func (*Mimir) XXX_Size added in v0.75.0

func (m *Mimir) XXX_Size() int

func (*Mimir) XXX_Unmarshal added in v0.75.0

func (m *Mimir) XXX_Unmarshal(b []byte) error

type MimirHandler

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

MimirHandler is to handle admin messages

func NewMimirHandler

func NewMimirHandler(mgr Manager) MimirHandler

NewMimirHandler create new instance of MimirHandler

func (MimirHandler) Run

func (h MimirHandler) Run(ctx cosmos.Context, m cosmos.Msg) (*cosmos.Result, error)

Run is the main entry point to execute mimir logic

type ModuleBalanceAction added in v1.116.0

type ModuleBalanceAction struct {
	ModuleName     string
	RuneRecipient  string
	RuneToTransfer cosmos.Uint
	SynthsToBurn   common.Coins
}

send RuneToTransfer from ModuleName to RuneRecipient burn SynthsToBurn from ModuleName

type MsgAddLiquidity added in v0.41.0

type MsgAddLiquidity = types.MsgAddLiquidity

type MsgBan

type MsgBan = types.MsgBan

type MsgBond

type MsgBond = types.MsgBond

type MsgConsolidate added in v0.54.0

type MsgConsolidate = types.MsgConsolidate

type MsgDeposit added in v0.41.0

type MsgDeposit = types.MsgDeposit

type MsgDonate added in v0.41.0

type MsgDonate = types.MsgDonate

type MsgErrataTx

type MsgErrataTx = types.MsgErrataTx

type MsgHandler

type MsgHandler interface {
	Run(ctx cosmos.Context, msg cosmos.Msg) (*cosmos.Result, error)
}

MsgHandler is an interface expect all handler to implement

type MsgLeave

type MsgLeave = types.MsgLeave

type MsgLoanOpen added in v1.107.0

type MsgLoanOpen = types.MsgLoanOpen

type MsgLoanRepayment added in v1.107.0

type MsgLoanRepayment = types.MsgLoanRepayment

type MsgManageTHORName added in v0.58.0

type MsgManageTHORName = types.MsgManageTHORName

type MsgMigrate

type MsgMigrate = types.MsgMigrate

type MsgMimir

type MsgMimir = types.MsgMimir

type MsgNetworkFee

type MsgNetworkFee = types.MsgNetworkFee

type MsgNoOp

type MsgNoOp = types.MsgNoOp

type MsgNodePauseChain added in v0.65.0

type MsgNodePauseChain = types.MsgNodePauseChain

type MsgObservedTxIn

type MsgObservedTxIn = types.MsgObservedTxIn

type MsgObservedTxOut

type MsgObservedTxOut = types.MsgObservedTxOut

type MsgOutboundTx

type MsgOutboundTx = types.MsgOutboundTx

type MsgRagnarok

type MsgRagnarok = types.MsgRagnarok

type MsgRefundTx

type MsgRefundTx = types.MsgRefundTx

type MsgReserveContributor

type MsgReserveContributor = types.MsgReserveContributor

type MsgSend

type MsgSend = types.MsgSend

type MsgSetIPAddress

type MsgSetIPAddress = types.MsgSetIPAddress

type MsgSetNodeKeys

type MsgSetNodeKeys = types.MsgSetNodeKeys

type MsgSetVersion

type MsgSetVersion = types.MsgSetVersion

type MsgSolvency added in v0.63.0

type MsgSolvency = types.MsgSolvency

type MsgSwap

type MsgSwap = types.MsgSwap

type MsgSwitch

type MsgSwitch = types.MsgSwitch

type MsgTradeAccountDeposit added in v1.128.0

type MsgTradeAccountDeposit = types.MsgTradeAccountDeposit

type MsgTradeAccountWithdrawal added in v1.128.0

type MsgTradeAccountWithdrawal = types.MsgTradeAccountWithdrawal

type MsgTssKeysignFail

type MsgTssKeysignFail = types.MsgTssKeysignFail

type MsgTssPool

type MsgTssPool = types.MsgTssPool

type MsgUnBond

type MsgUnBond = types.MsgUnBond

type MsgWithdrawLiquidity added in v0.41.0

type MsgWithdrawLiquidity = types.MsgWithdrawLiquidity

type MsgYggdrasil

type MsgYggdrasil = types.MsgYggdrasil

type Network added in v0.41.0

type Network = types.Network

type NetworkFee

type NetworkFee = types.NetworkFee

type NetworkFeeHandler

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

NetworkFeeHandler a handler to process MsgNetworkFee messages

func NewNetworkFeeHandler

func NewNetworkFeeHandler(mgr Manager) NetworkFeeHandler

NewNetworkFeeHandler create a new instance of network fee handler

func (NetworkFeeHandler) Run

Run is the main entry point for network fee logic

type NetworkManager added in v0.41.0

type NetworkManager interface {
	TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error
	RotateVault(ctx cosmos.Context, vault Vault) error
	BeginBlock(ctx cosmos.Context, mgr Manager) error
	EndBlock(ctx cosmos.Context, mgr Manager) error
	UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error
	RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNode common.PubKeys) error
	SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)
	CalcAnchor(_ cosmos.Context, _ Manager, _ common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)
}

NetworkManager interface define the contract of network Manager

func GetNetworkManager added in v0.69.0

func GetNetworkManager(version semver.Version, keeper keeper.Keeper, txOutStore TxOutStore, eventMgr EventManager) (NetworkManager, error)

GetNetworkManager retrieve a NetworkManager that is compatible with the given version

type NetworkMgrV102 added in v1.102.0

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

NetworkMgrV102 is going to manage the vaults

func (*NetworkMgrV102) BeginBlock added in v1.102.0

func (vm *NetworkMgrV102) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV102) CalcAnchor added in v1.120.0

func (*NetworkMgrV102) EndBlock added in v1.102.0

func (vm *NetworkMgrV102) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV102) POLCycle added in v1.102.0

func (vm *NetworkMgrV102) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV102) RecallChainFunds added in v1.102.0

func (vm *NetworkMgrV102) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV102) RotateVault added in v1.102.0

func (vm *NetworkMgrV102) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV102) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV102) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV102) TriggerKeygen added in v1.102.0

func (vm *NetworkMgrV102) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV102) UpdateNetwork added in v1.102.0

func (vm *NetworkMgrV102) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV106 added in v1.106.0

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

NetworkMgrV106 is going to manage the vaults

func (*NetworkMgrV106) BeginBlock added in v1.106.0

func (vm *NetworkMgrV106) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV106) CalcAnchor added in v1.120.0

func (*NetworkMgrV106) EndBlock added in v1.106.0

func (vm *NetworkMgrV106) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV106) POLCycle added in v1.106.0

func (vm *NetworkMgrV106) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV106) RecallChainFunds added in v1.106.0

func (vm *NetworkMgrV106) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV106) RotateVault added in v1.106.0

func (vm *NetworkMgrV106) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV106) SpawnDerivedAsset added in v1.106.0

func (vm *NetworkMgrV106) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV106) TriggerKeygen added in v1.106.0

func (vm *NetworkMgrV106) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV106) UpdateNetwork added in v1.106.0

func (vm *NetworkMgrV106) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV107 added in v1.107.0

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

NetworkMgrV107 is going to manage the vaults

func (*NetworkMgrV107) BeginBlock added in v1.107.0

func (vm *NetworkMgrV107) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV107) CalcAnchor added in v1.120.0

func (*NetworkMgrV107) EndBlock added in v1.107.0

func (vm *NetworkMgrV107) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV107) POLCycle added in v1.107.0

func (vm *NetworkMgrV107) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV107) RecallChainFunds added in v1.107.0

func (vm *NetworkMgrV107) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV107) RotateVault added in v1.107.0

func (vm *NetworkMgrV107) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV107) SpawnDerivedAsset added in v1.107.0

func (vm *NetworkMgrV107) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV107) TriggerKeygen added in v1.107.0

func (vm *NetworkMgrV107) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV107) UpdateNetwork added in v1.107.0

func (vm *NetworkMgrV107) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV109 added in v1.109.0

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

NetworkMgrV109 is going to manage the vaults

func (*NetworkMgrV109) BeginBlock added in v1.109.0

func (vm *NetworkMgrV109) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV109) CalcAnchor added in v1.120.0

func (*NetworkMgrV109) EndBlock added in v1.109.0

func (vm *NetworkMgrV109) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV109) POLCycle added in v1.109.0

func (vm *NetworkMgrV109) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV109) RecallChainFunds added in v1.109.0

func (vm *NetworkMgrV109) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV109) RotateVault added in v1.109.0

func (vm *NetworkMgrV109) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV109) SpawnDerivedAsset added in v1.109.0

func (vm *NetworkMgrV109) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV109) TriggerKeygen added in v1.109.0

func (vm *NetworkMgrV109) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV109) UpdateNetwork added in v1.109.0

func (vm *NetworkMgrV109) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV111 added in v1.111.0

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

NetworkMgrV111 is going to manage the vaults

func (*NetworkMgrV111) BeginBlock added in v1.111.0

func (vm *NetworkMgrV111) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV111) CalcAnchor added in v1.120.0

func (*NetworkMgrV111) EndBlock added in v1.111.0

func (vm *NetworkMgrV111) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV111) POLCycle added in v1.111.0

func (vm *NetworkMgrV111) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV111) RecallChainFunds added in v1.111.0

func (vm *NetworkMgrV111) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV111) RotateVault added in v1.111.0

func (vm *NetworkMgrV111) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV111) SpawnDerivedAsset added in v1.111.0

func (vm *NetworkMgrV111) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV111) TriggerKeygen added in v1.111.0

func (vm *NetworkMgrV111) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV111) UpdateNetwork added in v1.111.0

func (vm *NetworkMgrV111) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV112 added in v1.112.0

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

NetworkMgrV112 is going to manage the vaults

func (*NetworkMgrV112) BeginBlock added in v1.112.0

func (vm *NetworkMgrV112) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV112) CalcAnchor added in v1.120.0

func (*NetworkMgrV112) EndBlock added in v1.112.0

func (vm *NetworkMgrV112) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV112) POLCycle added in v1.112.0

func (vm *NetworkMgrV112) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV112) RecallChainFunds added in v1.112.0

func (vm *NetworkMgrV112) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV112) RotateVault added in v1.112.0

func (vm *NetworkMgrV112) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV112) SpawnDerivedAsset added in v1.112.0

func (vm *NetworkMgrV112) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV112) TriggerKeygen added in v1.112.0

func (vm *NetworkMgrV112) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV112) UpdateNetwork added in v1.112.0

func (vm *NetworkMgrV112) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV115 added in v1.115.0

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

NetworkMgrV115 is going to manage the vaults

func (*NetworkMgrV115) BeginBlock added in v1.115.0

func (vm *NetworkMgrV115) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV115) CalcAnchor added in v1.120.0

func (*NetworkMgrV115) EndBlock added in v1.115.0

func (vm *NetworkMgrV115) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV115) POLCycle added in v1.115.0

func (vm *NetworkMgrV115) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV115) RecallChainFunds added in v1.115.0

func (vm *NetworkMgrV115) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV115) RotateVault added in v1.115.0

func (vm *NetworkMgrV115) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV115) SpawnDerivedAsset added in v1.115.0

func (vm *NetworkMgrV115) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV115) TriggerKeygen added in v1.115.0

func (vm *NetworkMgrV115) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV115) UpdateNetwork added in v1.115.0

func (vm *NetworkMgrV115) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV117 added in v1.120.0

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

NetworkMgrV117 is going to manage the vaults

func (*NetworkMgrV117) BeginBlock added in v1.120.0

func (vm *NetworkMgrV117) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV117) CalcAnchor added in v1.120.0

func (vm *NetworkMgrV117) CalcAnchor(ctx cosmos.Context, mgr Manager, asset common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)

func (*NetworkMgrV117) EndBlock added in v1.120.0

func (vm *NetworkMgrV117) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV117) POLCycle added in v1.120.0

func (vm *NetworkMgrV117) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV117) RecallChainFunds added in v1.120.0

func (vm *NetworkMgrV117) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV117) RotateVault added in v1.120.0

func (vm *NetworkMgrV117) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV117) SpawnDerivedAsset added in v1.120.0

func (vm *NetworkMgrV117) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV117) TriggerKeygen added in v1.120.0

func (vm *NetworkMgrV117) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV117) UpdateNetwork added in v1.120.0

func (vm *NetworkMgrV117) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV120 added in v1.121.0

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

NetworkMgrV120 is going to manage the vaults

func (*NetworkMgrV120) BeginBlock added in v1.121.0

func (vm *NetworkMgrV120) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV120) CalcAnchor added in v1.121.0

func (vm *NetworkMgrV120) CalcAnchor(ctx cosmos.Context, mgr Manager, asset common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)

func (*NetworkMgrV120) EndBlock added in v1.121.0

func (vm *NetworkMgrV120) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV120) POLCycle added in v1.121.0

func (vm *NetworkMgrV120) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV120) RecallChainFunds added in v1.121.0

func (vm *NetworkMgrV120) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV120) RotateVault added in v1.121.0

func (vm *NetworkMgrV120) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV120) SpawnDerivedAsset added in v1.121.0

func (vm *NetworkMgrV120) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV120) TriggerKeygen added in v1.121.0

func (vm *NetworkMgrV120) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV120) UpdateNetwork added in v1.121.0

func (vm *NetworkMgrV120) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV121 added in v1.124.0

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

NetworkMgrV121 is going to manage the vaults

func (*NetworkMgrV121) BeginBlock added in v1.124.0

func (vm *NetworkMgrV121) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV121) CalcAnchor added in v1.124.0

func (vm *NetworkMgrV121) CalcAnchor(ctx cosmos.Context, mgr Manager, asset common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)

func (*NetworkMgrV121) EndBlock added in v1.124.0

func (vm *NetworkMgrV121) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV121) POLCycle added in v1.124.0

func (vm *NetworkMgrV121) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV121) RecallChainFunds added in v1.124.0

func (vm *NetworkMgrV121) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV121) RotateVault added in v1.124.0

func (vm *NetworkMgrV121) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV121) SpawnDerivedAsset added in v1.124.0

func (vm *NetworkMgrV121) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV121) TriggerKeygen added in v1.124.0

func (vm *NetworkMgrV121) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV121) UpdateNetwork added in v1.124.0

func (vm *NetworkMgrV121) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV124 added in v1.126.0

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

NetworkMgrV124 is going to manage the vaults

func (*NetworkMgrV124) BeginBlock added in v1.126.0

func (vm *NetworkMgrV124) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV124) CalcAnchor added in v1.126.0

func (vm *NetworkMgrV124) CalcAnchor(ctx cosmos.Context, mgr Manager, asset common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)

func (*NetworkMgrV124) EndBlock added in v1.126.0

func (vm *NetworkMgrV124) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV124) POLCycle added in v1.126.0

func (vm *NetworkMgrV124) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV124) RecallChainFunds added in v1.126.0

func (vm *NetworkMgrV124) RecallChainFunds(_ cosmos.Context, _ common.Chain, _ Manager, _ common.PubKeys) error

TODO remove on hard fork

func (*NetworkMgrV124) RotateVault added in v1.126.0

func (vm *NetworkMgrV124) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV124) SpawnDerivedAsset added in v1.126.0

func (vm *NetworkMgrV124) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV124) TriggerKeygen added in v1.126.0

func (vm *NetworkMgrV124) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV124) UpdateNetwork added in v1.126.0

func (vm *NetworkMgrV124) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV126 added in v1.128.0

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

NetworkMgrV126 is going to manage the vaults

func (*NetworkMgrV126) BeginBlock added in v1.128.0

func (vm *NetworkMgrV126) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV126) CalcAnchor added in v1.128.0

func (vm *NetworkMgrV126) CalcAnchor(ctx cosmos.Context, mgr Manager, asset common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)

func (*NetworkMgrV126) EndBlock added in v1.128.0

func (vm *NetworkMgrV126) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV126) POLCycle added in v1.128.0

func (vm *NetworkMgrV126) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV126) RecallChainFunds added in v1.128.0

func (vm *NetworkMgrV126) RecallChainFunds(_ cosmos.Context, _ common.Chain, _ Manager, _ common.PubKeys) error

TODO remove on hard fork

func (*NetworkMgrV126) RotateVault added in v1.128.0

func (vm *NetworkMgrV126) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV126) SpawnDerivedAsset added in v1.128.0

func (vm *NetworkMgrV126) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV126) TriggerKeygen added in v1.128.0

func (vm *NetworkMgrV126) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV126) UpdateNetwork added in v1.128.0

func (vm *NetworkMgrV126) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV128 added in v1.129.0

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

NetworkMgrV128 is going to manage the vaults

func (*NetworkMgrV128) BeginBlock added in v1.129.0

func (vm *NetworkMgrV128) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV128) CalcAnchor added in v1.129.0

func (vm *NetworkMgrV128) CalcAnchor(ctx cosmos.Context, mgr Manager, asset common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)

func (*NetworkMgrV128) EndBlock added in v1.129.0

func (vm *NetworkMgrV128) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV128) POLCycle added in v1.129.0

func (vm *NetworkMgrV128) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV128) RecallChainFunds added in v1.129.0

func (vm *NetworkMgrV128) RecallChainFunds(_ cosmos.Context, _ common.Chain, _ Manager, _ common.PubKeys) error

TODO remove on hard fork

func (*NetworkMgrV128) RotateVault added in v1.129.0

func (vm *NetworkMgrV128) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV128) SpawnDerivedAsset added in v1.129.0

func (vm *NetworkMgrV128) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV128) TriggerKeygen added in v1.129.0

func (vm *NetworkMgrV128) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV128) UpdateNetwork added in v1.129.0

func (vm *NetworkMgrV128) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV129 added in v1.131.0

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

NetworkMgrV129 is going to manage the vaults

func (*NetworkMgrV129) BeginBlock added in v1.131.0

func (vm *NetworkMgrV129) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV129) CalcAnchor added in v1.131.0

func (vm *NetworkMgrV129) CalcAnchor(ctx cosmos.Context, mgr Manager, asset common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)

func (*NetworkMgrV129) EndBlock added in v1.131.0

func (vm *NetworkMgrV129) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV129) POLCycle added in v1.131.0

func (vm *NetworkMgrV129) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV129) RecallChainFunds added in v1.131.0

func (vm *NetworkMgrV129) RecallChainFunds(_ cosmos.Context, _ common.Chain, _ Manager, _ common.PubKeys) error

TODO remove on hard fork

func (*NetworkMgrV129) RotateVault added in v1.131.0

func (vm *NetworkMgrV129) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV129) SpawnDerivedAsset added in v1.131.0

func (vm *NetworkMgrV129) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV129) TriggerKeygen added in v1.131.0

func (vm *NetworkMgrV129) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV129) UpdateNetwork added in v1.131.0

func (vm *NetworkMgrV129) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV76 added in v0.76.0

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

NetworkMgrV76 is going to manage the vaults

func (*NetworkMgrV76) BeginBlock added in v1.102.0

func (vm *NetworkMgrV76) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV76) CalcAnchor added in v1.120.0

func (*NetworkMgrV76) EndBlock added in v0.76.0

func (vm *NetworkMgrV76) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV76) RecallChainFunds added in v0.76.0

func (vm *NetworkMgrV76) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV76) RotateVault added in v0.76.0

func (vm *NetworkMgrV76) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV76) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV76) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV76) TriggerKeygen added in v0.76.0

func (vm *NetworkMgrV76) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV76) UpdateNetwork added in v0.76.0

func (vm *NetworkMgrV76) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV87 added in v1.87.0

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

NetworkMgrV87 is going to manage the vaults

func (*NetworkMgrV87) BeginBlock added in v1.102.0

func (vm *NetworkMgrV87) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV87) CalcAnchor added in v1.120.0

func (*NetworkMgrV87) EndBlock added in v1.87.0

func (vm *NetworkMgrV87) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV87) RecallChainFunds added in v1.87.0

func (vm *NetworkMgrV87) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV87) RotateVault added in v1.87.0

func (vm *NetworkMgrV87) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV87) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV87) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV87) TriggerKeygen added in v1.87.0

func (vm *NetworkMgrV87) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV87) UpdateNetwork added in v1.87.0

func (vm *NetworkMgrV87) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV89 added in v1.89.0

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

NetworkMgrV89 is going to manage the vaults

func (*NetworkMgrV89) BeginBlock added in v1.102.0

func (vm *NetworkMgrV89) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV89) CalcAnchor added in v1.120.0

func (*NetworkMgrV89) EndBlock added in v1.89.0

func (vm *NetworkMgrV89) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV89) RecallChainFunds added in v1.89.0

func (vm *NetworkMgrV89) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV89) RotateVault added in v1.89.0

func (vm *NetworkMgrV89) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV89) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV89) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV89) TriggerKeygen added in v1.89.0

func (vm *NetworkMgrV89) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV89) UpdateNetwork added in v1.89.0

func (vm *NetworkMgrV89) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV90 added in v1.90.0

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

NetworkMgrV90 is going to manage the vaults

func (*NetworkMgrV90) BeginBlock added in v1.102.0

func (vm *NetworkMgrV90) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV90) CalcAnchor added in v1.120.0

func (*NetworkMgrV90) EndBlock added in v1.90.0

func (vm *NetworkMgrV90) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV90) RecallChainFunds added in v1.90.0

func (vm *NetworkMgrV90) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV90) RotateVault added in v1.90.0

func (vm *NetworkMgrV90) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV90) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV90) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV90) TriggerKeygen added in v1.90.0

func (vm *NetworkMgrV90) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV90) UpdateNetwork added in v1.90.0

func (vm *NetworkMgrV90) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV91 added in v1.91.0

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

NetworkMgrV91 is going to manage the vaults

func (*NetworkMgrV91) BeginBlock added in v1.102.0

func (vm *NetworkMgrV91) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV91) CalcAnchor added in v1.120.0

func (*NetworkMgrV91) EndBlock added in v1.91.0

func (vm *NetworkMgrV91) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV91) RecallChainFunds added in v1.91.0

func (vm *NetworkMgrV91) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV91) RotateVault added in v1.91.0

func (vm *NetworkMgrV91) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV91) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV91) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV91) TriggerKeygen added in v1.91.0

func (vm *NetworkMgrV91) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV91) UpdateNetwork added in v1.91.0

func (vm *NetworkMgrV91) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV92 added in v1.92.0

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

NetworkMgrV92 is going to manage the vaults

func (*NetworkMgrV92) BeginBlock added in v1.102.0

func (vm *NetworkMgrV92) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV92) CalcAnchor added in v1.120.0

func (*NetworkMgrV92) EndBlock added in v1.92.0

func (vm *NetworkMgrV92) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV92) RecallChainFunds added in v1.92.0

func (vm *NetworkMgrV92) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV92) RotateVault added in v1.92.0

func (vm *NetworkMgrV92) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV92) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV92) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV92) TriggerKeygen added in v1.92.0

func (vm *NetworkMgrV92) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV92) UpdateNetwork added in v1.92.0

func (vm *NetworkMgrV92) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV93 added in v1.93.0

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

NetworkMgrV93 is going to manage the vaults

func (*NetworkMgrV93) BeginBlock added in v1.102.0

func (vm *NetworkMgrV93) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV93) CalcAnchor added in v1.120.0

func (*NetworkMgrV93) EndBlock added in v1.93.0

func (vm *NetworkMgrV93) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV93) RecallChainFunds added in v1.93.0

func (vm *NetworkMgrV93) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV93) RotateVault added in v1.93.0

func (vm *NetworkMgrV93) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV93) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV93) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV93) TriggerKeygen added in v1.93.0

func (vm *NetworkMgrV93) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV93) UpdateNetwork added in v1.93.0

func (vm *NetworkMgrV93) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV94 added in v1.95.0

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

NetworkMgrV94 is going to manage the vaults

func (*NetworkMgrV94) BeginBlock added in v1.102.0

func (vm *NetworkMgrV94) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV94) CalcAnchor added in v1.120.0

func (*NetworkMgrV94) EndBlock added in v1.95.0

func (vm *NetworkMgrV94) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV94) RecallChainFunds added in v1.95.0

func (vm *NetworkMgrV94) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV94) RotateVault added in v1.95.0

func (vm *NetworkMgrV94) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV94) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV94) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV94) TriggerKeygen added in v1.95.0

func (vm *NetworkMgrV94) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV94) UpdateNetwork added in v1.95.0

func (vm *NetworkMgrV94) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV95 added in v1.95.0

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

NetworkMgrV95 is going to manage the vaults

func (*NetworkMgrV95) BeginBlock added in v1.102.0

func (vm *NetworkMgrV95) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV95) CalcAnchor added in v1.120.0

func (*NetworkMgrV95) EndBlock added in v1.95.0

func (vm *NetworkMgrV95) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV95) POLCycle added in v1.95.0

func (vm *NetworkMgrV95) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV95) RecallChainFunds added in v1.95.0

func (vm *NetworkMgrV95) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV95) RotateVault added in v1.95.0

func (vm *NetworkMgrV95) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV95) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV95) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV95) TriggerKeygen added in v1.95.0

func (vm *NetworkMgrV95) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV95) UpdateNetwork added in v1.95.0

func (vm *NetworkMgrV95) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV96 added in v1.96.1

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

NetworkMgrV96 is going to manage the vaults

func (*NetworkMgrV96) BeginBlock added in v1.102.0

func (vm *NetworkMgrV96) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV96) CalcAnchor added in v1.120.0

func (*NetworkMgrV96) EndBlock added in v1.96.1

func (vm *NetworkMgrV96) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV96) POLCycle added in v1.96.1

func (vm *NetworkMgrV96) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV96) RecallChainFunds added in v1.96.1

func (vm *NetworkMgrV96) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV96) RotateVault added in v1.96.1

func (vm *NetworkMgrV96) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV96) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV96) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV96) TriggerKeygen added in v1.96.1

func (vm *NetworkMgrV96) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV96) UpdateNetwork added in v1.96.1

func (vm *NetworkMgrV96) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV98 added in v1.98.0

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

NetworkMgrV98 is going to manage the vaults

func (*NetworkMgrV98) BeginBlock added in v1.102.0

func (vm *NetworkMgrV98) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV98) CalcAnchor added in v1.120.0

func (*NetworkMgrV98) EndBlock added in v1.98.0

func (vm *NetworkMgrV98) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV98) POLCycle added in v1.98.0

func (vm *NetworkMgrV98) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV98) RecallChainFunds added in v1.98.0

func (vm *NetworkMgrV98) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV98) RotateVault added in v1.98.0

func (vm *NetworkMgrV98) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV98) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV98) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV98) TriggerKeygen added in v1.98.0

func (vm *NetworkMgrV98) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV98) UpdateNetwork added in v1.98.0

func (vm *NetworkMgrV98) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrV99 added in v1.99.0

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

NetworkMgrV99 is going to manage the vaults

func (*NetworkMgrV99) BeginBlock added in v1.102.0

func (vm *NetworkMgrV99) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV99) CalcAnchor added in v1.120.0

func (*NetworkMgrV99) EndBlock added in v1.99.0

func (vm *NetworkMgrV99) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrV99) POLCycle added in v1.99.0

func (vm *NetworkMgrV99) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrV99) RecallChainFunds added in v1.99.0

func (vm *NetworkMgrV99) RecallChainFunds(ctx cosmos.Context, chain common.Chain, mgr Manager, excludeNodes common.PubKeys) error

RecallChainFunds - sends a message to bifrost nodes to send back all funds associated with given chain

func (*NetworkMgrV99) RotateVault added in v1.99.0

func (vm *NetworkMgrV99) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrV99) SpawnDerivedAsset added in v1.103.0

func (vm *NetworkMgrV99) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrV99) TriggerKeygen added in v1.99.0

func (vm *NetworkMgrV99) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrV99) UpdateNetwork added in v1.99.0

func (vm *NetworkMgrV99) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NetworkMgrVCUR added in v1.116.0

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

NetworkMgrVCUR is going to manage the vaults

func (*NetworkMgrVCUR) BeginBlock added in v1.116.0

func (vm *NetworkMgrVCUR) BeginBlock(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrVCUR) CalcAnchor added in v1.120.0

func (vm *NetworkMgrVCUR) CalcAnchor(ctx cosmos.Context, mgr Manager, asset common.Asset) (cosmos.Uint, cosmos.Uint, cosmos.Uint)

func (*NetworkMgrVCUR) EndBlock added in v1.116.0

func (vm *NetworkMgrVCUR) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock move funds from retiring asgard vaults

func (*NetworkMgrVCUR) POLCycle added in v1.116.0

func (vm *NetworkMgrVCUR) POLCycle(ctx cosmos.Context, mgr Manager) error

func (*NetworkMgrVCUR) RecallChainFunds added in v1.116.0

func (vm *NetworkMgrVCUR) RecallChainFunds(_ cosmos.Context, _ common.Chain, _ Manager, _ common.PubKeys) error

TODO remove on hard fork

func (*NetworkMgrVCUR) RotateVault added in v1.116.0

func (vm *NetworkMgrVCUR) RotateVault(ctx cosmos.Context, vault Vault) error

RotateVault update vault to Retiring and new vault to active

func (*NetworkMgrVCUR) SpawnDerivedAsset added in v1.116.0

func (vm *NetworkMgrVCUR) SpawnDerivedAsset(ctx cosmos.Context, asset common.Asset, mgr Manager)

func (*NetworkMgrVCUR) TriggerKeygen added in v1.116.0

func (vm *NetworkMgrVCUR) TriggerKeygen(ctx cosmos.Context, nas NodeAccounts) error

TriggerKeygen generate a record to instruct signer kick off keygen process

func (*NetworkMgrVCUR) UpdateNetwork added in v1.116.0

func (vm *NetworkMgrVCUR) UpdateNetwork(ctx cosmos.Context, constAccessor constants.ConstantValues, gasManager GasManager, eventMgr EventManager) error

UpdateNetwork Update the network data to reflect changing in this block

type NoOpHandler added in v0.41.0

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

NoOpHandler is to handle donate message

func NewNoOpHandler added in v0.41.0

func NewNoOpHandler(mgr Manager) NoOpHandler

NewNoOpHandler create a new instance of NoOpHandler

func (NoOpHandler) Run added in v0.41.0

func (h NoOpHandler) Run(ctx cosmos.Context, m cosmos.Msg) (*cosmos.Result, error)

Run is the main entry point to execute donate logic

type NoOpMemo added in v0.41.0

type NoOpMemo = mem.NoOpMemo

type Node added in v0.41.0

type Node = types.Node

type NodeAccount

type NodeAccount = types.NodeAccount

type NodeAccounts

type NodeAccounts = types.NodeAccounts

type NodeMimir added in v0.78.0

type NodeMimir = types.NodeMimir

type NodeMimirs added in v0.78.0

type NodeMimirs = types.NodeMimirs

type NodePauseChainHandler added in v0.65.0

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

NodePauseChainHandler is to handle node pause chain messages

func NewNodePauseChainHandler added in v0.65.0

func NewNodePauseChainHandler(mgr Manager) NodePauseChainHandler

NewNodePauseChainHandler create new instance of NodePauseChainHandler

func (NodePauseChainHandler) Run added in v0.65.0

Run is the main entry point to execute node pause chain logic

type NodeStatus

type NodeStatus = types.NodeStatus

type ObservedNetworkFeeVoter

type ObservedNetworkFeeVoter = types.ObservedNetworkFeeVoter

type ObservedTx

type ObservedTx = types.ObservedTx

type ObservedTxInHandler

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

ObservedTxInHandler to handle MsgObservedTxIn

func NewObservedTxInHandler

func NewObservedTxInHandler(mgr Manager) ObservedTxInHandler

NewObservedTxInHandler create a new instance of ObservedTxInHandler

func (ObservedTxInHandler) Run

Run is the main entry point of ObservedTxInHandler

type ObservedTxOutHandler

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

ObservedTxOutHandler process MsgObservedTxOut messages

func NewObservedTxOutHandler

func NewObservedTxOutHandler(mgr Manager) ObservedTxOutHandler

NewObservedTxOutHandler create a new instance of ObservedTxOutHandler

func (ObservedTxOutHandler) Run

Run is the main entry point for ObservedTxOutHandler

type ObservedTxVoter

type ObservedTxVoter = types.ObservedTxVoter

type ObservedTxVoters

type ObservedTxVoters = types.ObservedTxVoters

type ObservedTxs

type ObservedTxs = types.ObservedTxs

type ObserverManager

type ObserverManager interface {
	BeginBlock()
	EndBlock(ctx cosmos.Context, keeper keeper.Keeper)
	AppendObserver(chain common.Chain, addrs []cosmos.AccAddress)
	List() []cosmos.AccAddress
}

ObserverManager define the method to manage observes

func GetObserverManager

func GetObserverManager(version semver.Version) (ObserverManager, error)

GetObserverManager return an instance that implements ObserverManager interface when there is no version can match the given semver , it will return nil

type ObserverMgrVCUR added in v1.116.0

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

ObserverMgrVCUR implement a ObserverManager which will store the observers in memory before written to chain

func (*ObserverMgrVCUR) AppendObserver added in v1.116.0

func (om *ObserverMgrVCUR) AppendObserver(chain common.Chain, addrs []cosmos.AccAddress)

AppendObserver add the address

func (*ObserverMgrVCUR) BeginBlock added in v1.116.0

func (om *ObserverMgrVCUR) BeginBlock()

BeginBlock called when a new block get proposed

func (*ObserverMgrVCUR) EndBlock added in v1.116.0

func (om *ObserverMgrVCUR) EndBlock(ctx cosmos.Context, keeper keeper.Keeper)

EndBlock emit the observers

func (*ObserverMgrVCUR) List added in v1.116.0

func (om *ObserverMgrVCUR) List() []cosmos.AccAddress

List - gets a list of addresses that have been observed in all chains

type OrderBook added in v1.96.1

type OrderBook interface {
	EndBlock(ctx cosmos.Context, mgr Manager) error
}

OrderBook interface define the contract of Order Book

func GetOrderBook added in v1.96.1

func GetOrderBook(version semver.Version, keeper keeper.Keeper) (OrderBook, error)

GetOrderBook retrieve a OrderBook that is compatible with the given version

type OrderBookV1 added in v1.96.1

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

OrderBookV1 is going to manage the swaps queue

func (*OrderBookV1) AddOrderBookItem added in v1.96.1

func (ob *OrderBookV1) AddOrderBookItem(ctx cosmos.Context, msg MsgSwap) error

func (*OrderBookV1) EndBlock added in v1.96.1

func (ob *OrderBookV1) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*OrderBookV1) FetchQueue added in v1.96.1

func (ob *OrderBookV1) FetchQueue(ctx cosmos.Context, mgr Manager, pairs tradePairs, pools Pools) (orderItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type OrderBookV103 added in v1.103.0

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

OrderBookV103 is going to manage the swaps queue

func (*OrderBookV103) AddOrderBookItem added in v1.103.0

func (ob *OrderBookV103) AddOrderBookItem(ctx cosmos.Context, msg MsgSwap) error

func (*OrderBookV103) EndBlock added in v1.103.0

func (ob *OrderBookV103) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*OrderBookV103) FetchQueue added in v1.103.0

func (ob *OrderBookV103) FetchQueue(ctx cosmos.Context, mgr Manager, pairs tradePairs, pools Pools) (orderItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type OrderBookVCUR added in v1.116.0

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

OrderBookVCUR is going to manage the swaps queue

func (*OrderBookVCUR) AddOrderBookItem added in v1.116.0

func (ob *OrderBookVCUR) AddOrderBookItem(ctx cosmos.Context, msg MsgSwap) error

func (*OrderBookVCUR) EndBlock added in v1.116.0

func (ob *OrderBookVCUR) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*OrderBookVCUR) FetchQueue added in v1.116.0

func (ob *OrderBookVCUR) FetchQueue(ctx cosmos.Context, mgr Manager, pairs tradePairs, pools Pools) (orderItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type OutAssetGas added in v1.131.0

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

type OutboundMemo

type OutboundMemo = mem.OutboundMemo

type OutboundTxHandler

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

func NewOutboundTxHandler

func NewOutboundTxHandler(mgr Manager) OutboundTxHandler

func (OutboundTxHandler) Run

type Pool

type Pool = types.Pool

type PoolAmt

type PoolAmt = types.PoolAmt

type PoolManager added in v1.96.1

type PoolManager interface {
	EndBlock(ctx cosmos.Context, mgr Manager) error
}

PoolManager interface define the contract of PoolManager

func GetPoolManager added in v1.96.1

func GetPoolManager(version semver.Version) (PoolManager, error)

GetPoolManager return an implementation of PoolManager

type PoolMgrV108 added in v1.108.0

type PoolMgrV108 struct{}

func (*PoolMgrV108) EndBlock added in v1.108.0

func (pm *PoolMgrV108) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock cycle pools if required and if ragnarok is not in progress

type PoolMgrV112 added in v1.112.0

type PoolMgrV112 struct{}

func (*PoolMgrV112) EndBlock added in v1.112.0

func (pm *PoolMgrV112) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock cycle pools if required and if ragnarok is not in progress

type PoolMgrV116 added in v1.121.0

type PoolMgrV116 struct{}

func (*PoolMgrV116) EndBlock added in v1.121.0

func (pm *PoolMgrV116) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock cycle pools if required and if ragnarok is not in progress

type PoolMgrV73 added in v1.96.1

type PoolMgrV73 struct{}

func (*PoolMgrV73) EndBlock added in v1.96.1

func (pm *PoolMgrV73) EndBlock(ctx cosmos.Context, mgr Manager) error

type PoolMgrV95 added in v1.96.1

type PoolMgrV95 struct{}

func (*PoolMgrV95) EndBlock added in v1.96.1

func (pm *PoolMgrV95) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock cycle pools if required and if ragnarok is not in progress

type PoolMgrV98 added in v1.98.0

type PoolMgrV98 struct{}

func (*PoolMgrV98) EndBlock added in v1.98.0

func (pm *PoolMgrV98) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock cycle pools if required and if ragnarok is not in progress

type PoolMgrVCUR added in v1.116.0

type PoolMgrVCUR struct{}

func (*PoolMgrVCUR) EndBlock added in v1.116.0

func (pm *PoolMgrVCUR) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock cycle pools if required and if ragnarok is not in progress

type PoolMod

type PoolMod = types.PoolMod

type PoolMods

type PoolMods = types.PoolMods

type PoolStatus

type PoolStatus = types.PoolStatus

type Pools

type Pools = types.Pools

type PreRegisterTHORName added in v1.88.0

type PreRegisterTHORName struct {
	Name    string
	Address string
}

type ProtoInt64 added in v1.121.0

type ProtoInt64 = types.ProtoInt64

type ProtoStrings added in v1.96.1

type ProtoStrings = types.ProtoStrings

Proto

type ProtocolOwnedLiquidity added in v1.95.0

type ProtocolOwnedLiquidity = types.ProtocolOwnedLiquidity

type RagnarokHandler

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

RagnarokHandler process MsgRagnarok

func NewRagnarokHandler

func NewRagnarokHandler(mgr Manager) RagnarokHandler

NewRagnarokHandler create a new instance of RagnarokHandler

func (RagnarokHandler) Run

Run is the main entry point of ragnarok handler

type RagnarokMemo

type RagnarokMemo = mem.RagnarokMemo

type RagnarokWithdrawPosition added in v0.41.0

type RagnarokWithdrawPosition = types.RagnarokWithdrawPosition

type RefundHandler

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

RefundHandler a handle to process tx that had refund memo usually this type or tx is because Thorchain fail to process the tx, which result in a refund, signer honour the tx and refund customer accordingly

func NewRefundHandler

func NewRefundHandler(mgr Manager) RefundHandler

NewRefundHandler create a new refund handler

func (RefundHandler) Run

Run is the main entry point to process refund outbound message

type RefundMemo

type RefundMemo = mem.RefundMemo

type ReserveContributor

type ReserveContributor = types.ReserveContributor

type ReserveContributorHandler

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

ReserveContributorHandler is handler to process MsgReserveContributor

func NewReserveContributorHandler

func NewReserveContributorHandler(mgr Manager) ReserveContributorHandler

NewReserveContributorHandler create a new instance of ReserveContributorHandler

func (ReserveContributorHandler) Run

Run is the main entry point for ReserveContributorHandler

type ReserveContributors

type ReserveContributors = types.ReserveContributors

type ReserveMemo

type ReserveMemo = mem.ReserveMemo

type RouterUpgradeController added in v0.59.1

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

func NewRouterUpgradeController added in v0.59.1

func NewRouterUpgradeController(mgr Manager) *RouterUpgradeController

NewRouterUpgradeController create a new instance of RouterUpgradeController

func (*RouterUpgradeController) Process added in v0.59.1

func (r *RouterUpgradeController) Process(ctx cosmos.Context)

Process is the main entry of router upgrade controller refunds all USDT liquidity, and then upgrades contract all these steps are controlled by mimir

type SetNodeKeysHandler

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

SetNodeKeysHandler process MsgSetNodeKeys MsgSetNodeKeys is used by operators after the node account had been white list , to update the consensus pubkey and node account pubkey

func NewSetNodeKeysHandler

func NewSetNodeKeysHandler(mgr Manager) SetNodeKeysHandler

NewSetNodeKeysHandler create a new instance of SetNodeKeysHandler

func (SetNodeKeysHandler) Run

Run is the main entry point to process MsgSetNodeKeys

type Slasher

type Slasher interface {
	BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)
	LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error
	LackSigning(ctx cosmos.Context, mgr Manager) error
	SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error
	IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)
	DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)
}

Slasher define all the method to perform slash

func GetSlasher

func GetSlasher(version semver.Version, keeper keeper.Keeper, eventMgr EventManager) (Slasher, error)

GetSlasher return an implementation of Slasher

type SlasherV108 added in v1.108.0

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

SlasherV108 is v88 implementation of slasher

func (*SlasherV108) BeginBlock added in v1.108.0

func (s *SlasherV108) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV108) DecSlashPoints added in v1.108.0

func (s *SlasherV108) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV108) HandleDoubleSign added in v1.108.0

func (s *SlasherV108) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV108) IncSlashPoints added in v1.108.0

func (s *SlasherV108) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV108) LackObserving added in v1.108.0

func (s *SlasherV108) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV108) LackSigning added in v1.108.0

func (s *SlasherV108) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV108) SlashVault added in v1.108.0

func (s *SlasherV108) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV109 added in v1.109.0

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

SlasherV109 is v88 implementation of slasher

func (*SlasherV109) BeginBlock added in v1.109.0

func (s *SlasherV109) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV109) DecSlashPoints added in v1.109.0

func (s *SlasherV109) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV109) HandleDoubleSign added in v1.109.0

func (s *SlasherV109) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV109) IncSlashPoints added in v1.109.0

func (s *SlasherV109) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV109) LackObserving added in v1.109.0

func (s *SlasherV109) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV109) LackSigning added in v1.109.0

func (s *SlasherV109) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV109) SlashVault added in v1.109.0

func (s *SlasherV109) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV112 added in v1.112.0

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

SlasherV112 is v88 implementation of slasher

func (*SlasherV112) BeginBlock added in v1.112.0

func (s *SlasherV112) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV112) DecSlashPoints added in v1.112.0

func (s *SlasherV112) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV112) HandleDoubleSign added in v1.112.0

func (s *SlasherV112) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV112) IncSlashPoints added in v1.112.0

func (s *SlasherV112) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV112) LackObserving added in v1.112.0

func (s *SlasherV112) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV112) LackSigning added in v1.112.0

func (s *SlasherV112) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV112) SlashVault added in v1.112.0

func (s *SlasherV112) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV115 added in v1.115.0

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

SlasherV115 is v88 implementation of slasher

func (*SlasherV115) BeginBlock added in v1.115.0

func (s *SlasherV115) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV115) DecSlashPoints added in v1.115.0

func (s *SlasherV115) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV115) HandleDoubleSign added in v1.115.0

func (s *SlasherV115) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV115) IncSlashPoints added in v1.115.0

func (s *SlasherV115) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV115) LackObserving added in v1.115.0

func (s *SlasherV115) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV115) LackSigning added in v1.115.0

func (s *SlasherV115) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV115) SlashVault added in v1.115.0

func (s *SlasherV115) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV116 added in v1.124.0

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

SlasherV116 is v88 implementation of slasher

func (*SlasherV116) BeginBlock added in v1.124.0

func (s *SlasherV116) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV116) DecSlashPoints added in v1.124.0

func (s *SlasherV116) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV116) HandleDoubleSign added in v1.124.0

func (s *SlasherV116) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV116) IncSlashPoints added in v1.124.0

func (s *SlasherV116) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV116) LackObserving added in v1.124.0

func (s *SlasherV116) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV116) LackSigning added in v1.124.0

func (s *SlasherV116) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV116) SlashVault added in v1.124.0

func (s *SlasherV116) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV124 added in v1.125.0

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

SlasherV124 is V124 implementation of slasher

func (*SlasherV124) BeginBlock added in v1.125.0

func (s *SlasherV124) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV124) DecSlashPoints added in v1.125.0

func (s *SlasherV124) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV124) HandleDoubleSign added in v1.125.0

func (s *SlasherV124) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPairV124) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV124) HandleMissingSign added in v1.125.0

func (s *SlasherV124) HandleMissingSign(ctx cosmos.Context, addr crypto.Address, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPairV124) error

HandleMissingSign - slashes a validator for not signing a block

func (*SlasherV124) IncSlashPoints added in v1.125.0

func (s *SlasherV124) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV124) LackObserving added in v1.125.0

func (s *SlasherV124) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV124) LackSigning added in v1.125.0

func (s *SlasherV124) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV124) SlashVault added in v1.125.0

func (s *SlasherV124) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV125 added in v1.126.0

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

SlasherV125 is VCUR implementation of slasher

func (*SlasherV125) BeginBlock added in v1.126.0

func (s *SlasherV125) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV125) DecSlashPoints added in v1.126.0

func (s *SlasherV125) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV125) HandleDoubleSign added in v1.126.0

func (s *SlasherV125) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV125) HandleMissingSign added in v1.126.0

func (s *SlasherV125) HandleMissingSign(ctx cosmos.Context, addr crypto.Address, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleMissingSign - slashes a validator for not signing a block

func (*SlasherV125) IncSlashPoints added in v1.126.0

func (s *SlasherV125) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV125) LackObserving added in v1.126.0

func (s *SlasherV125) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV125) LackSigning added in v1.126.0

func (s *SlasherV125) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV125) SlashVault added in v1.126.0

func (s *SlasherV125) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV126 added in v1.127.0

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

SlasherV126 is V126 implementation of slasher

func (*SlasherV126) BeginBlock added in v1.127.0

func (s *SlasherV126) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV126) DecSlashPoints added in v1.127.0

func (s *SlasherV126) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV126) HandleDoubleSign added in v1.127.0

func (s *SlasherV126) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV126) HandleMissingSign added in v1.127.0

func (s *SlasherV126) HandleMissingSign(ctx cosmos.Context, addr crypto.Address, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleMissingSign - slashes a validator for not signing a block

func (*SlasherV126) IncSlashPoints added in v1.127.0

func (s *SlasherV126) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV126) LackObserving added in v1.127.0

func (s *SlasherV126) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV126) LackSigning added in v1.127.0

func (s *SlasherV126) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV126) SlashVault added in v1.127.0

func (s *SlasherV126) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV127 added in v1.128.0

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

SlasherV127 is V127 implementation of slasher

func (*SlasherV127) BeginBlock added in v1.128.0

func (s *SlasherV127) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV127) DecSlashPoints added in v1.128.0

func (s *SlasherV127) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV127) HandleDoubleSign added in v1.128.0

func (s *SlasherV127) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV127) HandleMissingSign added in v1.128.0

func (s *SlasherV127) HandleMissingSign(ctx cosmos.Context, addr crypto.Address, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleMissingSign - slashes a validator for not signing a block

func (*SlasherV127) IncSlashPoints added in v1.128.0

func (s *SlasherV127) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV127) LackObserving added in v1.128.0

func (s *SlasherV127) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV127) LackSigning added in v1.128.0

func (s *SlasherV127) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV127) SlashVault added in v1.128.0

func (s *SlasherV127) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV128 added in v1.129.0

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

SlasherV128 is V128 implementation of slasher

func (*SlasherV128) BeginBlock added in v1.129.0

func (s *SlasherV128) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV128) DecSlashPoints added in v1.129.0

func (s *SlasherV128) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV128) HandleDoubleSign added in v1.129.0

func (s *SlasherV128) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV128) HandleMissingSign added in v1.129.0

func (s *SlasherV128) HandleMissingSign(ctx cosmos.Context, addr crypto.Address, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleMissingSign - slashes a validator for not signing a block

func (*SlasherV128) IncSlashPoints added in v1.129.0

func (s *SlasherV128) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV128) LackObserving added in v1.129.0

func (s *SlasherV128) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV128) LackSigning added in v1.129.0

func (s *SlasherV128) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV128) SlashVault added in v1.129.0

func (s *SlasherV128) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV129 added in v1.131.0

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

SlasherV129 is V129 implementation of slasher

func (*SlasherV129) BeginBlock added in v1.131.0

func (s *SlasherV129) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV129) DecSlashPoints added in v1.131.0

func (s *SlasherV129) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV129) HandleDoubleSign added in v1.131.0

func (s *SlasherV129) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV129) HandleMissingSign added in v1.131.0

func (s *SlasherV129) HandleMissingSign(ctx cosmos.Context, addr crypto.Address, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleMissingSign - slashes a validator for not signing a block

func (*SlasherV129) IncSlashPoints added in v1.131.0

func (s *SlasherV129) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV129) LackObserving added in v1.131.0

func (s *SlasherV129) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV129) LackSigning added in v1.131.0

func (s *SlasherV129) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV129) SlashVault added in v1.131.0

func (s *SlasherV129) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV75 added in v0.75.0

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

SlasherV75 is v54 implementation of slasher

func (*SlasherV75) BeginBlock added in v0.75.0

func (s *SlasherV75) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV75) DecSlashPoints added in v0.75.0

func (s *SlasherV75) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV75) HandleDoubleSign added in v0.75.0

func (s *SlasherV75) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV75) IncSlashPoints added in v0.75.0

func (s *SlasherV75) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV75) LackObserving added in v0.75.0

func (s *SlasherV75) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV75) LackSigning added in v0.75.0

func (s *SlasherV75) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV75) SlashVault added in v0.75.0

func (s *SlasherV75) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV86 added in v1.86.0

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

SlasherV86 is v54 implementation of slasher

func (*SlasherV86) BeginBlock added in v1.86.0

func (s *SlasherV86) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV86) DecSlashPoints added in v1.86.0

func (s *SlasherV86) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV86) HandleDoubleSign added in v1.86.0

func (s *SlasherV86) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV86) IncSlashPoints added in v1.86.0

func (s *SlasherV86) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV86) LackObserving added in v1.86.0

func (s *SlasherV86) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV86) LackSigning added in v1.86.0

func (s *SlasherV86) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV86) SlashVault added in v1.86.0

func (s *SlasherV86) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV87 added in v1.87.0

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

SlasherV87 is v54 implementation of slasher

func (*SlasherV87) BeginBlock added in v1.87.0

func (s *SlasherV87) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV87) DecSlashPoints added in v1.87.0

func (s *SlasherV87) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV87) HandleDoubleSign added in v1.87.0

func (s *SlasherV87) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV87) IncSlashPoints added in v1.87.0

func (s *SlasherV87) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV87) LackObserving added in v1.87.0

func (s *SlasherV87) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV87) LackSigning added in v1.87.0

func (s *SlasherV87) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV87) SlashVault added in v1.87.0

func (s *SlasherV87) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV88 added in v1.88.0

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

SlasherV88 is v88 implementation of slasher

func (*SlasherV88) BeginBlock added in v1.88.0

func (s *SlasherV88) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV88) DecSlashPoints added in v1.88.0

func (s *SlasherV88) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV88) HandleDoubleSign added in v1.88.0

func (s *SlasherV88) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV88) IncSlashPoints added in v1.88.0

func (s *SlasherV88) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV88) LackObserving added in v1.88.0

func (s *SlasherV88) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV88) LackSigning added in v1.88.0

func (s *SlasherV88) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV88) SlashVault added in v1.88.0

func (s *SlasherV88) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV89 added in v1.89.0

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

SlasherV89 is v88 implementation of slasher

func (*SlasherV89) BeginBlock added in v1.89.0

func (s *SlasherV89) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV89) DecSlashPoints added in v1.89.0

func (s *SlasherV89) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV89) HandleDoubleSign added in v1.89.0

func (s *SlasherV89) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV89) IncSlashPoints added in v1.89.0

func (s *SlasherV89) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV89) LackObserving added in v1.89.0

func (s *SlasherV89) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV89) LackSigning added in v1.89.0

func (s *SlasherV89) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV89) SlashVault added in v1.89.0

func (s *SlasherV89) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherV92 added in v1.92.0

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

SlasherV92 is v88 implementation of slasher

func (*SlasherV92) BeginBlock added in v1.92.0

func (s *SlasherV92) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherV92) DecSlashPoints added in v1.92.0

func (s *SlasherV92) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherV92) HandleDoubleSign added in v1.92.0

func (s *SlasherV92) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherV92) IncSlashPoints added in v1.92.0

func (s *SlasherV92) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherV92) LackObserving added in v1.92.0

func (s *SlasherV92) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherV92) LackSigning added in v1.92.0

func (s *SlasherV92) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherV92) SlashVault added in v1.92.0

func (s *SlasherV92) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool and yggdrasil pool, usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SlasherVCUR added in v1.116.0

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

SlasherVCUR is VCUR implementation of slasher

func (*SlasherVCUR) BeginBlock added in v1.116.0

func (s *SlasherVCUR) BeginBlock(ctx cosmos.Context, req abci.RequestBeginBlock, constAccessor constants.ConstantValues)

BeginBlock called when a new block get proposed to detect whether there are duplicate vote

func (*SlasherVCUR) DecSlashPoints added in v1.116.0

func (s *SlasherVCUR) DecSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

DecSlashPoints will decrease the given account's slash points

func (*SlasherVCUR) HandleDoubleSign added in v1.116.0

func (s *SlasherVCUR) HandleDoubleSign(ctx cosmos.Context, addr crypto.Address, infractionHeight int64, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleDoubleSign - slashes a validator for signing two blocks at the same block height https://blog.cosmos.network/consensus-compare-casper-vs-tendermint-6df154ad56ae

func (*SlasherVCUR) HandleMissingSign added in v1.124.0

func (s *SlasherVCUR) HandleMissingSign(ctx cosmos.Context, addr crypto.Address, constAccessor constants.ConstantValues, validatorAddresses []nodeAddressValidatorAddressPair) error

HandleMissingSign - slashes a validator for not signing a block

func (*SlasherVCUR) IncSlashPoints added in v1.116.0

func (s *SlasherVCUR) IncSlashPoints(ctx cosmos.Context, point int64, addresses ...cosmos.AccAddress)

IncSlashPoints will increase the given account's slash points

func (*SlasherVCUR) LackObserving added in v1.116.0

func (s *SlasherVCUR) LackObserving(ctx cosmos.Context, constAccessor constants.ConstantValues) error

LackObserving Slash node accounts that didn't observe a single inbound txn

func (*SlasherVCUR) LackSigning added in v1.116.0

func (s *SlasherVCUR) LackSigning(ctx cosmos.Context, mgr Manager) error

LackSigning slash account that fail to sign tx

func (*SlasherVCUR) SlashVault added in v1.116.0

func (s *SlasherVCUR) SlashVault(ctx cosmos.Context, vaultPK common.PubKey, coins common.Coins, mgr Manager) error

SlashVault thorchain keep monitoring the outbound tx from asgard pool usually the txout is triggered by thorchain itself by adding an item into the txout array, refer to TxOutItem for the detail, the TxOutItem contains a specific coin and amount. if somehow thorchain discover signer send out fund more than the amount specified in TxOutItem, it will slash the node account who does that by taking 1.5 * extra fund from node account's bond and subsidise the pool that actually lost it.

type SolvencyHandler added in v0.63.0

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

SolvencyHandler is to process MsgSolvency message from bifrost Bifrost constantly monitor the account balance , and report to THORNode If it detect that wallet is short of fund , much less than vault, the network should automatically halt trading

func NewSolvencyHandler added in v0.63.0

func NewSolvencyHandler(mgr Manager) SolvencyHandler

NewSolvencyHandler create a new instance of solvency handler

func (SolvencyHandler) Run added in v0.63.0

Run is the main entry point to process MsgSolvency

type StoreManager

type StoreManager interface {
	Iterator(_ cosmos.Context) error
}

StoreManager define the method as the entry point for store upgrade

type StoreMgr

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

StoreMgr implement StoreManager interface

func (*StoreMgr) Iterator

func (smgr *StoreMgr) Iterator(ctx cosmos.Context) error

Iterator implement StoreManager interface decide whether it need to upgrade store

type StreamingSwap added in v1.115.0

type StreamingSwap = types.StreamingSwap

type StreamingSwaps added in v1.115.0

type StreamingSwaps = types.StreamingSwaps

type SwapHandler

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

SwapHandler is the handler to process swap request

func NewSwapHandler

func NewSwapHandler(mgr Manager) SwapHandler

NewSwapHandler create a new instance of swap handler

func (SwapHandler) Run

func (h SwapHandler) Run(ctx cosmos.Context, m cosmos.Msg) (*cosmos.Result, error)

Run is the main entry point of swap message

type SwapMemo

type SwapMemo = mem.SwapMemo

Memo

type SwapQueue

type SwapQueue interface {
	EndBlock(ctx cosmos.Context, mgr Manager) error
}

SwapQueue interface define the contract of Swap Queue

func GetSwapQueue

func GetSwapQueue(version semver.Version, keeper keeper.Keeper) (SwapQueue, error)

GetSwapQueue retrieve a SwapQueue that is compatible with the given version

type SwapQueueV103 added in v1.103.0

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

SwapQueueV103 is going to manage the swaps queue

func (*SwapQueueV103) EndBlock added in v1.103.0

func (vm *SwapQueueV103) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueV103) FetchQueue added in v1.103.0

func (vm *SwapQueueV103) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQueueV104 added in v1.104.0

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

SwapQueueV104 is going to manage the swaps queue

func (*SwapQueueV104) EndBlock added in v1.104.0

func (vm *SwapQueueV104) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueV104) FetchQueue added in v1.104.0

func (vm *SwapQueueV104) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQueueV115 added in v1.115.0

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

SwapQueueV115 is going to manage the swaps queue

func (*SwapQueueV115) EndBlock added in v1.115.0

func (vm *SwapQueueV115) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueV115) FetchQueue added in v1.115.0

func (vm *SwapQueueV115) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQueueV116 added in v1.117.0

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

SwapQueueV116 is going to manage the swaps queue

func (*SwapQueueV116) EndBlock added in v1.117.0

func (vm *SwapQueueV116) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueV116) FetchQueue added in v1.117.0

func (vm *SwapQueueV116) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQueueV117 added in v1.120.0

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

SwapQueueV117 is going to manage the swaps queue

func (*SwapQueueV117) EndBlock added in v1.120.0

func (vm *SwapQueueV117) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueV117) FetchQueue added in v1.120.0

func (vm *SwapQueueV117) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQueueV120 added in v1.121.0

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

SwapQueueV120 is going to manage the swaps queue

func (*SwapQueueV120) EndBlock added in v1.121.0

func (vm *SwapQueueV120) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueV120) FetchQueue added in v1.121.0

func (vm *SwapQueueV120) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQueueV121 added in v1.123.0

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

SwapQueueV121 is going to manage the swaps queue

func (*SwapQueueV121) EndBlock added in v1.123.0

func (vm *SwapQueueV121) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueV121) FetchQueue added in v1.123.0

func (vm *SwapQueueV121) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQueueV123 added in v1.124.0

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

SwapQueueV123 is going to manage the swaps queue

func (*SwapQueueV123) EndBlock added in v1.124.0

func (vm *SwapQueueV123) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueV123) FetchQueue added in v1.124.0

func (vm *SwapQueueV123) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQueueVCUR added in v1.116.0

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

SwapQueueVCUR is going to manage the swaps queue

func (*SwapQueueVCUR) EndBlock added in v1.116.0

func (vm *SwapQueueVCUR) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQueueVCUR) FetchQueue added in v1.116.0

func (vm *SwapQueueVCUR) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQv58 added in v0.58.0

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

SwapQv58 is going to manage the swaps queue

func (*SwapQv58) EndBlock added in v0.58.0

func (vm *SwapQv58) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQv58) FetchQueue added in v0.58.0

func (vm *SwapQv58) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQv94 added in v1.95.0

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

SwapQv94 is going to manage the swaps queue

func (*SwapQv94) EndBlock added in v1.95.0

func (vm *SwapQv94) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQv94) FetchQueue added in v1.95.0

func (vm *SwapQv94) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type SwapQv95 added in v1.95.0

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

SwapQv95 is going to manage the swaps queue

func (*SwapQv95) EndBlock added in v1.95.0

func (vm *SwapQv95) EndBlock(ctx cosmos.Context, mgr Manager) error

EndBlock trigger the real swap to be processed

func (*SwapQv95) FetchQueue added in v1.95.0

func (vm *SwapQv95) FetchQueue(ctx cosmos.Context) (swapItems, error)

FetchQueue - grabs all swap queue items from the kvstore and returns them

type Swapper added in v1.91.0

type Swapper interface {
	Swap(ctx cosmos.Context,
		keeper keeper.Keeper,
		tx common.Tx,
		target common.Asset,
		destination common.Address,
		swapTarget cosmos.Uint,
		dexAgg string,
		dexAggTargetAsset string,
		dexAggLimit *cosmos.Uint,
		swp StreamingSwap,
		transactionFee cosmos.Uint,
		synthVirtualDepthMult int64,
		mgr Manager,
	) (cosmos.Uint, []*EventSwap, error)
	CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint
	CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint
	CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint
}

Though Swapper is not a full manager, it is recorded here for versioning convenience.

func GetSwapper added in v1.91.0

func GetSwapper(version semver.Version) (Swapper, error)

Though Swapper is not a full manager, it is recorded here for versioning convenience. GetSwapper return an implementation of Swapper

type SwapperClout added in v1.125.0

type SwapperClout = types.SwapperClout

type SwapperV102 added in v1.102.0

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

func (*SwapperV102) CalcAssetEmission added in v1.102.0

func (s *SwapperV102) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV102) CalcLiquidityFee added in v1.102.0

func (s *SwapperV102) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV102) CalcSwapSlip added in v1.102.0

func (s *SwapperV102) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV102) Swap added in v1.102.0

func (s *SwapperV102) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV103 added in v1.103.0

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

func (*SwapperV103) CalcAssetEmission added in v1.103.0

func (s *SwapperV103) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV103) CalcLiquidityFee added in v1.103.0

func (s *SwapperV103) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV103) CalcSwapSlip added in v1.103.0

func (s *SwapperV103) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV103) Swap added in v1.103.0

func (s *SwapperV103) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV110 added in v1.110.0

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

func (*SwapperV110) CalcAssetEmission added in v1.110.0

func (s *SwapperV110) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV110) CalcLiquidityFee added in v1.110.0

func (s *SwapperV110) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV110) CalcSwapSlip added in v1.110.0

func (s *SwapperV110) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV110) Swap added in v1.110.0

func (s *SwapperV110) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV115 added in v1.115.0

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

func (*SwapperV115) CalcAssetEmission added in v1.115.0

func (s *SwapperV115) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV115) CalcLiquidityFee added in v1.115.0

func (s *SwapperV115) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV115) CalcSwapSlip added in v1.115.0

func (s *SwapperV115) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV115) Swap added in v1.115.0

func (s *SwapperV115) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV116 added in v1.116.0

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

func (*SwapperV116) CalcAssetEmission added in v1.116.0

func (s *SwapperV116) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV116) CalcLiquidityFee added in v1.116.0

func (s *SwapperV116) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV116) CalcSwapSlip added in v1.116.0

func (s *SwapperV116) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV116) Swap added in v1.116.0

func (s *SwapperV116) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV117 added in v1.117.0

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

func (*SwapperV117) CalcAssetEmission added in v1.117.0

func (s *SwapperV117) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV117) CalcLiquidityFee added in v1.117.0

func (s *SwapperV117) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV117) CalcSwapSlip added in v1.117.0

func (s *SwapperV117) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV117) Swap added in v1.117.0

func (s *SwapperV117) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV121 added in v1.122.0

type SwapperV121 struct{}

func (*SwapperV121) CalcAssetEmission added in v1.122.0

func (s *SwapperV121) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV121) CalcLiquidityFee added in v1.122.0

func (s *SwapperV121) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV121) CalcSwapSlip added in v1.122.0

func (s *SwapperV121) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV121) Swap added in v1.122.0

func (s *SwapperV121) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV122 added in v1.125.0

type SwapperV122 struct{}

func (*SwapperV122) CalcAssetEmission added in v1.125.0

func (s *SwapperV122) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV122) CalcLiquidityFee added in v1.125.0

func (s *SwapperV122) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV122) CalcSwapSlip added in v1.125.0

func (s *SwapperV122) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV122) Swap added in v1.125.0

func (s *SwapperV122) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV125 added in v1.128.0

type SwapperV125 struct{}

func (*SwapperV125) CalcAssetEmission added in v1.128.0

func (s *SwapperV125) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV125) CalcLiquidityFee added in v1.128.0

func (s *SwapperV125) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV125) CalcSwapSlip added in v1.128.0

func (s *SwapperV125) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV125) Swap added in v1.128.0

func (s *SwapperV125) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV128 added in v1.129.0

type SwapperV128 struct{}

func (*SwapperV128) CalcAssetEmission added in v1.129.0

func (s *SwapperV128) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV128) CalcLiquidityFee added in v1.129.0

func (s *SwapperV128) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV128) CalcMaxAssetEmission added in v1.129.0

func (s *SwapperV128) CalcMaxAssetEmission(X, x, Y, fee cosmos.Uint) cosmos.Uint

calculate the asset amount to be sent to address using a predefined fee (fee calculated using artificial floor) nolint

func (*SwapperV128) CalcMinLiquidityFee added in v1.129.0

func (s *SwapperV128) CalcMinLiquidityFee(X, x, Y, minSlipBps cosmos.Uint) cosmos.Uint

CalcMinLiquidityFee calculates the fee of the swap using min artificial slip floor nolint

func (*SwapperV128) CalcSwapSlip added in v1.129.0

func (s *SwapperV128) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV128) GetSwapCalc added in v1.129.0

func (s *SwapperV128) GetSwapCalc(X, x, Y, slipBps, minSlipBps cosmos.Uint) (emitAssets, liquidityFee, slip cosmos.Uint)

GetSwapCalc returns emission, liquidity fee and slip for a swap nolint

func (*SwapperV128) MinSlipBps added in v1.129.0

func (s *SwapperV128) MinSlipBps(
	ctx cosmos.Context,
	k keeper.Keeper,
	isSynth bool,
	isTradeAccounts bool,
) cosmos.Uint

MinSlipBps returns artificial slip floor, expressed in basis points (10000)

func (*SwapperV128) Swap added in v1.129.0

func (s *SwapperV128) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV81 added in v0.81.0

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

func (*SwapperV81) CalcAssetEmission added in v1.95.0

func (s *SwapperV81) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV81) CalcLiquidityFee added in v1.95.0

func (s *SwapperV81) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

calculateFee the fee of the swap nolint

func (*SwapperV81) CalcSwapSlip added in v1.95.0

func (s *SwapperV81) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV81) Swap added in v1.91.0

func (s *SwapperV81) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint,
	synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV90 added in v1.90.0

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

func (*SwapperV90) CalcAssetEmission added in v1.95.0

func (s *SwapperV90) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV90) CalcLiquidityFee added in v1.95.0

func (s *SwapperV90) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateFee the fee of the swap nolint

func (*SwapperV90) CalcSwapSlip added in v1.95.0

func (s *SwapperV90) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV90) Swap added in v1.91.0

func (s *SwapperV90) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV91 added in v1.91.0

type SwapperV91 struct{}

func (*SwapperV91) CalcAssetEmission added in v1.95.0

func (s *SwapperV91) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV91) CalcLiquidityFee added in v1.95.0

func (s *SwapperV91) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateFee the fee of the swap nolint

func (*SwapperV91) CalcSwapSlip added in v1.95.0

func (s *SwapperV91) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV91) Swap added in v1.91.0

func (s *SwapperV91) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV92 added in v1.92.0

type SwapperV92 struct{}

func (*SwapperV92) CalcAssetEmission added in v1.95.0

func (s *SwapperV92) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV92) CalcLiquidityFee added in v1.95.0

func (s *SwapperV92) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV92) CalcSwapSlip added in v1.95.0

func (s *SwapperV92) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV92) Swap added in v1.92.0

func (s *SwapperV92) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV94 added in v1.95.0

type SwapperV94 struct{}

func (*SwapperV94) CalcAssetEmission added in v1.95.0

func (s *SwapperV94) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV94) CalcLiquidityFee added in v1.95.0

func (s *SwapperV94) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV94) CalcSwapSlip added in v1.95.0

func (s *SwapperV94) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV94) Swap added in v1.95.0

func (s *SwapperV94) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV95 added in v1.95.0

type SwapperV95 struct{}

func (*SwapperV95) CalcAssetEmission added in v1.95.0

func (s *SwapperV95) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV95) CalcLiquidityFee added in v1.95.0

func (s *SwapperV95) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV95) CalcSwapSlip added in v1.95.0

func (s *SwapperV95) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV95) Swap added in v1.95.0

func (s *SwapperV95) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperV98 added in v1.98.0

type SwapperV98 struct{}

func (*SwapperV98) CalcAssetEmission added in v1.98.0

func (s *SwapperV98) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperV98) CalcLiquidityFee added in v1.98.0

func (s *SwapperV98) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperV98) CalcSwapSlip added in v1.98.0

func (s *SwapperV98) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperV98) Swap added in v1.98.0

func (s *SwapperV98) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwapperVCUR added in v1.121.0

type SwapperVCUR struct{}

func (*SwapperVCUR) CalcAssetEmission added in v1.121.0

func (s *SwapperVCUR) CalcAssetEmission(X, x, Y cosmos.Uint) cosmos.Uint

calculate the number of assets sent to the address (includes liquidity fee) nolint

func (*SwapperVCUR) CalcLiquidityFee added in v1.121.0

func (s *SwapperVCUR) CalcLiquidityFee(X, x, Y cosmos.Uint) cosmos.Uint

CalculateLiquidityFee the fee of the swap nolint

func (*SwapperVCUR) CalcMaxAssetEmission added in v1.128.0

func (s *SwapperVCUR) CalcMaxAssetEmission(X, x, Y, fee cosmos.Uint) cosmos.Uint

calculate the asset amount to be sent to address using a predefined fee (fee calculated using artificial floor) nolint

func (*SwapperVCUR) CalcMinLiquidityFee added in v1.128.0

func (s *SwapperVCUR) CalcMinLiquidityFee(X, x, Y, minSlipBps cosmos.Uint) cosmos.Uint

CalcMinLiquidityFee calculates the fee of the swap using min artificial slip floor nolint

func (*SwapperVCUR) CalcSwapSlip added in v1.121.0

func (s *SwapperVCUR) CalcSwapSlip(Xi, xi cosmos.Uint) cosmos.Uint

CalcSwapSlip - calculate the swap slip, expressed in basis points (10000) nolint

func (*SwapperVCUR) GetSwapCalc added in v1.128.0

func (s *SwapperVCUR) GetSwapCalc(X, x, Y, slipBps, minSlipBps cosmos.Uint) (emitAssets, liquidityFee, slip cosmos.Uint)

GetSwapCalc returns emission, liquidity fee and slip for a swap nolint

func (*SwapperVCUR) MinSlipBps added in v1.128.0

func (s *SwapperVCUR) MinSlipBps(
	ctx cosmos.Context,
	k keeper.Keeper,
	isSynth bool,
	isTradeAccounts bool,
) cosmos.Uint

MinSlipBps returns artificial slip floor, expressed in basis points (10000)

func (*SwapperVCUR) Swap added in v1.121.0

func (s *SwapperVCUR) Swap(ctx cosmos.Context,
	keeper keeper.Keeper,
	tx common.Tx,
	target common.Asset,
	destination common.Address,
	swapTarget cosmos.Uint,
	dexAgg string,
	dexAggTargetAsset string,
	dexAggLimit *cosmos.Uint,
	swp StreamingSwap,
	transactionFee cosmos.Uint, synthVirtualDepthMult int64, mgr Manager,
) (cosmos.Uint, []*EventSwap, error)

type SwitchHandler

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

SwitchHandler is to handle Switch message MsgSwitch is used to switch from bep2 RUNE to native RUNE

func NewSwitchHandler

func NewSwitchHandler(mgr Manager) SwitchHandler

NewSwitchHandler create new instance of SwitchHandler

func (SwitchHandler) Run

Run it the main entry point to execute Switch logic

type SwitchMemo

type SwitchMemo = mem.SwitchMemo

type THORName added in v0.58.0

type THORName = types.THORName

type THORNameAlias added in v0.58.0

type THORNameAlias = types.THORNameAlias

type TradeAccount added in v1.128.0

type TradeAccount = types.TradeAccount

type TradeAccountDepositHandler added in v1.128.0

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

TradeAccountDepositHandler is handler to process MsgTradeAccountDeposit

func NewTradeAccountDepositHandler added in v1.128.0

func NewTradeAccountDepositHandler(mgr Manager) TradeAccountDepositHandler

NewTradeAccountDepositHandler create a new instance of TradeAccountDepositHandler

func (TradeAccountDepositHandler) Run added in v1.128.0

Run is the main entry point for TradeAccountDepositHandler

type TradeAccountDepositMemo added in v1.128.0

type TradeAccountDepositMemo = mem.TradeAccountDepositMemo

type TradeAccountManager added in v1.128.0

type TradeAccountManager interface {
	EndBlock(ctx cosmos.Context, keeper keeper.Keeper) error
	Deposit(_ cosmos.Context, _ common.Asset, _ cosmos.Uint, _ cosmos.AccAddress) (cosmos.Uint, error)
	Withdrawal(_ cosmos.Context, _ common.Asset, _ cosmos.Uint, _ cosmos.AccAddress) (cosmos.Uint, error)
	BalanceOf(_ cosmos.Context, _ common.Asset, _ cosmos.AccAddress) cosmos.Uint
}

func GetTradeAccountManager added in v1.128.0

func GetTradeAccountManager(version semver.Version, keeper keeper.Keeper) (TradeAccountManager, error)

type TradeAccountWithdrawalHandler added in v1.128.0

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

TradeAccountWithdrawalHandler is handler to process MsgTradeAccountWithdrawal

func NewTradeAccountWithdrawalHandler added in v1.128.0

func NewTradeAccountWithdrawalHandler(mgr Manager) TradeAccountWithdrawalHandler

NewTradeAccountWithdrawalHandler create a new instance of TradeAccountWithdrawalHandler

func (TradeAccountWithdrawalHandler) Run added in v1.128.0

Run is the main entry point for TradeAccountWithdrawalHandler

type TradeAccountWithdrawalMemo added in v1.128.0

type TradeAccountWithdrawalMemo = mem.TradeAccountWithdrawalMemo

type TradeMgrV128 added in v1.131.0

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

TradeMgrV128 is V128 implementation of slasher

func (*TradeMgrV128) BalanceOf added in v1.131.0

func (s *TradeMgrV128) BalanceOf(ctx cosmos.Context, asset common.Asset, addr cosmos.AccAddress) cosmos.Uint

func (*TradeMgrV128) Deposit added in v1.131.0

func (s *TradeMgrV128) Deposit(ctx cosmos.Context, asset common.Asset, amount cosmos.Uint, addr cosmos.AccAddress) (cosmos.Uint, error)

func (*TradeMgrV128) EndBlock added in v1.131.0

func (s *TradeMgrV128) EndBlock(ctx cosmos.Context, keeper keeper.Keeper) error

func (*TradeMgrV128) Withdrawal added in v1.131.0

func (s *TradeMgrV128) Withdrawal(ctx cosmos.Context, asset common.Asset, amount cosmos.Uint, addr cosmos.AccAddress) (cosmos.Uint, error)

type TradeMgrVCUR added in v1.128.0

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

TradeMgrVCUR is VCUR implementation of slasher

func (*TradeMgrVCUR) BalanceOf added in v1.128.0

func (s *TradeMgrVCUR) BalanceOf(ctx cosmos.Context, asset common.Asset, addr cosmos.AccAddress) cosmos.Uint

func (*TradeMgrVCUR) Deposit added in v1.128.0

func (s *TradeMgrVCUR) Deposit(ctx cosmos.Context, asset common.Asset, amount cosmos.Uint, addr cosmos.AccAddress) (cosmos.Uint, error)

func (*TradeMgrVCUR) EndBlock added in v1.128.0

func (s *TradeMgrVCUR) EndBlock(ctx cosmos.Context, keeper keeper.Keeper) error

func (*TradeMgrVCUR) Withdrawal added in v1.128.0

func (s *TradeMgrVCUR) Withdrawal(ctx cosmos.Context, asset common.Asset, amount cosmos.Uint, addr cosmos.AccAddress) (cosmos.Uint, error)

type TradeUnit added in v1.128.0

type TradeUnit = types.TradeUnit

type TssHandler

type TssHandler = BaseHandler[*MsgTssPool]

type TssKeysignFailVoter

type TssKeysignFailVoter = types.TssKeysignFailVoter

type TssKeysignHandler

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

TssKeysignHandler is design to process MsgTssKeysignFail

func NewTssKeysignHandler

func NewTssKeysignHandler(mgr Manager) TssKeysignHandler

NewTssKeysignHandler create a new instance of TssKeysignHandler when a signer fail to join tss keysign , thorchain need to slash the node account

func (TssKeysignHandler) Run

Run is the main entry to process MsgTssKeysignFail

type TssVoter

type TssVoter = types.TssVoter

type TxOut

type TxOut = types.TxOut

type TxOutItem

type TxOutItem = types.TxOutItem

type TxOutStorageV102 added in v1.102.0

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

TxOutStorageV102 is going to manage all the outgoing tx

func (*TxOutStorageV102) CalcTxOutHeight added in v1.102.0

func (tos *TxOutStorageV102) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV102) ClearOutboundItems added in v1.102.0

func (tos *TxOutStorageV102) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV102) EndBlock added in v1.102.0

func (tos *TxOutStorageV102) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV102) GetBlockOut added in v1.102.0

func (tos *TxOutStorageV102) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV102) GetOutboundItemByToAddress added in v1.102.0

func (tos *TxOutStorageV102) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV102) GetOutboundItems added in v1.102.0

func (tos *TxOutStorageV102) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV102) TryAddTxOutItem added in v1.102.0

func (tos *TxOutStorageV102) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV102) UnSafeAddTxOutItem added in v1.102.0

func (tos *TxOutStorageV102) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV107 added in v1.107.0

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

TxOutStorageV107 is going to manage all the outgoing tx

func (*TxOutStorageV107) CalcTxOutHeight added in v1.107.0

func (tos *TxOutStorageV107) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV107) ClearOutboundItems added in v1.107.0

func (tos *TxOutStorageV107) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV107) EndBlock added in v1.107.0

func (tos *TxOutStorageV107) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV107) GetBlockOut added in v1.107.0

func (tos *TxOutStorageV107) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV107) GetOutboundItemByToAddress added in v1.107.0

func (tos *TxOutStorageV107) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV107) GetOutboundItems added in v1.107.0

func (tos *TxOutStorageV107) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV107) TryAddTxOutItem added in v1.107.0

func (tos *TxOutStorageV107) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV107) UnSafeAddTxOutItem added in v1.107.0

func (tos *TxOutStorageV107) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV108 added in v1.108.0

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

TxOutStorageV108 is going to manage all the outgoing tx

func (*TxOutStorageV108) CalcTxOutHeight added in v1.108.0

func (tos *TxOutStorageV108) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV108) ClearOutboundItems added in v1.108.0

func (tos *TxOutStorageV108) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV108) EndBlock added in v1.108.0

func (tos *TxOutStorageV108) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV108) GetBlockOut added in v1.108.0

func (tos *TxOutStorageV108) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV108) GetOutboundItemByToAddress added in v1.108.0

func (tos *TxOutStorageV108) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV108) GetOutboundItems added in v1.108.0

func (tos *TxOutStorageV108) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV108) TryAddTxOutItem added in v1.108.0

func (tos *TxOutStorageV108) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV108) UnSafeAddTxOutItem added in v1.108.0

func (tos *TxOutStorageV108) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV109 added in v1.109.0

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

TxOutStorageV109 is going to manage all the outgoing tx

func (*TxOutStorageV109) CalcTxOutHeight added in v1.109.0

func (tos *TxOutStorageV109) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV109) ClearOutboundItems added in v1.109.0

func (tos *TxOutStorageV109) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV109) EndBlock added in v1.109.0

func (tos *TxOutStorageV109) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV109) GetBlockOut added in v1.109.0

func (tos *TxOutStorageV109) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV109) GetOutboundItemByToAddress added in v1.109.0

func (tos *TxOutStorageV109) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV109) GetOutboundItems added in v1.109.0

func (tos *TxOutStorageV109) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV109) TryAddTxOutItem added in v1.109.0

func (tos *TxOutStorageV109) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV109) UnSafeAddTxOutItem added in v1.109.0

func (tos *TxOutStorageV109) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV112 added in v1.112.0

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

TxOutStorageV112 is going to manage all the outgoing tx

func (*TxOutStorageV112) CalcTxOutHeight added in v1.112.0

func (tos *TxOutStorageV112) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV112) ClearOutboundItems added in v1.112.0

func (tos *TxOutStorageV112) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV112) EndBlock added in v1.112.0

func (tos *TxOutStorageV112) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV112) GetBlockOut added in v1.112.0

func (tos *TxOutStorageV112) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV112) GetOutboundItemByToAddress added in v1.112.0

func (tos *TxOutStorageV112) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV112) GetOutboundItems added in v1.112.0

func (tos *TxOutStorageV112) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV112) TryAddTxOutItem added in v1.112.0

func (tos *TxOutStorageV112) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV112) UnSafeAddTxOutItem added in v1.112.0

func (tos *TxOutStorageV112) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV113 added in v1.113.0

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

TxOutStorageV113 is going to manage all the outgoing tx

func (*TxOutStorageV113) CalcTxOutHeight added in v1.113.0

func (tos *TxOutStorageV113) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV113) ClearOutboundItems added in v1.113.0

func (tos *TxOutStorageV113) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV113) EndBlock added in v1.113.0

func (tos *TxOutStorageV113) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV113) GetBlockOut added in v1.113.0

func (tos *TxOutStorageV113) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV113) GetOutboundItemByToAddress added in v1.113.0

func (tos *TxOutStorageV113) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV113) GetOutboundItems added in v1.113.0

func (tos *TxOutStorageV113) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV113) TryAddTxOutItem added in v1.113.0

func (tos *TxOutStorageV113) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV113) UnSafeAddTxOutItem added in v1.113.0

func (tos *TxOutStorageV113) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV115 added in v1.115.0

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

TxOutStorageV115 is going to manage all the outgoing tx

func (*TxOutStorageV115) CalcTxOutHeight added in v1.115.0

func (tos *TxOutStorageV115) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV115) ClearOutboundItems added in v1.115.0

func (tos *TxOutStorageV115) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV115) EndBlock added in v1.115.0

func (tos *TxOutStorageV115) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV115) GetBlockOut added in v1.115.0

func (tos *TxOutStorageV115) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV115) GetOutboundItemByToAddress added in v1.115.0

func (tos *TxOutStorageV115) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV115) GetOutboundItems added in v1.115.0

func (tos *TxOutStorageV115) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV115) TryAddTxOutItem added in v1.115.0

func (tos *TxOutStorageV115) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV115) UnSafeAddTxOutItem added in v1.115.0

func (tos *TxOutStorageV115) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV116 added in v1.117.0

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

TxOutStorageV116 is going to manage all the outgoing tx

func (*TxOutStorageV116) CalcTxOutHeight added in v1.117.0

func (tos *TxOutStorageV116) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV116) ClearOutboundItems added in v1.117.0

func (tos *TxOutStorageV116) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV116) EndBlock added in v1.117.0

func (tos *TxOutStorageV116) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV116) GetBlockOut added in v1.117.0

func (tos *TxOutStorageV116) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV116) GetOutboundItemByToAddress added in v1.117.0

func (tos *TxOutStorageV116) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV116) GetOutboundItems added in v1.117.0

func (tos *TxOutStorageV116) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV116) TryAddTxOutItem added in v1.117.0

func (tos *TxOutStorageV116) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV116) UnSafeAddTxOutItem added in v1.117.0

func (tos *TxOutStorageV116) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV117 added in v1.119.0

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

TxOutStorageV117 is going to manage all the outgoing tx

func (*TxOutStorageV117) CalcTxOutHeight added in v1.119.0

func (tos *TxOutStorageV117) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV117) ClearOutboundItems added in v1.119.0

func (tos *TxOutStorageV117) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV117) EndBlock added in v1.119.0

func (tos *TxOutStorageV117) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV117) GetBlockOut added in v1.119.0

func (tos *TxOutStorageV117) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV117) GetOutboundItemByToAddress added in v1.119.0

func (tos *TxOutStorageV117) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV117) GetOutboundItems added in v1.119.0

func (tos *TxOutStorageV117) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV117) TryAddTxOutItem added in v1.119.0

func (tos *TxOutStorageV117) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV117) UnSafeAddTxOutItem added in v1.119.0

func (tos *TxOutStorageV117) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV119 added in v1.122.0

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

TxOutStorageV119 is going to manage all the outgoing tx

func (*TxOutStorageV119) CalcTxOutHeight added in v1.122.0

func (tos *TxOutStorageV119) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV119) ClearOutboundItems added in v1.122.0

func (tos *TxOutStorageV119) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV119) EndBlock added in v1.122.0

func (tos *TxOutStorageV119) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV119) GetBlockOut added in v1.122.0

func (tos *TxOutStorageV119) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV119) GetOutboundItemByToAddress added in v1.122.0

func (tos *TxOutStorageV119) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV119) GetOutboundItems added in v1.122.0

func (tos *TxOutStorageV119) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV119) TryAddTxOutItem added in v1.122.0

func (tos *TxOutStorageV119) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV119) UnSafeAddTxOutItem added in v1.122.0

func (tos *TxOutStorageV119) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV122 added in v1.124.0

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

TxOutStorageV122 is going to manage all the outgoing tx

func (*TxOutStorageV122) CalcTxOutHeight added in v1.124.0

func (tos *TxOutStorageV122) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV122) ClearOutboundItems added in v1.124.0

func (tos *TxOutStorageV122) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV122) EndBlock added in v1.124.0

func (tos *TxOutStorageV122) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV122) GetBlockOut added in v1.124.0

func (tos *TxOutStorageV122) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV122) GetOutboundItemByToAddress added in v1.124.0

func (tos *TxOutStorageV122) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV122) GetOutboundItems added in v1.124.0

func (tos *TxOutStorageV122) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV122) TryAddTxOutItem added in v1.124.0

func (tos *TxOutStorageV122) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV122) UnSafeAddTxOutItem added in v1.124.0

func (tos *TxOutStorageV122) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV124 added in v1.125.0

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

TxOutStorageV124 is going to manage all the outgoing tx

func (*TxOutStorageV124) CalcTxOutHeight added in v1.125.0

func (tos *TxOutStorageV124) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV124) ClearOutboundItems added in v1.125.0

func (tos *TxOutStorageV124) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV124) EndBlock added in v1.125.0

func (tos *TxOutStorageV124) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV124) GetBlockOut added in v1.125.0

func (tos *TxOutStorageV124) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV124) GetOutboundItemByToAddress added in v1.125.0

func (tos *TxOutStorageV124) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV124) GetOutboundItems added in v1.125.0

func (tos *TxOutStorageV124) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV124) TryAddTxOutItem added in v1.125.0

func (tos *TxOutStorageV124) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV124) UnSafeAddTxOutItem added in v1.125.0

func (tos *TxOutStorageV124) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV125 added in v1.127.0

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

TxOutStorageV125 is going to manage all the outgoing tx

func (*TxOutStorageV125) CalcTxOutHeight added in v1.127.0

func (tos *TxOutStorageV125) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV125) ClearOutboundItems added in v1.127.0

func (tos *TxOutStorageV125) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV125) EndBlock added in v1.127.0

func (tos *TxOutStorageV125) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV125) GetBlockOut added in v1.127.0

func (tos *TxOutStorageV125) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV125) GetOutboundItemByToAddress added in v1.127.0

func (tos *TxOutStorageV125) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV125) GetOutboundItems added in v1.127.0

func (tos *TxOutStorageV125) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV125) TryAddTxOutItem added in v1.127.0

func (tos *TxOutStorageV125) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV125) UnSafeAddTxOutItem added in v1.127.0

func (tos *TxOutStorageV125) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV127 added in v1.128.0

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

TxOutStorageV127 is going to manage all the outgoing tx

func (*TxOutStorageV127) CalcTxOutHeight added in v1.128.0

func (tos *TxOutStorageV127) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV127) ClearOutboundItems added in v1.128.0

func (tos *TxOutStorageV127) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV127) EndBlock added in v1.128.0

func (tos *TxOutStorageV127) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV127) GetBlockOut added in v1.128.0

func (tos *TxOutStorageV127) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV127) GetOutboundItemByToAddress added in v1.128.0

func (tos *TxOutStorageV127) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV127) GetOutboundItems added in v1.128.0

func (tos *TxOutStorageV127) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV127) TryAddTxOutItem added in v1.128.0

func (tos *TxOutStorageV127) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV127) UnSafeAddTxOutItem added in v1.128.0

func (tos *TxOutStorageV127) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV128 added in v1.131.0

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

TxOutStorageV128 is going to manage all the outgoing tx

func (*TxOutStorageV128) CalcTxOutHeight added in v1.131.0

func (tos *TxOutStorageV128) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV128) ClearOutboundItems added in v1.131.0

func (tos *TxOutStorageV128) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV128) EndBlock added in v1.131.0

func (tos *TxOutStorageV128) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV128) GetBlockOut added in v1.131.0

func (tos *TxOutStorageV128) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV128) GetOutboundItemByToAddress added in v1.131.0

func (tos *TxOutStorageV128) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV128) GetOutboundItems added in v1.131.0

func (tos *TxOutStorageV128) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV128) TryAddTxOutItem added in v1.131.0

func (tos *TxOutStorageV128) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageV128) UnSafeAddTxOutItem added in v1.131.0

func (tos *TxOutStorageV128) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV78 added in v0.78.0

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

TxOutStorageV78 is going to manage all the outgoing tx

func (*TxOutStorageV78) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV78) CalcTxOutHeight(ctx cosmos.Context, _ semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV78) ClearOutboundItems added in v0.78.0

func (tos *TxOutStorageV78) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV78) EndBlock added in v0.78.0

func (tos *TxOutStorageV78) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV78) GetBlockOut added in v0.78.0

func (tos *TxOutStorageV78) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV78) GetOutboundItemByToAddress added in v0.78.0

func (tos *TxOutStorageV78) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV78) GetOutboundItems added in v0.78.0

func (tos *TxOutStorageV78) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV78) TryAddTxOutItem added in v0.78.0

func (tos *TxOutStorageV78) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, _ cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV78) UnSafeAddTxOutItem added in v0.78.0

func (tos *TxOutStorageV78) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV83 added in v1.83.0

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

TxOutStorageV83 is going to manage all the outgoing tx

func (*TxOutStorageV83) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV83) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV83) ClearOutboundItems added in v1.83.0

func (tos *TxOutStorageV83) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV83) EndBlock added in v1.83.0

func (tos *TxOutStorageV83) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV83) GetBlockOut added in v1.83.0

func (tos *TxOutStorageV83) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV83) GetOutboundItemByToAddress added in v1.83.0

func (tos *TxOutStorageV83) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV83) GetOutboundItems added in v1.83.0

func (tos *TxOutStorageV83) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV83) TryAddTxOutItem added in v1.83.0

func (tos *TxOutStorageV83) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, _ cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV83) UnSafeAddTxOutItem added in v1.83.0

func (tos *TxOutStorageV83) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV84 added in v1.84.0

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

TxOutStorageV84 is going to manage all the outgoing tx

func (*TxOutStorageV84) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV84) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV84) ClearOutboundItems added in v1.84.0

func (tos *TxOutStorageV84) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV84) EndBlock added in v1.84.0

func (tos *TxOutStorageV84) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV84) GetBlockOut added in v1.84.0

func (tos *TxOutStorageV84) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV84) GetOutboundItemByToAddress added in v1.84.0

func (tos *TxOutStorageV84) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV84) GetOutboundItems added in v1.84.0

func (tos *TxOutStorageV84) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV84) TryAddTxOutItem added in v1.84.0

func (tos *TxOutStorageV84) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, _ cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV84) UnSafeAddTxOutItem added in v1.84.0

func (tos *TxOutStorageV84) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV85 added in v1.85.0

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

TxOutStorageV85 is going to manage all the outgoing tx

func (*TxOutStorageV85) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV85) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV85) ClearOutboundItems added in v1.85.0

func (tos *TxOutStorageV85) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV85) EndBlock added in v1.85.0

func (tos *TxOutStorageV85) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV85) GetBlockOut added in v1.85.0

func (tos *TxOutStorageV85) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV85) GetOutboundItemByToAddress added in v1.85.0

func (tos *TxOutStorageV85) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV85) GetOutboundItems added in v1.85.0

func (tos *TxOutStorageV85) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV85) TryAddTxOutItem added in v1.85.0

func (tos *TxOutStorageV85) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, _ cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV85) UnSafeAddTxOutItem added in v1.85.0

func (tos *TxOutStorageV85) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV88 added in v1.88.0

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

TxOutStorageV88 is going to manage all the outgoing tx

func (*TxOutStorageV88) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV88) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV88) ClearOutboundItems added in v1.88.0

func (tos *TxOutStorageV88) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV88) EndBlock added in v1.88.0

func (tos *TxOutStorageV88) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV88) GetBlockOut added in v1.88.0

func (tos *TxOutStorageV88) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV88) GetOutboundItemByToAddress added in v1.88.0

func (tos *TxOutStorageV88) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV88) GetOutboundItems added in v1.88.0

func (tos *TxOutStorageV88) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV88) TryAddTxOutItem added in v1.88.0

func (tos *TxOutStorageV88) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, _ cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV88) UnSafeAddTxOutItem added in v1.88.0

func (tos *TxOutStorageV88) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV93 added in v1.93.0

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

TxOutStorageV93 is going to manage all the outgoing tx

func (*TxOutStorageV93) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV93) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV93) ClearOutboundItems added in v1.93.0

func (tos *TxOutStorageV93) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV93) EndBlock added in v1.93.0

func (tos *TxOutStorageV93) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV93) GetBlockOut added in v1.93.0

func (tos *TxOutStorageV93) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV93) GetOutboundItemByToAddress added in v1.93.0

func (tos *TxOutStorageV93) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV93) GetOutboundItems added in v1.93.0

func (tos *TxOutStorageV93) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV93) TryAddTxOutItem added in v1.93.0

func (tos *TxOutStorageV93) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV93) UnSafeAddTxOutItem added in v1.93.0

func (tos *TxOutStorageV93) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV94 added in v1.95.0

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

TxOutStorageV94 is going to manage all the outgoing tx

func (*TxOutStorageV94) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV94) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV94) ClearOutboundItems added in v1.95.0

func (tos *TxOutStorageV94) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV94) EndBlock added in v1.95.0

func (tos *TxOutStorageV94) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV94) GetBlockOut added in v1.95.0

func (tos *TxOutStorageV94) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV94) GetOutboundItemByToAddress added in v1.95.0

func (tos *TxOutStorageV94) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV94) GetOutboundItems added in v1.95.0

func (tos *TxOutStorageV94) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV94) TryAddTxOutItem added in v1.95.0

func (tos *TxOutStorageV94) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV94) UnSafeAddTxOutItem added in v1.95.0

func (tos *TxOutStorageV94) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV95 added in v1.95.0

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

TxOutStorageV95 is going to manage all the outgoing tx

func (*TxOutStorageV95) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV95) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV95) ClearOutboundItems added in v1.95.0

func (tos *TxOutStorageV95) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV95) EndBlock added in v1.95.0

func (tos *TxOutStorageV95) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV95) GetBlockOut added in v1.95.0

func (tos *TxOutStorageV95) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV95) GetOutboundItemByToAddress added in v1.95.0

func (tos *TxOutStorageV95) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV95) GetOutboundItems added in v1.95.0

func (tos *TxOutStorageV95) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV95) TryAddTxOutItem added in v1.95.0

func (tos *TxOutStorageV95) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV95) UnSafeAddTxOutItem added in v1.95.0

func (tos *TxOutStorageV95) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV97 added in v1.97.0

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

TxOutStorageV97 is going to manage all the outgoing tx

func (*TxOutStorageV97) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV97) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV97) ClearOutboundItems added in v1.97.0

func (tos *TxOutStorageV97) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV97) EndBlock added in v1.97.0

func (tos *TxOutStorageV97) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV97) GetBlockOut added in v1.97.0

func (tos *TxOutStorageV97) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV97) GetOutboundItemByToAddress added in v1.97.0

func (tos *TxOutStorageV97) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV97) GetOutboundItems added in v1.97.0

func (tos *TxOutStorageV97) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV97) TryAddTxOutItem added in v1.97.0

func (tos *TxOutStorageV97) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV97) UnSafeAddTxOutItem added in v1.97.0

func (tos *TxOutStorageV97) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageV98 added in v1.98.0

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

TxOutStorageV98 is going to manage all the outgoing tx

func (*TxOutStorageV98) CalcTxOutHeight added in v1.99.0

func (tos *TxOutStorageV98) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageV98) ClearOutboundItems added in v1.98.0

func (tos *TxOutStorageV98) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageV98) EndBlock added in v1.98.0

func (tos *TxOutStorageV98) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageV98) GetBlockOut added in v1.98.0

func (tos *TxOutStorageV98) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageV98) GetOutboundItemByToAddress added in v1.98.0

func (tos *TxOutStorageV98) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageV98) GetOutboundItems added in v1.98.0

func (tos *TxOutStorageV98) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageV98) TryAddTxOutItem added in v1.98.0

func (tos *TxOutStorageV98) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

TryAddTxOutItem add an outbound tx to block return bool indicate whether the transaction had been added successful or not return error indicate error

func (*TxOutStorageV98) UnSafeAddTxOutItem added in v1.98.0

func (tos *TxOutStorageV98) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStorageVCUR added in v1.116.0

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

TxOutStorageVCUR is going to manage all the outgoing tx

func (*TxOutStorageVCUR) CalcTxOutHeight added in v1.116.0

func (tos *TxOutStorageVCUR) CalcTxOutHeight(ctx cosmos.Context, version semver.Version, toi TxOutItem) (int64, cosmos.Uint, error)

func (*TxOutStorageVCUR) ClearOutboundItems added in v1.116.0

func (tos *TxOutStorageVCUR) ClearOutboundItems(ctx cosmos.Context)

ClearOutboundItems remove all the tx out items , mostly used for test

func (*TxOutStorageVCUR) EndBlock added in v1.116.0

func (tos *TxOutStorageVCUR) EndBlock(ctx cosmos.Context, mgr Manager) error

func (*TxOutStorageVCUR) GetBlockOut added in v1.116.0

func (tos *TxOutStorageVCUR) GetBlockOut(ctx cosmos.Context) (*TxOut, error)

GetBlockOut read the TxOut from kv store

func (*TxOutStorageVCUR) GetOutboundItemByToAddress added in v1.116.0

func (tos *TxOutStorageVCUR) GetOutboundItemByToAddress(ctx cosmos.Context, to common.Address) []TxOutItem

GetOutboundItemByToAddress read all the outbound items filter by the given to address

func (*TxOutStorageVCUR) GetOutboundItems added in v1.116.0

func (tos *TxOutStorageVCUR) GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)

GetOutboundItems read all the outbound item from kv store

func (*TxOutStorageVCUR) TryAddTxOutItem added in v1.116.0

func (tos *TxOutStorageVCUR) TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)

When TryAddTxOutItem returns an error, there should be no state changes from it, including funds movements or fee events from prepareTxOutItem. So, use CacheContext to only commit state changes when cachedTryAddTxOutItem doesn't return an error.

func (*TxOutStorageVCUR) UnSafeAddTxOutItem added in v1.116.0

func (tos *TxOutStorageVCUR) UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error

UnSafeAddTxOutItem - blindly adds a tx out, skipping vault selection, transaction fee deduction, etc

type TxOutStore

type TxOutStore interface {
	EndBlock(ctx cosmos.Context, mgr Manager) error
	GetBlockOut(ctx cosmos.Context) (*TxOut, error)
	ClearOutboundItems(ctx cosmos.Context)
	GetOutboundItems(ctx cosmos.Context) ([]TxOutItem, error)
	TryAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, minOut cosmos.Uint) (bool, error)
	UnSafeAddTxOutItem(ctx cosmos.Context, mgr Manager, toi TxOutItem, height int64) error
	GetOutboundItemByToAddress(cosmos.Context, common.Address) []TxOutItem
	CalcTxOutHeight(cosmos.Context, semver.Version, TxOutItem) (int64, cosmos.Uint, error)
}

TxOutStore define the method required for TxOutStore

func GetTxOutStore

func GetTxOutStore(version semver.Version, keeper keeper.Keeper, eventMgr EventManager, gasManager GasManager) (TxOutStore, error)

GetTxOutStore will return an implementation of the txout store that

type TypedHandler added in v1.107.0

type TypedHandler[M cosmos.Msg] interface {
	MsgHandler
	// contains filtered or unexported methods
}

type UnBondHandler

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

UnBondHandler a handler to process unbond request

func NewUnBondHandler

func NewUnBondHandler(mgr Manager) UnBondHandler

NewUnBondHandler create new UnBondHandler

func (UnBondHandler) Run

Run execute the handler

type UnbondMemo

type UnbondMemo = mem.UnbondMemo

type ValidatorManager

type ValidatorManager interface {
	BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error
	EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate
	RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error // TODO remove on hard fork

	NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, constAccessor constants.ConstantValues) (NodeStatus, error)
	// contains filtered or unexported methods
}

ValidatorManager define the method to manage validators

func GetValidatorManager

func GetValidatorManager(version semver.Version, keeper keeper.Keeper, networkMgr NetworkManager, txOutStore TxOutStore, eventMgr EventManager) (ValidatorManager, error)

GetValidatorManager create a new instance of Validator Manager

type ValidatorMgrV103 added in v1.103.0

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

ValidatorMgrV103 is to manage a list of validators , and rotate them

func (*ValidatorMgrV103) BeginBlock added in v1.103.0

func (vm *ValidatorMgrV103) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV103) EndBlock added in v1.103.0

func (vm *ValidatorMgrV103) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV103) NodeAccountPreflightCheck added in v1.103.0

func (vm *ValidatorMgrV103) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, constAccessor constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV103) RequestYggReturn added in v1.103.0

func (vm *ValidatorMgrV103) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV106 added in v1.106.0

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

ValidatorMgrV106 is to manage a list of validators , and rotate them

func (*ValidatorMgrV106) BeginBlock added in v1.106.0

func (vm *ValidatorMgrV106) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV106) EndBlock added in v1.106.0

func (vm *ValidatorMgrV106) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV106) NodeAccountPreflightCheck added in v1.106.0

func (vm *ValidatorMgrV106) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, constAccessor constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV106) RequestYggReturn added in v1.106.0

func (vm *ValidatorMgrV106) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV109 added in v1.109.0

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

ValidatorMgrV109 is to manage a list of validators , and rotate them

func (*ValidatorMgrV109) BeginBlock added in v1.109.0

func (vm *ValidatorMgrV109) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV109) EndBlock added in v1.109.0

func (vm *ValidatorMgrV109) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV109) NodeAccountPreflightCheck added in v1.109.0

func (vm *ValidatorMgrV109) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, constAccessor constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV109) RequestYggReturn added in v1.109.0

func (vm *ValidatorMgrV109) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV110 added in v1.110.0

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

ValidatorMgrV110 is to manage a list of validators , and rotate them

func (*ValidatorMgrV110) BeginBlock added in v1.110.0

func (vm *ValidatorMgrV110) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV110) EndBlock added in v1.110.0

func (vm *ValidatorMgrV110) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV110) NodeAccountPreflightCheck added in v1.110.0

func (vm *ValidatorMgrV110) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV110) RequestYggReturn added in v1.110.0

func (vm *ValidatorMgrV110) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV112 added in v1.112.0

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

ValidatorMgrV112 is to manage a list of validators , and rotate them

func (*ValidatorMgrV112) BeginBlock added in v1.112.0

func (vm *ValidatorMgrV112) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV112) EndBlock added in v1.112.0

func (vm *ValidatorMgrV112) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV112) NodeAccountPreflightCheck added in v1.112.0

func (vm *ValidatorMgrV112) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV112) RequestYggReturn added in v1.112.0

func (vm *ValidatorMgrV112) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV116 added in v1.117.0

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

ValidatorMgrV116 is to manage a list of validators , and rotate them

func (*ValidatorMgrV116) BeginBlock added in v1.117.0

func (vm *ValidatorMgrV116) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV116) EndBlock added in v1.117.0

func (vm *ValidatorMgrV116) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV116) NodeAccountPreflightCheck added in v1.117.0

func (vm *ValidatorMgrV116) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV116) RequestYggReturn added in v1.117.0

func (vm *ValidatorMgrV116) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV117 added in v1.119.0

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

ValidatorMgrV117 is to manage a list of validators , and rotate them

func (*ValidatorMgrV117) BeginBlock added in v1.119.0

func (vm *ValidatorMgrV117) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV117) EndBlock added in v1.119.0

func (vm *ValidatorMgrV117) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV117) NodeAccountPreflightCheck added in v1.119.0

func (vm *ValidatorMgrV117) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV117) RequestYggReturn added in v1.119.0

func (vm *ValidatorMgrV117) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV119 added in v1.121.0

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

ValidatorMgrV119 is to manage a list of validators , and rotate them

func (*ValidatorMgrV119) BeginBlock added in v1.121.0

func (vm *ValidatorMgrV119) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV119) EndBlock added in v1.121.0

func (vm *ValidatorMgrV119) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV119) NodeAccountPreflightCheck added in v1.121.0

func (vm *ValidatorMgrV119) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV119) RequestYggReturn added in v1.121.0

func (vm *ValidatorMgrV119) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV121 added in v1.123.0

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

ValidatorMgrV121 is to manage a list of validators , and rotate them

func (*ValidatorMgrV121) BeginBlock added in v1.123.0

func (vm *ValidatorMgrV121) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV121) EndBlock added in v1.123.0

func (vm *ValidatorMgrV121) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV121) NodeAccountPreflightCheck added in v1.123.0

func (vm *ValidatorMgrV121) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV121) RequestYggReturn added in v1.123.0

func (vm *ValidatorMgrV121) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV123 added in v1.124.0

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

ValidatorMgrV123 is to manage a list of validators , and rotate them

func (*ValidatorMgrV123) BeginBlock added in v1.124.0

func (vm *ValidatorMgrV123) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV123) EndBlock added in v1.124.0

func (vm *ValidatorMgrV123) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV123) NodeAccountPreflightCheck added in v1.124.0

func (vm *ValidatorMgrV123) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV123) RequestYggReturn added in v1.124.0

func (vm *ValidatorMgrV123) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

RequestYggReturn request the node that had been removed (yggdrasil) to return their fund

type ValidatorMgrV124 added in v1.126.0

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

ValidatorMgrV124 is to manage a list of validators , and rotate them

func (*ValidatorMgrV124) BeginBlock added in v1.126.0

func (vm *ValidatorMgrV124) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV124) EndBlock added in v1.126.0

func (vm *ValidatorMgrV124) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV124) NodeAccountPreflightCheck added in v1.126.0

func (vm *ValidatorMgrV124) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV124) RequestYggReturn added in v1.126.0

func (vm *ValidatorMgrV124) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

TODO remove on hard fork

type ValidatorMgrV126 added in v1.128.0

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

ValidatorMgrV126 is to manage a list of validators , and rotate them

func (*ValidatorMgrV126) BeginBlock added in v1.128.0

func (vm *ValidatorMgrV126) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrV126) EndBlock added in v1.128.0

func (vm *ValidatorMgrV126) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrV126) NodeAccountPreflightCheck added in v1.128.0

func (vm *ValidatorMgrV126) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrV126) RequestYggReturn added in v1.128.0

func (vm *ValidatorMgrV126) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

TODO remove on hard fork

type ValidatorMgrVCUR added in v1.116.0

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

ValidatorMgrVCUR is to manage a list of validators , and rotate them

func (*ValidatorMgrVCUR) BeginBlock added in v1.116.0

func (vm *ValidatorMgrVCUR) BeginBlock(ctx cosmos.Context, mgr Manager, existingValidators []string) error

BeginBlock when block begin

func (*ValidatorMgrVCUR) EndBlock added in v1.116.0

func (vm *ValidatorMgrVCUR) EndBlock(ctx cosmos.Context, mgr Manager) []abci.ValidatorUpdate

EndBlock when block commit

func (*ValidatorMgrVCUR) NodeAccountPreflightCheck added in v1.116.0

func (vm *ValidatorMgrVCUR) NodeAccountPreflightCheck(ctx cosmos.Context, na NodeAccount, _ constants.ConstantValues) (NodeStatus, error)

NodeAccountPreflightCheck preflight check to find out what the node account's next status will be

func (*ValidatorMgrVCUR) RequestYggReturn added in v1.116.0

func (vm *ValidatorMgrVCUR) RequestYggReturn(ctx cosmos.Context, node NodeAccount, mgr Manager) error

TODO remove on hard fork

type Vault

type Vault = types.Vault

type VaultStatus

type VaultStatus = types.VaultStatus

type Vaults

type Vaults = types.Vaults

type VersionHandler

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

VersionHandler is to handle Version message

func NewVersionHandler

func NewVersionHandler(mgr Manager) VersionHandler

NewVersionHandler create new instance of VersionHandler

func (VersionHandler) Run

Run it the main entry point to execute Version logic

type WithdrawLiquidityHandler added in v0.41.0

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

WithdrawLiquidityHandler to process withdraw requests

func NewWithdrawLiquidityHandler added in v0.41.0

func NewWithdrawLiquidityHandler(mgr Manager) WithdrawLiquidityHandler

NewWithdrawLiquidityHandler create a new instance of WithdrawLiquidityHandler to process withdraw request

func (WithdrawLiquidityHandler) Run added in v0.41.0

Run is the main entry point of withdraw

type WithdrawLiquidityMemo added in v0.41.0

type WithdrawLiquidityMemo = mem.WithdrawLiquidityMemo

type YggManager

type YggManager interface {
	Fund(ctx cosmos.Context, mgr Manager) error
}

YggManager define method to fund yggdrasil TODO remove on hard fork

func GetYggManager

func GetYggManager(version semver.Version, keeper keeper.Keeper) (YggManager, error)

GetYggManager return an implementation of YggManager TODO remove on hard fork

type YggMgrV112 added in v1.112.0

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

YggMgrV112 is an implementation of YggManager

func (YggMgrV112) Fund added in v1.112.0

func (ymgr YggMgrV112) Fund(ctx cosmos.Context, mgr Manager) error

Fund is a method to fund yggdrasil pool

type YggMgrV116 added in v1.124.0

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

YggMgrV116 is an implementation of YggManager

func (YggMgrV116) Fund added in v1.124.0

func (ymgr YggMgrV116) Fund(ctx cosmos.Context, mgr Manager) error

Fund is a method to fund yggdrasil pool

type YggMgrV79 added in v0.79.0

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

YggMgrV79 is an implementation of YggManager

func (YggMgrV79) Fund added in v0.79.0

func (ymgr YggMgrV79) Fund(ctx cosmos.Context, mgr Manager) error

Fund is a method to fund yggdrasil pool

type YggdrasilFundMemo

type YggdrasilFundMemo = mem.YggdrasilFundMemo

type YggdrasilHandler

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

YggdrasilHandler is to process yggdrasil messages When thorchain fund yggdrasil pool , observer should observe two transactions 1. outbound tx from asgard vault 2. inbound tx to yggdrasil vault when yggdrasil pool return fund , observer should observe two transactions as well 1. outbound tx from yggdrasil vault 2. inbound tx to asgard vault

func NewYggdrasilHandler

func NewYggdrasilHandler(mgr Manager) YggdrasilHandler

NewYggdrasilHandler create a new Yggdrasil handler

func (YggdrasilHandler) Run

Run execute the logic in Yggdrasil Handler

type YggdrasilReturnMemo

type YggdrasilReturnMemo = mem.YggdrasilReturnMemo

Source Files

Directories

Path Synopsis
client
cli
v1
Please put all the test related function to here
Please put all the test related function to here

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL