diff --git a/loglist/schema.go b/loglist/schema.go index d6d22de..b6a7e1d 100644 --- a/loglist/schema.go +++ b/loglist/schema.go @@ -45,8 +45,8 @@ type Log struct { } `json:"temporal_interval"` // certspotter-specific extensions - GetEntriesSize int `json:"get_entries_size,omitempty"` - DownloadWorkers int `json:"certspotter_download_workers,omitempty"` + GetEntriesSize int `json:"get_entries_size,omitempty"` + ParallelGetEntries int `json:"parallel_get_entries,omitempty"` // TODO: add previous_operators } diff --git a/monitor/monitor.go b/monitor/monitor.go index 04c3bfa..d1e98eb 100644 --- a/monitor/monitor.go +++ b/monitor/monitor.go @@ -38,15 +38,15 @@ func downloadJobSize(ctlog *loglist.Log) uint64 { } else if ctlog.GetEntriesSize != 0 { return uint64(ctlog.GetEntriesSize) } else { - return 256 + return 1000 } } func downloadWorkers(ctlog *loglist.Log) int { - if ctlog.DownloadWorkers != 0 { - return ctlog.DownloadWorkers + if ctlog.ParallelGetEntries != 0 { + return ctlog.ParallelGetEntries } else { - return 4 + return 1 } }