diff options
Diffstat (limited to 'stdin.go')
| -rw-r--r-- | stdin.go | 15 |
1 files changed, 12 insertions, 3 deletions
@@ -9,6 +9,14 @@ import ( "time" ) +var ( + logger *log.Logger +) + +func init() { + logger = log.New(os.Stdout, "[stdin]", log.LstdFlags) +} + //Starts a process that reads from stdin and //puts the strings read on the returned channel func readFromStdin() <-chan []byte { @@ -27,18 +35,19 @@ func parseRawData(in <-chan []byte, cfg *Config) <-chan []RawData { out := make(chan []RawData) ival, err := cfg.getInterval() if err != nil { - log.Println("Could not parse interval: ", err) + logger.Println("Could not parse interval: ", err) } timeBin := time.Now().Add(ival / -2) //Make sure we are inside the correct timeBin go func() { rDat := make([]RawData, 0) for line := range in { if !strings.HasPrefix(string(line), "{") { + logger.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 { - log.Println("Could not parse interval: ", err) + logger.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 @@ -52,7 +61,7 @@ func parseRawData(in <-chan []byte, cfg *Config) <-chan []RawData { var rd RawData err := json.Unmarshal(line, &rd) if err != nil { - log.Println("Failed in parsing json:", err) + logger.Println("Failed in parsing json:", err) close(out) return } |