Versions in this module Expand all Collapse all v0 v0.1.3 Oct 3, 2023 v0.1.2 Oct 3, 2023 Changes in this version + func WithBlockBatchSize(blockBatchSize int) options.Option[Manager] + func WithConcurrency(concurrency int) options.Option[Manager] + type LoadBlockFunc func(blockId mesh_old.BlockID) (*mesh_old.Block, error) + type Manager struct + func NewManager(p2pManager *p2p.Manager, blockLoaderFunc LoadBlockFunc, ...) *Manager + func (m *Manager) IsStopped() bool + func (m *Manager) Stop() + func (m *Manager) WarpRange(ctx context.Context, start, end epoch.Index, startEC epoch.EC, ...) (err error) + type ProcessBlockFunc func(blk *mesh_old.Block, peer *peer.Peer)
Go to main page