sync

type ByRangeCmd struct {
	*base.Base

	Blocks bdb.DB
	Chain  chain.FullChain

	PeerID         flags.PeerIDFlag      `ask:"--peer" help:"Peers to make blocks-by-range request to."`
	StartSlot      beacon.Slot           `ask:"--start" help:"Start slot of request"`
	Count          uint64                `ask:"--count" help:"Count of blocks of request"`
	Step           uint64                `ask:"--step" help:"Step between slots of blocks of request"`
	Timeout        time.Duration         `ask:"--timeout" help:"Timeout for full request and response. 0 to disable"`
	ProcessTimeout time.Duration         `ask:"--process-timeout" help:"Timeout for parallel processing of blocks. 0 to disable."`
	Compression    flags.CompressionFlag `ask:"--compression" help:"Compression. 'none' to disable, 'snappy' for streaming-snappy"`
	Store          bool                  `ask:"--store" help:"If the blocks should be stored in the blocks DB"`
	Process        bool                  `ask:"--process" help:"If the blocks should be added to the current chain view, ignored otherwise"`
}

type ByRootCmd struct {
	*base.Base

	Blocks bdb.DB
	Chain  chain.FullChain

	PeerID flags.PeerIDFlag `ask:"--peer" help:"Peers to make blocks-by-root request to."`

	Roots []beacon.Root `ask:"--roots" help:"Block roots to request"`

	Timeout        time.Duration         `ask:"--timeout" help:"Timeout for full request and response. 0 to disable"`
	ProcessTimeout time.Duration         `ask:"--process-timeout" help:"Timeout for parallel processing of blocks. 0 to disable."`
	Compression    flags.CompressionFlag `ask:"--compression" help:"Compression. 'none' to disable, 'snappy' for streaming-snappy"`
	Store          bool                  `ask:"--store" help:"If the blocks should be stored in the blocks DB"`
	Process        bool                  `ask:"--process" help:"If the blocks should be added to the current chain view, ignored otherwise"`
}

type SyncCmd struct {
	*base.Base
	Chain  chain.FullChain
	Blocks bdb.DB
}

type SyncFn func(blocksCh chan<- *beacon.SignedBeaconBlock) error