snapshotsync

Documentation

Index

• func BuildProtoRequest(downloadRequest []services.DownloadRequest) *proto_downloader.DownloadRequest
• func RequestSnapshotsDownload(ctx context.Context, downloadRequest []services.DownloadRequest, ...) error
• func WaitForDownloader(logPrefix string, ctx context.Context, histV3 bool, caplin CaplinMode, ...) error
• type CaplinMode

Functions

func BuildProtoRequest

func BuildProtoRequest(downloadRequest []services.DownloadRequest) *proto_downloader.DownloadRequest

func RequestSnapshotsDownload

func RequestSnapshotsDownload(ctx context.Context, downloadRequest []services.DownloadRequest, downloader proto_downloader.DownloaderClient) error

RequestSnapshotsDownload - builds the snapshots download request and downloads them

func WaitForDownloader

func WaitForDownloader(logPrefix string, ctx context.Context, histV3 bool, caplin CaplinMode, agg *state.AggregatorV3, tx kv.RwTx, blockReader services.FullBlockReader, notifier services.DBEventNotifier, cc *chain.Config, snapshotDownloader proto_downloader.DownloaderClient) error

WaitForDownloader - wait for Downloader service to download all expected snapshots for MVP we sync with Downloader only once, in future will send new snapshots also

Types

type CaplinMode

type CaplinMode int

const (

	// CaplinModeNone - no caplin mode
	NoCaplin   CaplinMode = 1
	OnlyCaplin CaplinMode = 2
	AlsoCaplin CaplinMode = 3
)