Skip to content

Commit 5b4e833

Browse files
committed
[-] fix log message for rows written in JSONWriter
1 parent ef1b116 commit 5b4e833

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

internal/sinks/json.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ func (jw *JSONWriter) Write(msgs []metrics.MeasurementEnvelope) error {
3939
}
4040
enc := json.NewEncoder(jw.lw)
4141
t1 := time.Now()
42+
written := 0
4243
for _, msg := range msgs {
4344
dataRow := map[string]any{
4445
"metric": msg.MetricName,
@@ -49,9 +50,10 @@ func (jw *JSONWriter) Write(msgs []metrics.MeasurementEnvelope) error {
4950
if err := enc.Encode(dataRow); err != nil {
5051
return err
5152
}
53+
written += len(msg.Data)
5254
}
5355
diff := time.Since(t1)
54-
log.GetLogger(jw.ctx).WithField("rows", len(msgs)).WithField("elapsed", diff).Info("measurements written")
56+
log.GetLogger(jw.ctx).WithField("rows", written).WithField("elapsed", diff).Info("measurements written")
5557
return nil
5658
}
5759

0 commit comments

Comments
 (0)