multidownloader

package
v0.10.0-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 20, 2026 License: Apache-2.0, MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrLogsNotAvailable = fmt.Errorf("logs not available")
)

Functions

This section is empty.

Types

type EVMDownloader

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

func NewEVMDownloader

func NewEVMDownloader(
	mdr mdrsynctypes.MultidownloaderInterface,
	logger aggkitcommon.Logger,
	rh *sync.RetryHandler,
	appender sync.LogAppenderMap,
	waitPeriodToCatchUpMaximumLogRange time.Duration,
	pullingPeriod time.Duration,
) *EVMDownloader

func (*EVMDownloader) ChainID

func (d *EVMDownloader) ChainID(ctx context.Context) (uint64, error)

func (*EVMDownloader) DownloadNextBlocks

func (d *EVMDownloader) DownloadNextBlocks(ctx context.Context,
	lastBlockHeader *aggkittypes.BlockHeader,
	maxBlocks uint64,
	syncerConfig aggkittypes.SyncerConfig) (*mdrsynctypes.DownloadResult, error)

func (*EVMDownloader) Finality

type EVMDriver

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

func NewEVMDriver

func NewEVMDriver(
	logger aggkitcommon.Logger,
	processor mdrsynctypes.ProcessorInterface,
	downloader mdrsynctypes.DownloaderInterface,
	syncerConfig aggkittypes.SyncerConfig,
	syncBlockChunkSize uint64,
	rh *aggkitsync.RetryHandler,
	compatibilityChecker compatibility.CompatibilityChecker,
) *EVMDriver

func (*EVMDriver) GetCompletionPercentage

func (d *EVMDriver) GetCompletionPercentage() *float64

func (*EVMDriver) Sync

func (d *EVMDriver) Sync(ctx context.Context, firstBlockNumber *uint64)

type RuntimeData

type RuntimeData struct {
	ChainID   uint64
	Addresses []common.Address
}

RuntimeData is the data that is used to check that the DB is compatible with the runtime data basically it contains the relevant data from runtime environment

func (RuntimeData) IsCompatible

func (r RuntimeData) IsCompatible(other RuntimeData) (*RuntimeData, error)

func (RuntimeData) String

func (r RuntimeData) String() string

Directories

Path Synopsis
agglayer
aggsender

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL