syncstrategy

package

v1.7.66 Latest Latest Go to latest Published: Oct 15, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

type SyncedHeight = int64

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(logger applogger.Logger, size int) *Window

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