warpsync

package

v0.1.3 Latest Latest Go to latest Published: Oct 3, 2023 License: Apache-2.0, BSD-2-Clause Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/izuc/zipp

Links

Open Source Insights

Documentation ¶

Index ¶

func WithBlockBatchSize(blockBatchSize int) options.Option[Manager]
func WithConcurrency(concurrency int) options.Option[Manager]
type LoadBlockFunc
type Manager
- func NewManager(p2pManager *p2p.Manager, blockLoaderFunc LoadBlockFunc, ...) *Manager
type ProcessBlockFunc

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func WithBlockBatchSize ¶

func WithBlockBatchSize(blockBatchSize int) options.Option[Manager]

WithBlockBatchSize allows to set the size of the block batch returned as part of epoch blocks response.

func WithConcurrency ¶

func WithConcurrency(concurrency int) options.Option[Manager]

WithConcurrency allows to set how many epochs can be requested at once.

Types ¶

type LoadBlockFunc ¶

type LoadBlockFunc func(blockId mesh_old.BlockID) (*mesh_old.Block, error)

LoadBlockFunc defines a function that returns the block for the given id.

type Manager ¶

type Manager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

The Manager handles the connected neighbors.

func NewManager ¶

func NewManager(p2pManager *p2p.Manager, blockLoaderFunc LoadBlockFunc, blockProcessorFunc ProcessBlockFunc, log *logger.Logger, opts ...options.Option[Manager]) *Manager

NewManager creates a new Manager.

func (*Manager) IsStopped ¶

func (m *Manager) IsStopped() bool

IsStopped returns true if the manager is stopped.

func (*Manager) Stop ¶

func (m *Manager) Stop()

Stop stops the manager and closes all established connections.

func (*Manager) WarpRange ¶

func (m *Manager) WarpRange(ctx context.Context, start, end epoch.Index, startEC epoch.EC, endPrevEC epoch.EC) (err error)

type ProcessBlockFunc ¶

type ProcessBlockFunc func(blk *mesh_old.Block, peer *peer.Peer)

ProcessBlockFunc defines a function that processes block's bytes from a given peer.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
warpsyncproto

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL