From 39ce24b4a0a9946b759149900373bb888d98f0d0 Mon Sep 17 00:00:00 2001 From: Daniel Langesten Date: Wed, 18 Mar 2015 15:36:45 +0100 Subject: compile issues --- main.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/main.go b/main.go index 05bbac3..ac004de 100644 --- a/main.go +++ b/main.go @@ -18,9 +18,9 @@ func main() { switch cfg.DataSource { case "stdin": - processFromStdin() + processFromStdin(cfg) case "mysq": - pricessFromDB() + processFromDB(cfg) default: log.Println("Invalid dataSource in config. Needs to be either 'stdin' or 'mysql'.") } @@ -28,14 +28,14 @@ func main() { log.Println("Finished processing, now exiting") } -func processFromStdin() { +func processFromStdin(cfg *Config) { log.Println("Starting to process from stdin...") input := readFromStdin() rDatChan := parseRawData(input, cfg) cleanFromStdin(rDatChan, cfg) } -func processFromDB() { +func processFromDB(cfg *Config) { log.Print("Cleaning data...") starttime := time.Now() numOfRowsNotCleaned, err := cleanFromDB(cfg) -- cgit v1.1