(before, after []api.Message)
| 41 | } |
| 42 | |
| 43 | func (l *LoggingStrategy) writeEvent(before, after []api.Message) error { |
| 44 | f, err := os.OpenFile(l.FilePath, os.O_APPEND|os.O_CREATE|os.O_WRONLY, 0644) |
| 45 | if err != nil { |
| 46 | return err |
| 47 | } |
| 48 | defer f.Close() |
| 49 | fmt.Fprintln(f, "=========================") |
| 50 | fmt.Fprintf(f, "[%s] compaction event\n", time.Now().UTC().Format(time.RFC3339)) |
| 51 | fmt.Fprintf(f, "BEFORE (%d messages):\n%s\n", len(before), api.RenderTranscript(before)) |
| 52 | fmt.Fprintln(f, "---") |
| 53 | fmt.Fprintf(f, "AFTER (%d messages):\n%s\n", len(after), api.RenderTranscript(after)) |
| 54 | return nil |
| 55 | } |
no test coverage detected