statesync

Documentation

Index

• func FillAccountsWithOverlappingStorage(t *testing.T, trieDB *trie.Database, root common.Hash, numAccounts int, ...) (common.Hash, map[*keystore.Key]*types.StateAccount)
• func NewEVMStateSyncer(config *EVMStateSyncerConfig) (*stateSyncer, error)
• type EVMStateSyncerConfig
• type StateSyncProgress
• type StorageTrieProgress
• type SyncETA
  • func NewSyncEta(mainTrieRoot common.Hash) SyncETA
• type TrieProgress
  • func NewTrieProgress(db ethdb.Batcher, batchSize int, eta SyncETA) *TrieProgress

Functions

func FillAccountsWithOverlappingStorage

func FillAccountsWithOverlappingStorage(
	t *testing.T, trieDB *trie.Database, root common.Hash, numAccounts int, numOverlappingStorageRoots int,
) (common.Hash, map[*keystore.Key]*types.StateAccount)

FillAccountsWithOverlappingStorage adds [numAccounts] randomly generated accounts to the secure trie at [root] and commits it to [trieDB]. For each 3 accounts created: - One does not have a storage trie, - One has a storage trie shared with other accounts (total number of shared storage tries [numOverlappingStorageRoots]), - One has a uniquely generated storage trie, returns the new trie root and a map of funded keys to StateAccount structs.

func NewEVMStateSyncer

func NewEVMStateSyncer(config *EVMStateSyncerConfig) (*stateSyncer, error)

Types

type EVMStateSyncerConfig

type EVMStateSyncerConfig struct {
	Root      common.Hash
	Client    syncclient.Client
	DB        ethdb.Database
	BatchSize int
}

type StateSyncProgress

type StateSyncProgress struct {
	MainTrie     *TrieProgress
	MainTrieDone bool
	Root         common.Hash
	StorageTries map[common.Hash]*StorageTrieProgress
}

StateSyncProgress tracks the progress of syncing the main trie and the sub-tasks for syncing storage tries.

type StorageTrieProgress

type StorageTrieProgress struct {
	*TrieProgress
	Account            common.Hash
	AdditionalAccounts []common.Hash
	Skipped            bool
}

type SyncETA

type SyncETA interface {
	// NotifyProgress is called when leafs are received to estimate progress and
	// updates the overall ETA if needed, logging a message if it has been more
	// than [updateInterval] since the last update.
	NotifyProgress(root common.Hash, startTime time.Time, startKey []byte, key []byte)

	// RemoveSyncedTrie is called when a trie is done syncing, so it will no longer
	// be considered for calculating the ETA.
	RemoveSyncedTrie(root common.Hash, skipped bool)
}

func NewSyncEta

func NewSyncEta(mainTrieRoot common.Hash) SyncETA

type TrieProgress

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

func NewTrieProgress

func NewTrieProgress(db ethdb.Batcher, batchSize int, eta SyncETA) *TrieProgress