diff --git a/pkg/engine/engine.go b/pkg/engine/engine.go index 04938cd5148b..3489d980d375 100644 --- a/pkg/engine/engine.go +++ b/pkg/engine/engine.go @@ -415,6 +415,13 @@ func (e *Engine) ResultsChan() chan detectors.ResultWithMetadata { return e.results } +// ScanChunk injects a chunk into the output stream of chunks to be scanned. +// This method should rarely be used. TODO: Remove when dependencies no longer +// rely on this functionality. +func (e *Engine) ScanChunk(chunk *sources.Chunk) { + e.sourceManager.ScanChunk(chunk) +} + // detectableChunk is a decoded chunk that is ready to be scanned by its detector. type detectableChunk struct { detector detectors.Detector diff --git a/pkg/sources/source_manager.go b/pkg/sources/source_manager.go index 0528e9b048a7..923f04648c4b 100644 --- a/pkg/sources/source_manager.go +++ b/pkg/sources/source_manager.go @@ -191,6 +191,13 @@ func (s *SourceManager) Wait() error { return s.pool.Wait() } +// ScanChunk injects a chunk into the output stream of chunks to be scanned. +// This method should rarely be used. TODO: Remove when dependencies no longer +// rely on this functionality. +func (s *SourceManager) ScanChunk(chunk *Chunk) { + s.outputChunks <- chunk +} + // preflightChecks is a helper method to check the Manager or the context isn't // done and that the handle is valid. func (s *SourceManager) preflightChecks(ctx context.Context, handle handle) error {