(p []byte)
| 25 | } |
| 26 | |
| 27 | func (c *consoleWriter) Write(p []byte) (n int, err error) { |
| 28 | var evt map[string]any |
| 29 | d := json.NewDecoder(bytes.NewReader(p)) |
| 30 | d.UseNumber() |
| 31 | err = d.Decode(&evt) |
| 32 | if err != nil { |
| 33 | return n, fmt.Errorf("cannot decode event: %s", err) |
| 34 | } |
| 35 | e := json.NewEncoder(c.out) |
| 36 | return len(p), e.Encode(evt) |
| 37 | } |