wip collect

1 files changed, 10 insertions, 2 deletions

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: