diff options
Diffstat (limited to 'collect.go')
| -rw-r--r-- | collect.go | 8 |
1 files changed, 4 insertions, 4 deletions
@@ -87,7 +87,7 @@ func collect(opts options) error { } cli, err := client.New(string(log.URL), &http.Client{Transport: &http.Transport{IdleConnTimeout: 120 * time.Second}}, - jsonclient.Options{UserAgent: opts.httpAgent}, + jsonclient.Options{UserAgent: opts.HTTPAgent}, ) if err != nil { fmt.Fprintf(os.Stderr, "ERROR: %s: %v\n", *log.Description, err) @@ -95,10 +95,10 @@ func collect(opts options) error { return } fetcher := scanner.NewFetcher(cli, &scanner.FetcherOptions{ - BatchSize: int(opts.batchSize), + BatchSize: int(opts.BatchSize), StartIndex: th.TreeSize, EndIndex: int64(sth.TreeSize), - ParallelFetch: int(opts.workersPerLog), + ParallelFetch: int(opts.WorkersPerLog), }) // @@ -150,7 +150,7 @@ func collect(opts options) error { } c = h.TPop() - putBack, err := persistChunk(cli, opts, id[:], int64(opts.persistSize), c) + putBack, err := persistChunk(cli, opts, id[:], int64(opts.PersistSize), c) if err != nil { cancel() fmt.Fprintf(os.Stderr, "ERROR: %s: %v\n", *log.Description, err) |