Skip to content

N
nebula
Commit 709e1bf9 authored by Sebastian Stammler's avatar Sebastian Stammler Committed by GitHub
Browse files
Options

op-node/rollup/derive: add info logging (#13753)

parent f7ce7829
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 2 deletions
op-node/rollup/derive/channel_assembler.go
View file @ 709e1bf9
......@@ -96,6 +96,7 @@ func (ca *ChannelAssembler) NextRawChannel(ctx context.Context) ([]byte, error)
if frame.FrameNumber == 0 {
ca.metrics.RecordHeadChannelOpened()
ca.channel = NewChannel(frame.ID, origin, true)
lgr.Info("created new channel")
}
if frame.FrameNumber > 0 && ca.channel == nil {
lgr.Warn("dropping non-first frame without channel",
......
op-node/rollup/derive/channel_in_reader.go
View file @ 709e1bf9
......@@ -105,7 +105,7 @@ func (cr *ChannelInReader) NextBatch(ctx context.Context) (Batch, error) {
if err != nil {
return nil, err
}
batch.LogContext(cr.log).Debug("decoded singular batch from channel", "stage_origin", cr.Origin())
batch.LogContext(cr.log).Info("decoded singular batch from channel", "stage_origin", cr.Origin())
cr.metrics.RecordDerivedBatches("singular")
return batch, nil
case SpanBatchType:
......@@ -119,7 +119,7 @@ func (cr *ChannelInReader) NextBatch(ctx context.Context) (Batch, error) {
if err != nil {
return nil, err
}
batch.LogContext(cr.log).Debug("decoded span batch from channel", "stage_origin", cr.Origin())
batch.LogContext(cr.log).Info("decoded span batch from channel", "stage_origin", cr.Origin())
cr.metrics.RecordDerivedBatches("span")
return batch, nil
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