task_syncer

Documentation

Index

• func BuildMerkleTree(datas []*dao.Proof) (*utils.MerkleTree, error)
• type Task
  • func NewTask(cfg *config.Config, dao *db.WrapDb) (*Task, error)
  • func (task *Task) MerkleTreeDealedEpoch(storage *storage.Storage) (*big.Int, error)
  • func (task *Task) Start() error
  • func (task *Task) Stop()

Functions

func BuildMerkleTree

func BuildMerkleTree(datas []*dao.Proof) (*utils.MerkleTree, error)

Types

type Task

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

sync deposit/stake events and pool latest info from execute chain sync validator latest info and epoch balance from consensus chain sync beacon block info from consensus chain sort by head: eth1 syncer -> latestInfo syncer -> eth2Block syncer -> valBalance syncer -> nodeBalance collector -> merkle tree

func NewTask

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

func (*Task) MerkleTreeDealedEpoch

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

func (*Task) Start

func (task *Task) Start() error

func (*Task) Stop

func (task *Task) Stop()