(ctx context.Context, cfg *Config)
| 315 | } |
| 316 | |
| 317 | func (n *EsNode) initArchiver(ctx context.Context, cfg *Config) error { |
| 318 | if cfg.Archiver == nil { |
| 319 | // not enabled |
| 320 | return nil |
| 321 | } |
| 322 | n.archiverAPI = archiver.NewService(*cfg.Archiver, n.storageManager, n.l1Beacon, n.l1Source, n.lg) |
| 323 | n.lg.Info("Initialized blob archiver API server") |
| 324 | if err := n.archiverAPI.Start(ctx); err != nil { |
| 325 | return fmt.Errorf("unable to start blob archiver API server: %w", err) |
| 326 | } |
| 327 | return nil |
| 328 | } |
| 329 | |
| 330 | func (n *EsNode) initScanner(ctx context.Context, cfg *Config) { |
| 331 | if cfg.Scanner == nil { |
no test coverage detected