diff options
Diffstat (limited to 'stdin.go')
| -rw-r--r-- | stdin.go | 20 |
1 files changed, 10 insertions, 10 deletions
@@ -10,11 +10,11 @@ import ( ) var ( - logger *log.Logger + stlogger *log.Logger ) func init() { - logger = log.New(os.Stdout, "[stdin]", log.LstdFlags) + stlogger = log.New(os.Stdout, "[stdin]", log.LstdFlags) } //Starts a process that reads from stdin and @@ -22,12 +22,12 @@ func init() { func readFromStdin() <-chan []byte { out := make(chan []byte) go func() { - logger.Println("Now listening on stdin...") + stlogger.Println("Now listening on stdin...") scanner := bufio.NewScanner(os.Stdin) for scanner.Scan() { out <- []byte(scanner.Text()) } - logger.Println("Finished listening to stdin!") + stlogger.Println("Finished listening to stdin!") close(out) }() return out @@ -37,20 +37,20 @@ func parseRawData(in <-chan []byte, cfg *Config) <-chan []RawData { out := make(chan []RawData) ival, err := cfg.getInterval() if err != nil { - logger.Println("Could not parse interval: ", err) + stlogger.Println("Could not parse interval: ", err) } timeBin := time.Now().Add(ival / -2) //Make sure we are inside the correct timeBin - logger.Println("Now parsing data from stdin...") + stlogger.Println("Now parsing data from stdin...") go func() { rDat := make([]RawData, 0) for line := range in { if !strings.HasPrefix(string(line), "{") { - logger.Println("Got message:", string(line)) + stlogger.Println("Got message:", string(line)) //This should be a break in the output from pmacct //so we deploy our collected data and set a new timeBin ival, err := cfg.getInterval() if err != nil { - logger.Println("Could not parse interval: ", err) + stlogger.Println("Could not parse interval: ", err) } timeBin = time.Now().Add(ival / -2) //Make sure we are inside the correct timeBin //Send the data if we have something to send @@ -64,7 +64,7 @@ func parseRawData(in <-chan []byte, cfg *Config) <-chan []RawData { var rd RawData err := json.Unmarshal(line, &rd) if err != nil { - logger.Println("Failed in parsing json:", err) + stlogger.Println("Failed in parsing json:", err) close(out) return } @@ -76,7 +76,7 @@ func parseRawData(in <-chan []byte, cfg *Config) <-chan []RawData { if len(rDat) > 0 { out <- rDat } - logger.Println("Finished parsing data from stdin...") + stlogger.Println("Finished parsing data from stdin...") close(out) }() return out |