catchup

Documentation

Index

• type SyncOption
  • func WithBenchmark(benchmark bool) SyncOption
  • func WithMaxDbRows(dbRows int) SyncOption
  • func WithMinBatchDbRows(dbRows int) SyncOption
  • func WithWorkers(workers []*worker) SyncOption
• type Syncer
  • func MustNewSyncer(cfx sdk.ClientOperator, db *mysql.MysqlStore, elm election.LeaderManager, ...) *Syncer
  • func (s *Syncer) Close()
  • func (s *Syncer) Sync(ctx context.Context)

Types

type SyncOption

type SyncOption func(*Syncer)

functional options for syncer

func WithBenchmark

func WithBenchmark(benchmark bool) SyncOption

func WithMaxDbRows

func WithMaxDbRows(dbRows int) SyncOption

func WithMinBatchDbRows

func WithMinBatchDbRows(dbRows int) SyncOption

func WithWorkers

func WithWorkers(workers []*worker) SyncOption

type Syncer

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

Syncer accelerates core space epoch data catch-up using concurrently workers. Specifically, each worker will be dispatched as round-robin load balancing.

func MustNewSyncer

func MustNewSyncer(
	cfx sdk.ClientOperator, db *mysql.MysqlStore,
	elm election.LeaderManager, opts ...SyncOption) *Syncer

func (*Syncer) Close

func (s *Syncer) Close()

func (*Syncer) Sync

func (s *Syncer) Sync(ctx context.Context)