statesyncclient

Jul 20, 2022

Changes in this version

type LeafSyncTask

+ End func() []byte

Jun 3, 2022

Changes in this version

type ClientConfig

+ BlockParser EthBlockParser

+ type EthBlockParser interface

+ ParseEthBlock func(b []byte) (*types.Block, error)

type LeafSyncTask

+ Account common.Hash

May 24, 2022

Changes in this version

+ var StateSyncVersion = version.NewDefaultApplication(constants.PlatformName, 1, 7, 11)

+ func IncrOne(bytes []byte)

+ func NewClient(config *ClientConfig) *client

+ type CallbackLeafSyncer struct

+ func NewCallbackLeafSyncer(client LeafClient) *CallbackLeafSyncer

+ func (c *CallbackLeafSyncer) Done() <-chan error

+ func (c *CallbackLeafSyncer) Start(ctx context.Context, numThreads int, task *LeafSyncTask, ...)

+ type Client interface

+ GetBlocks func(blockHash common.Hash, height uint64, parents uint16) ([]*types.Block, error)

+ GetCode func(hashes []common.Hash) ([][]byte, error)

+ GetLeafs func(request message.LeafsRequest) (message.LeafsResponse, error)

+ type ClientConfig struct

+ Codec codec.Manager

+ MaxAttempts uint8

+ MaxRetryDelay time.Duration

+ NetworkClient peer.NetworkClient

+ StateSyncNodeIDs []ids.NodeID

+ Stats stats.ClientSyncerStats

+ type LeafClient interface

+ GetLeafs func(message.LeafsRequest) (message.LeafsResponse, error)

+ type LeafSyncTask struct

+ NodeType message.NodeType

+ OnFinish OnFinish

+ OnLeafs OnLeafs

+ OnStart OnStart

+ OnSyncFailure OnSyncFailure

+ Root common.Hash

+ Start []byte

+ type MockClient struct

+ GetBlocksIntercept func(blockReq message.BlockRequest, blocks types.Blocks) (types.Blocks, error)

+ GetCodeIntercept func(hashes []common.Hash, codeBytes [][]byte) ([][]byte, error)

+ GetLeafsIntercept func(req message.LeafsRequest, res message.LeafsResponse) (message.LeafsResponse, error)

+ func NewMockClient(codec codec.Manager, leafHandler *handlers.LeafsRequestHandler, ...) *MockClient

+ func (ml *MockClient) BlocksReceived() int32

+ func (ml *MockClient) CodeReceived() int32

+ func (ml *MockClient) GetBlocks(blockHash common.Hash, height uint64, numParents uint16) ([]*types.Block, error)

+ func (ml *MockClient) GetCode(hashes []common.Hash) ([][]byte, error)

+ func (ml *MockClient) GetLeafs(request message.LeafsRequest) (message.LeafsResponse, error)

+ func (ml *MockClient) LeavesReceived() int32

+ type OnFinish func(root common.Hash) error

+ type OnLeafs func(root common.Hash, keys [][]byte, values [][]byte) ([]*LeafSyncTask, error)

+ type OnStart func(root common.Hash) (bool, error)

+ type OnSyncFailure func(error) error