warpsync

Documentation

Index

• func WithBlockBatchSize(blockBatchSize int) options.Option[Manager]
• func WithConcurrency(concurrency int) options.Option[Manager]
• type LoadBlockFunc
• type Manager
  • func NewManager(blockLoaderFunc LoadBlockFunc, blockProcessorFunc ProcessBlockFunc, ...) *Manager
  • func (m *Manager) IsStopped() bool
  • func (m *Manager) Stop()
• type ProcessBlockFunc

Functions

func WithBlockBatchSize

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

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

func WithConcurrency

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

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

Types

type LoadBlockFunc

type LoadBlockFunc func(models.BlockID) (*models.Block, bool)

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(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.

type ProcessBlockFunc

type ProcessBlockFunc func(*p2p.Neighbor, *models.Block)

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