syncstrategy

Documentation

Index

• type Strategy
• type SyncBlockWorker
• type SyncedHeight
• type Window
  • func NewWindow(logger applogger.Logger, size int) *Window
  • func (window *Window) Sync(currentHeight int64, latestHeight int64, worker SyncBlockWorker) ([][]command.Command, SyncedHeight, error)

Types

type Strategy

type Strategy interface {
	Sync(currentHeight int64, latestHeight int64, worker SyncBlockWorker) ([][]command.Command, SyncedHeight, error)
}

type SyncBlockWorker

type SyncBlockWorker = func(blockHeight int64) ([]command.Command, error)

type SyncedHeight

type SyncedHeight = int64

type Window

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

Simple sync strategy by using a window of n concurrent block syncs at a time

func NewWindow

func NewWindow(logger applogger.Logger, size int) *Window

func (*Window) Sync

func (window *Window) Sync(
	currentHeight int64,
	latestHeight int64,
	worker SyncBlockWorker,
) ([][]command.Command, SyncedHeight, error)