task_syncer

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Mar 9, 2023 License: GPL-3.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL