Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

plugin

package

Go to main page

Versions in this module

v1

v1.2.2

Feb 27, 2024

v1.2.1

Feb 27, 2024

v1.2.0

Apr 20, 2023

v1.1.3

Apr 19, 2023

v1.1.2

Apr 19, 2023

v1.1.1

Apr 19, 2023

v1.1.0

Apr 19, 2023

v1.0.0

Apr 18, 2023

Changes in this version

+ const AfterFoundationYearDeveloperRewardRate

+ const AfterFoundationYearFoundRewardRate

+ const CurrentRound

+ const EpochValIndexSize

+ const FreeVon

+ const HundredDenominator

+ const LessThanFoundationYearDeveloperRate

+ const NextRound

+ const PreviousRound

+ const QueryStartIrr

+ const QueryStartNotIrr

+ const RestrictAndFreeVon

+ const RestrictVon

+ const RewardPoolIncreaseRate

+ const RoundValIndexSize

+ const TenThousandDenominator

+ var DecodeTxDataErr = errors.New("decode tx data is err")

+ var FnParamsLenErr = errors.New("the params len and func params len is not equal")

+ var FuncNotExistErr = errors.New("the func is not exist")

+ func AppendDelegateRewardPer(blockHash common.Hash, nodeID discover.NodeID, stakingNum uint64, ...) error

+ func CheckOperatingThreshold(blockNumber uint64, blockHash common.Hash, balance *big.Int) (bool, *big.Int)

+ func CheckStakeThreshold(blockNumber uint64, blockHash common.Hash, stake *big.Int) (bool, *big.Int)

+ func Decimal(value float64) int

+ func GetBlockNumberByEpoch(epoch uint64) uint64

+ func GetHistoryCumulativeIssue(state xcom.StateDB, year uint32) *big.Int

+ func GetYearEndBalance(state xcom.StateDB, year uint32) *big.Int

+ func IsExistInitialChosenValidators(nodeId discover.NodeID) bool

+ func LoadChainYearNumber(hash common.Hash, snapshotDB snapshotdb.DB) (uint32, error)

+ func LoadNewBlockReward(hash common.Hash, snapshotDB snapshotdb.DB) (*big.Int, error)

+ func LoadRemainingReward(hash common.Hash, snapshotDB snapshotdb.DB) (*big.Int, error)

+ func LoadStakingReward(hash common.Hash, snapshotDB snapshotdb.DB) (*big.Int, error)

+ func LoadYearStartTime(hash common.Hash, snapshotDB snapshotdb.DB) (yearStartBlockNumber uint64, yearStartTime int64, error error)

+ func SetYearEndBalance(state xcom.StateDB, year uint32, balance *big.Int)

+ func SetYearEndCumulativeIssue(state xcom.StateDB, year uint32, total *big.Int)

+ func StorageChainYearNumber(hash common.Hash, snapshotDB snapshotdb.DB, yearNumber uint32) error

+ func StorageNewBlockReward(hash common.Hash, snapshotDB snapshotdb.DB, newBlockReward *big.Int) error

+ func StorageRemainingReward(hash common.Hash, snapshotDB snapshotdb.DB, remainReward *big.Int) error

+ func StorageStakingReward(hash common.Hash, snapshotDB snapshotdb.DB, stakingReward *big.Int) error

+ func StorageYearStartTime(hash common.Hash, snapshotDB snapshotdb.DB, blockNumber uint64, ...) error

+ func UpdateDelegateRewardPer(blockHash common.Hash, nodeID discover.NodeID, stakingNum uint64, ...) error

+ func VerifyTxData(input []byte, command map[uint16]interface{}) (cnCode uint16, fn interface{}, FnParams []reflect.Value, err error)

+ type BasePlugin interface

+ BeginBlock func(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ Confirmed func(nodeId discover.NodeID, block *types.Block) error

+ EndBlock func(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ type DelegationInfoWithRewardPerList struct

+ DelegationInfo *staking.DelegationInfo

+ RewardPerList []*reward.DelegateRewardPer

+ func NewDelegationInfoWithRewardPerList(delegationInfo *staking.DelegationInfo, ...) *DelegationInfoWithRewardPerList

+ func (d *DelegationInfoWithRewardPerList) String() string

+ type GovPlugin struct

+ func GovPluginInstance() *GovPlugin

+ func (govPlugin *GovPlugin) BeginBlock(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ func (govPlugin *GovPlugin) Confirmed(nodeId discover.NodeID, block *types.Block) error

+ func (govPlugin *GovPlugin) EndBlock(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ func (govPlugin *GovPlugin) SetChainID(chainId *big.Int)

+ type PublicDPOSAPI struct

+ func NewPublicDPOSAPI() *PublicDPOSAPI

+ func (p *PublicDPOSAPI) GetWaitSlashingNodeList() string

+ type RestrictingPlugin struct

+ func NewRestrictingPlugin(snapdb snapshotdb.DB) *RestrictingPlugin

+ func RestrictingInstance() *RestrictingPlugin

+ func (rp *RestrictingPlugin) AddRestrictingRecord(from, account common.Address, blockNum uint64, blockHash common.Hash, ...) error

+ func (rp *RestrictingPlugin) AdvanceLockedFunds(account common.Address, amount *big.Int, state xcom.StateDB) error

+ func (rp *RestrictingPlugin) BeginBlock(blockHash common.Hash, head *types.Header, state xcom.StateDB) error

+ func (rp *RestrictingPlugin) Confirmed(nodeId discover.NodeID, block *types.Block) error

+ func (rp *RestrictingPlugin) EndBlock(blockHash common.Hash, head *types.Header, state xcom.StateDB) error

+ func (rp *RestrictingPlugin) GetRestrictingInfo(account common.Address, state xcom.StateDB) (*restricting.Result, *common.BizError)

+ func (rp *RestrictingPlugin) InitGenesisRestrictingPlans(statedb xcom.StateDB) error

+ func (rp *RestrictingPlugin) MixAdvanceLockedFunds(account common.Address, amount *big.Int, state xcom.StateDB) (*big.Int, *big.Int, error)

+ func (rp *RestrictingPlugin) ReturnLockFunds(account common.Address, amount *big.Int, state xcom.StateDB) error

+ func (rp *RestrictingPlugin) SlashingNotify(account common.Address, amount *big.Int, state xcom.StateDB) error

+ type RewardMgrPlugin struct

+ func RewardMgrInstance() *RewardMgrPlugin

+ func (rmp *RewardMgrPlugin) AllocatePackageBlock(blockHash common.Hash, head *types.Header, reward *big.Int, state xcom.StateDB) error

+ func (rmp *RewardMgrPlugin) AllocateStakingReward(blockNumber uint64, blockHash common.Hash, sreward *big.Int, ...) ([]*staking.Candidate, error)

+ func (rmp *RewardMgrPlugin) BeginBlock(blockHash common.Hash, head *types.Header, state xcom.StateDB) error

+ func (rmp *RewardMgrPlugin) CalDelegateRewardAndNodeReward(totalReward *big.Int, per uint16) (*big.Int, *big.Int)

+ func (rmp *RewardMgrPlugin) CalcEpochReward(blockHash common.Hash, head *types.Header, state xcom.StateDB) (*big.Int, *big.Int, error)

+ func (rmp *RewardMgrPlugin) Confirmed(nodeId discover.NodeID, block *types.Block) error

+ func (rmp *RewardMgrPlugin) EndBlock(blockHash common.Hash, head *types.Header, state xcom.StateDB) error

+ func (rmp *RewardMgrPlugin) GetDelegateReward(blockHash common.Hash, blockNum uint64, account common.Address, ...) ([]reward.NodeDelegateRewardPresenter, error)

+ func (rmp *RewardMgrPlugin) GetDelegateRewardPerList(blockHash common.Hash, nodeID discover.NodeID, ...) ([]*reward.DelegateRewardPer, error)

+ func (rmp *RewardMgrPlugin) HandleDelegatePerReward(blockHash common.Hash, blockNumber uint64, list []*staking.Candidate, ...) error

+ func (rmp *RewardMgrPlugin) ReturnDelegateReward(address common.Address, amount *big.Int, state xcom.StateDB) error

+ func (rmp *RewardMgrPlugin) SetCurrentNodeID(nodeId discover.NodeID)

+ func (rmp *RewardMgrPlugin) WithdrawDelegateReward(blockHash common.Hash, blockNum uint64, account common.Address, ...) ([]reward.NodeDelegateReward, error)

+ type SlashingPlugin struct

+ func SlashInstance() *SlashingPlugin

+ func (sp *SlashingPlugin) BeginBlock(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ func (sp *SlashingPlugin) CheckDuplicateSign(nodeId discover.NodeID, blockNumber uint64, dupType consensus.EvidenceType, ...) ([]byte, error)

+ func (sp *SlashingPlugin) Confirmed(nodeId discover.NodeID, block *types.Block) error

+ func (sp *SlashingPlugin) DecodeEvidence(dupType consensus.EvidenceType, data string) (consensus.Evidence, error)

+ func (sp *SlashingPlugin) EndBlock(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ func (sp *SlashingPlugin) GetPrePackAmount(blockNumber uint64, parentHash common.Hash) (map[discover.NodeID]uint32, error)

+ func (sp *SlashingPlugin) SetDecodeEvidenceFun(...)

+ func (sp *SlashingPlugin) SetPrivateKey(privateKey *ecdsa.PrivateKey)

+ func (sp *SlashingPlugin) Slash(evidence consensus.Evidence, blockHash common.Hash, blockNumber uint64, ...) error

+ type StakingPlugin struct

+ func NewStakingPlugin(db snapshotdb.DB) *StakingPlugin

+ func StakingInstance() *StakingPlugin

+ func (sk *StakingPlugin) BeginBlock(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ func (sk *StakingPlugin) Confirmed(nodeId discover.NodeID, block *types.Block) error

+ func (sk *StakingPlugin) CreateCandidate(state xcom.StateDB, blockHash common.Hash, blockNumber, amount *big.Int, ...) error

+ func (sk *StakingPlugin) DeclarePromoteNotify(blockHash common.Hash, blockNumber uint64, nodeId discover.NodeID, ...) error

+ func (sk *StakingPlugin) Delegate(state xcom.StateDB, blockHash common.Hash, blockNumber *big.Int, ...) error

+ func (sk *StakingPlugin) EditCandidate(blockHash common.Hash, blockNumber *big.Int, canAddr common.NodeAddress, ...) error

+ func (sk *StakingPlugin) ElectNextVerifierList(blockHash common.Hash, blockNumber uint64, state xcom.StateDB) error

+ func (sk *StakingPlugin) Election(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ func (sk *StakingPlugin) EndBlock(blockHash common.Hash, header *types.Header, state xcom.StateDB) error

+ func (sk *StakingPlugin) GetCanBase(blockHash common.Hash, addr common.NodeAddress) (*staking.CandidateBase, error)

+ func (sk *StakingPlugin) GetCanBaseByIrr(addr common.NodeAddress) (*staking.CandidateBase, error)

+ func (sk *StakingPlugin) GetCanBaseList(blockHash common.Hash, blockNumber uint64) (staking.CandidateBaseQueue, error)

+ func (sk *StakingPlugin) GetCanMutable(blockHash common.Hash, addr common.NodeAddress) (*staking.CandidateMutable, error)

+ func (sk *StakingPlugin) GetCanMutableByIrr(addr common.NodeAddress) (*staking.CandidateMutable, error)

+ func (sk *StakingPlugin) GetCandidateCompactInfo(blockHash common.Hash, blockNumber uint64, addr common.NodeAddress) (*staking.CandidateHex, error)

+ func (sk *StakingPlugin) GetCandidateInfo(blockHash common.Hash, addr common.NodeAddress) (*staking.Candidate, error)

+ func (sk *StakingPlugin) GetCandidateInfoByIrr(addr common.NodeAddress) (*staking.Candidate, error)

+ func (sk *StakingPlugin) GetCandidateList(blockHash common.Hash, blockNumber uint64) (staking.CandidateHexQueue, error)

+ func (sk *StakingPlugin) GetCandidateONEpoch(blockHash common.Hash, blockNumber uint64, isCommit bool) (staking.CandidateQueue, error)

+ func (sk *StakingPlugin) GetCandidateONRound(blockHash common.Hash, blockNumber uint64, flag uint, isCommit bool) (staking.CandidateQueue, error)

+ func (sk *StakingPlugin) GetDelegateExCompactInfo(blockHash common.Hash, blockNumber uint64, delAddr common.Address, ...) (*staking.DelegationEx, error)

+ func (sk *StakingPlugin) GetDelegateExInfo(blockHash common.Hash, delAddr common.Address, nodeId discover.NodeID, ...) (*staking.DelegationEx, error)

+ func (sk *StakingPlugin) GetDelegateExInfoByIrr(delAddr common.Address, nodeId discover.NodeID, stakeBlockNumber uint64) (*staking.DelegationEx, error)

+ func (sk *StakingPlugin) GetDelegateInfo(blockHash common.Hash, delAddr common.Address, nodeId discover.NodeID, ...) (*staking.Delegation, error)

+ func (sk *StakingPlugin) GetDelegateInfoByIrr(delAddr common.Address, nodeId discover.NodeID, stakeBlockNumber uint64) (*staking.Delegation, error)

+ func (sk *StakingPlugin) GetDelegatesInfo(blockHash common.Hash, delAddr common.Address) ([]*staking.DelegationInfo, error)

+ func (sk *StakingPlugin) GetLastNumber(blockNumber uint64) uint64

+ func (sk *StakingPlugin) GetRelatedListByDelAddr(blockHash common.Hash, addr common.Address) (staking.DelRelatedQueue, error)

+ func (sk *StakingPlugin) GetValidator(blockNumber uint64) (*pbfttypes.Validators, error)

+ func (sk *StakingPlugin) GetValidatorList(blockHash common.Hash, blockNumber uint64, flag uint, isCommit bool) (staking.ValidatorExQueue, error)

+ func (sk *StakingPlugin) GetVerifierCandidateInfo(blockHash common.Hash, blockNumber uint64) ([]*staking.Candidate, error)

+ func (sk *StakingPlugin) GetVerifierList(blockHash common.Hash, blockNumber uint64, isCommit bool) (staking.ValidatorExQueue, error)

+ func (sk *StakingPlugin) HandleUnCandidateItem(state xcom.StateDB, blockNumber uint64, blockHash common.Hash, epoch uint64) error

+ func (sk *StakingPlugin) HasStake(blockHash common.Hash, addr common.Address) (bool, error)

+ func (sk *StakingPlugin) IncreaseStaking(state xcom.StateDB, blockHash common.Hash, blockNumber, amount *big.Int, ...) error

+ func (sk *StakingPlugin) IsCandidate(blockHash common.Hash, nodeId discover.NodeID, isCommit bool) (bool, error)

+ func (sk *StakingPlugin) IsCandidateNode(nodeID discover.NodeID) bool

+ func (sk *StakingPlugin) IsCurrValidator(blockHash common.Hash, blockNumber uint64, nodeId discover.NodeID, ...) (bool, error)

+ func (sk *StakingPlugin) IsCurrVerifier(blockHash common.Hash, blockNumber uint64, nodeId discover.NodeID, ...) (bool, error)

+ func (sk *StakingPlugin) ListCurrentValidatorID(blockHash common.Hash, blockNumber uint64) ([]discover.NodeID, error)

+ func (sk *StakingPlugin) ListVerifierNodeID(blockHash common.Hash, blockNumber uint64) ([]discover.NodeID, error)

+ func (sk *StakingPlugin) ProposalPassedNotify(blockHash common.Hash, blockNumber uint64, nodeIds []discover.NodeID, ...) error

+ func (sk *StakingPlugin) RollBackStaking(state xcom.StateDB, blockHash common.Hash, blockNumber *big.Int, ...) error

+ func (sk *StakingPlugin) SetEventMux(eventMux *event.TypeMux)

+ func (sk *StakingPlugin) SlashCandidates(state xcom.StateDB, blockHash common.Hash, blockNumber uint64, ...) error

+ func (sk *StakingPlugin) WithdrewDelegation(state xcom.StateDB, blockHash common.Hash, blockNumber, amount *big.Int, ...) (*big.Int, error)

+ func (sk *StakingPlugin) WithdrewStaking(state xcom.StateDB, blockHash common.Hash, blockNumber *big.Int, ...) error

+ type WaitSlashingNode struct

+ CountBit uint64

+ NodeId discover.NodeID

+ Round uint64

+ func (w *WaitSlashingNode) String() string