added better logging

1 files changed, 4 insertions, 0 deletions

diff --git a/cleaner.go b/cleaner.go
index 001542f..f7f697e 100644
--- a/cleaner.go
+++ b/cleaner.go
@@ -19,6 +19,7 @@ func init() {
 }
 
 func cleanFromDB(cfg *Config) (rowsLeft int, err error) {
+	cllogger.Println("Starting to clean from db...")
 
 	db, err := sql.Open("mysql", cfg.DBUser+":"+cfg.DBPass+"@"+cfg.DBConn+"/"+cfg.DBName)
 	if err != nil {
@@ -82,10 +83,12 @@ func cleanFromDB(cfg *Config) (rowsLeft int, err error) {
 	}
 
 	tx.Commit()
+	cllogger.Println("Finished cleaning from db!")
 	return
 }
 
 func cleanFromStdin(rDatChan <-chan []RawData, cfg *Config) error {
+	cllogger.Println("Starting to clean from stdin")
 	for rDat := range rDatChan {
 		cDat, err := clean(rDat, cfg)
 		if err != nil {
@@ -98,6 +101,7 @@ func cleanFromStdin(rDatChan <-chan []RawData, cfg *Config) error {
 			return err
 		}
 	}
+	cllogger.Println("Finished cleaning from stdin!")
 	return nil
 }