Versions in this module Expand all Collapse all v0 v0.0.1 Jun 7, 2022 Changes in this version + type Worker struct + Count int + StatsBuffer int + StatsReader database.StatsReader + func (w *Worker) Process(queryParams chan streamer.QueryParams) (statsChan chan database.Stat, errChan chan error)