ScrapeManager is the interface that ScrapeWorker uses to interact with the scraper lifecycle and result collection.
| 110 | // ScrapeManager is the interface that ScrapeWorker uses to interact with |
| 111 | // the scraper lifecycle and result collection. |
| 112 | type ScrapeManager interface { |
| 113 | JobDone() |
| 114 | SubmitJob(ctx context.Context, job scrapemate.IJob) error |
| 115 | RegisterJob(jobID string, riverJobID int64, keyword string) <-chan scraper.FlushResult |
| 116 | MarkDone(jobID string) |
| 117 | ForceFlush(jobID string) |
| 118 | } |
| 119 | |
| 120 | type ScrapeWorker struct { |
| 121 | river.WorkerDefaults[ScrapeJobArgs] |
no outgoing calls
no test coverage detected