| 33 | } |
| 34 | |
| 35 | func (d *BufferedZapCore) Write(entry zapcore.Entry, fields []zapcore.Field) error { |
| 36 | fields = append(fields, d.fields...) |
| 37 | // encode fields using zapcore.Encoder, send empty entry as we want to store the message separately |
| 38 | fieldsBuf, err := d.enc.EncodeEntry(zapcore.Entry{}, fields) |
| 39 | if err != nil { |
| 40 | return err |
| 41 | } |
| 42 | defer fieldsBuf.Free() |
| 43 | payload := fieldsBuf.String() |
| 44 | |
| 45 | return d.logs.AddEntry(zapLevelToPBLevel(entry.Level), entry.Time, entry.Message, payload) |
| 46 | } |
| 47 | |
| 48 | func (d *BufferedZapCore) With(fields []zapcore.Field) zapcore.Core { |
| 49 | clone := *d |