task_voter

Documentation

Index

• type Task
  • func NewTask(cfg *config.Config, dao *db.WrapDb, keyPair *secp256k1.Keypair) (*Task, error)
  • func (task *Task) MerkleTreeDealedEpoch(storage *storage.Storage) (*big.Int, error)
  • func (task *Task) NodeVotedBalanceSubmission(storage *storage.Storage, sender common.Address, _block *big.Int, ...) (bool, error)
  • func (task *Task) NodeVotedDistributeWithdrawals(storage *storage.Storage, sender common.Address, ...) (bool, error)
  • func (task *Task) Start() error
  • func (task *Task) Stop()

Types

type Task

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

func NewTask

func NewTask(cfg *config.Config, dao *db.WrapDb, keyPair *secp256k1.Keypair) (*Task, error)

func (*Task) MerkleTreeDealedEpoch

func (task *Task) MerkleTreeDealedEpoch(storage *storage.Storage) (*big.Int, error)

func (*Task) NodeVotedBalanceSubmission

func (task *Task) NodeVotedBalanceSubmission(storage *storage.Storage, sender common.Address, _block *big.Int, _totalEth *big.Int, _stakingEth *big.Int, _rethSupply *big.Int) (bool, error)

func (*Task) NodeVotedDistributeWithdrawals

func (task *Task) NodeVotedDistributeWithdrawals(storage *storage.Storage, sender common.Address, _dealedHeight, _userAmount, _nodeAmount, _platformAmount, _maxClaimableWithdrawIndex *big.Int) (bool, error)

func (*Task) Start

func (task *Task) Start() error

func (*Task) Stop

func (task *Task) Stop()