sync

package

v1.6.10-testnet Latest Latest Go to latest Published: Jun 9, 2026 License: MIT Imports: 29 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Chainable[H comparable] interface {
	Number() uint64
	Hash() H
	ParentHash() H
}

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

DatabaseSyncer is used to sync blockchain data into database against the latest confirmed epoch.

func MustNewDatabaseSyncer(cfxClients []*sdk.Client, db *mysql.CfxStore) *DatabaseSyncer

MustNewDatabaseSyncer creates an instance of DatabaseSyncer to sync blockchain data.

func (syncer *DatabaseSyncer) OnStateChange(state monitor.HealthState, details ...string)

func (syncer *DatabaseSyncer) Sync(ctx context.Context, wg *sync.WaitGroup)

Sync starts to sync epoch blockchain data.

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

EthSyncer is used to synchronize evm space blockchain data into db store.

func MustNewEthSyncer(ethClients []*web3go.Client, db *mysql.EthStore) *EthSyncer

MustNewEthSyncer creates an instance of EthSyncer to sync Conflux EVM space chaindata.

func (syncer *EthSyncer) OnStateChange(state monitor.HealthState, details ...string)

func (syncer *EthSyncer) Sync(ctx context.Context, wg *sync.WaitGroup)

Sync starts to sync Conflux EVM space blockchain data.

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

TraceLogSyncer orchestrates the synchronization of internal contract trace logs.

func MustNewTraceLogSyncer(clients []*sdk.Client, store *mysql.CfxStore) *TraceLogSyncer

MustNewTraceLogSyncer creates a new TraceLogSyncer, panicking on any initialization error.

func (s *TraceLogSyncer) MustSync(ctx context.Context, wg *gosync.WaitGroup)

MustSync starts the synchronization process: first catches up, then follows latest.