syncer

Documentation

Index

• Variables
• func Close()
• func DialServer() (err error)
• func InitMongoServer(mongoURL, dbName, dbUser, dbPassword string)
• func SetJobCount(count uint64)
• type Message
• type Syncer
  • func NewSyncer(stable, start, end uint64) *Syncer
  • func (s *Syncer) Sync()
  • func (s *Syncer) UpdateBlockInfo(wg *sync.WaitGroup)
• type Worker
  • func (w *Worker) Parse(block *types.Block, receipts types.Receipts)

Variables

var (
	ServerURL     string
	Overwrite     bool
	ArchiveMode   bool
	JobCount      uint64 = 10
	BlockInterval uint64 = 100
)

Functions

func Close

func Close()

func DialServer

func DialServer() (err error)

func InitMongoServer

func InitMongoServer(mongoURL, dbName, dbUser, dbPassword string)

func SetJobCount

func SetJobCount(count uint64)

Types

type Message

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

type Syncer

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

func NewSyncer

func NewSyncer(stable, start, end uint64) *Syncer

func (*Syncer) Sync

func (s *Syncer) Sync()

func (*Syncer) UpdateBlockInfo

func (s *Syncer) UpdateBlockInfo(wg *sync.WaitGroup)

type Worker

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

func (*Worker) Parse

func (w *Worker) Parse(block *types.Block, receipts types.Receipts)