proper logrus usage

Author: Dieterbe

cmd/mt-update-ttl/main.go

@@ -85,7 +85,7 @@ func main() {
 	session, err := NewCassandraStore()
 
 	if err != nil {
-		panic(fmt.Sprintf("Failed to instantiate cassandra: %s", err))
+		log.Fatalf("Failed to instantiate cassandra: %s", err)
 	}
 
 	update(session, ttl, tableIn, tableOut)
@@ -182,26 +182,26 @@ func worker(id int, jobs <-chan string, wg *sync.WaitGroup, session *gocql.Sessi
 				query = fmt.Sprintf("INSERT INTO %s (data, key, ts) values(?,?,?) USING TTL %d", tableOut, newTTL)
 			}
 			if *verbose {
-				log.Printf("id=%d processing rownum=%d table=%q key=%q ts=%d query=%q data='%x'\n", id, atomic.LoadUint64(&doneRows)+1, tableIn, key, ts, query, data)
+				log.Infof("id=%d processing rownum=%d table=%q key=%q ts=%d query=%q data='%x'\n", id, atomic.LoadUint64(&doneRows)+1, tableIn, key, ts, query, data)
 			}
 
 			err := session.Query(query, data, key, ts).Exec()
 			if err != nil {
-				fmt.Fprintf(os.Stderr, "ERROR: id=%d failed updating %s %s %d: %q", id, tableOut, key, ts, err)
+				log.Errorf("id=%d failed updating %s %s %d: %q", id, tableOut, key, ts, err)
 			}
 
 			doneRowsSnap := atomic.AddUint64(&doneRows, 1)
 			if doneRowsSnap%10000 == 0 {
 				doneKeysSnap := atomic.LoadUint64(&doneKeys)
 				completeness := completenessEstimate(token)
-				log.Printf("WORKING: id=%d processed %d keys, %d rows. (last token: %d, completeness estimate %.1f%%)", id, doneKeysSnap, doneRowsSnap, token, completeness*100)
+				log.Infof("WORKING: id=%d processed %d keys, %d rows. (last token: %d, completeness estimate %.1f%%)", id, doneKeysSnap, doneRowsSnap, token, completeness*100)
 			}
 		}
 		err := iter.Close()
 		if err != nil {
 			doneKeysSnap := atomic.LoadUint64(&doneKeys)
 			doneRowsSnap := atomic.LoadUint64(&doneRows)
-			fmt.Fprintf(os.Stderr, "ERROR: id=%d failed querying %s: %q. processed %d keys, %d rows", id, tableIn, err, doneKeysSnap, doneRowsSnap)
+			log.Errorf("id=%d failed querying %s: %q. processed %d keys, %d rows", id, tableIn, err, doneKeysSnap, doneRowsSnap)
 		}
 		atomic.AddUint64(&doneKeys, 1)
 	}
@@ -229,11 +229,11 @@ func update(session *gocql.Session, ttl int, tableIn, tableOut string) {
 	if err != nil {
 		doneKeysSnap := atomic.LoadUint64(&doneKeys)
 		doneRowsSnap := atomic.LoadUint64(&doneRows)
-		fmt.Fprintf(os.Stderr, "ERROR: failed querying %s: %q. processed %d keys, %d rows", tableIn, err, doneKeysSnap, doneRowsSnap)
+		log.Errorf("failed querying %s: %q. processed %d keys, %d rows", tableIn, err, doneKeysSnap, doneRowsSnap)
 		wg.Wait()
 		os.Exit(2)
 	}
 
 	wg.Wait()
-	log.Printf("DONE.  Processed %d keys, %d rows", doneKeys, doneRows)
+	log.Infof("DONE.  Processed %d keys, %d rows", doneKeys, doneRows)
 }