Function New

ethstorage/scanner/scanner.go:33–53

(
	ctx context.Context,
	cfg Config,
	sm *es.StorageManager,
	fetchBlob es.FetchBlobFunc,
	l1 IL1,
	feed *event.Feed,
	lg log.Logger,
)

}

func New(
	ctx context.Context,
	cfg Config,
	sm *es.StorageManager,
	fetchBlob es.FetchBlobFunc,
	l1 IL1,
	feed *event.Feed,
	lg log.Logger,
) *Scanner {
	cctx, cancel := context.WithCancel(ctx)
	return &Scanner{
		worker:     NewWorker(sm, fetchBlob, l1, lg),
		feed:       feed,
		cfg:        cfg,
		ctx:        cctx,
		cancel:     cancel,
		lg:         lg,
		stats:      make(mismatchTracker),
		scanPermit: make(chan struct{}, 1),
	}
}

// Start begins the scanner's background processing. Must be called after New().
func (s *Scanner) Start() {