Skip to content

N
nebula
Commit e2acd4df authored by protolambda's avatar protolambda
Browse files
Options

op-node: add batch log meta data

parent ea25157d
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
op-node/rollup/derive/channel_in_reader.go
View file @ e2acd4df
...@@ -95,7 +95,7 @@ func (cr *ChannelInReader) NextBatch(ctx context.Context) (Batch, error) { ...@@ -95,7 +95,7 @@ func (cr *ChannelInReader) NextBatch(ctx context.Context) (Batch, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
cr.log.Debug("decoded singular batch from channel") singularBatch.LogContext(cr.log).Debug("decoded singular batch from channel", "stage_origin", cr.Origin())
cr.metrics.RecordDerivedBatches("singular") cr.metrics.RecordDerivedBatches("singular")
return singularBatch, nil return singularBatch, nil
case SpanBatchType: case SpanBatchType:
...@@ -109,7 +109,7 @@ func (cr *ChannelInReader) NextBatch(ctx context.Context) (Batch, error) { ...@@ -109,7 +109,7 @@ func (cr *ChannelInReader) NextBatch(ctx context.Context) (Batch, error) {
if err != nil { if err != nil {
return nil, err return nil, err
} }
cr.log.Debug("decoded span batch from channel") spanBatch.LogContext(cr.log).Debug("decoded span batch from channel", "stage_origin", cr.Origin())
cr.metrics.RecordDerivedBatches("span") cr.metrics.RecordDerivedBatches("span")
return spanBatch, nil return spanBatch, nil
default: default:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment