(ctx context.Context, cfg *Config)
| 131 | } |
| 132 | |
| 133 | func (n *EsNode) initL2(ctx context.Context, cfg *Config) error { |
| 134 | n.blobCache = downloader.NewBlobDiskCache(cfg.DataDir, n.lg) |
| 135 | n.downloader = downloader.NewDownloader( |
| 136 | n.l1Source, |
| 137 | n.l1Beacon, |
| 138 | n.daClient, |
| 139 | n.db, |
| 140 | n.storageManager, |
| 141 | n.blobCache, |
| 142 | cfg.L1.L1MinDurationForBlobsRequest, |
| 143 | cfg.Downloader, |
| 144 | n.lg, |
| 145 | ) |
| 146 | return nil |
| 147 | } |
| 148 | |
| 149 | func (n *EsNode) initL1(ctx context.Context, cfg *Config) error { |
| 150 | client, err := eth.Dial(cfg.L1.L1NodeAddr, cfg.Storage.L1Contract, cfg.L1.L1BlockTime, n.lg) |
no test coverage detected