collector

func RunCollector ¶

func RunCollector(ctx context.Context, wg *sync.WaitGroup, expectedResults int, resultsCh chan types.ContainerReport, backend storage.ReportStorage, reportID string) error

RunCollector starts the collector which will block on reading all expected ContainerReports from the results channel, before sending them to the ReportStorage backend.