From b53aa358d64a22e8747bf3a9d117df7135b9edac Mon Sep 17 00:00:00 2001
From: Rasmus Dahlberg <rasmus@rgdd.se>
Date: Fri, 17 Mar 2023 10:49:48 +0100
Subject: wip collect

---
 main.go | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

(limited to 'main.go')

diff --git a/main.go b/main.go
index 0511ab7..02ed413 100644
--- a/main.go
+++ b/main.go
@@ -51,6 +51,10 @@ type options struct {
 	sthFile               string
 	stateFile             string
 	sansFile              string
+
+	workersPerLog uint64
+	batchSize     uint64
+	persistSize   uint64
 }
 
 func main() {
@@ -82,13 +86,17 @@ func main() {
 	opts.stateFile = "th.json"
 	opts.sansFile = "sans.lst"
 
+	opts.workersPerLog = 10
+	opts.batchSize = 16384
+	opts.persistSize = 256
+
 	// Hand-over to the respective subcommands
 	var err error
 	switch cmd := os.Args[1]; cmd {
 	case "snapshot":
 		err = snapshot(opts)
-	//case "collect":
-	//	err = collect(opts)
+	case "collect":
+		err = collect(opts)
 	case "assemble":
 		err = assemble(opts)
 	default:
-- 
cgit v1.2.3