(freq int)
| 34 | } |
| 35 | |
| 36 | func newEventLogger(freq int) log.Logger { |
| 37 | l := log.NewLogfmtLogger(log.NewSyncWriter(os.Stderr)) |
| 38 | l = log.WithPrefix(l, key, event) |
| 39 | l = log.With(l, "ts", log.DefaultTimestampUTC) |
| 40 | return &samplingFilter{next: l, freq: freq} |
| 41 | } |
| 42 | |
| 43 | type samplingFilter struct { |
| 44 | next log.Logger |